function createRecordsFromEvents()

in source/services/transformer/index.ts [174:196]

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

function createRecordsFromEvents(
  logEvents: ILogEvent[],
  owner: string,
  logGroup: string,
  logStream: string
) {
  const records: Record[] = [];
  logEvents.forEach((event: ILogEvent) => {
    const transformedEvent = transform(event, owner, logGroup, logStream);
    logger.debug({
      label: "createRecordsFromEvents",
      message: `transformed event: ${JSON.stringify(transformedEvent)}`,
    });
    records.push({
      Data: Buffer.from(JSON.stringify(transformedEvent)),
    });
  });
  logger.info({
    label: "createRecordsFromEvents",
    message: "records created from log events",
  });
  return records;
}