function getAudioEventMessageTransformer()

in lib/transcribe-service.js [41:61]

• 21 lines of code
• 1 McCabe index (conditional complexity)

function getAudioEventMessageTransformer() {
  return new Transform({
    transform: (chunk, encoding, callback) => {
      const message = {
        headers: {
          ":message-type": {
            type: "string",
            value: "event",
          },
          ":event-type": {
            type: "string",
            value: "AudioEvent",
          },
        },
        body: Buffer.from(chunk),
      };
      const binary = eventStreamMarshaller.marshall(message);
      return callback(null, Buffer.from(binary));
    },
  });
}