mirror of
https://github.com/stablyai/orca.git
synced 2026-11-01 01:27:35 +00:00
Brennan Benson
8c1ade9e44
* fix(native-chat): retire acknowledged send echoes after catch-up * test: follow phone lint rules in reconnect regression * test: format reconnect message expectation * Keep current chat requests independent of loaded history * Read current chat requests in bounded cursor pieces * Fix current request subscription static checks * Match generated request schema import ordering * fix(native-chat): correct current request type boundaries * Exercise current request reads in wire compatibility inventory * Align current request fixtures with provider commit and RPC surface * test(native-chat): include current request browser capability * Keep the mobile chat session hook within its line budget * Format mobile current request readers * fix(native-chat): reopen once for a current-request version whose read keeps failing A deterministic read failure reopened the subscription, whose first frame re-read the same version and reset the backoff, so the pane resubscribed every 750 ms forever. * test(native-chat): type the current-request snapshot fixture * test(native-chat): wait for the hydrated open before driving the subscription
95 lines
2.8 KiB
TypeScript
95 lines
2.8 KiB
TypeScript
import { createAgentSessionCurrentRequestsReader } from '../../../src/shared/agent-session-current-requests-reader'
|
|
import type {
|
|
AgentSessionCurrentRequestsPiece,
|
|
AgentSessionCurrentRequestsRead
|
|
} from '../../../src/shared/agent-session-current-requests-wire'
|
|
import type { AgentSessionSubscribeEvent } from '../../../src/shared/agent-session-wire'
|
|
import type { StructuredAgentSessionAction } from '../../../src/shared/structured-agent-session-reducer'
|
|
import { isSubscribeEvent } from './mobile-structured-transcript-subscription'
|
|
|
|
/** A failed piece gets one fresh subscription opening; another failure settles this owner. */
|
|
export function startMobileStructuredTranscriptRead(args: {
|
|
sessionId: string
|
|
open: (onFrame: (raw: unknown) => void) => () => void
|
|
read: (request: AgentSessionCurrentRequestsRead) => Promise<AgentSessionCurrentRequestsPiece>
|
|
apply: (action: StructuredAgentSessionAction) => void
|
|
applyQueued: (event: AgentSessionSubscribeEvent) => void
|
|
error: (error: unknown) => void
|
|
isCurrent: () => boolean
|
|
}): () => void {
|
|
let stopped = false
|
|
let generation = 0
|
|
let reopened = false
|
|
let close = (): void => {}
|
|
const current = () => !stopped && args.isCurrent()
|
|
const retire = (): void => {
|
|
generation += 1
|
|
reader.invalidate()
|
|
const end = close
|
|
close = () => {}
|
|
end()
|
|
}
|
|
const reader = createAgentSessionCurrentRequestsReader({
|
|
read: args.read,
|
|
complete: (marker, items) => {
|
|
if (current()) {
|
|
args.apply({ type: 'requests-complete', marker, items })
|
|
}
|
|
},
|
|
replaceMarker: (marker) => {
|
|
if (current()) {
|
|
args.apply({ type: 'requests-marker', marker })
|
|
}
|
|
},
|
|
error: (error) => {
|
|
if (!current()) {
|
|
return
|
|
}
|
|
retire()
|
|
args.error(error)
|
|
if (!reopened) {
|
|
reopened = true
|
|
open()
|
|
} else {
|
|
stopped = true
|
|
}
|
|
}
|
|
})
|
|
function open(): void {
|
|
const openedGeneration = ++generation
|
|
let openingFrame = true
|
|
close = args.open((raw) => {
|
|
if (!current() || generation !== openedGeneration) {
|
|
return
|
|
}
|
|
if (typeof raw === 'object' && raw !== null && 'type' in raw && raw.type === 'error') {
|
|
retire()
|
|
stopped = true
|
|
args.error(raw)
|
|
return
|
|
}
|
|
if (!isSubscribeEvent(raw)) {
|
|
return
|
|
}
|
|
if (raw.type === 'snapshot' || raw.type === 'reset') {
|
|
reader.invalidate()
|
|
}
|
|
args.apply({ type: 'event', event: raw, opensSubscription: openingFrame })
|
|
args.applyQueued(raw)
|
|
if (raw.type === 'end') {
|
|
reader.invalidate()
|
|
} else {
|
|
openingFrame = false
|
|
if (raw.currentRequests?.sessionId === args.sessionId) {
|
|
reader.observe(raw.currentRequests)
|
|
}
|
|
}
|
|
})
|
|
}
|
|
open()
|
|
return () => {
|
|
stopped = true
|
|
retire()
|
|
}
|
|
}
|