promiseFromRecord()

in lambda/Message_Archiver/queuer/lib/processor.js [48:70]

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

  promiseFromRecord(record, out) {

    // Decode the base64 message
    const decoded = Buffer.from(record.data, 'base64').toString('ascii');
    this.options.logger.log({
      level: 'info',
      message: decoded
    });

    const pinpointEvent = JSON.parse(decoded);

    const p = this.journeyCampaignEventTypes.includes(pinpointEvent.event_type)
      ? this.journeyCampaignEvent(pinpointEvent)
      : this.defaultEvent(record);

    return p.then((data) => {
      return {
        data,
        recordId: record.recordId,
        result: 'Ok'
      };
    });
  }