Function toDots

packages/common/src/object.ts:16–67

(
  obj: Record<string, unknown>,
  path = '',
)

}

export function toDots(
  obj: Record<string, unknown>,
  path = '',
): Record<string, string> {
  // Clickhouse breaks on insert if a property contains invalid surrogate pairs
  function removeInvalidSurrogates(value: string): string {
    const validSurrogatePairRegex =
      /[\uD800-\uDBFF][\uDC00-\uDFFF]|[^\uD800-\uDFFF]/g;
    return value.match(validSurrogatePairRegex)?.join('') || '';
  }

  return Object.entries(obj).reduce((acc, [key, value]) => {
    if (typeof value === 'object' && value !== null) {
      return {
        ...acc,
        ...toDots(value as Record<string, unknown>, `${path}${key}.`),
      };
    }

    if (value === undefined || value === null || value === '') {
      return acc;
    }

    if (typeof value === 'string' && isMalformedJsonString(value)) {
      // Skip it
      return acc;
    }

    // Fix nested json strings - but catch parse errors for malformed JSON
    if (typeof value === 'string' && isValidJsonString(value)) {
      try {
        return {
          ...acc,
          ...toDots(JSON.parse(value), `${path}${key}.`),
        };
      } catch {
        // Skip it
        return acc;
      }
    }

    const cleanedValue =
      typeof value === 'string'
        ? removeInvalidSurrogates(value).trim()
        : String(value);

    return {
      ...acc,
      [`${path}${key}`]: cleanedValue,
    };
  }, {});
}

export function toObject(
  obj: Record<string, string | undefined>,