function transform()

in source/services/transformer/index.ts [66:88]


function transform(
  logEvent: ILogEvent,
  owner: string,
  logGroup: string,
  logStream: string
) {
  const source = buildSource(logEvent.message, logEvent.extractedFields);
  if ("requestParameters" in source)
    source["requestParameters"] = JSON.stringify(source["requestParameters"]);
  if ("responseElements" in source)
    source["responseElements"] = JSON.stringify(source["responseElements"]);
  if ("apiVersion" in source) source["apiVersion"] = "" + source["apiVersion"];
  if ("account_id" in source) source["account_id"] = "" + source["account_id"];
  source["timestamp"] = new Date(1 * logEvent.timestamp).toISOString();
  source["id"] = logEvent.id;
  source["type"] = "CloudWatchLogs";
  source["@message"] = logEvent.message;
  source["@owner"] = owner;
  source["@log_group"] = logGroup;
  source["@log_stream"] = logStream;

  return source;
}