From 42aeceffe2c395d1e8bf10b5db6f500e690a46a1 Mon Sep 17 00:00:00 2001
From: Cody Henthorne <cody@signal.org>
Date: Mon, 22 Apr 2024 16:32:27 -0400
Subject: [PATCH] Revert full usage of ActiveCallManager.

---
 app/src/main/AndroidManifest.xml              |   6 +
 .../service/webrtc/AndroidCallConnection.kt   |   8 +-
 .../service/webrtc/WebRtcCallService.java     | 467 ++++++++++++++++++
 .../service/webrtc/WebRtcInteractor.java      |  30 +-
 .../securesms/util/FeatureFlags.java          |   7 +
 .../webrtc/CallNotificationBuilder.java       |   7 +-
 6 files changed, 503 insertions(+), 22 deletions(-)
 create mode 100644 app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcCallService.java

diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml
index 0f55e9c3a6..a74e94c4d5 100644
--- a/app/src/main/AndroidManifest.xml
+++ b/app/src/main/AndroidManifest.xml
@@ -1113,6 +1113,12 @@
               android:configChanges="touchscreen|keyboard|keyboardHidden|orientation|screenLayout|screenSize"
               android:exported="false"/>
 
+    <service
+        android:enabled="true"
+        android:name=".service.webrtc.WebRtcCallService"
+        android:foregroundServiceType="camera|microphone"
+        android:exported="false"/>
+
     <service
         android:enabled="true"
         android:exported="false"
diff --git a/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/AndroidCallConnection.kt b/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/AndroidCallConnection.kt
index e963ba94aa..ca8b34046c 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/AndroidCallConnection.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/AndroidCallConnection.kt
@@ -38,7 +38,7 @@ class AndroidCallConnection(
 
   override fun onShowIncomingCallUi() {
     Log.i(TAG, "onShowIncomingCallUi()")
-    ActiveCallManager.update(context, CallNotificationBuilder.TYPE_INCOMING_CONNECTING, recipientId, isVideoCall)
+    WebRtcCallService.update(context, CallNotificationBuilder.TYPE_INCOMING_CONNECTING, recipientId, isVideoCall)
     setRinging()
   }
 
@@ -74,17 +74,17 @@ class AndroidCallConnection(
   }
 
   override fun onSilence() {
-    ActiveCallManager.sendAudioManagerCommand(context, AudioManagerCommand.SilenceIncomingRinger())
+    WebRtcCallService.sendAudioManagerCommand(context, AudioManagerCommand.SilenceIncomingRinger())
   }
 
   override fun onReject() {
     Log.i(TAG, "onReject()")
-    ActiveCallManager.denyCall()
+    WebRtcCallService.denyCall(context)
   }
 
   override fun onDisconnect() {
     Log.i(TAG, "onDisconnect()")
-    ActiveCallManager.hangup()
+    WebRtcCallService.hangup(context)
   }
 
   companion object {
diff --git a/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcCallService.java b/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcCallService.java
new file mode 100644
index 0000000000..a128ac9e21
--- /dev/null
+++ b/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcCallService.java
@@ -0,0 +1,467 @@
+package org.thoughtcrime.securesms.service.webrtc;
+
+import android.app.Notification;
+import android.app.PendingIntent;
+import android.app.Service;
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+import android.content.IntentFilter;
+import android.content.pm.ServiceInfo;
+import android.net.ConnectivityManager;
+import android.net.NetworkInfo;
+import android.os.Build;
+import android.os.IBinder;
+import android.telephony.PhoneStateListener;
+import android.telephony.TelephonyManager;
+
+import androidx.annotation.MainThread;
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+
+import org.signal.core.util.PendingIntentFlags;
+import org.signal.core.util.ThreadUtil;
+import org.signal.core.util.concurrent.SignalExecutors;
+import org.signal.core.util.logging.Log;
+import org.thoughtcrime.securesms.dependencies.ApplicationDependencies;
+import org.thoughtcrime.securesms.jobs.ForegroundServiceUtil;
+import org.thoughtcrime.securesms.recipients.Recipient;
+import org.thoughtcrime.securesms.recipients.RecipientId;
+import org.thoughtcrime.securesms.util.FeatureFlags;
+import org.thoughtcrime.securesms.util.TelephonyUtil;
+import org.thoughtcrime.securesms.webrtc.CallNotificationBuilder;
+import org.thoughtcrime.securesms.webrtc.UncaughtExceptionHandlerManager;
+import org.thoughtcrime.securesms.webrtc.audio.AudioManagerCommand;
+import org.thoughtcrime.securesms.webrtc.audio.SignalAudioManager;
+import org.thoughtcrime.securesms.webrtc.locks.LockManager;
+
+import java.util.Objects;
+import java.util.Set;
+import java.util.concurrent.Executor;
+import java.util.concurrent.TimeUnit;
+
+import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
+import io.reactivex.rxjava3.core.Single;
+import io.reactivex.rxjava3.disposables.Disposable;
+import io.reactivex.rxjava3.schedulers.Schedulers;
+
+/**
+ * Provide a foreground service for {@link SignalCallManager} to leverage to run in the background when necessary. Also
+ * provides devices listeners needed for during a call (i.e., bluetooth, power button).
+ */
+public final class WebRtcCallService extends Service implements SignalAudioManager.EventListener {
+
+  private static final String TAG                        = Log.tag(WebRtcCallService.class);
+  private static final String WEBSOCKET_KEEP_ALIVE_TOKEN = WebRtcCallService.class.getName();
+
+  private static final String ACTION_UPDATE              = "UPDATE";
+  private static final String ACTION_STOP                = "STOP";
+  private static final String ACTION_DENY_CALL           = "DENY_CALL";
+  private static final String ACTION_LOCAL_HANGUP        = "LOCAL_HANGUP";
+  private static final String ACTION_CHANGE_POWER_BUTTON = "CHANGE_POWER_BUTTON";
+  private static final String ACTION_SEND_AUDIO_COMMAND  = "SEND_AUDIO_COMMAND";
+
+  private static final String EXTRA_UPDATE_TYPE   = "UPDATE_TYPE";
+  private static final String EXTRA_RECIPIENT_ID  = "RECIPIENT_ID";
+  private static final String EXTRA_ENABLED       = "ENABLED";
+  private static final String EXTRA_AUDIO_COMMAND = "AUDIO_COMMAND";
+  private static final String EXTRA_IS_VIDEO_CALL = "IS_VIDEO_CALL";
+
+  private static final int  INVALID_NOTIFICATION_ID           = -1;
+  private static final long REQUEST_WEBSOCKET_STAY_OPEN_DELAY = TimeUnit.MINUTES.toMillis(1);
+  private static final long FOREGROUND_SERVICE_TIMEOUT        = TimeUnit.SECONDS.toMillis(10);
+
+  private final WebSocketKeepAliveTask webSocketKeepAliveTask = new WebSocketKeepAliveTask();
+  private final Executor               singleThreadExecutor   = SignalExecutors.newCachedSingleThreadExecutor("signal-webrtc-in-call", ThreadUtil.PRIORITY_IMPORTANT_BACKGROUND_THREAD);
+
+  private SignalCallManager callManager;
+
+  private NetworkReceiver                 networkReceiver;
+  private PowerButtonReceiver             powerButtonReceiver;
+  private UncaughtExceptionHandlerManager uncaughtExceptionHandlerManager;
+  private PhoneStateListener              hangUpRtcOnDeviceCallAnswered;
+  private SignalAudioManager              signalAudioManager;
+  private int                             lastNotificationId;
+  private Notification                    lastNotification;
+  private long                            lastNotificationRequestTime;
+  private Disposable                      lastNotificationDisposable = Disposable.disposed();
+  private boolean                         stopping                   = false;
+
+  public synchronized static void update(@NonNull Context context, int type, @NonNull RecipientId recipientId, boolean isVideoCall) {
+    if (FeatureFlags.useActiveCallManager()) {
+      ActiveCallManager.update(context, type, recipientId, isVideoCall);
+
+      return;
+    }
+
+    Intent intent = new Intent(context, WebRtcCallService.class);
+    intent.setAction(ACTION_UPDATE)
+          .putExtra(EXTRA_UPDATE_TYPE, type)
+          .putExtra(EXTRA_RECIPIENT_ID, recipientId)
+          .putExtra(EXTRA_IS_VIDEO_CALL, isVideoCall);
+
+    ForegroundServiceUtil.tryToStartWhenCapable(context, intent, FOREGROUND_SERVICE_TIMEOUT);
+  }
+
+  public static void denyCall(@NonNull Context context) {
+    if (FeatureFlags.useActiveCallManager()) {
+      ActiveCallManager.denyCall();
+      return;
+    }
+
+    ForegroundServiceUtil.tryToStartWhenCapable(context, new Intent(context, WebRtcCallService.class).setAction(ACTION_DENY_CALL), FOREGROUND_SERVICE_TIMEOUT);
+  }
+
+  public static void hangup(@NonNull Context context) {
+    if (FeatureFlags.useActiveCallManager()) {
+      ActiveCallManager.hangup();
+      return;
+    }
+
+    ForegroundServiceUtil.tryToStartWhenCapable(context, new Intent(context, WebRtcCallService.class).setAction(ACTION_LOCAL_HANGUP), FOREGROUND_SERVICE_TIMEOUT);
+  }
+
+  public synchronized static void stop(@NonNull Context context) {
+    if (FeatureFlags.useActiveCallManager()) {
+      ActiveCallManager.stop();
+      return;
+    }
+
+    Intent intent = new Intent(context, WebRtcCallService.class);
+    intent.setAction(ACTION_STOP);
+
+    ForegroundServiceUtil.tryToStartWhenCapable(context, intent, FOREGROUND_SERVICE_TIMEOUT);
+  }
+
+  public synchronized static @NonNull PendingIntent denyCallIntent(@NonNull Context context) {
+    if (FeatureFlags.useActiveCallManager()) {
+      return ActiveCallManager.denyCallIntent(context);
+    }
+
+    return getServicePendingIntent(context, new Intent(context, WebRtcCallService.class).setAction(ACTION_DENY_CALL));
+  }
+
+  public synchronized static @NonNull PendingIntent hangupIntent(@NonNull Context context) {
+    if (FeatureFlags.useActiveCallManager()) {
+      return ActiveCallManager.hangupIntent(context);
+    }
+
+    return getServicePendingIntent(context, new Intent(context, WebRtcCallService.class).setAction(ACTION_LOCAL_HANGUP));
+  }
+
+  public synchronized static void sendAudioManagerCommand(@NonNull Context context, @NonNull AudioManagerCommand command) {
+    if (FeatureFlags.useActiveCallManager()) {
+      ActiveCallManager.sendAudioManagerCommand(context, command);
+      return;
+    }
+
+    Intent intent = new Intent(context, WebRtcCallService.class);
+    intent.setAction(ACTION_SEND_AUDIO_COMMAND)
+          .putExtra(EXTRA_AUDIO_COMMAND, command);
+    ForegroundServiceUtil.tryToStartWhenCapable(context, intent, FOREGROUND_SERVICE_TIMEOUT);
+  }
+
+  public synchronized static void changePowerButtonReceiver(@NonNull Context context, boolean register) {
+    if (FeatureFlags.useActiveCallManager()) {
+      ActiveCallManager.changePowerButtonReceiver(context, register);
+      return;
+    }
+
+    Intent intent = new Intent(context, WebRtcCallService.class);
+    intent.setAction(ACTION_CHANGE_POWER_BUTTON)
+          .putExtra(EXTRA_ENABLED, register);
+
+    ForegroundServiceUtil.tryToStartWhenCapable(context, intent, FOREGROUND_SERVICE_TIMEOUT);
+  }
+
+  @Override
+  public void onCreate() {
+    Log.v(TAG, "onCreate");
+    super.onCreate();
+    this.callManager                   = ApplicationDependencies.getSignalCallManager();
+    this.hangUpRtcOnDeviceCallAnswered = new HangUpRtcOnPstnCallAnsweredListener();
+    this.lastNotificationId            = INVALID_NOTIFICATION_ID;
+
+    registerUncaughtExceptionHandler();
+    registerNetworkReceiver();
+
+    if (!AndroidTelecomUtil.getTelecomSupported()) {
+      try {
+        TelephonyUtil.getManager(this).listen(hangUpRtcOnDeviceCallAnswered, PhoneStateListener.LISTEN_CALL_STATE);
+      } catch (SecurityException e) {
+        Log.w(TAG, "Failed to listen to PSTN call answers!", e);
+      }
+    }
+  }
+
+  @Override
+  public void onDestroy() {
+    Log.v(TAG, "onDestroy");
+    super.onDestroy();
+
+    if (uncaughtExceptionHandlerManager != null) {
+      uncaughtExceptionHandlerManager.unregister();
+    }
+
+    if (signalAudioManager != null) {
+      signalAudioManager.shutdown();
+    }
+
+    unregisterNetworkReceiver();
+    unregisterPowerButtonReceiver();
+
+    if (!AndroidTelecomUtil.getTelecomSupported()) {
+      TelephonyUtil.getManager(this).listen(hangUpRtcOnDeviceCallAnswered, PhoneStateListener.LISTEN_NONE);
+    }
+
+    webSocketKeepAliveTask.stop();
+  }
+
+  @Override
+  public int onStartCommand(Intent intent, int flags, int startId) {
+    if (intent == null || intent.getAction() == null) {
+      Log.w(TAG, "Service running with null intent/action likely from system restart, stopping");
+      stop();
+      return START_NOT_STICKY;
+    }
+
+    Log.i(TAG, "action: " + intent.getAction());
+    webSocketKeepAliveTask.start();
+
+    switch (intent.getAction()) {
+      case ACTION_UPDATE:
+        setCallInProgressNotification(intent.getIntExtra(EXTRA_UPDATE_TYPE, 0),
+                                      Objects.requireNonNull(intent.getParcelableExtra(EXTRA_RECIPIENT_ID)),
+                                      intent.getBooleanExtra(EXTRA_IS_VIDEO_CALL, false));
+        return START_STICKY;
+      case ACTION_SEND_AUDIO_COMMAND:
+        setCallNotification();
+        if (signalAudioManager == null) {
+          signalAudioManager = SignalAudioManager.create(this, this);
+        }
+        AudioManagerCommand audioCommand = Objects.requireNonNull(intent.getParcelableExtra(EXTRA_AUDIO_COMMAND));
+        Log.i(TAG, "Sending audio command [" + audioCommand.getClass().getSimpleName() + "] to " + signalAudioManager.getClass().getSimpleName());
+        signalAudioManager.handleCommand(audioCommand);
+        return START_STICKY;
+      case ACTION_CHANGE_POWER_BUTTON:
+        setCallNotification();
+        if (intent.getBooleanExtra(EXTRA_ENABLED, false)) {
+          registerPowerButtonReceiver();
+        } else {
+          unregisterPowerButtonReceiver();
+        }
+        return START_STICKY;
+      case ACTION_STOP:
+        setCallNotification(true);
+        stop();
+        return START_NOT_STICKY;
+      case ACTION_DENY_CALL:
+        setCallNotification();
+        callManager.denyCall();
+        return START_NOT_STICKY;
+      case ACTION_LOCAL_HANGUP:
+        setCallNotification();
+        callManager.localHangup();
+        return START_NOT_STICKY;
+      default:
+        throw new AssertionError("Unknown action: " + intent.getAction());
+    }
+  }
+
+  private void setCallNotification() {
+    setCallNotification(false);
+  }
+
+  private void setCallNotification(boolean stopping) {
+    if (!stopping && lastNotificationId != INVALID_NOTIFICATION_ID) {
+      startForegroundCompat(lastNotificationId, lastNotification);
+    } else {
+      if (!stopping) {
+        Log.i(TAG, "Service was started without calling UPDATE first, using temporary notification.");
+      }
+      startForegroundCompat(CallNotificationBuilder.getStartingStoppingNotificationId(), stopping ? CallNotificationBuilder.getStoppingNotification(this)
+                                                                                                  : CallNotificationBuilder.getStartingNotification(this));
+    }
+  }
+
+  public void setCallInProgressNotification(int type, @NonNull RecipientId id, boolean isVideoCall) {
+    lastNotificationDisposable.dispose();
+
+    boolean requiresAsyncNotificationLoad = Build.VERSION.SDK_INT <= 29;
+
+    lastNotificationId = CallNotificationBuilder.getNotificationId(type);
+    lastNotification   = CallNotificationBuilder.getCallInProgressNotification(this, type, Recipient.resolved(id), isVideoCall, requiresAsyncNotificationLoad);
+
+    startForegroundCompat(lastNotificationId, lastNotification);
+
+    if (requiresAsyncNotificationLoad) {
+      final long requestTime = System.currentTimeMillis();
+      lastNotificationRequestTime = requestTime;
+      lastNotificationDisposable  = Single
+          .fromCallable(() -> CallNotificationBuilder.getCallInProgressNotification(this, type, Recipient.resolved(id), isVideoCall, false))
+          .subscribeOn(Schedulers.from(singleThreadExecutor))
+          .observeOn(AndroidSchedulers.mainThread())
+          .filter(unused -> requestTime == lastNotificationRequestTime && !stopping)
+          .subscribe(notification -> {
+            lastNotification = notification;
+            startForegroundCompat(lastNotificationId, lastNotification);
+          });
+    }
+  }
+
+  private synchronized void startForegroundCompat(int notificationId, Notification notification) {
+    if (stopping) {
+      return;
+    }
+
+    if (Build.VERSION.SDK_INT >= 30) {
+      startForeground(notificationId, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_CAMERA | ServiceInfo.FOREGROUND_SERVICE_TYPE_MICROPHONE);
+    } else {
+      startForeground(notificationId, notification);
+    }
+  }
+
+  private synchronized void stop() {
+    stopping = true;
+    stopForeground(true);
+    stopSelf();
+  }
+
+  private void registerUncaughtExceptionHandler() {
+    uncaughtExceptionHandlerManager = new UncaughtExceptionHandlerManager();
+    uncaughtExceptionHandlerManager.registerHandler(new ProximityLockRelease(callManager.getLockManager()));
+  }
+
+  private void registerNetworkReceiver() {
+    if (networkReceiver == null) {
+      networkReceiver = new NetworkReceiver();
+
+      registerReceiver(networkReceiver, new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION));
+    }
+  }
+
+  private void unregisterNetworkReceiver() {
+    if (networkReceiver != null) {
+      unregisterReceiver(networkReceiver);
+
+      networkReceiver = null;
+    }
+  }
+
+  public void registerPowerButtonReceiver() {
+    if (!AndroidTelecomUtil.getTelecomSupported() && powerButtonReceiver == null) {
+      powerButtonReceiver = new PowerButtonReceiver();
+
+      registerReceiver(powerButtonReceiver, new IntentFilter(Intent.ACTION_SCREEN_OFF));
+    }
+  }
+
+  public void unregisterPowerButtonReceiver() {
+    if (powerButtonReceiver != null) {
+      unregisterReceiver(powerButtonReceiver);
+
+      powerButtonReceiver = null;
+    }
+  }
+
+  @Override
+  public @Nullable IBinder onBind(Intent intent) {
+    return null;
+  }
+
+  @Override
+  public void onAudioDeviceChanged(@NonNull SignalAudioManager.AudioDevice activeDevice, @NonNull Set<SignalAudioManager.AudioDevice> availableDevices) {
+    callManager.onAudioDeviceChanged(activeDevice, availableDevices);
+  }
+
+  @Override
+  public void onBluetoothPermissionDenied() {
+    callManager.onBluetoothPermissionDenied();
+  }
+
+  public static PendingIntent getServicePendingIntent(@NonNull Context context, @NonNull Intent intent) {
+    return Build.VERSION.SDK_INT >= 26 ? PendingIntent.getForegroundService(context, 0, intent, PendingIntentFlags.mutable())
+                                       : PendingIntent.getService(context, 0, intent, PendingIntentFlags.mutable());
+  }
+
+  @SuppressWarnings("deprecation")
+  private class HangUpRtcOnPstnCallAnsweredListener extends PhoneStateListener {
+    @Override
+    public void onCallStateChanged(int state, @NonNull String phoneNumber) {
+      super.onCallStateChanged(state, phoneNumber);
+      if (state == TelephonyManager.CALL_STATE_OFFHOOK) {
+        hangup();
+        Log.i(TAG, "Device phone call ended Signal call.");
+      }
+    }
+
+    private void hangup() {
+      callManager.localHangup();
+    }
+  }
+
+  /**
+   * Periodically request the web socket stay open if we are doing anything call related.
+   */
+  private class WebSocketKeepAliveTask implements Runnable {
+    private boolean keepRunning = false;
+
+    @MainThread
+    public void start() {
+      if (!keepRunning) {
+        keepRunning = true;
+        run();
+      }
+    }
+
+    @MainThread
+    public void stop() {
+      keepRunning = false;
+      ThreadUtil.cancelRunnableOnMain(webSocketKeepAliveTask);
+      ApplicationDependencies.getIncomingMessageObserver().removeKeepAliveToken(WEBSOCKET_KEEP_ALIVE_TOKEN);
+    }
+
+    @MainThread
+    @Override
+    public void run() {
+      if (keepRunning) {
+        ApplicationDependencies.getIncomingMessageObserver().registerKeepAliveToken(WEBSOCKET_KEEP_ALIVE_TOKEN);
+        ThreadUtil.runOnMainDelayed(this, REQUEST_WEBSOCKET_STAY_OPEN_DELAY);
+      }
+    }
+  }
+
+  private static class NetworkReceiver extends BroadcastReceiver {
+    @Override
+    public void onReceive(Context context, Intent intent) {
+      ConnectivityManager connectivityManager = (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);
+      NetworkInfo         activeNetworkInfo   = connectivityManager.getActiveNetworkInfo();
+
+      ApplicationDependencies.getSignalCallManager().networkChange(activeNetworkInfo != null && activeNetworkInfo.isConnected());
+      ApplicationDependencies.getSignalCallManager().dataModeUpdate();
+    }
+  }
+
+  private static class PowerButtonReceiver extends BroadcastReceiver {
+    @Override
+    public void onReceive(@NonNull Context context, @NonNull Intent intent) {
+      if (Intent.ACTION_SCREEN_OFF.equals(intent.getAction())) {
+        ApplicationDependencies.getSignalCallManager().screenOff();
+      }
+    }
+  }
+
+  private static class ProximityLockRelease implements Thread.UncaughtExceptionHandler {
+    private final LockManager lockManager;
+
+    private ProximityLockRelease(@NonNull LockManager lockManager) {
+      this.lockManager = lockManager;
+    }
+
+    @Override
+    public void uncaughtException(@NonNull Thread thread, @NonNull Throwable throwable) {
+      Log.i(TAG, "Uncaught exception - releasing proximity lock", throwable);
+      lockManager.updatePhoneState(LockManager.PhoneState.IDLE);
+    }
+  }
+}
diff --git a/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcInteractor.java b/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcInteractor.java
index 219c3431cd..2e5d5d248b 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcInteractor.java
+++ b/app/src/main/java/org/thoughtcrime/securesms/service/webrtc/WebRtcInteractor.java
@@ -95,11 +95,11 @@ public class WebRtcInteractor {
   }
 
   void setCallInProgressNotification(int type, @NonNull RemotePeer remotePeer, boolean isVideoCall) {
-    ActiveCallManager.update(context, type, remotePeer.getRecipient().getId(), isVideoCall);
+    WebRtcCallService.update(context, type, remotePeer.getRecipient().getId(), isVideoCall);
   }
 
   void setCallInProgressNotification(int type, @NonNull Recipient recipient, boolean isVideoCall) {
-    ActiveCallManager.update(context, type, recipient.getId(), isVideoCall);
+    WebRtcCallService.update(context, type, recipient.getId(), isVideoCall);
   }
 
   void retrieveTurnServers(@NonNull RemotePeer remotePeer) {
@@ -107,7 +107,7 @@ public class WebRtcInteractor {
   }
 
   void stopForegroundService() {
-    ActiveCallManager.stop();
+    WebRtcCallService.stop(context);
   }
 
   void insertMissedCall(@NonNull RemotePeer remotePeer, long timestamp, boolean isVideoOffer) {
@@ -127,51 +127,51 @@ public class WebRtcInteractor {
   }
 
   void registerPowerButtonReceiver() {
-    ActiveCallManager.changePowerButtonReceiver(context, true);
+    WebRtcCallService.changePowerButtonReceiver(context, true);
   }
 
   void unregisterPowerButtonReceiver() {
-    ActiveCallManager.changePowerButtonReceiver(context, false);
+    WebRtcCallService.changePowerButtonReceiver(context, false);
   }
 
   void silenceIncomingRinger() {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.SilenceIncomingRinger());
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.SilenceIncomingRinger());
   }
 
   void initializeAudioForCall() {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.Initialize());
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.Initialize());
   }
 
   void startIncomingRinger(@Nullable Uri ringtoneUri, boolean vibrate) {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.StartIncomingRinger(ringtoneUri, vibrate));
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.StartIncomingRinger(ringtoneUri, vibrate));
   }
 
   void startOutgoingRinger() {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.StartOutgoingRinger());
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.StartOutgoingRinger());
   }
 
   void stopAudio(boolean playDisconnect) {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.Stop(playDisconnect));
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.Stop(playDisconnect));
   }
 
   void startAudioCommunication() {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.Start());
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.Start());
   }
 
   public void setUserAudioDevice(@Nullable RecipientId recipientId, @NonNull SignalAudioManager.ChosenAudioDeviceIdentifier userDevice) {
     if (userDevice.isLegacy()) {
-      ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.SetUserDevice(recipientId, userDevice.getDesiredAudioDeviceLegacy().ordinal(), false));
+      WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.SetUserDevice(recipientId, userDevice.getDesiredAudioDeviceLegacy().ordinal(), false));
     } else {
-      ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.SetUserDevice(recipientId, userDevice.getDesiredAudioDevice31(), true));
+      WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.SetUserDevice(recipientId, userDevice.getDesiredAudioDevice31(), true));
     }
   }
 
   public void setDefaultAudioDevice(@NonNull RecipientId recipientId, @NonNull SignalAudioManager.AudioDevice userDevice, boolean clearUserEarpieceSelection) {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.SetDefaultDevice(recipientId, userDevice, clearUserEarpieceSelection));
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.SetDefaultDevice(recipientId, userDevice, clearUserEarpieceSelection));
   }
 
   public void playStateChangeUp() {
-    ActiveCallManager.sendAudioManagerCommand(context, new AudioManagerCommand.PlayStateChangeUp());
+    WebRtcCallService.sendAudioManagerCommand(context, new AudioManagerCommand.PlayStateChangeUp());
   }
 
   void peekGroupCallForRingingCheck(@NonNull GroupCallRingCheckInfo groupCallRingCheckInfo) {
diff --git a/app/src/main/java/org/thoughtcrime/securesms/util/FeatureFlags.java b/app/src/main/java/org/thoughtcrime/securesms/util/FeatureFlags.java
index 82e8e028f0..e99380aa9c 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/util/FeatureFlags.java
+++ b/app/src/main/java/org/thoughtcrime/securesms/util/FeatureFlags.java
@@ -116,6 +116,7 @@ public final class FeatureFlags {
   private static final String CALLING_REACTIONS                 = "android.calling.reactions";
   private static final String NOTIFICATION_THUMBNAIL_BLOCKLIST  = "android.notificationThumbnailProductBlocklist";
   private static final String CALLING_RAISE_HAND                = "android.calling.raiseHand";
+  private static final String USE_ACTIVE_CALL_MANAGER           = "android.calling.useActiveCallManager.5";
   private static final String GIF_SEARCH                        = "global.gifSearch";
   private static final String AUDIO_REMUXING                    = "android.media.audioRemux.1";
   private static final String VIDEO_RECORD_1X_ZOOM              = "android.media.videoCaptureDefaultZoom";
@@ -197,6 +198,7 @@ public final class FeatureFlags {
       CALLING_REACTIONS,
       NOTIFICATION_THUMBNAIL_BLOCKLIST,
       CALLING_RAISE_HAND,
+      USE_ACTIVE_CALL_MANAGER,
       GIF_SEARCH,
       AUDIO_REMUXING,
       VIDEO_RECORD_1X_ZOOM,
@@ -693,6 +695,11 @@ public final class FeatureFlags {
     return getString(NOTIFICATION_THUMBNAIL_BLOCKLIST, "");
   }
 
+  /** Whether or not to use active call manager instead of WebRtcCallService. */
+  public static boolean useActiveCallManager() {
+    return getBoolean(USE_ACTIVE_CALL_MANAGER, false);
+  }
+
   /** Whether the in-app GIF search is available for use. */
   public static boolean gifSearchAvailable() {
     return getBoolean(GIF_SEARCH, true);
diff --git a/app/src/main/java/org/thoughtcrime/securesms/webrtc/CallNotificationBuilder.java b/app/src/main/java/org/thoughtcrime/securesms/webrtc/CallNotificationBuilder.java
index a6cc907b87..43df76007f 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/webrtc/CallNotificationBuilder.java
+++ b/app/src/main/java/org/thoughtcrime/securesms/webrtc/CallNotificationBuilder.java
@@ -19,6 +19,7 @@ import org.thoughtcrime.securesms.WebRtcCallActivity;
 import org.thoughtcrime.securesms.notifications.NotificationChannels;
 import org.thoughtcrime.securesms.recipients.Recipient;
 import org.thoughtcrime.securesms.service.webrtc.ActiveCallManager;
+import org.thoughtcrime.securesms.service.webrtc.WebRtcCallService;
 import org.thoughtcrime.securesms.util.ConversationUtil;
 
 /**
@@ -114,7 +115,7 @@ public class CallNotificationBuilder {
       if (deviceVersionSupportsIncomingCallStyle()) {
         builder.setStyle(NotificationCompat.CallStyle.forIncomingCall(
             person,
-            ActiveCallManager.denyCallIntent(context),
+            WebRtcCallService.denyCallIntent(context),
             getActivityPendingIntent(context, isVideoCall ? LaunchCallScreenIntentState.VIDEO : LaunchCallScreenIntentState.AUDIO)
         ).setIsVideo(isVideoCall));
       }
@@ -122,7 +123,7 @@ public class CallNotificationBuilder {
       return builder.build();
     } else if (type == TYPE_OUTGOING_RINGING) {
       builder.setContentText(context.getString(R.string.NotificationBarManager__establishing_signal_call));
-      builder.addAction(getServiceNotificationAction(context, ActiveCallManager.hangupIntent(context), R.drawable.symbol_phone_down_fill_24, R.string.NotificationBarManager__cancel_call));
+      builder.addAction(getServiceNotificationAction(context, WebRtcCallService.hangupIntent(context), R.drawable.symbol_phone_down_fill_24, R.string.NotificationBarManager__cancel_call));
       return builder.build();
     } else {
       builder.setContentText(getOngoingCallContentText(context, recipient, isVideoCall));
@@ -138,7 +139,7 @@ public class CallNotificationBuilder {
       if (deviceVersionSupportsIncomingCallStyle()) {
         builder.setStyle(NotificationCompat.CallStyle.forOngoingCall(
             person,
-            ActiveCallManager.hangupIntent(context)
+            WebRtcCallService.hangupIntent(context)
         ).setIsVideo(isVideoCall));
       }