[REFACTOR]: Ensure the code is free of memory leaks

privmx-endpoint-streams/android/src/main/java/com/simplito/java/privmx_endpoint/modules/stream/JanusConnection.java

@@ -120,9 +120,10 @@ public boolean isEnded(){
                 peerConnection.connectionState() == PeerConnection.PeerConnectionState.FAILED;
     }
 
-    public void close(){
-        if(peerConnection.connectionState() != PeerConnection.PeerConnectionState.CLOSED) {
+    public void close() {
+        if (peerConnection.connectionState() != PeerConnection.PeerConnectionState.CLOSED) {
             peerConnection.dispose();
+            pcObserver.dispose();
         }
     }
 

privmx-endpoint-streams/android/src/main/java/com/simplito/java/privmx_endpoint/modules/stream/JanusPublisher.java

@@ -92,7 +92,11 @@ public void removeAudioTrack(String id) {
             AudioTrackInfo audioTrackInfo = audioTracks.get(id);
             if (audioTrackInfo == null) return;
             peerConnection.removeTrack(audioTrackInfo.sender);
-            audioTracks.remove(id);
+
+            AudioTrackInfo removedAudioTrackInfo = audioTracks.remove(id);
+            if (removedAudioTrackInfo != null) {
+                removedAudioTrackInfo.frameCryptor.dispose();
+            }
         }
     }
 
@@ -102,6 +106,11 @@ public void removeVideoTrack(String id) {
             if (videoTrackInfo == null) return;
             peerConnection.removeTrack(videoTrackInfo.sender);
             videoTracks.remove(id);
+
+            VideoTrackInfo removedVideoTrackInfo = videoTracks.remove(id);
+            if (removedVideoTrackInfo != null) {
+                removedVideoTrackInfo.frameCryptor.dispose();
+            }
         }
     }
 
@@ -124,9 +133,14 @@ public void setAnswer(String sdp, String type){
 
     @Override
     public void close() {
-        super.close();
+        try {
+            audioTracks.values().forEach(track -> track.frameCryptor.dispose());
+            videoTracks.values().forEach(track -> track.frameCryptor.dispose());
+        } catch (IllegalStateException ignored) {}
         audioTracks.clear();
         videoTracks.clear();
+
+        super.close();
     }
 
     @Override

privmx-endpoint-streams/android/src/main/java/com/simplito/java/privmx_endpoint/modules/stream/PcObserver.java

@@ -130,15 +130,23 @@ public void onAddTrack(RtpReceiver receiver, MediaStream[] mediaStreams) {
         }
     }
 
+    public void dispose() {
+        frameCryptorMap.forEach((id, cryptor) -> {
+            if (cryptor != null) cryptor.dispose();
+        });
+        frameCryptorMap.clear();
+    }
+
     @Override
     public void onRemoveTrack(RtpReceiver receiver) {
         MediaStreamTrack track = receiver.track();
-        if(track != null) {
+        if (track != null) {
             PmxFrameCryptor removedCryptor = frameCryptorMap.remove(track.id());
             if(removedCryptor != null) {
                 removedCryptor.dispose();
             }
         }
+        receiver.dispose();
     }
 
     public void setFrameCryptorOptions(PmxFrameCryptor.PmxFrameCryptorOptions options) {

privmx-endpoint-streams/android/src/main/java/com/simplito/java/privmx_endpoint/modules/stream/PeerConnectionManager.java

@@ -6,17 +6,16 @@
 import com.simplito.java.privmx_endpoint.model.stream.StreamHandle;
 import com.simplito.java.privmx_endpoint.model.stream.SdpWithTypeModel;
 
-import org.webrtc.PeerConnection;
 import org.webrtc.PeerConnectionFactory;
 
 import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Optional;
+import java.util.Set;
 import java.util.function.BiConsumer;
 
-class PeerConnectionManager {
+class PeerConnectionManager implements AutoCloseable {
     private final Map<String, RoomJanusSession> sessions = new HashMap<>();
     private final Map<Long, String> sessionHandles = new HashMap<>();
     protected final PeerConnectionFactory pcFactory;
@@ -45,7 +44,6 @@ public RoomJanusSession getSession(@NonNull String streamRoomId) {
         return sessions.get(streamRoomId);
     }
 
-
     @Nullable
     public RoomJanusSession getSession(@NonNull StreamHandle handle) {
         String streamRoomId = sessionHandles.get(handle.getValue());
@@ -62,5 +60,15 @@ public void createHandleToRoom(
     public void leaveStreamRoom(@NonNull String streamRoomId) {
         sessions.remove(streamRoomId);
     }
+
+    public Set<String> getRoomIds(){
+        return sessions.keySet();
+    }
+
+    @Override
+    public void close() throws Exception {
+        sessionHandles.clear();
+        pcFactory.dispose();
+    }
 }
 

privmx-endpoint-streams/android/src/main/java/com/simplito/java/privmx_endpoint/modules/stream/StreamApi.java

@@ -35,8 +35,9 @@
 import java.util.List;
 import java.util.Objects;
 import java.util.function.Consumer;
+import java.util.stream.Collectors;
 
-public class StreamApi {
+public class StreamApi implements AutoCloseable{
     private final StreamApiLow api;
     private final PeerConnectionManager pcManager;
     public final TrackFactory trackFactory;
@@ -386,6 +387,13 @@ public String buildSubscriptionQuery(
         );
     }
 
+    @Override
+    public void close() throws Exception {
+        pcManager.getRoomIds().forEach(this::leaveStreamRoom);
+        pcManager.close();
+        api.close();
+    }
+
     private List<PeerConnection.IceServer> getRTCConfiguration() {
         return api.getTurnCredentials().stream().map(item ->
                 PeerConnection.IceServer.builder(item.url)