chore: cleanup for android on bridge reload

Author: santhoshvai

android/src/main/java/com/oney/WebRTCModule/GetUserMediaImpl.java

@@ -285,6 +285,17 @@ void mediaStreamTrackSetEnabled(String trackId, final boolean enabled) {
         }
     }
 
+    void disposeAllTracks() {
+        for (Map.Entry<String, TrackPrivate> entry : tracks.entrySet()) {
+            try {
+                entry.getValue().dispose();
+            } catch (Exception e) {
+                Log.w(TAG, "disposeAllTracks: error disposing " + entry.getKey(), e);
+            }
+        }
+        tracks.clear();
+    }
+
     void disposeTrack(String id) {
         TrackPrivate track = tracks.remove(id);
         if (track != null) {
@@ -344,6 +355,8 @@ public void run() {
     }
 
     private void createScreenStream() {
+        // Guards against onServiceConnected firing after invalidate() has disposed and nulled mFactory.
+        if (webRTCModule.mFactory == null) return;
         VideoTrack track = createScreenTrack();
 
         if (track == null) {

android/src/main/java/com/oney/WebRTCModule/WebRTCModule.java

@@ -124,6 +124,46 @@ public WebRTCModule(ReactApplicationContext reactContext) {
         getUserMediaImpl = new GetUserMediaImpl(this, reactContext);
     }
 
+    @Override
+    public void invalidate() {
+        Log.d(TAG, "invalidate()");
+
+        try {
+            ThreadUtils.submitToExecutor(() -> {
+                // 1. Dispose PeerConnections (dispose() calls close() internally)
+                for (int i = 0; i < mPeerConnectionObservers.size(); i++) {
+                    try {
+                        mPeerConnectionObservers.valueAt(i).dispose();
+                    } catch (Exception e) {
+                        Log.w(TAG, "invalidate(): error disposing PC " + mPeerConnectionObservers.keyAt(i), e);
+                    }
+                }
+                mPeerConnectionObservers.clear();
+
+                // 2. Stop capturers + dispose tracks (prevents use-after-free on factory threads)
+                getUserMediaImpl.disposeAllTracks();
+
+                // 3. Dispose local streams
+                for (MediaStream stream : localStreams.values()) {
+                    stream.dispose();
+                }
+                localStreams.clear();
+
+                // 4. Dispose factory (frees C++ factory + 3 threads)
+                if (mFactory != null) {
+                    mFactory.dispose();
+                    mFactory = null;
+                }
+
+                return null;
+            }).get();
+        } catch (InterruptedException | ExecutionException e) {
+            Log.e(TAG, "invalidate() error", e);
+        }
+
+        super.invalidate();
+    }
+
     private JavaAudioDeviceModule createAudioDeviceModule(ReactApplicationContext reactContext) {
         speechActivityDetector = new SpeechActivityDetector(new SpeechActivityDetector.Listener() {
             @Override