NodeJS Request Log Tracing : SNS Event Publisher

sns-event-publisher.js

const requestTracing = require('request-tracing'); // Wrapper library to read the tracing information from CLS context

class SNSEventPublisher {
  constructor(sns, topicNameToArnMap) {
    this.sns = sns;
    this.topicNameToArnMap = topicNameToArnMap;
  }

  async publish(topicName, message) {
    const messageAttributes = {};
    const tracingId = requestTracing.getTracingId(); // Same as requestTracingNamespace.get('tracingId');
    if(tracingId) {
      messageAttributes['X-Tracing-Id'] = {
        DataType: 'String',
        StringValue: tracingId
      };
    }

    const params = {
      Message: message,
      TopicArn: this.topicNameToArnMap[topicName],
      MessageAttributes: messageAttributes
    };

    const resp = await this.sns.publish(params).promise();
    return resp.MessageId;
  }
}