fastify-google-pubsub

Fastify Plugin for Google Pubsub

A plugin for Fastify to use the Google Cloud Pub/Sub Client for publishing and subscribing to topics.

Install

npm install fastify-google-pubsub

Basic Usage

After registering the plugin, publish() and subscribe() functions are added to a pubsub decorator on the fastify object. The options object on the register call needs to include all topics used by subsequent calls to publish() or subscribe(), or those calls with throw an error.

Single Topic Example

const pubsubClient = require('fastify-google-pubsub')

module.exports = async function(fastify, opts) {
  // Register the client as a plugin
  fastify.register(pubsubClient, { topics: 'topic-name']})

  // Subscribe to the topic
  const messageHandler = (message) => {
    console.log('Received Message: ', message.data.toString())
  }
  const optionalCloseHandler = () => {
    console.log('Subscription closed')
  }
  await fastify.pubsub.subscribe('topic-name', 'topic-subscription-name', messageHandler, optionalCloseHandler)

  // Publish to the same topic
  await fastify.pubsub.publish('topic-name', JSON.stringify({ message: 'contents' }), { attribute: 'value' })
}

Dual Topic Example

const pubsubClient = require('fastify-google-pubsub')

module.exports = async function(fastify, opts) {
  // Register the client as a plugin
  fastify.register(pubsubClient, { topics: ['topic-1-name', 'topic-2-name']})

  // Subscribe to the first topic
  const messageHandler = (message) => {
    console.log('Received Message: ', message.data.toString())
  }
  await fastify.pubsub.subscribe('topic-1-name', 'topic-1-subscription-name', messageHandler)

  // Publish to the second topic
  await fastify.pubsub.publish('topic-2-name', JSON.stringify({ message: 'contents' }), { attribute: 'value' })
}