ert78gb / google-pubsub-emulator Goto Github PK

TypeError: PubSub is not a constructor
    at PubSubEmulator._getPubSubClient (node_modules/google-pubsub-emulator/src/pubsub-emulator.js:292:22)
    at PubSubEmulator._createTopics (node_modules/google-pubsub-emulator/src/pubsub-emulator.js:302:25)
    at PubSubEmulator.startSuccessListener (node_modules/google-pubsub-emulator/src/pubsub-emulator.js:59:18)
    at PubSubEmulator._setState (node_modules/google-pubsub-emulator/src/pubsub-emulator.js:207:24)
    at PubSubEmulator._processStd (node_modules/google-pubsub-emulator/src/pubsub-emulator.js:154:12)
    at PubSubEmulator._emulatorStdErrListener (node_modules/google-pubsub-emulator/src/pubsub-emulator.js:253:10)
    at addChunk (_stream_readable.js:263:12)
    at readableAddChunk (_stream_readable.js:250:11)
    at Socket.Readable.push (_stream_readable.js:208:10)
    at Pipe.onread (net.js:594:20)

Exception in thread "main" java.net.BindException: Address already in use

'use strict'

const _ = require('underscore')
const async = require('async')

var config = require('../../../../config')

const logger = require('./bunyan').logger
const PubSub = require('@google-cloud/pubsub')

const Emulator = require('google-pubsub-emulator')

const projectId = 'xxx-communication-service'

const pubsubClient = PubSub({
  projectId: projectId
})

var prefix = `projects/${projectId}/topics/`

function init (callback) {
  createQueues(callback)
}

function createQueues (parentCallback) {
  var topicsNames = []
  var subscriptionNames = []
  async.waterfall([
    function (callback) {
      process.env.GCLOUD_PROJECT = projectId
      const options = {
        debug: true, // if you like to see the emulator output
        topics: [
          'projects/project-id/topics/topic-1' // automatically created topic
        ]
      }
      var emulator = new Emulator(options)

      emulator.start().then(() => {
        console.log(`emulator started.`)
        callback()
      })
                                .catch((err) => {
                                  console.error('ERROR:', err)
                                  callback(err)
                                })
    },
    function (callback) {
      //get all topics already existing
      pubsubClient.getTopics(function (err, topics) {
        if (!err) {
          topicsNames = _.union(topicsNames, _.pluck(topics, 'name'))
          // logger.info('got topics ' + JSON.stringify(topicsNames))
          callback(null)
        } else {
          callback(err)
        }
      })
    },
    function (callback) {
      //get all subscriptions already existing
      pubsubClient.getSubscriptions(function (err, subscriptions) {
        if (!err) {
          logger.info('got subscriptions ' + JSON.stringify(subscriptions))
          subscriptionNames = _.union(subscriptions, _.pluck(subscriptions, 'name'))
              // logger.info('got subscriptions ' + JSON.stringify(subscriptionNames))
          callback(null)
        } else {
          callback(err)
        }
      })
    },
    function (callback) {
      //set up poison pill topic which will be pull
      var topic = 'error'
      if (!_.contains(topicsNames, `${prefix}${topic}-${config['PUBSUB_ENV']}`)) {
        pubsubClient.createTopic(`${topic}-${config['PUBSUB_ENV']}`)
                  .then((results) => {
                    const topic = results[0]
                    console.log(`Topic ${topic.name} created.`)
                    callback()
                  })
                  .catch((err) => {
                    console.error('ERROR:', err)
                    callback(err)
                  })
      } else {
        callback()
      }
    }, function (callback) {
      //set up email topic if not existing
      var topic = 'email-job'
      if (!_.contains(topicsNames, `${prefix}${topic}-${config['PUBSUB_ENV']}`)) {
        pubsubClient.createTopic(`${topic}-${config['PUBSUB_ENV']}`)
                        .then((results) => {
                          const topic = results[0]
                          console.log(`Topic ${topic.name} created.`)
                          callback()
                        })
                        .catch((err) => {
                          console.error('ERROR:', err)
                          callback(err)
                        })
      } else {
        callback()
      }
    }, function (callback) {
    //set up subscriber to email topic if not existing
//      var subscriber = 'email-job-subscriber'
//      if (!_.contains(subscriptionNames, `${prefix}${subscriber}-${config['PUBSUB_ENV']}`)) {
//        callback()
//      } else {
//        callback()
//      }
    }], function (err, result) {
    if (err) {
      console.log(JSON.stringify(err))
      parentCallback(err)
    } else {
      parentCallback()
    }
  })
}

module.exports = {
  init: init
}

Build-agent version 1.0.167651-d52a9c2e (2023-04-18T11:21:26+0000)
System information:
 Server Version: 20.10.18
 Storage Driver: overlay2
  Backing Filesystem: xfs
 Cgroup Driver: cgroupfs
 Cgroup Version: 1
 Kernel Version: 5.15.0-1030-aws
 Operating System: Ubuntu 20.04.5 LTS
 OSType: linux
 Architecture: x86_64

Starting container hiveops/circleci-deploy:16.14

stderr: DEBUG: Running [gcloud.beta.emulators.pubsub.start] with arguments: [--host-port: "<googlecloudsdk.calliope.arg_parsers.HostPort object at 0x7ffa961d4650>", --log-http: "true", --user-output-enabled: "true", --verbosity: "debug"]
stderr: DEBUG: Found Cloud SDK root: /home/oc/google-cloud-sdk-215.0.0-linux-x86_64/google-cloud-sdk
stderr: Executing: /home/oc/google-cloud-sdk-215.0.0-linux-x86_64/google-cloud-sdk/platform/pubsub-emulator/bin/cloud-pubsub-emulator --host=localhost --port=12202
stderr: [pubsub] This is the Google Pub/Sub fake.
stderr: [pubsub] Implementation may be incomplete or differ from the real system.
stderr: [pubsub] mai 30, 2019 11:12:10 AM com.google.cloud.pubsub.testing.v1.Main main
stderr: [pubsub] INFOS: IAM integration is disabled. IAM policy methods and ACL checks are not supported
stderr: [pubsub] mai 30, 2019 11:12:11 AM io.gapi.emulators.netty.NettyUtil applyJava7LongHostnameWorkaround
stderr: [pubsub] INFOS: Applied Java 7 long hostname workaround.
stderr: [pubsub] mai 30, 2019 11:12:11 AM com.google.cloud.pubsub.testing.v1.Main main
stderr: [pubsub] INFOS: Server started, listening on 12202