feat: 改进 /v1/messages 日志显示

- IN 日志显示原始模型 → 实际模型和 API 路径
- OUT 日志实时显示 chunk 计数，完成后显示 ✓
- 使用 ANSI 转义序列实现单行进度更新
- 跳过 /v1/messages 的 Hono logger 避免日志冲突

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: cuipengfei

.beads/issues.jsonl

@@ -1 +1,2 @@
-{"id":"copilot-api-b5q","content_hash":"544922c60eaba023693cf621f3e2bec394c03c6269b2d79ce4f552fb51232bc7","title":"改进模型请求日志：覆盖两条路径并记录原始/实际模型","description":"当前日志只在 ChatCompletions 路径记录 openAIPayload.model。需要：\n1. 在两条路径（ChatCompletions 和 Responses API）都记录日志\n2. 记录原始请求的模型（anthropicPayload.model）\n3. 记录实际使用的模型（翻译后的模型名）\n\n相关文件：\n- src/routes/messages/handler.ts:76-78\n- src/routes/messages/non-stream-translation.ts:49 (translateModelName)\n- src/routes/messages/responses-translation.ts:64 (model 直接透传)","notes":"实施计划：\n\n1. 在 handleCompletion 函数中（路由分叉前）添加统一日志：\n   - 记录原始请求模型：anthropicPayload.model\n   - 记录使用的 API 路径：ChatCompletions 或 Responses\n\n2. ChatCompletions 路径：\n   - 在 handleWithChatCompletions 中记录 openAIPayload.model（翻译后的模型名）\n\n3. Responses API 路径：\n   - 在 handleWithResponsesApi 中添加类似日志\n   - 记录 responsesPayload.model（Responses API 不翻译模型名）\n\n4. 移除原有的单点日志：handler.ts:76\n\n5. 删除代码中的三个 TODO 注释","status":"closed","priority":2,"issue_type":"task","created_at":"2025-11-28T22:52:37.566511883+08:00","updated_at":"2025-11-28T22:56:59.002176965+08:00","closed_at":"2025-11-28T22:56:59.002176965+08:00","source_repo":"."}
+{"id":"copilot-api-0jp","title":"改进 /v1/messages 日志：IN/OUT 格式 + 实时 chunk 计数","description":"目标日志格式：\n[/v1/messages] IN  gpt-5-mini → gpt-5 (Responses)\n[/v1/messages] OUT gpt-5 (Responses) 42 chunks ✓\n\n要求：\n- IN：请求进来时打印，原始模型 → 实际模型 (API路径)\n- OUT：streaming 时用 \\r 实时更新 chunk 数，结束后加 ✓ 并换行\n- Non-streaming：打印 OUT model (API) ✓\n\n关键约束：\n- 不能消费 stream（只计数，不读取内容）\n- 不能破坏现有 streaming 行为\n- chunk 计数在循环中递增，不影响数据传输\n\n修改文件：src/routes/messages/handler.ts","status":"closed","priority":1,"issue_type":"task","created_at":"2025-11-28T23:33:01.113239475+08:00","updated_at":"2025-11-28T23:39:50.896628851+08:00","closed_at":"2025-11-28T23:39:50.896628851+08:00"}
+{"id":"copilot-api-b5q","title":"改进模型请求日志：覆盖两条路径并记录原始/实际模型","description":"当前日志只在 ChatCompletions 路径记录 openAIPayload.model。需要：\n1. 在两条路径（ChatCompletions 和 Responses API）都记录日志\n2. 记录原始请求的模型（anthropicPayload.model）\n3. 记录实际使用的模型（翻译后的模型名）\n\n相关文件：\n- src/routes/messages/handler.ts:76-78\n- src/routes/messages/non-stream-translation.ts:49 (translateModelName)\n- src/routes/messages/responses-translation.ts:64 (model 直接透传)","notes":"实施计划：\n\n1. 在 handleCompletion 函数中（路由分叉前）添加统一日志：\n   - 记录原始请求模型：anthropicPayload.model\n   - 记录使用的 API 路径：ChatCompletions 或 Responses\n\n2. ChatCompletions 路径：\n   - 在 handleWithChatCompletions 中记录 openAIPayload.model（翻译后的模型名）\n\n3. Responses API 路径：\n   - 在 handleWithResponsesApi 中添加类似日志\n   - 记录 responsesPayload.model（Responses API 不翻译模型名）\n\n4. 移除原有的单点日志：handler.ts:76\n\n5. 删除代码中的三个 TODO 注释","status":"closed","priority":2,"issue_type":"task","created_at":"2025-11-28T22:52:37.566511883+08:00","updated_at":"2025-11-28T22:56:59.002176965+08:00","closed_at":"2025-11-28T22:56:59.002176965+08:00"}

src/routes/messages/handler.ts

@@ -42,6 +42,15 @@ import { translateChunkToAnthropicEvents } from "./stream-translation"
 
 const logger = createHandlerLogger("messages-handler")
 
+interface OutLogOptions {
+  model: string
+  chunks: number
+  done: boolean
+}
+
+const formatOutLog = ({ model, chunks, done }: OutLogOptions): string =>
+  `\x1b[2K\r↪ ${model} ${chunks}${done ? " ✓" : ""}`
+
 export async function handleCompletion(c: Context) {
   await checkRateLimit(state)
 
@@ -55,10 +64,6 @@ export async function handleCompletion(c: Context) {
 
   const useResponsesApi = shouldUseResponsesApi(anthropicPayload.model)
 
-  consola.info(
-    `[/v1/messages] Original model: ${anthropicPayload.model}, API path: ${useResponsesApi ? "Responses" : "ChatCompletions"}`,
-  )
-
   if (state.manualApprove) {
     await awaitApproval()
   }
@@ -77,7 +82,9 @@ const handleWithChatCompletions = async (
   anthropicPayload: AnthropicMessagesPayload,
 ) => {
   const openAIPayload = translateToOpenAI(anthropicPayload)
-  consola.info(`[/v1/messages] Translated model: ${openAIPayload.model}`)
+  consola.info(
+    `[/v1/messages] IN  ${anthropicPayload.model} → ${openAIPayload.model} (ChatCompletions)`,
+  )
   logger.debug(
     "Translated OpenAI request payload:",
     JSON.stringify(openAIPayload),
@@ -95,6 +102,9 @@ const handleWithChatCompletions = async (
       "Translated Anthropic response:",
       JSON.stringify(anthropicResponse),
     )
+    process.stdout.write(
+      `${formatOutLog({ model: openAIPayload.model, chunks: 0, done: true })}\n`,
+    )
     return c.json(anthropicResponse)
   }
 
@@ -110,6 +120,7 @@ const handleWithChatCompletions = async (
       thinkingBlockOpen: false,
     }
 
+    let chunkCount = 0
     try {
       for await (const rawEvent of response) {
         logger.debug("Copilot raw stream event:", JSON.stringify(rawEvent))
@@ -121,6 +132,15 @@ const handleWithChatCompletions = async (
           continue
         }
 
+        chunkCount++
+        process.stdout.write(
+          formatOutLog({
+            model: openAIPayload.model,
+            chunks: chunkCount,
+            done: false,
+          }),
+        )
+
         const chunk = JSON.parse(rawEvent.data) as ChatCompletionChunk
         const events = translateChunkToAnthropicEvents(chunk, streamState)
 
@@ -134,6 +154,9 @@ const handleWithChatCompletions = async (
       }
     } finally {
       clearInterval(pingInterval)
+      process.stdout.write(
+        `${formatOutLog({ model: openAIPayload.model, chunks: chunkCount, done: true })}\n`,
+      )
     }
   })
 }
@@ -144,7 +167,9 @@ const handleWithResponsesApi = async (
 ) => {
   const responsesPayload =
     translateAnthropicMessagesToResponsesPayload(anthropicPayload)
-  consola.info(`[/v1/messages] Using model: ${responsesPayload.model}`)
+  consola.info(
+    `[/v1/messages] IN  ${anthropicPayload.model} → ${responsesPayload.model} (Responses)`,
+  )
   logger.debug(
     "Translated Responses payload:",
     JSON.stringify(responsesPayload),
@@ -163,6 +188,7 @@ const handleWithResponsesApi = async (
 
       const streamState = createResponsesStreamState()
 
+      let chunkCount = 0
       try {
         for await (const chunk of response) {
           const eventName = chunk.event
@@ -176,6 +202,15 @@ const handleWithResponsesApi = async (
             continue
           }
 
+          chunkCount++
+          process.stdout.write(
+            formatOutLog({
+              model: responsesPayload.model,
+              chunks: chunkCount,
+              done: false,
+            }),
+          )
+
           logger.debug("Responses raw stream event:", data)
 
           const events = translateResponsesStreamEvent(
@@ -211,6 +246,9 @@ const handleWithResponsesApi = async (
         }
       } finally {
         clearInterval(pingInterval)
+        process.stdout.write(
+          `${formatOutLog({ model: responsesPayload.model, chunks: chunkCount, done: true })}\n`,
+        )
       }
     })
   }
@@ -226,6 +264,9 @@ const handleWithResponsesApi = async (
     "Translated Anthropic response:",
     JSON.stringify(anthropicResponse),
   )
+  process.stdout.write(
+    `${formatOutLog({ model: responsesPayload.model, chunks: 0, done: true })}\n`,
+  )
   return c.json(anthropicResponse)
 }
 

src/server.ts

@@ -13,7 +13,13 @@ import { usageRoute } from "./routes/usage/route"
 
 export const server = new Hono()
 
-server.use(logger())
+server.use("*", async (c, next) => {
+  // /v1/messages 有自己的 IN/OUT 日志，跳过 Hono logger
+  if (c.req.path.startsWith("/v1/messages")) {
+    return next()
+  }
+  return logger()(c, next)
+})
 server.use(cors())
 
 server.get("/", (c) => c.text("Server running"))