Function decodeTurnProviderRetry

packages/runtime-host/src/protocol/turn.ts:683–716

(value: unknown)

}

export function decodeTurnProviderRetry(value: unknown): TurnProviderRetry {
  const record = requireRecord(value, 'Turn provider retry');
  const phase = record.phase;
  const attempt = requirePositiveCount(record.attempt, 'attempt');
  const maxAttempts = requirePositiveCount(record.maxAttempts, 'maxAttempts');
  if (attempt > maxAttempts) throw invalidProtocolFrame('Invalid Turn provider retry');
  const reason = requireProviderRetryReason(record.reason);
  if (phase === 'scheduled') {
    assertExactKeys(record, 'scheduled Turn provider retry', [
      'phase',
      'attempt',
      'maxAttempts',
      'delayMs',
      'reason',
    ]);
    return {
      phase,
      attempt,
      maxAttempts,
      delayMs: requireCount(record.delayMs, 'delayMs'),
      reason,
    };
  }
  if (phase === 'started') {
    assertExactKeys(record, 'started Turn provider retry', [
      'phase',
      'attempt',
      'maxAttempts',
      'reason',
    ]);
    return { phase, attempt, maxAttempts, reason };
  }
  throw invalidProtocolFrame('Invalid Turn provider retry');
}

function requireProviderRetryReason(value: unknown): ProviderRetryReason {
  if (