Log a pubsub topic to console

pubsub_logger.js

'use strict'


const PubSub = require('@google-cloud/pubsub')
const pubSubClient = PubSub({
    projectId: '<project-id>',
    keyFilename: 'service_account_test.json'
  })

var topic = pubSubClient.topic('<topic-name>');
//topic.subscribe('newMessages', function(err, subscription, apiResponse) {});

topic.subscription('message-logger').get({ autoCreate: true }, (err, subscription, apiResponse) => {

    if (err) {
        console.error(err)
        return done()
    }

    let subscriptionName = subscription.name.split('/')[subscription.name.split('/').length - 1]

    console.log('\n- subscription found:', subscriptionName)
    console.log('- listing incoming messages:')

    subscription.on('message', (msg) => {
        console.log('received', msg)
    })

})