fix(gql): interceptors now work with subscriptions

integration/src/gql/gql.module.ts

@@ -1,20 +1,31 @@
 import { Module } from '@nestjs/common';
 import { GraphQLModule } from '@nestjs/graphql';
+// import { PubSub } from 'graphql-subscriptions';
 import { AppService } from '../app.service';
 import { GqlResolver } from './gql.resolver';
 
 @Module({
   imports: [
     GraphQLModule.forRoot({
-      context: ({ req, res, request, reply }) => ({
-        req,
-        res,
-        request,
-        reply,
-      }),
+      context: async ({ req, res, request, reply }) => {
+        return {
+          req,
+          res,
+          request,
+          reply,
+        };
+      },
       autoSchemaFile: true,
+      // installSubscriptionHandlers: true,
     }),
   ],
-  providers: [AppService, GqlResolver],
+  providers: [
+    AppService,
+    GqlResolver,
+    /* {
+      provide: 'PUB_SUB',
+      useClass: PubSub,
+    }, */
+  ],
 })
 export class GqlModule {}

integration/src/gql/gql.resolver.ts

@@ -1,12 +1,15 @@
 import { BadRequestException } from '@nestjs/common';
-import { Mutation, Query, Resolver } from '@nestjs/graphql';
+import { Mutation, Query, Resolver, Subscription } from '@nestjs/graphql';
 import { OgmaSkip } from '@ogma/nestjs-module';
+// import { PubSub } from 'graphql-subscriptions';
 import { AppService } from '../app.service';
 import { SimpleObject } from './simple-object.model';
 
 @Resolver(() => SimpleObject)
 export class GqlResolver {
-  constructor(private readonly appService: AppService) {}
+  constructor(
+    private readonly appService: AppService, // @Inject('PUB_SUB') private readonly pubSub: PubSub,
+  ) {}
 
   @Query(() => SimpleObject)
   getQuery(): SimpleObject {
@@ -26,6 +29,14 @@ export class GqlResolver {
   @OgmaSkip()
   @Query(() => SimpleObject)
   getSkip(): SimpleObject {
-    return this.appService.getHello();
+    // eslint-disable-next-line sonarjs/prefer-immediate-return
+    const obj = this.appService.getHello();
+    // this.pubSub.publish('subscribed', { subscribed: obj });
+    return obj;
   }
+
+  /* @Subscription(() => SimpleObject)
+  subscribed() {
+    return this.pubSub.asyncIterator('subscribed');
+  } */
 }

packages/platform-graphql-fastify/src/graphql-fastify-interceptor.service.ts

@@ -20,4 +20,13 @@ export class GraphQLFastifyParser extends FastifyParser {
   getResponse(context: ExecutionContext): FastifyReply {
     return this.getContext(context).getContext().reply;
   }
+
+  setRequestId(context: ExecutionContext, requestId: string): void {
+    const ctx = this.getContext(context).getContext();
+    if (ctx.request) {
+      ctx.request.requestId = requestId;
+    } else {
+      ctx.requestId = requestId;
+    }
+  }
 }

packages/platform-graphql/src/graphql-interceptor.service.ts

@@ -19,4 +19,13 @@ export class GraphQLParser extends ExpressParser {
   getResponse(context: ExecutionContext): Response {
     return this.getContext(context).getContext().res;
   }
+
+  setRequestId(context: ExecutionContext, requestId: string): void {
+    const ctx = this.getContext(context).getContext();
+    if (ctx.req) {
+      ctx.req.requestId = requestId;
+    } else {
+      ctx.requestId = requestId;
+    }
+  }
 }