add Subscriber queries

Author: burak-58

webrtc-android-framework/src/main/java/io/antmedia/webrtcandroidframework/api/DefaultWebRTCListener.java

@@ -10,6 +10,7 @@
 import de.tavendo.autobahn.WebSocket;
 import io.antmedia.webrtcandroidframework.core.StreamInfo;
 import io.antmedia.webrtcandroidframework.websocket.Broadcast;
+import io.antmedia.webrtcandroidframework.websocket.Subscriber;
 
 /**
  * Default implementation of {@link IWebRTCListener}
@@ -258,6 +259,18 @@ public void onLeft(String streamId) {
         callbackCalled(messageText);
     }
 
+    @Override
+    public void onSubscriberCount(String streamId, int count) {
+        String messageText = "On Subscriber Count "+streamId;
+        callbackCalled(messageText);
+    }
+
+    @Override
+    public void onSubscriberList(String streamId, Subscriber[] subscribers) {
+        String messageText = "On Subscriber List "+streamId;
+        callbackCalled(messageText);
+    }
+
     @Override
     public void onPlayAttempt(String streamId) {
         String messageText = "Play attempt for stream "+streamId;

webrtc-android-framework/src/main/java/io/antmedia/webrtcandroidframework/api/IWebRTCClient.java

@@ -368,4 +368,20 @@ void publish(String streamId, String token, boolean videoCallEnabled, boolean au
      */
     boolean isSendVideoEnabled();
 
+    /**
+     * Called to get the subscriber count for a broadcast
+     *
+     * @param streamId: id for the broadcast
+     */
+    void getSubscriberCount(String streamId);
+
+    /**
+     * Called to get the subscriber list for a broadcast
+     *
+     * @param streamId: id for the broadcast
+     * @param offset: offset of the list
+     * @param size: size of the list
+     */
+    void getSubscriberList(String streamId, long offset, long size);
+
 }

webrtc-android-framework/src/main/java/io/antmedia/webrtcandroidframework/api/IWebRTCListener.java

@@ -7,6 +7,7 @@
 import de.tavendo.autobahn.WebSocket;
 import io.antmedia.webrtcandroidframework.core.StreamInfo;
 import io.antmedia.webrtcandroidframework.websocket.Broadcast;
+import io.antmedia.webrtcandroidframework.websocket.Subscriber;
 
 /**
  * Created by karinca on 23.10.2017.
@@ -251,4 +252,14 @@ public interface IWebRTCListener {
      * It's called when user left P2P room.
      */
     void onLeft(String streamId);
+
+   /**
+    * It's called when Subscriber Count received.
+    */
+    void onSubscriberCount(String streamId, int count);
+
+   /**
+    * It's called when Subscriber List received.
+    */
+    void onSubscriberList(String streamId, Subscriber[] subscribers);
 }

webrtc-android-framework/src/main/java/io/antmedia/webrtcandroidframework/core/WebRTCClient.java

@@ -86,11 +86,29 @@
 import io.antmedia.webrtcandroidframework.apprtc.AppRTCAudioManager;
 import io.antmedia.webrtcandroidframework.websocket.AntMediaSignallingEvents;
 import io.antmedia.webrtcandroidframework.websocket.Broadcast;
+import io.antmedia.webrtcandroidframework.websocket.Subscriber;
 import io.antmedia.webrtcandroidframework.websocket.WebSocketHandler;
 
 public class WebRTCClient implements IWebRTCClient, AntMediaSignallingEvents {
     private static final String TAG = "WebRTCClient";
 
+    @Override
+    public void onSubscriberCount(String streamId, int count) {
+        this.handler.post(() -> {
+            if (config.webRTCListener != null) {
+                config.webRTCListener.onSubscriberCount(streamId, count);
+            }
+        });
+    }
+
+    @Override
+    public void onSubscriberList(String streamId, Subscriber[] subscribers) {
+        this.handler.post(() -> {
+            if (config.webRTCListener != null) {
+                config.webRTCListener.onSubscriberList(streamId, subscribers);
+            }
+        });
+    }
 
     public enum Mode {
         PUBLISH, PLAY, P2P, MULTI_TRACK_PLAY
@@ -2853,6 +2871,20 @@ public boolean isSendVideoEnabled() {
         return sendVideoEnabled;
     }
 
+    @Override
+    public void getSubscriberCount(String streamId) {
+        if (wsHandler != null && wsHandler.isConnected()) {
+            wsHandler.getSubscriberCount(streamId);
+        }
+    }
+
+    @Override
+    public void getSubscriberList(String streamId, long offset, long size) {
+        if (wsHandler != null && wsHandler.isConnected()) {
+            wsHandler.getSubscriberList(streamId, offset, size);
+        }
+    }
+
     @Override
     public boolean isSendAudioEnabled() {
         return sendAudioEnabled;

webrtc-android-framework/src/main/java/io/antmedia/webrtcandroidframework/websocket/AntMediaSignallingEvents.java

@@ -152,4 +152,18 @@ public interface AntMediaSignallingEvents {
      * @param streamId Peer to peer room name/id.
      */
     void onLeft(String streamId);
+
+    /**
+     * It's called when subscriber count received from server
+     * @param streamId Stream Id
+     * @param count Count
+     */
+    void onSubscriberCount(String streamId, int count);
+
+    /**
+     * It's called when subscriber list received from server
+     * @param streamId Stream Id
+     * @param subscribers subscriber array
+     */
+    void onSubscriberList(String streamId, Subscriber[] subscribers);
 }

webrtc-android-framework/src/main/java/io/antmedia/webrtcandroidframework/websocket/Subscriber.java

@@ -0,0 +1,49 @@
+package io.antmedia.webrtcandroidframework.websocket;
+
+
+public class Subscriber {
+    
+    private String subscriberId;
+    private String streamId;
+    private boolean connected;
+    private int currentConcurrentConnections = 0;
+    private int concurrentConnectionsLimit = 1;
+
+	public void setSubscriberId(String subscriberId) {
+		this.subscriberId = subscriberId;
+	}
+	
+	public String getSubscriberId() {
+		return subscriberId;
+	}
+
+	public void setStreamId(String streamId) {
+		this.streamId = streamId;
+	}	
+	
+	public String getStreamId() {
+		return streamId;
+	}
+	public boolean isConnected() {
+		return connected;
+	}
+	public void setConnected(boolean connected) {
+		this.connected = connected;
+	}
+
+	public int getCurrentConcurrentConnections() {
+		return currentConcurrentConnections;
+	}
+
+	public void setCurrentConcurrentConnections(int currentConcurrentConnections) {
+		this.currentConcurrentConnections = currentConcurrentConnections;
+	}
+
+	public int getConcurrentConnectionsLimit() {
+		return concurrentConnectionsLimit;
+	}
+
+	public void setConcurrentConnectionsLimit(int concurrentConnectionsLimit) {
+		this.concurrentConnectionsLimit = concurrentConnectionsLimit;
+	}
+}