import {
  ApolloServer,
  AuthenticationError,
  ForbiddenError,
} from "apollo-server-express";
import program from "commander";
import cors from "cors";
import * as dns from "dns";
import express from "express";
import * as os from "os";

import typeDefs from "./graphql/schema";
import { sequelize } from "./models";
import resolvers from "./resolvers";
import admin from "./utils/firebaseAdmin";

program.option("-s, --sync-db", "Sync database").parse(process.argv);

const origin = "http://localhost:3000";

async function run() {
  if (program.syncDb) {
    sequelize.sync({ force: true });
  } else {
    try {
      await sequelize.authenticate();
    } catch (error) {
      // eslint-disable-next-line no-console
      console.error("Can't connect to the database.\n", error);
    }
    const app = express();
    app.use(
      cors({
        origin,
        credentials: true,
      })
    );

    const server = new ApolloServer({
      typeDefs,
      resolvers,
      context: async ({ req }) => {
        // Get the user token from the headers
        const token = req.headers.authorization || "";
        if (!token) {
          throw new AuthenticationError("must authenticate");
        }

        let decodedToken: admin.auth.DecodedIdToken;
        try {
          decodedToken = await admin
            .auth()
            .verifyIdToken(token.slice("Bearer ".length));
        } catch (error) {
          throw new ForbiddenError("not authorized");
        }
        const user = await admin.auth().getUser(decodedToken.uid);
        return { user };
      },
    });
    server.applyMiddleware({ app });

    dns.lookup(os.hostname(), async (_, localIp) => {
      const port = process.env.PORT || 4000;
      await app.listen(port);
      // eslint-disable-next-line no-console
      console.log(
        `🚀  Server ready at http://localhost:${port}/graphql and http://${localIp}:${port}/graphql`
      );
    });
  }
}

run();