Function process

packages/arctic/src/session/processor.ts:52–479

(streamInput: StreamInput)

        return toolcalls[toolCallID]
      },
      async process(streamInput: StreamInput) {
        log.info("process")
        let reasoningMap: Record<string, MessageV2.ReasoningPart> = {}
        while (true) {
          try {
            let currentText: MessageV2.TextPart | undefined
            const stream = streamText(streamInput)

            // batching for text deltas to reduce ui update frequency
            let textDeltaBatch = ""
            let textDeltaTimer: Timer | undefined
            const flushTextDelta = async () => {
              if (textDeltaBatch && currentText) {
                await Session.updatePart({
                  part: currentText,
                  delta: textDeltaBatch,
                })
                textDeltaBatch = ""
              }
            }

            // batching for reasoning deltas
            const reasoningDeltaBatch: Record<string, string> = {}
            let reasoningDeltaTimer: Timer | undefined
            const flushReasoningDelta = async () => {
              for (const [id, delta] of Object.entries(reasoningDeltaBatch)) {
                const part = reasoningMap[id]
                if (part && delta) {
                  await Session.updatePart({ part, delta })
                }
              }
              Object.keys(reasoningDeltaBatch).forEach((key) => {
                reasoningDeltaBatch[key] = ""
              })
            }

            for await (const value of stream.fullStream) {
              input.abort.throwIfAborted()
              switch (value.type) {
                case "start":
                  SessionStatus.set(input.sessionID, { type: "busy" })
                  break

                case "reasoning-start":
                  if (value.id in reasoningMap) {
                    continue
                  }
                  reasoningMap[value.id] = {
                    id: Identifier.ascending("part"),
                    messageID: input.assistantMessage.id,
                    sessionID: input.assistantMessage.sessionID,
                    type: "reasoning",
                    text: "",
                    time: {
                      start: Date.now(),
                    },
                    metadata: value.providerMetadata,
                  }