feat: handle lifecycle on android video effects

Author: santhoshvai

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

@@ -584,6 +584,11 @@ void setVideoEffects(String trackId, ReadableArray names) {
             VideoSource videoSource = (VideoSource) track.mediaSource;
             SurfaceTextureHelper surfaceTextureHelper = track.surfaceTextureHelper;
 
+            // Swap first, dispose last — otherwise a frame in flight could hit a freed
+            // processor. onCapturerStopped can't replace this; it also fires on pauses.
+            VideoEffectProcessor previousProcessor = track.videoEffectProcessor;
+            track.videoEffectProcessor = null;
+
             if (names != null) {
                 List<VideoFrameProcessor> processors =
                         names.toArrayList()
@@ -602,10 +607,15 @@ void setVideoEffects(String trackId, ReadableArray names) {
 
                 VideoEffectProcessor videoEffectProcessor = new VideoEffectProcessor(processors, surfaceTextureHelper);
                 videoSource.setVideoProcessor(videoEffectProcessor);
+                track.videoEffectProcessor = videoEffectProcessor;
 
             } else {
                 videoSource.setVideoProcessor(null);
             }
+
+            if (previousProcessor != null) {
+                previousProcessor.dispose();
+            }
         }
     }
 
@@ -643,6 +653,9 @@ private static class TrackPrivate {
          */
         public final VideoTrackAdapter videoTrackAdapter;
 
+        /** Current effect processor, disposed on filter switch and on track teardown. */
+        public VideoEffectProcessor videoEffectProcessor;
+
         /**
          * Whether this object has been disposed or not.
          */
@@ -693,6 +706,13 @@ public void dispose() {
                     }
                 }
 
+                // After stopCapture so no frame can still reach it; before
+                // surfaceTextureHelper dispose so GL is still alive for cleanup.
+                if (!isClone && videoEffectProcessor != null) {
+                    videoEffectProcessor.dispose();
+                    videoEffectProcessor = null;
+                }
+
                 // Clean up VideoTrackAdapter for video tracks (each TrackPrivate, incl. clones, has its own)
                 if (videoTrackAdapter != null && track instanceof VideoTrack) {
                     videoTrackAdapter.removeDimensionDetector((VideoTrack) track);

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

@@ -15,6 +15,7 @@ public class VideoEffectProcessor implements VideoProcessor {
     private VideoSink mSink;
     final private SurfaceTextureHelper textureHelper;
     final private List<VideoFrameProcessor> videoFrameProcessors;
+    private boolean disposed = false;
 
     public VideoEffectProcessor(List<VideoFrameProcessor> processors, SurfaceTextureHelper textureHelper) {
         this.textureHelper = textureHelper;
@@ -27,6 +28,22 @@ public void onCapturerStarted(boolean success) {}
     @Override
     public void onCapturerStopped() {}
 
+    /**
+     * Disposes each wrapped processor. Posted to the capturer handler so it runs
+     * after any in-flight {@link #onFrameCaptured}, letting implementations release
+     * GL resources inline. Idempotent. Called by the owner — not wired to
+     * {@link #onCapturerStopped}, which also fires on pauses.
+     */
+    public void dispose() {
+        textureHelper.getHandler().post(() -> {
+            if (disposed) return;
+            disposed = true;
+            for (VideoFrameProcessor processor : this.videoFrameProcessors) {
+                processor.dispose();
+            }
+        });
+    }
+
     @Override
     public void setSink(VideoSink sink) {
         mSink = sink;

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

@@ -16,4 +16,10 @@ public interface VideoFrameProcessor {
      * @return processed videoframe which will rendered
      */
     public VideoFrame process(VideoFrame frame, SurfaceTextureHelper textureHelper);
+
+    /**
+     * Called once when this processor leaves the pipeline. Release any native or
+     * GL resources here. Runs on the capturer handler. Default no-op.
+     */
+    default void dispose() {}
 }