(
muxMetadata: unknown
)
| 7581 | } |
| 7582 | |
| 7583 | private getWorkspaceTurnMetadataFromValue( |
| 7584 | muxMetadata: unknown |
| 7585 | ): { taskHandleId: string; ownerWorkspaceId: string; turnId: string } | null { |
| 7586 | if (typeof muxMetadata !== "object" || muxMetadata == null || Array.isArray(muxMetadata)) { |
| 7587 | return null; |
| 7588 | } |
| 7589 | const data = muxMetadata as Record<string, unknown>; |
| 7590 | if (data.type !== "workspace-turn-task") { |
| 7591 | return null; |
| 7592 | } |
| 7593 | const taskHandleId = coerceNonEmptyString(data.taskHandleId); |
| 7594 | const ownerWorkspaceId = coerceNonEmptyString(data.ownerWorkspaceId); |
| 7595 | const turnId = coerceNonEmptyString(data.turnId); |
| 7596 | if (!taskHandleId || !ownerWorkspaceId || !turnId) { |
| 7597 | return null; |
| 7598 | } |
| 7599 | return { taskHandleId, ownerWorkspaceId, turnId }; |
| 7600 | } |
| 7601 | |
| 7602 | private getWorkspaceTurnMetadata( |
| 7603 | event: StreamEndEvent |
no test coverage detected