(sessionId: string)
| 2393 | } |
| 2394 | |
| 2395 | private ensureSteering(sessionId: string): SessionSteeringState { |
| 2396 | const existing = this.steeringBySession.get(sessionId); |
| 2397 | if (existing) return existing; |
| 2398 | const created: SessionSteeringState = { steering: [], inFlight: [], followup: [] }; |
| 2399 | this.steeringBySession.set(sessionId, created); |
| 2400 | return created; |
| 2401 | } |
| 2402 | |
| 2403 | private assertEmbeddedMessageQueue(operation: string): void { |
| 2404 | if (this.deps.messageAuthority) { |
no test coverage detected