refactor: update graphql and apollo server

package.json

@@ -58,10 +58,12 @@
     "typescript": "^4.5.5"
   },
   "dependencies": {
-    "apollo-server-express": "^2.19.1",
+    "@graphql-tools/schema": "^8.3.1",
+    "@graphql-tools/utils": "^8.6.1",
+    "apollo-server-express": "^3.6.2",
     "bcrypt": "^5.0.1",
     "express": "^4.17.2",
-    "graphql": "^15.4.0",
+    "graphql": "^16.3.0",
     "graphql-iso-date": "^3.6.1",
     "jsonwebtoken": "^8.5.1",
     "module-alias": "^2.2.2",

src/main/config/app.ts

@@ -1,14 +1,21 @@
-import express from 'express'
-import setupMiddlewares from './middlewares'
-import setupApolloServer from './apollo-server'
-import setupRoutes from './routes'
-import setupSwagger from './swagger'
-import setupStaticFiles from './static-files'
-
-const app = express()
-setupApolloServer(app)
-setupStaticFiles(app)
-setupSwagger(app)
-setupMiddlewares(app)
-setupRoutes(app)
-export default app
+import express, { Express } from 'express'
+
+import setupMiddlewares from '@/main/config/middlewares'
+import setupRoutes from '@/main/config/routes'
+import setupSwagger from '@/main/config/swagger'
+import setupStaticFiles from '@/main/config/static-files'
+import { setupApolloServer } from '../graphql/apollo'
+
+export const setupApp = async (): Promise<Express> => {
+  const app = express()
+  setupStaticFiles(app)
+  setupSwagger(app)
+  setupMiddlewares(app)
+  setupRoutes(app)
+
+  const apolloServer = setupApolloServer()
+  await apolloServer.start()
+  apolloServer.applyMiddleware({ app })
+
+  return app
+}

src/main/config/apollo-server.ts → src/main/graphql/apollo/apollo-server.ts

@@ -1,10 +1,10 @@
 import typeDefs from '@/main/graphql/type-defs'
 import resolvers from '@/main/graphql/resolvers'
-import schemaDirectives from '@/main/graphql/directives'
+import { authDirectiveTransformer } from '@/main/graphql/directives'
 
 import { ApolloServer } from 'apollo-server-express'
-import { Express } from 'express'
 import { GraphQLError } from 'graphql'
+import { makeExecutableSchema } from '@graphql-tools/schema'
 
 type GraqphQLErrorsTypes = {
   name: string
@@ -45,17 +45,16 @@ const checkError = (error: GraphQLError, errorName: string): boolean => {
   return [error.name, error.originalError?.name].some(name => name === errorName)
 }
 
-export default (app: Express): void => {
-  const server = new ApolloServer({
-    resolvers,
-    typeDefs,
-    schemaDirectives,
-    context: ({ req }) => ({ req }),
-    plugins: [{
-      requestDidStart: () => ({
-        willSendResponse: ({ response, errors }) => handleErrors(response, errors)
-      })
-    }]
-  })
-  server.applyMiddleware({ app })
-}
+let schema = makeExecutableSchema({ resolvers, typeDefs })
+schema = authDirectiveTransformer(schema)
+
+export const setupApolloServer = (): ApolloServer => new ApolloServer({
+  schema,
+  context: ({ req }) => ({ req }),
+  plugins: [{
+    requestDidStart: async () => ({
+      willSendResponse: async ({ response, errors }) => handleErrors(response, errors)
+    })
+  }]
+})
+// server.applyMiddleware({ app })

src/main/graphql/apollo/index.ts

@@ -0,0 +1 @@
+export * from './apollo-server'

src/main/graphql/directives/auth-directive.ts

@@ -1,21 +1,30 @@
+import { getDirective, MapperKind, mapSchema } from '@graphql-tools/utils'
+import { ForbiddenError } from 'apollo-server-express'
+import { GraphQLSchema } from 'graphql'
+
 import { makeAuthMiddleware } from '@/main/factories'
-import { ForbiddenError, SchemaDirectiveVisitor } from 'apollo-server-express'
-import { defaultFieldResolver, GraphQLField } from 'graphql'
 
-export class AuthDirective extends SchemaDirectiveVisitor {
-  visitFieldDefinition (field: GraphQLField<any, any>): any {
-    const { resolve = defaultFieldResolver } = field
-    field.resolve = async (parent, args, context, info) => {
-      const request = {
-        accessToken: context?.req?.headers?.['x-access-token']
-      }
-      const httpResponse = await makeAuthMiddleware().handle(request)
-      if (httpResponse.statusCode === 200) {
-        Object.assign(context.req, httpResponse.body)
-        return resolve.call(this, parent, args, context, info)
-      } else {
-        throw new ForbiddenError(httpResponse.body)
+export const authDirectiveTransformer = (schema: GraphQLSchema): GraphQLSchema => {
+  return mapSchema(schema, {
+    [MapperKind.OBJECT_FIELD]: (fieldConfig) => {
+      const authDirective = getDirective(schema, fieldConfig, 'auth')
+
+      if (authDirective) {
+        const { resolve } = fieldConfig
+        fieldConfig.resolve = async (parent, args, context, info) => {
+          const request = {
+            accessToken: context?.req?.headers?.['x-access-token']
+          }
+          const httpResponse = await makeAuthMiddleware().handle(request)
+          if (httpResponse.statusCode === 200) {
+            Object.assign(context.req, httpResponse.body)
+            return resolve.call(this, parent, args, context, info)
+          } else {
+            throw new ForbiddenError(httpResponse.body)
+          }
+        }
       }
+      return fieldConfig
     }
-  }
+  })
 }

src/main/graphql/directives/index.ts

@@ -1,5 +1 @@
-import { AuthDirective } from './auth-directive'
-
-export default {
-  auth: AuthDirective
-}
+export * from './auth-directive'

src/main/server.ts

@@ -1,10 +1,12 @@
 import 'module-alias/register'
-import app from '@/main/config/app'
+
 import env from '@/main/config/env'
 import { MongoHelper } from '@/infra/db'
 
 MongoHelper.connect(env.mongoUrl)
-  .then(() => {
+  .then(async () => {
+    const { setupApp } = await import('./config/app')
+    const app = await setupApp()
     app.listen(env.port, () => console.log(`Server running at http://localhost:${env.port}`))
   })
   .catch(e => console.error(e))

tests/main/graphql/login.test.ts

@@ -1,14 +1,17 @@
 import { MongoHelper } from '@/infra/db'
 import request from 'supertest'
-import app from '@/main/config/app'
+import { setupApp } from '@/main/config/app'
 
 import { Collection } from 'mongodb'
 import { hash } from 'bcrypt'
+import { Express } from 'express'
 
 let accountCollection: Collection
+let app: Express
 
 describe('Login GraphQL', () => {
   beforeAll(async () => {
+    app = await setupApp()
     await MongoHelper.connect(process.env.MONGO_URL)
   })
 

tests/main/graphql/survey-result.test.ts

@@ -1,17 +1,18 @@
 import env from '@/main/config/env'
 import request from 'supertest'
-import app from '@/main/config/app'
-
+import { setupApp } from '@/main/config/app'
 import { MongoHelper } from '@/infra/db'
 import { SurveyModel } from '@/domain/models'
 
 import { Collection } from 'mongodb'
 import { sign } from 'jsonwebtoken'
 import Mockdate from 'mockdate'
+import { Express } from 'express'
 
 let surveyCollection: Collection
 let accountCollection: Collection
 let surveyResultCollection: Collection
+let app: Express
 
 const mockAccessToken = async (): Promise<string> => {
   const res = await accountCollection.insertOne({
@@ -46,6 +47,7 @@ const mockSurvey = async (): Promise<SurveyModel> => {
 
 describe('Survey Result GraphQL', () => {
   beforeAll(async () => {
+    app = await setupApp()
     Mockdate.set(new Date())
 
     await MongoHelper.connect(process.env.MONGO_URL)

tests/main/graphql/survey.test.ts

@@ -1,14 +1,16 @@
 import env from '@/main/config/env'
-import request from 'supertest'
-import app from '@/main/config/app'
 import { MongoHelper } from '@/infra/db'
+import { setupApp } from '@/main/config/app'
 
+import request from 'supertest'
 import { sign } from 'jsonwebtoken'
 import { Collection } from 'mongodb'
 import Mockdate from 'mockdate'
+import { Express } from 'express'
 
 let surveyCollection: Collection
 let accountCollection: Collection
+let app: Express
 
 const mockAccessToken = async (): Promise<string> => {
   const res = await accountCollection.insertOne({
@@ -42,6 +44,7 @@ const createSurveys = async (): Promise<void> => {
 
 describe('Survey GraphQL', () => {
   beforeAll(async () => {
+    app = await setupApp()
     Mockdate.set(new Date())
 
     await MongoHelper.connect(process.env.MONGO_URL)

tests/main/middlewares/body-parser.test.ts

@@ -1,8 +1,10 @@
+import { setupApp } from '@/main/config/app'
+
 import request from 'supertest'
-import app from '@/main/config/app'
 
 describe('Body Parser Middleware', () => {
   test('Should parse body as json', async () => {
+    const app = await setupApp()
     app.post('/test_body_parser', (req, res) => {
       res.send(req.body)
     })

tests/main/middlewares/content-type.test.ts

@@ -1,7 +1,15 @@
+import { setupApp } from '@/main/config/app'
+
 import request from 'supertest'
-import app from '@/main/config/app'
+import { Express } from 'express'
+
+let app: Express
 
 describe('Content Type Middleware', () => {
+  beforeAll(async () => {
+    app = await setupApp()
+  })
+
   test('Should return default content type as json', async () => {
     app.get('/test_content_type', (req, res) => {
       res.send('')

tests/main/middlewares/cors.test.ts

@@ -1,8 +1,10 @@
+import { setupApp } from '@/main/config/app'
+
 import request from 'supertest'
-import app from '@/main/config/app'
 
 describe('CORS Middleware', () => {
   test('Should enable CORS', async () => {
+    const app = await setupApp()
     app.get('/test_cors', (req, res) => {
       res.send()
     })

tests/main/middlewares/no-cache.test.ts

@@ -1,9 +1,11 @@
-import request from 'supertest'
 import { noCache } from '@/main/middlewares'
-import app from '@/main/config/app'
+import { setupApp } from '@/main/config/app'
+
+import request from 'supertest'
 
 describe('No Cache Middleware', () => {
   test('Should disable cache', async () => {
+    const app = await setupApp()
     app.get('/test_no_cache', noCache, (req, res) => {
       res.send()
     })

tests/main/routes/login-routes.test.ts

@@ -1,13 +1,17 @@
-import request from 'supertest'
-import app from '@/main/config/app'
 import { MongoHelper } from '@/infra/db'
+import { setupApp } from '@/main/config/app'
+
 import { Collection } from 'mongodb'
 import { hash } from 'bcrypt'
+import request from 'supertest'
+import { Express } from 'express'
 
 let accountCollection: Collection
+let app: Express
 
 describe('Login Routes', () => {
   beforeAll(async () => {
+    app = await setupApp()
     await MongoHelper.connect(process.env.MONGO_URL)
   })
 

tests/main/routes/survey-result-routes.test.ts

@@ -1,14 +1,17 @@
-import { sign } from 'jsonwebtoken'
-import { Collection } from 'mongodb'
 import env from '@/main/config/env'
-import request from 'supertest'
 import { MongoHelper } from '@/infra/db'
-import app from '@/main/config/app'
 import { SurveyModel } from '@/domain/models'
+import { setupApp } from '@/main/config/app'
+
+import { sign } from 'jsonwebtoken'
+import request from 'supertest'
+import { Collection } from 'mongodb'
+import { Express } from 'express'
 
 let surveyCollection: Collection
 let accountCollection: Collection
 let surveyResultCollection: Collection
+let app: Express
 
 const mockAccessToken = async (): Promise<string> => {
   const res = await accountCollection.insertOne({
@@ -43,6 +46,7 @@ const mockSurvey = async (): Promise<SurveyModel> => {
 
 describe('Survey Routes', () => {
   beforeAll(async () => {
+    app = await setupApp()
     await MongoHelper.connect(process.env.MONGO_URL)
   })
 

tests/main/routes/survey-routes.test.ts

@@ -1,12 +1,15 @@
-import { sign } from 'jsonwebtoken'
-import { Collection } from 'mongodb'
 import env from '@/main/config/env'
 import request from 'supertest'
 import { MongoHelper } from '@/infra/db'
-import app from '@/main/config/app'
+import { setupApp } from '@/main/config/app'
+
+import { sign } from 'jsonwebtoken'
+import { Collection } from 'mongodb'
+import { Express } from 'express'
 
 let surveyCollection: Collection
 let accountCollection: Collection
+let app: Express
 
 const mockAccessToken = async (): Promise<string> => {
   const res = await accountCollection.insertOne({
@@ -40,6 +43,7 @@ const createSurveys = async (): Promise<void> => {
 
 describe('Survey Routes', () => {
   beforeAll(async () => {
+    app = await setupApp()
     await MongoHelper.connect(process.env.MONGO_URL)
   })