starred/orca
1
0
Fork 0
mirror of https://github.com/stablyai/orca.git synced 2026-10-19 16:03:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(remote): fail missing probe requests

Browse Source
This commit is contained in:
OrcaWin
2026-07-30 16:24:36 -07:00
parent 051167beb1
commit e30e48e86f
1 changed files with 18 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/renderer/src/runtime/remote-runtime-terminal-stall-recovery.test.ts
+18 -8
View File
@@ -225,20 +225,30 @@ describe('remote terminal stalled stream recovery', () => {
expect(stream.sendInput('regressed-snapshot\r')).toBe(true)
await vi.advanceTimersByTimeAsync(REMOTE_TERMINAL_COMMAND_RESPONSE_TIMEOUT_MS)
const regressedRequest = sentFrames(TerminalStreamOpcode.SnapshotRequest)[2]
const regressedPayload = regressedRequest
? decodeTerminalStreamJson<{ requestId: number }>(regressedRequest.payload)
: null
emitSnapshot(stream.streamId, regressedPayload?.requestId ?? 0, 'partial-output', 8)
expect(regressedRequest).toBeDefined()
if (!regressedRequest) {
throw new Error('Missing regressed snapshot request')
}
const regressedPayload = decodeTerminalStreamJson<{ requestId: number }>(
regressedRequest.payload
)
expect(regressedPayload.requestId).toBeTypeOf('number')
emitSnapshot(stream.streamId, regressedPayload.requestId, 'partial-output', 8)
await vi.advanceTimersByTimeAsync(0)
expect(onTransportClose).not.toHaveBeenCalled()
expect(stream.sendInput('still-below-baseline\r')).toBe(true)
await vi.advanceTimersByTimeAsync(REMOTE_TERMINAL_COMMAND_RESPONSE_TIMEOUT_MS)
const belowBaselineRequest = sentFrames(TerminalStreamOpcode.SnapshotRequest)[3]
const belowBaselinePayload = belowBaselineRequest
? decodeTerminalStreamJson<{ requestId: number }>(belowBaselineRequest.payload)
: null
emitSnapshot(stream.streamId, belowBaselinePayload?.requestId ?? 0, 'partial-output', 10)
expect(belowBaselineRequest).toBeDefined()
if (!belowBaselineRequest) {
throw new Error('Missing below-baseline snapshot request')
}
const belowBaselinePayload = decodeTerminalStreamJson<{ requestId: number }>(
belowBaselineRequest.payload
)
expect(belowBaselinePayload.requestId).toBeTypeOf('number')
emitSnapshot(stream.streamId, belowBaselinePayload.requestId, 'partial-output', 10)
await vi.advanceTimersByTimeAsync(0)
expect(onTransportClose).not.toHaveBeenCalled()