@gojob/nest-cloud-pub-sub-transport

Nest Cloud Pub/Sub Transport

A Custom Transport strategy for Cloud Pub/Sub in Nest microservices.

Getting started

yarn add @gojob/nest-cloud-pub-sub-transport
# or
npm install @gojob/nest-cloud-pub-sub-transport

Here is an example of implementation in your Nest application:

async function bootstrap() {
  const app = await NestFactory.create(AppModule);
  const configService = app.get(ConfigService);

  app.connectMicroservice({
    strategy: new CloudServerPubSub({
      // configuration passed "as is" to the Cloud PubSub client
      clientConfig: {
        keyFile: configService.get('GCP_KEY_FILE_PUBSUB'),
      },
      // custom options, specific to this package
      options: {
        logger: app.get(LOGGER),
        // useful when your app is using a single topic & subscription
        defaultTopic: configService.get('DEFAULT_PUB_SUB_TOPIC'),
        defaultSubscription: configService.get('DEFAULT_PUB_SUB_SUBSCRIPTION'),
      },
    }),
  });

  await app.startAllMicroservices();
  await app.listen(3000);
}

Then use @EventPattern from @nestjs/microservices to call your event handlers when a new message is received in Pub/Sub.

Contributing

Command	Action
yarn compile	Ensure the TypeScript code can be compiled using tsc
yarn build	Build the project (transpile the code to JavaScript)
yarn lint	Lint the code (ESLintà
yarn test	Run unit tests
yarn integration	Run integration tests