test: WebSearchTool log

src/services/telegram/TelegramService.ts

@@ -15,8 +15,11 @@ import type {
   TelegramUpdate,
 } from './telegramTypes.js'
 
-// 日志函数 - 只写入文件
+// 日志函数 - 已禁用，不再写入文件
 function logTelegramDebug(message: string, level: 'debug' | 'error' | 'info' = 'debug'): void {
+  // Telegram 功能已完成，禁用日志输出到 log.md
+  // 如需调试，可以临时取消注释下面的代码
+  /*
   try {
     const fs = require('node:fs')
     const path = require('node:path')
@@ -27,6 +30,7 @@ function logTelegramDebug(message: string, level: 'debug' | 'error' | 'info' = '
   } catch (error) {
     // 忽略文件写入错误
   }
+  */
 }
 
 type Listener = () => void

src/tools/WebSearchTool/WebSearchTool.ts

@@ -10,6 +10,49 @@ import {
   renderToolUseMessage,
   renderToolUseProgressMessage,
 } from './UI.js'
+import { readFileSync, writeFileSync, existsSync } from 'fs'
+import { join } from 'path'
+
+/**
+ * 日志记录函数 - 将日志写入 log.md 文件
+ */
+function logToMarkdown(level: 'INFO' | 'WARN' | 'ERROR' | 'DEBUG', message: string, data?: any) {
+  const timestamp = new Date().toISOString()
+  const emoji = {
+    INFO: '🔵',
+    WARN: '⚠️',
+    ERROR: '❌',
+    DEBUG: '🔍'
+  }[level]
+
+  let logEntry = `\n[${timestamp}] [${level}] ${emoji} ${message}`
+
+  if (data !== undefined) {
+    if (typeof data === 'string') {
+      logEntry += `\n\`\`\`\n${data}\n\`\`\``
+    } else {
+      logEntry += `\n\`\`\`json\n${JSON.stringify(data, null, 2)}\n\`\`\``
+    }
+  }
+
+  const logPath = join(process.cwd(), 'log.md')
+
+  try {
+    // 追加日志到文件
+    if (existsSync(logPath)) {
+      const existingContent = readFileSync(logPath, 'utf-8')
+      writeFileSync(logPath, existingContent + logEntry, 'utf-8')
+    } else {
+      writeFileSync(logPath, logEntry, 'utf-8')
+    }
+  } catch (error) {
+    // 如果写入日志失败，仍然输出到控制台
+    console.error(`[WebSearch] 无法写入日志文件: ${error}`)
+  }
+
+  // 同时输出到控制台
+  console.log(`[WebSearch] ${level}: ${message}`, data !== undefined ? data : '')
+}
 
 const inputSchema = lazySchema(() =>
   z.strictObject({
@@ -53,44 +96,128 @@ import type { WebSearchProgress } from '../../types/tools.js'
 async function searchSearXNG(
   query: string
 ): Promise<Array<{ title: string; url: string; snippet?: string }>> {
-  console.log(`[WebSearch] Searching SearXNG for: "${query}"`)
+  logToMarkdown('INFO', '开始搜索 SearXNG')
+  logToMarkdown('DEBUG', '搜索查询', query)
+
+  // 断言：查询参数必须有效
+  console.assert(
+    typeof query === 'string' && query.trim().length > 0,
+    `[WebSearch] ❌ 无效的查询参数: ${JSON.stringify(query)}`
+  )
 
   try {
     const url = new URL('http://localhost:8080/search')
     url.searchParams.set('q', query)
     url.searchParams.set('format', 'json')
 
+    const finalUrl = url.toString()
+    logToMarkdown('DEBUG', '请求 URL', finalUrl)
+
     const controller = new AbortController()
     const timeout = setTimeout(() => controller.abort(), 10000)
 
-    const res = await fetch(url.toString(), {
+    logToMarkdown('INFO', '发起 HTTP 请求 (10秒超时)')
+    const startTime = Date.now()
+    const res = await fetch(finalUrl, {
       signal: controller.signal,
       headers: {
         'User-Agent': 'Mozilla/5.0 (compatible; WebSearchTool/1.0)',
         'Accept': 'application/json',
       },
     })
+    const elapsed = Date.now() - startTime
 
     clearTimeout(timeout)
 
+    const statusInfo = `${res.status} ${res.statusText} (${elapsed}ms)`
+    logToMarkdown('INFO', 'HTTP 响应状态', statusInfo)
+    logToMarkdown('DEBUG', '响应头 Content-Type', res.headers.get('content-type'))
+
+    // 断言：HTTP 状态码应该是 2xx
+    console.assert(
+      res.ok,
+      `[WebSearch] ❌ HTTP 请求失败: ${res.status} ${res.statusText}`
+    )
+
     if (!res.ok) {
-      throw new Error(`HTTP ${res.status}`)
+      const errorText = await res.text()
+      logToMarkdown('ERROR', '错误响应内容', errorText)
+      throw new Error(`HTTP ${res.status}: ${errorText}`)
     }
 
+    logToMarkdown('INFO', '解析 JSON 响应')
     const data = await res.json()
 
-    return (data.results || [])
+    const resultStats = {
+      query: data.query,
+      totalResults: data.number_of_results,
+      resultsCount: data.results?.length || 0,
+    }
+    logToMarkdown('INFO', '返回结果统计', resultStats)
+
+    // 断言：响应数据应该包含 results 数组
+    console.assert(
+      Array.isArray(data.results),
+      `[WebSearch] ❌ 响应数据格式错误: results 不是数组, 类型: ${typeof data.results}`
+    )
+
+    const results = (data.results || [])
       .slice(0, 10)
-      .map((r: any) => ({
-        title: r.title,
-        url: r.url,
-        snippet: r.content,
-      }))
+      .map((r: any, index: number) => {
+        // 断言：每个结果必须有 title 和 url
+        console.assert(
+          r.title && r.url,
+          `[WebSearch] ⚠️ 结果 ${index} 缺少必要字段: ${JSON.stringify(r)}`
+        )
+
+        return {
+          title: r.title,
+          url: r.url,
+          snippet: r.content,
+        }
+      })
+
+    logToMarkdown('INFO', `搜索完成，返回 ${results.length} 条结果`)
+    return results
   } catch (error) {
-    console.error('[WebSearch] SearXNG failed:', error)
+    const errorMessage = error instanceof Error ? error.message : String(error)
+    const errorStack = error instanceof Error ? error.stack : undefined
+
+    logToMarkdown('ERROR', '搜索失败', errorMessage)
+    if (errorStack) {
+      logToMarkdown('ERROR', '错误堆栈', errorStack)
+    }
+
     logError('SearXNG search failed', error)
+
+    // 根据错误类型提供��详细的诊断信息
+    if (error instanceof Error) {
+      if (error.name === 'AbortError') {
+        const timeoutReasons = [
+          'SearXNG 服务响应过慢',
+          '网络连接问题',
+          'SearXNG 服务未运行'
+        ]
+        logToMarkdown('ERROR', '请求超时 (10秒)，可能原因', timeoutReasons)
+      } else if (error.message.includes('ECONNREFUSED')) {
+        const connectionReasons = [
+          'SearXNG 服务未启动',
+          '端口 8080 未开放',
+          '防火墙阻止连接'
+        ]
+        logToMarkdown('ERROR', '连接被拒绝，可能原因', connectionReasons)
+      } else if (error.message.includes('HTTP 403')) {
+        const forbiddenReasons = [
+          'SearXNG 配置不允许 JSON 格式',
+          'IP 被限制',
+          '需要认证'
+        ]
+        logToMarkdown('ERROR', 'HTTP 403 禁止访问，可能原因', forbiddenReasons)
+      }
+    }
+
     throw new Error(
-      `SearXNG search failed: ${error instanceof Error ? error.message : String(error)}`
+      `SearXNG search failed: ${errorMessage}`
     )
   }
 }
@@ -133,7 +260,9 @@ export const WebSearchTool = buildTool({
   },
 
   isEnabled() {
-    return true
+    const enabled = true
+    logToMarkdown('DEBUG', `isEnabled() = ${enabled}`)
+    return enabled
   },
 
   get inputSchema() {
@@ -175,17 +304,34 @@ export const WebSearchTool = buildTool({
   },
 
   async validateInput(input) {
+    logToMarkdown('DEBUG', 'validateInput() 被调用')
+    logToMarkdown('DEBUG', '输入参数', input)
+
     if (!input?.query) {
+      logToMarkdown('ERROR', '验证失败: Missing query')
       return { result: false, message: 'Missing query', errorCode: 1 }
     }
+
+    logToMarkdown('INFO', '验证通过')
     return { result: true }
   },
 
   async call(input, _context, _canUseTool, _parentMessage, onProgress) {
     const start = performance.now()
 
+    logToMarkdown('INFO', 'WebSearchTool.call() 被调用')
+    logToMarkdown('DEBUG', '输入参数', input)
+
+    // 断言：input 必须存在
+    console.assert(
+      input !== null && input !== undefined,
+      `[WebSearch] ❌ input 参数为 null/undefined`
+    )
+
     try {
+      // 验证查询参数
       if (!input?.query || input.query.trim() === '') {
+        logToMarkdown('WARN', '查询参数为空，返回错误')
         return {
           query: input?.query || '',
           results: ['Error: Missing query'],
@@ -193,19 +339,38 @@ export const WebSearchTool = buildTool({
         }
       }
 
+      // 断言：查询长度必须至少 2 个字符（根据 inputSchema 定义）
+      console.assert(
+        input.query.trim().length >= 2,
+        `[WebSearch] ❌ 查询长度不足: "${input.query}" (长度: ${input.query.length})`
+      )
+
+      logToMarkdown('INFO', `查询参数验证通过: "${input.query}"`)
+
       if (onProgress) {
+        logToMarkdown('DEBUG', '发送进度更新')
         onProgress({
           toolUseID: 'search-start',
           data: { type: 'query_update', query: input.query },
         })
       }
 
+      logToMarkdown('INFO', '调用 searchSearXNG()')
       const results = await searchSearXNG(input.query)
 
-      const cleaned = results.map(r => ({
-        ...r,
-        ...cleanSearchResult(r),
-      }))
+      logToMarkdown('INFO', '清洗搜索结果')
+      const cleaned = results.map(r => {
+        const cleanedResult = cleanSearchResult(r)
+        logToMarkdown('DEBUG', '清洗结果', {
+          originalTitle: r.title,
+          cleanedTitle: cleanedResult.title,
+          hasSnippet: !!r.snippet,
+        })
+        return {
+          ...r,
+          ...cleanedResult,
+        }
+      })
 
       const output =
         cleaned.length === 0
@@ -217,18 +382,37 @@ export const WebSearchTool = buildTool({
               },
             ]
 
+      const duration = (performance.now() - start) / 1000
+
+      const finalStats = {
+        query: input.query,
+        resultsCount: cleaned.length,
+        durationSeconds: duration.toFixed(3),
+      }
+      logToMarkdown('INFO', '搜索成功完成')
+      logToMarkdown('INFO', '最终统计', finalStats)
+
       return {
         query: input.query,
         results: output,
-        durationSeconds: (performance.now() - start) / 1000,
+        durationSeconds: duration,
       }
     } catch (error) {
+      const duration = (performance.now() - start) / 1000
+      const errorMessage = error instanceof Error ? error.message : String(error)
+
+      logToMarkdown('ERROR', 'WebSearchTool.call() 发生异常')
+      logToMarkdown('ERROR', '异常信息', errorMessage)
+      if (error instanceof Error && error.stack) {
+        logToMarkdown('ERROR', '异常堆栈', error.stack)
+      }
+
       logError(error)
 
       return {
-        query: input.query,
-        results: [`Error: ${error instanceof Error ? error.message : String(error)}`],
-        durationSeconds: (performance.now() - start) / 1000,
+        query: input?.query || '',
+        results: [`Error: ${errorMessage}`],
+        durationSeconds: duration,
       }
     }
   },