Function applyDesensitize

packages/node-runtime/src/ai/preprocessor/pipeline.ts:216–234

(
  messages: T[],
  rules: DesensitizeRule[],
  logger: PreprocessLogger
)

}

function applyDesensitize<T extends PreprocessableMessage>(
  messages: T[],
  rules: DesensitizeRule[],
  logger: PreprocessLogger
): T[] {
  const compiledRules = compileRules(rules, logger)
  if (compiledRules.length === 0) return messages

  return messages.map((msg) => {
    if (!msg.content) return msg
    let content = msg.content
    for (const { regex, replacement } of compiledRules) {
      regex.lastIndex = 0
      content = content.replace(regex, replacement)
    }
    if (content === msg.content) return msg
    return { ...msg, content }
  })
}

const regexCache = new Map<string, RegExp | null>()