Сигнальный сервер WebRTC: как подтвердить установление звонка между двумя абонентами?

Я разрабатываю приложение на основе WebRTC, где установление звонка имеет критическое значение, и мне нужно выполнить определенные вычисления при его установлении.

Требования:

Время установления звонка:

Мне нужно обнаружить, когда оба пользователя (Пользователь 1 и Пользователь 2) подключены в одной сессии звонка. Если Пользователь 1 подключается в 13:00, а Пользователь 2 в 16:00, звонок не должен быть отмечен как установленный, так как разрыв в подключении слишком велик.

Временной интервал для синхронизации:

Сервер должен отмечать звонок как установленный только в том случае, если оба пользователя подключаются в пределах определенного временного окна (например, в пределах 30 секунд друг от друга). Если один пользователь подключается слишком рано, а другой слишком поздно, звонок должен быть отменен или завершен.

Зависимость от биллинга:

Точность в определении этого момента является критической.

Обработка крайних случаев:

Текущий подход:

Я использую события iceConnectionState для отслеживания, когда каждый пользователь подключается, и отправляю сигнал на сервер, как только iceConnectionState === ‘connected’. Сервер ждет, пока оба пользователя отправят это состояние подключения, прежде чем отметить звонок как установленный.

Проблемы:

На данный момент, если Пользователь 1 подключается в 13:00, а Пользователь 2 подключается через несколько часов, звонок все равно отмечается как установленный, что неприемлемо для моих требований по биллингу. Для этой проблемы я также реализовал механизм таймаута, но он неэффективен для всех случаев использования.

Поэтому мне нужен надежный и устойчивый подход, чтобы точно определить время подключения, так как это критично с точки зрения масштабируемости и эффективности, а также solid логика для установления звонков WebRTC.

Содержание

Ответ
Общая архитектура
Логика подтверждения установления вызова
Обработка ошибок и таймауты
Заключение
Дополнительные советы

Ответ

Для решения проблемы подтверждения установления вызова между двумя пользователями в WebRTC с учетом заданных требований, необходимо создать надежный механизм, который будет отслеживать соединения и обеспечивать правильное время установления вызова. Вот пошаговое руководство:

Общая архитектура

Сигнальный сервер: Создайте сигнальный сервер, например, на Node.js с использованием WebSocket или Socket.io, для управления всеми событиями соединения пользователей.
Хранение состояния соединения: Реализуйте механизм хранения состояния соединения для каждого пользователя. Это может быть сделано с помощью объекта в памяти или базы данных, где будет храниться информация о времени подключения и текущем состоянии соединения (например, "в ожидании" и "подключен").

Логика подтверждения установления вызова

Отслеживание соединения: Используйте событие iceConnectionState для отслеживания состояния соединений. Когда пользователь подключается и iceConnectionState становится connected, отправьте сигнал на сервер с меткой времени подключения.
```
const connection = new RTCPeerConnection();
connection.oniceconnectionstatechange = () => {
   if (connection.iceConnectionState === 'connected') {
       const timestamp = Date.now();
       socket.emit('userConnected', { userId: userId, time: timestamp });
   }
};
```
Обработка событий на сервере: На сервере создайте обработчик для события userConnected. Когда он получает сигнал о том, что пользователь подключился, запишите время и состояние подключения для этого пользовател.
```
const connections = {};

socket.on('userConnected', ({ userId, time }) => {
   connections[userId] = { time, state: 'connected' };
   checkCallEstablishment();
});
```

Проверка установления вызова: Создайте функцию checkCallEstablishment, которая проверяет, подключены ли оба пользователя и находятся ли они в пределах установленного временного окна.

function checkCallEstablishment() {
   const userIds = Object.keys(connections);
   if (userIds.length < 2) return; // Ожидание второго пользователя

   const [user1, user2] = userIds;
   const timeDiff = Math.abs(connections[user1].time - connections[user2].time);

   // Определяем, находится ли разница времени в допустимых пределах (например, 30 секунд)
   if (timeDiff <= 30000) { // 30 секунд
       console.log('Call established between', user1, 'and', user2);
       // Здесь можно пометить вызов как установленный и начать считать время
   } else {
       console.log('Call not established due to timing issue:', user1, user2);
       // Можно реализовать логику для сброса или уведомления пользователей
   }
}

Обработка ошибок и таймауты

Таймаут: Рассмотрите возможность добавления тайм-аута для каждого пользователя. Если один из пользователей не подключается в течение определенного времени после того, как другой подключился, вызов следует отклонить.

const TIMEOUT_DURATION = 60000; // 60 секунд
let timeouts = {};

socket.on('userConnected', ({ userId, time }) => {
   // Устанавливаем таймаут на случай, если соединение будет потеряно
   if (timeouts[userId]) clearTimeout(timeouts[userId]);
   timeouts[userId] = setTimeout(() => {
       console.log('User timed out:', userId);
       delete connections[userId];
       // Здесь также можно уведомить пользователя о том, что вызов не установлен
   }, TIMEOUT_DURATION);
});

Заключение

Данная реализация позволяет точно отслеживать время подключения каждого пользователя и устанавливать вызов только в том случае, если оба пользователя подключились в пределах заданного временного окна. Следуя этой логике, вы сможете достичь точности, необходимой для ваших требований к биллингу и предотвратить ошибки, связанные с недостаточным временем подключения.

Дополнительные советы

Логи и мониторинг: Внедрите логи и мониторинг для вашего сигнального сервера, чтобы лучше отслеживать соединения и выявлять потенциальные проблемы.
Тестирование: Обязательно протестируйте систему при различных сценариях использования, чтобы убедиться, что все крайние случаи были покрыты.

С помощью этих шагов вы сможете создать надежную и эффективную систему подтверждения установления вызова для вашего WebRTC-приложения.