function buildSource()

in source/services/transformer/index.ts [95:133]

33 lines of code
7 McCabe index (conditional complexity)


function buildSource(message: string, extractedFields: any) {
  if (extractedFields) {
    logger.debug({
      label: "handler",
      message: `extractedFields: ${extractedFields} `,
    });
    const source: { [key: string]: any } = {};

    for (const key in extractedFields) {
      if (extractedFields[key]) {
        const value = extractedFields[key];
        if (isNumeric(value)) {
          source[key] = 1 * value;
          continue;
        }

        const _jsonSubString = extractJson(value);
        if (_jsonSubString !== null) {
          source["$" + key] = JSON.parse(_jsonSubString);
        }

        source[key] = value;
      }
    }

    return source;
  }

  logger.debug({
    label: "handler",
    message: `message: ${message} `,
  });
  const jsonSubString = extractJson(message);
  if (jsonSubString !== null) {
    return JSON.parse(jsonSubString);
  }

  return {};
}