async function forwardFromPubSub()

in src/forwarder/index.js [82:105]

• 22 lines of code
• 2 McCabe index (conditional complexity)

async function forwardFromPubSub(pubSubEvent, context) {
  let payload;
  try {
    payload = Buffer.from(pubSubEvent.data, 'base64');
    JSON.parse(payload.toString()); // Log exception in App project if payload
    // cannot be parsed

    const pollerTopicName = assertDefined(
      process.env.POLLER_TOPIC,
      'POLLER_TOPIC environment variable',
    );
    const pollerTopic = pubSub.topic(pollerTopicName);
    pollerTopic.publishMessage({data: payload});
    logger.debug({
      message: `Poll request forwarded to PubSub Topic ${pollerTopicName}`,
    });
  } catch (err) {
    logger.error({
      message: `An error occurred in the Autoscaler forwarder (PubSub): ${err}`,
      err: err,
      payload: payload,
    });
  }
}