tweaks

Author: Brazol

android/src/main/java/io/getstream/webrtc/flutter/MethodCallHandlerImpl.java

@@ -822,6 +822,9 @@ public void onInterruptionEnd() {
           break;
         }
         AudioSwitchManager.instance.requestAudioFocus();
+        if (audioFocusManager != null) {
+          audioFocusManager.notifyManualAudioFocusRegain();
+        }
         result.success(null);
         break;
       }

android/src/main/java/io/getstream/webrtc/flutter/audio/AudioFocusManager.java

@@ -29,6 +29,7 @@ public enum InterruptionSource {
     private TelephonyCallback telephonyCallback;
 
     private AudioFocusChangeListener focusChangeListener;
+    private boolean interruptionActive = false;
 
     private final AudioManager.OnAudioFocusChangeListener audioSwitchFocusListener = focusChange -> {
         switch (focusChange) {
@@ -82,6 +83,7 @@ public void setAudioFocusChangeListener(AudioFocusChangeListener listener) {
     }
 
     public void startMonitoring() {
+        interruptionActive = false;
         if (monitorAudioFocus) {
             if (AudioSwitchManager.instance != null) {
                 AudioSwitchManager.instance.setAudioFocusChangeListener(audioSwitchFocusListener);
@@ -100,6 +102,7 @@ public void stopMonitoring() {
         if (monitorAudioFocus && AudioSwitchManager.instance != null) {
             AudioSwitchManager.instance.setAudioFocusChangeListener(null);
         }
+        interruptionActive = false;
 
         if (monitorTelephony) {
             unregisterTelephonyListener();
@@ -200,7 +203,13 @@ private void handleInterruptionStart(String logMessage) {
             return;
         }
 
+        if (interruptionActive) {
+            Log.d(TAG, "Ignoring duplicate interruption start: " + logMessage);
+            return;
+        }
+
         Log.d(TAG, logMessage);
+        interruptionActive = true;
         focusChangeListener.onInterruptionStart();
     }
 
@@ -209,7 +218,20 @@ private void handleInterruptionEnd(String logMessage) {
             return;
         }
 
+        if (!interruptionActive) {
+            Log.d(TAG, "Ignoring interruption end with no active interruption: " + logMessage);
+            return;
+        }
+
         Log.d(TAG, logMessage);
+        interruptionActive = false;
         focusChangeListener.onInterruptionEnd();
     }
+
+    public void notifyManualAudioFocusRegain() {
+        if (!monitorAudioFocus) {
+            return;
+        }
+        handleInterruptionEnd("Audio focus manually requested");
+    }
 }