Method sendMessageStreaming

src/main/aiHandler.ts:279–335

(
    event: Electron.IpcMainInvokeEvent,
    request: AIRequest,
    eventChannel: string
  )

  }

  public async sendMessageStreaming(
    event: Electron.IpcMainInvokeEvent,
    request: AIRequest,
    eventChannel: string
  ): Promise<void> {
    const abortController = new AbortController()
    this.abortControllers.set(request.requestId, abortController)

    try {
      const modelConfig = this.getModelConfig(request.modelConfig)
      const apiMessages = await this.prepareApiMessages(request.messages, modelConfig)

      const response = await this.fetchStreamingResponse(
        request,
        apiMessages,
        modelConfig,
        abortController
      )

      if (!response.ok) {
        this.sendError(event, eventChannel, `HTTP error! status: ${response.status}`)
        return
      }

      const reader = response.body?.getReader()
      if (!reader) {
        this.sendError(event, eventChannel, 'No response body reader available')
        return
      }

      const fullResponse = { value: '' }
      const fullReasoning = { value: '' }

      const parser = this.createStreamParser(event, eventChannel, fullResponse, fullReasoning)

      await this.processStreamResponse(
        reader,
        parser,
        event,
        eventChannel,
        fullResponse,
        fullReasoning
      )
    } catch (error) {
      if (error instanceof Error && error.name === 'AbortError') {
        this.sendComplete(event, eventChannel, '', undefined)
      } else {
        this.sendError(
          event,
          eventChannel,
          error instanceof Error ? error.message : 'Unknown error'
        )
      }
    } finally {
      this.abortControllers.delete(request.requestId)
    }
  }