Function makeStreamMessage

services/cloud-agent-next/src/websocket/ingest.test.ts:81–87

(streamEventType: string, data?: Record<string, unknown>)

    wrapperConnectionId: 'conn-1',
    connectedAt: now,
    kiloSessionState: { captured: false },
    lastHeartbeatUpdate: now,
    lastEventAtUpdate: now,
    ...overrides,
  };
}

function makeStreamMessage(streamEventType: string, data?: Record<string, unknown>) {
  return JSON.stringify({
    streamEventType,