Method createStreamParser

src/main/aiHandler.ts:198–241

* 创建 SSE 事件解析器

(
    event: Electron.IpcMainInvokeEvent,
    eventChannel: string,
    fullResponse: { value: string },
    fullReasoning: { value: string }
  )

   * 创建 SSE 事件解析器
   */
  private createStreamParser(
    event: Electron.IpcMainInvokeEvent,
    eventChannel: string,
    fullResponse: { value: string },
    fullReasoning: { value: string }
  ) {
    return createParser({
      onEvent: (eventData) => {
        if (eventData.data === '[DONE]') {
          this.sendComplete(event, eventChannel, fullResponse.value, fullReasoning.value)
          return
        }

        try {
          const parsed = JSON.parse(eventData.data)
          const delta = parsed.choices?.[0]?.delta
          const content = delta?.content
          const reasoning_content =
            delta?.reasoning_content ||
            delta?.reasoning ||
            parsed.reasoning_content ||
            parsed?.reasoning

          if (content) {
            fullResponse.value += content
            event.sender.send(eventChannel, {
              type: 'chunk',
              content: content
            } as AIStreamChunk)
          }

          if (reasoning_content) {
            fullReasoning.value += reasoning_content
            event.sender.send(eventChannel, {
              type: 'reasoning_content',
              reasoning_content: reasoning_content
            } as AIStreamChunk)
          }
        } catch (e) {
          console.warn('Failed to parse streaming data:', e)
        }
      }
    })
  }

  /**
   * 处理流式响应