Method markMessageQueued

hub/src/sync/sessionCache.ts:282–307

(sessionId: string, time: number = Date.now())

    }

    markMessageQueued(sessionId: string, time: number = Date.now()): void {
        const session = this.sessions.get(sessionId) ?? this.refreshSession(sessionId)
        if (!session) return
        if (!session.active) return

        const nextTime = clampAliveTime(time) ?? Date.now()
        const wasThinking = session.thinking
        const previousUpdatedAt = session.updatedAt

        session.thinking = true
        session.thinkingAt = nextTime
        session.updatedAt = Math.max(session.updatedAt, nextTime)
        this.pendingThinkingUntilBySessionId.set(session.id, nextTime + QUEUED_MESSAGE_THINKING_GRACE_MS)

        if (!wasThinking || session.updatedAt !== previousUpdatedAt) {
            this.lastBroadcastAtBySessionId.set(session.id, Date.now())
            this.publisher.emit({
                type: 'session-updated',
                sessionId: session.id,
                data: {
                    thinking: true,
                    updatedAt: session.updatedAt
                } satisfies SessionPatch
            })
        }
    }

    applyBackgroundTaskDelta(sessionId: string, delta: { started: number; completed: number }): void {
        const session = this.sessions.get(sessionId)