Trajectory: 错误码查询（agent 主动自我进化）

import { readFileSync, existsSync } from 'node:fs'
import { isAbsolute, resolve } from 'node:path'
import { defineTool } from '@deepseek-ai/dsh-tools'

export const name = 'error-code-lookup'
export const inject = ['tools']

const FALLBACKS = [
  '/tmp/demo-shop/docs/error-codes.md',
  '/private/tmp/demo-shop/docs/error-codes.md',
  'docs/error-codes.md',
]

export function apply(ctx, config) {
  const configured = config && config.path ? config.path : null
  ctx.tools.register(defineTool({
    name: 'lookup_error_code',
    description: '查询 demo-shop 错误码表（docs/error-codes.md）。输入错误码（如 E4103）或关键词（如 库存 / 超时 / payment）即可返回 code、含义、owner、是否可重试；输入为空则列出全部。每次调用实时解析表文件，表格更新后无需重新挂载。',
    parameters: {
      code: { type: 'string', required: true, description: '错误码（如 E4103）或含义/owner 关键词；留空字符串可列出全部。' },
    },
    output: {
      schema: { type: 'string' },
      render: (_args, value) => [{ type: 'text', text: value }],
    },
    async execute(args) {
      const file = resolveFile(configured)
      if (!file) {
        const tried = (configured ? [configured] : []).concat(FALLBACKS).join(', ')
        return '未找到错误码表文件，尝试过：' + tried + '。可用 config.path 指定实际路径后重新挂载。'
      }
      const text = readFileSync(file, 'utf8')
      const rows = parseTable(text)
      const q = String(args.code == null ? '' : args.code).trim().toUpperCase()
      const hits = q
        ? rows.filter((r) => r.code.toUpperCase() === q || r.meaning.toUpperCase().includes(q) || r.owner.toUpperCase().includes(q))
        : rows
      if (hits.length === 0) {
        return '表内共 ' + rows.length + ' 条错误码，未匹配 "' + q + '"。可查看 ' + file + ' 确认是否已登记。'
      }
      const lines = hits.map((r) => r.code + ' | ' + r.meaning + ' | owner: ' + r.owner + ' | retry: ' + r.retry)
      return '来源：' + file + '\n' + lines.join('\n')
    },
  }))
}

function resolveFile(configured) {
  const candidates = []
  if (configured) candidates.push(configured)
  candidates.push(...FALLBACKS)
  for (const c of candidates) {
    const p = isAbsolute(c) ? c : resolve(process.cwd(), c)
    if (existsSync(p)) return p
  }
  return null
}

function parseTable(text) {
  const rows = []
  for (const line of text.split('\n')) {
    const t = line.trim()
    if (!t.startsWith('|')) continue
    if (/^\|[\s:|-]+\|$/.test(t)) continue
    const cells = t.replace(/^\|/, '').replace(/\|$/, '').split('|').map((c) => c.trim())
    if (cells.length < 4) continue
    if (cells[0].toUpperCase() === 'CODE') continue
    rows.push({ code: cells[0], meaning: cells[1], owner: cells[2], retry: cells[3] })
  }
  return rows
}