修复 Qwen AI (chat.qwen.ai) 对话结束后未销毁的问题

将删除逻辑从 handler 内部的 onEnd 回调（事件处理期间触发，stream
提前断开则丢失）改为 transformedStream.end() 时执行，与 Kimi 修复模式一致。

Co-Authored-By: DeepSeek V4 Pro <noreply@deepseek.com>

Author: bennylii

src/main/proxy/adapters/qwen-ai.ts

@@ -370,15 +370,13 @@ export class QwenAiStreamHandler {
   private chatId: string = ''
   private model: string
   private created: number
-  private onEnd?: (chatId: string) => void
   private responseId: string = ''
   private content: string = ''
   private toolCallsSent: boolean = false
 
-  constructor(model: string, onEnd?: (chatId: string) => void) {
+  constructor(model: string) {
     this.model = model
     this.created = Math.floor(Date.now() / 1000)
-    this.onEnd = onEnd
   }
 
   setChatId(chatId: string) {
@@ -432,9 +430,6 @@ export class QwenAiStreamHandler {
         })}\n\n`
       )
       transStream.end('data: [DONE]\n\n')
-      if (this.onEnd && this.chatId) {
-        this.onEnd(this.chatId)
-      }
     }
   }
 
@@ -611,10 +606,6 @@ export class QwenAiStreamHandler {
               }
               transStream.write(`data: ${JSON.stringify(finalChunk)}\n\n`)
               transStream.end('data: [DONE]\n\n')
-
-              if (this.onEnd && this.chatId) {
-                this.onEnd(this.chatId)
-              }
             }
           }
         } catch (err) {
@@ -715,10 +706,6 @@ export class QwenAiStreamHandler {
                     data.choices[0].message.reasoning_content = finalReasoning
                   }
 
-                  if (this.onEnd && this.chatId) {
-                    this.onEnd(this.chatId)
-                  }
-
                   resolveOnce(data)
                 }
               } else if (phase === null && content) {

src/main/proxy/forwarder.ts

@@ -1006,22 +1006,22 @@ CRITICAL RULES:
         }
       }
 
-      const deleteChatCallback = shouldDeleteSession()
-        ? async (cid: string) => {
-            try {
-              await adapter.deleteChat(cid)
-            } catch (err) {
-              console.error('[QwenAI] Failed to delete chat:', err)
-            }
-          }
-        : undefined
-
-      const handler = new QwenAiStreamHandler(actualModel, deleteChatCallback)
+      const handler = new QwenAiStreamHandler(actualModel)
       handler.setChatId(chatId)
 
       if (request.stream) {
         const transformedStream = await handler.handleStream(response.data)
 
+        if (shouldDeleteSession()) {
+          const originalEnd = transformedStream.end.bind(transformedStream)
+          transformedStream.end = function(chunk?: any, encoding?: any, callback?: any) {
+            adapter.deleteChat(chatId).catch(err => {
+              console.error('[QwenAI] Failed to delete chat:', err)
+            })
+            return originalEnd(chunk, encoding, callback)
+          }
+        }
+
         return {
           success: true,
           status: response.status,
@@ -1037,8 +1037,8 @@ CRITICAL RULES:
 
       this.applyToolCallsToResponse(result, request.model, request.tools)
 
-      if (deleteChatCallback) {
-        await deleteChatCallback(chatId)
+      if (shouldDeleteSession()) {
+        await adapter.deleteChat(chatId)
       }
 
       return {