Function decodeTurnResumeQueryInput

packages/runtime-host/src/protocol/turn.ts:482–506

(value: unknown)

}

function decodeTurnResumeQueryInput(value: unknown): TurnResumeQueryInput {
  const record = requireShapedRecord(
    value,
    'turn.resume.query input',
    ['sessionId'],
    ['sourceRunId', 'expectedRuntimeEventHighWater'],
  );
  if (record.expectedRuntimeEventHighWater !== undefined && record.sourceRunId === undefined) {
    throw invalidProtocolFrame('Turn resume high-water requires a source Run');
  }
  return {
    sessionId: requireEntityId(record.sessionId, 'sessionId'),
    ...(record.sourceRunId !== undefined
      ? { sourceRunId: requireEntityId(record.sourceRunId, 'sourceRunId') }
      : {}),
    ...(record.expectedRuntimeEventHighWater !== undefined
      ? {
          expectedRuntimeEventHighWater: requirePositiveCount(
            record.expectedRuntimeEventHighWater,
            'expectedRuntimeEventHighWater',
          ),
        }
      : {}),
  };
}

function decodeTurnResumeStartInput(value: unknown): TurnResumeStartInput {
  const record = requireExactRecord(value, 'turn.resume.start input', [