feat: bump nestjs to 10

.circleci/config.yml

@@ -1,46 +1,37 @@
-version: 2
+version: 2.1
 
-aliases:
-  - &restore-cache
-    restore_cache:
-      key: dependency-cache-{{ checksum "package.json" }}
-  - &install-deps
-    run:
-      name: Install dependencies
-      command: yarn install --frozen-lockfile
-  - &build-packages
-    run:
-      name: Build
-      command: yarn build
+orbs:
+  node: circleci/node@5.1.0
 
 jobs:
   build:
     working_directory: ~/nestjs-google-pubsub-microservice
-    docker:
-      - image: circleci/node:12
+    executor: node/default
     steps:
       - checkout
       - run:
           name: Update NPM version
           command: 'sudo npm install -g npm@latest'
-      - *restore-cache
-      - *install-deps
-      - save_cache:
-          key: dependency-cache-{{ checksum "package.json" }}
-          paths:
-            - ./node_modules
-      - *build-packages
+      - node/install-packages
+      - run:
+          name: Build
+          command: npm run build
       - run:
           name: Unit tests
-          command: yarn test
+          command: npm run test
+      - persist_to_workspace:
+          root: .
+          paths:
+            - .
 
   integration_tests:
     working_directory: ~/nestjs-google-pubsub-microservice
     machine: true
     environment:
       PUBSUB_EMULATOR_HOST: localhost:8681
     steps:
-      - checkout
+      - attach_workspace:
+          at: .
       - run:
           name: Prepare nvm
           command: |
@@ -49,20 +40,15 @@ jobs:
       - run:
           name: Upgrade Node.js
           command: |
-            nvm install v12
+            nvm install v18
             node -v
-            nvm alias default v12
-      - run:
-          name: Install Yarn
-          command: npm install yarn -g
+            nvm alias default v18
       - run:
           name: Install Docker Compose
           command: |
             curl -L https://github.com/docker/compose/releases/download/1.19.0/docker-compose-`uname -s`-`uname -m` > ~/docker-compose
             chmod +x ~/docker-compose
             sudo mv ~/docker-compose /usr/local/bin/docker-compose
-      - *restore-cache
-      - *install-deps
       - run:
           name: Prepare
           command: |
@@ -73,10 +59,9 @@ jobs:
           command: docker ps
       - run:
           name: e2e tests
-          command: yarn test:e2e
+          command: npm run test:e2e
 
 workflows:
-  version: 2
   build-and-test:
     jobs:
       - build

.eslintrc.js

@@ -2,6 +2,7 @@ module.exports = {
   parser: '@typescript-eslint/parser',
   parserOptions: {
     project: 'tsconfig.json',
+    tsconfigRootDir: __dirname,
     sourceType: 'module',
   },
   plugins: ['@typescript-eslint/eslint-plugin'],

docker-compose.yml

@@ -1,7 +1,10 @@
-version: "3"
+version: '3.3'
+
 services:
   pubsub:
-    image: messagebird/gcloud-pubsub-emulator:latest
+    image: gcr.io/google.com/cloudsdktool/cloud-sdk:416.0.0-emulators
+    entrypoint: gcloud
+    command: ["beta", "emulators", "pubsub", "start", "--host-port=0.0.0.0:8681"]
     ports:
       - '8681:8681'
     restart: always

lib/gc-pubsub.client.ts

@@ -4,9 +4,9 @@ import {
   PubSub,
   Subscription,
   Topic,
+  PublishOptions,
+  SubscriberOptions,
 } from '@google-cloud/pubsub';
-import { PublishOptions } from '@google-cloud/pubsub/build/src/publisher';
-import { SubscriberOptions } from '@google-cloud/pubsub/build/src/subscriber';
 import { Logger } from '@nestjs/common';
 import {
   ClientProxy,

lib/gc-pubsub.context.ts

@@ -1,24 +1,26 @@
 import { Message } from '@google-cloud/pubsub';
 import { BaseRpcContext } from '@nestjs/microservices/ctx-host/base-rpc.context';
 
-type GCPubSubContextArgs = [Message, string];
+type GCPubSubContextArgs<P> = [Message, P];
 
-export class GCPubSubContext extends BaseRpcContext<GCPubSubContextArgs> {
-  constructor(args: GCPubSubContextArgs) {
+export class GCPubSubContext<P = string> extends BaseRpcContext<
+  GCPubSubContextArgs<P>
+> {
+  constructor(args: GCPubSubContextArgs<P>) {
     super(args);
   }
 
   /**
    * Returns the original message (with properties, fields, and content).
    */
-  getMessage() {
+  getMessage(): Message {
     return this.args[0];
   }
 
   /**
    * Returns the name of the pattern.
    */
-  getPattern() {
+  getPattern(): P {
     return this.args[1];
   }
 }

lib/gc-pubsub.interface.ts

@@ -1,7 +1,9 @@
-import { ClientConfig } from '@google-cloud/pubsub';
+import {
+  ClientConfig,
+  PublishOptions,
+  SubscriberOptions,
+} from '@google-cloud/pubsub';
 import { Deserializer, Serializer } from '@nestjs/microservices';
-import { PublishOptions } from '@google-cloud/pubsub/build/src/publisher';
-import { SubscriberOptions } from '@google-cloud/pubsub/build/src/subscriber';
 
 export interface GCPubSubOptions {
   client?: ClientConfig;

lib/gc-pubsub.server.spec.ts

@@ -219,9 +219,7 @@ describe('GCPubSubServer', () => {
         const correlationId = '0';
 
         await server.sendMessage(message, replyTo, correlationId);
-        expect(Array.from(server['replyTopics'].values())).to.deep.eq([
-          'my-keytest',
-        ]);
+        expect(Array.from(server['replyTopics'].values())).to.deep.eq(['test']);
       });
     });
   });

lib/gc-pubsub.server.ts

@@ -1,11 +1,11 @@
 import {
   ClientConfig,
   Message,
+  PublishOptions,
   PubSub,
+  SubscriberOptions,
   Subscription,
 } from '@google-cloud/pubsub';
-import { PublishOptions } from '@google-cloud/pubsub/build/src/publisher';
-import { SubscriberOptions } from '@google-cloud/pubsub/build/src/subscriber';
 import { Observable } from 'rxjs';
 import {
   CustomTransportStrategy,
@@ -210,8 +210,6 @@ export class GCPubSubServer extends Server implements CustomTransportStrategy {
       message as unknown as OutgoingResponse,
     );
 
-    replyTo = `${this.scopedEnvKey}${replyTo}`;
-
     this.replyTopics.add(replyTo);
 
     await this.client