Merge pull request 'Видеосообщения (кружочки)' (#19) from dev into main

Reviewed-on: #19

src/main/java/im/rosetta/calls/CallSession.java

@@ -18,7 +18,9 @@ public class CallSession {
      * Клиенты в этом списке не могут принимать другие звонки, так как они уже заняты дозвоном,
      * но они еще не в звонке, так как не приняли звонок
      * 
-     * Клиенты удаляются из этого списка, когда они принимают звонок или отклоняют его, тогда они либо переходят в звонок, либо становятся свободными для других звонков
+     * Клиенты удаляются из этого списка, когда они принимают звонок или отклоняют его, 
+     * тогда они либо переходят в звонок, либо становятся свободными для других звонков
+     * pk -> время начала дозвона (timestamp в миллисекундах)
      */
     public HashMap<String, Long> ringing;
     /**
@@ -48,6 +50,16 @@ public class CallSession {
         this.clients.put(publicKey, client);
     }
 
+    /**
+     * Проверяет, может ли этот публичный ключ выполнять какие-либо действия в рамках этой сессии звонка,
+     * чтобы не допустить выполнение действий от посторонних публичных ключей, которые не участвуют в звонке
+     * @param publicKey Публичный ключ для проверки
+     * @return true, если этот публичный ключ может выполнять действия в рамках этой сессии звонка, false иначе
+     */
+    public boolean isValidSource(String publicKey) {
+        return this.ringing.containsKey(publicKey) || this.clients.containsKey(publicKey);
+    }
+
     /**
      * Получаем публичный ключ клиента по его сокету, чтобы понимать, кто отправляет сигналы в рамках звонка
      * @param client Сокет клиента, для которого нужно получить публичный ключ

src/main/java/im/rosetta/client/ClientManager.java

@@ -56,9 +56,10 @@ public class ClientManager {
      * Отправить пакет ВСЕМ АВТОРИЗОВАННЫМ клиентам с публичным ключом publicKey
      * @param publicKey публичный ключ получателя
      * @param packet пакет для отправки
+     * @param exclude клиент, который не должен получать этот пакет, может быть null
      * @throws ProtocolException если произошла ошибка при отправке пакета клиенту
      */
-    public void sendPacketToAuthorizedPK(String publicKey, Packet packet) throws ProtocolException {
+    public void sendPacketToAuthorizedPK(String publicKey, Packet packet, Client exclude) throws ProtocolException {
         Set<Client> clients = this.clientIndexer.getClients(ECIAuthentificate.class, "publicKey", publicKey);
         if(clients == null){
             /**
@@ -77,12 +78,55 @@ public class ClientManager {
                 continue;
             }
             /**
-             * Отправляем пакет каждому клиенту с таким публичным ключом (то есть всем его авторизованным сессиям/устройствам)
+             * Отправляем пакет каждому клиенту с таким публичным ключом (то есть всем его авторизованным сессиям/устройствам),
+             * исключая клиента exclude
              */
+            if(exclude != null && client.equals(exclude)){
+                /**
+                 * Этот клиент является исключением, он не должен получать этот пакет
+                 */
+                continue;
+            }
             client.send(packet);
         }
     }
 
+    /**
+     * Отправить пакет ВСЕМ АВТОРИЗОВАННЫМ клиентам с публичным ключом publicKey
+     * @param publicKey публичный ключ получателя
+     * @param packet пакет для отправки
+     * @throws ProtocolException если произошла ошибка при отправке пакета клиенту
+     */
+    public void sendPacketToAuthorizedPK(String publicKey, Packet packet) throws ProtocolException {
+        this.sendPacketToAuthorizedPK(publicKey, packet, null);
+    }
+
+    /**
+     * Отправить пакет всем клиентам с публичными ключами из списка publicKeys
+     * @param publicKeys список публичных ключей получателей
+     * @param packet пакет для отправки
+     * @param exclude клиент, который не должен получать этот пакет, может быть null
+     * @throws ProtocolException если произошла ошибка при отправке пакета клиенту
+     */
+    public void sendPacketToAuthorizedPK(List<String> publicKeys, Packet packet, Client exclude) throws ProtocolException {
+        for(String publicKey : publicKeys){
+            this.sendPacketToAuthorizedPK(publicKey, packet, exclude);
+        }
+    }
+
+    /**
+     * Отправить пакет всем клиентам с публичными ключами из списка publicKeys
+     * @param publicKeys список публичных ключей получателей
+     * @param packet пакет для отправки
+     * @throws ProtocolException если произошла ошибка при отправке пакета клиенту
+     */
+    public void sendPacketToAuthorizedPK(List<String> publicKeys, Packet packet) throws ProtocolException {
+        for(String publicKey : publicKeys){
+            this.sendPacketToAuthorizedPK(publicKey, packet, null);
+        }
+    }
+
+
     /**
      * Отправить пакет всем клиентам с публичными ключом как у client, кроме клиента client, который является отправителем и не должен получать этот пакет
      * @param client клиент
@@ -111,18 +155,6 @@ public class ClientManager {
         }
     }
 
-    /**
-     * Отправить пакет всем клиентам с публичными ключами из списка publicKeys
-     * @param publicKeys список публичных ключей получателей
-     * @param packet пакет для отправки
-     * @throws ProtocolException если произошла ошибка при отправке пакета клиенту
-     */
-    public void sendPacketToAuthorizedPK(List<String> publicKeys, Packet packet) throws ProtocolException {
-        for(String publicKey : publicKeys){
-            this.sendPacketToAuthorizedPK(publicKey, packet);
-        }
-    }
-
     /**
      * Получить список клиентов по публичному ключу (get PublicKey clients), могут быть неавторизованные клиенты
      * @param publicKey публичный ключ клиента

src/main/java/im/rosetta/executors/Executor26SignalPeer.java

@@ -127,6 +127,13 @@ public class Executor26SignalPeer extends PacketExecutor<Packet26SignalPeer> {
                 client.disconnect(Failures.NO_CALL_SESSION);
                 return;
             }
+            if(!session.isValidSource(src)) {
+                /**
+                 * Клиент не состоит в сессии звонка, отключаем его от сервера, так как он отправляет некорректные данные
+                 */
+                client.disconnect(Failures.DATA_MISSMATCH);
+                return;
+            }
             Room room = this.fus.createRoom();
             session.setRoom(room);
             session.joinCall(src, client);
@@ -134,6 +141,13 @@ public class Executor26SignalPeer extends PacketExecutor<Packet26SignalPeer> {
                 room.addParticipant(participant);
             }
             session.sendPacket(packet, client);
+            /**
+             * Сбрасываем вызов на всех остальных устройствах пользователя, который принимает звонок,
+             * чтобы он не смог принять или отклонить звонок с другого устройства
+             */
+            Packet26SignalPeer endCallOtherDevices = new Packet26SignalPeer();
+            endCallOtherDevices.setSignalType(NetworkSignalType.END_CALL);
+            this.clientManager.sendPacketToAuthorizedPK(src, endCallOtherDevices, client);
             return;
         }
         if(type == NetworkSignalType.KEY_EXCHANGE){
@@ -170,13 +184,22 @@ public class Executor26SignalPeer extends PacketExecutor<Packet26SignalPeer> {
             }
             if(session == null) {
                 /**
-                 * Сессии звонка нет
+                 * Сессии звонка нет, скорее всего она была удалена при обрыве RTC Peer Connection,
+                 * при срабатывании RTCPeerConnection::close на клиенте раньше, чем клиент отправил сигнал END_CALL
                  */
-                client.disconnect(Failures.NO_CALL_SESSION);
                 return;
             }
+            /**
+             * Отправляем сигнал окончания звонка всем участникам сессии, кроме отправителя
+             */
             session.sendPacket(packet, client);
+            /**
+             * Отправляем пакет вызываемым (ringing) пользователям (которые еще не в сессии)
+             */
             this.callManager.sendPacketToRinging(session, packet);
+            /**
+             * Удаляем сессию из активных сессий звонков
+             */
             this.callManager.removeSession(session);
             return;
         }

src/main/java/im/rosetta/packet/runtime/AttachmentType.java

@@ -8,7 +8,9 @@ public enum AttachmentType {
     MESSAGES(1),
     FILE(2),
     AVATAR(3),
-    CALL(4);
+    CALL(4),
+    VOICE(5),
+    VIDEO_CIRCLE(6);
 
 
     private final int code;

src/main/java/im/rosetta/service/dispatch/push/dispatchers/FCM.java

@@ -61,9 +61,10 @@ public class FCM extends Pusher {
                  * Тихий тип уведомления для очистки отправленных уведомлений на устройстве, 
                  * не должен отображаться пользователю, поэтому не задаем звук и ставим contentAvailable для iOS и high priority для Android
                  */
-                apnsConfig.setAps(Aps.builder().setContentAvailable(true).setSound("default").build());
+                apnsConfig.setAps(Aps.builder().setContentAvailable(true).setMutableContent(true).build());
                 androidConfig.setPriority(AndroidConfig.Priority.HIGH);
                 messageBuilder.setApnsConfig(apnsConfig.build());
+                messageBuilder.setNotification(Notification.builder().setTitle("").setBody("").build());
                 messageBuilder.setAndroidConfig(androidConfig.build());
                 break;
             case PushType.PERSONAL_MESSAGE: