(sessionId: string, turnId: string)
| 686 | } |
| 687 | |
| 688 | function sessionObservation(sessionId: string, turnId: string): SessionObservationRecord { |
| 689 | const current = observations.get(sessionId); |
| 690 | if (current?.turnId === turnId) return current; |
| 691 | if (current) sessionState(sessionId, turnId).reobserveRequired(); |
| 692 | const next = { turnId, state: new CuaFrameState() }; |
| 693 | observations.set(sessionId, next); |
| 694 | return next; |
| 695 | } |
| 696 | |
| 697 | function trackPendingInvocation(sessionId: string, turnId: string): () => void { |
| 698 | const turns = pendingInvocationTurns.get(sessionId) ?? new Set<string>(); |
no test coverage detected