feat: Voice support

.github/workflows/prettier.yml

@@ -46,5 +46,5 @@ jobs:
           git config user.name "${{ github.actor }}"
           git config user.email "${{ github.actor }}@users.noreply.github.com"
           git add .
-          git commit -m "chore: format code and fix lint issues [skip ci]"
+          git commit -m "chore: format code and fix lint issues"
           git push origin ${{ github.ref_name }}

__mocks__/react-native-callkeep.js

@@ -0,0 +1,10 @@
+export default {
+	setup: jest.fn(),
+	canMakeMultipleCalls: jest.fn(),
+	displayIncomingCall: jest.fn(),
+	endCall: jest.fn(),
+	setCurrentCallActive: jest.fn(),
+	addEventListener: jest.fn((event, callback) => ({
+		remove: jest.fn()
+	}))
+};

android/app/build.gradle

@@ -148,6 +148,7 @@ dependencies {
 
     implementation "com.google.code.gson:gson:2.8.9"
     implementation "com.tencent:mmkv-static:1.2.10"
+    implementation "com.github.bumptech.glide:glide:${rootProject.ext.glideVersion}"
     implementation 'com.facebook.soloader:soloader:0.10.4'
 
     // For SecureKeystore (EncryptedSharedPreferences)

android/app/src/main/AndroidManifest.xml

@@ -13,6 +13,18 @@
     <!-- permissions related to jitsi call -->
     <uses-permission android:name="android.permission.BLUETOOTH" />
 
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE_MICROPHONE" />
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE_PHONE_CALL" />
+    <uses-permission android:name="android.permission.READ_PHONE_STATE" />
+    <uses-permission android:name="android.permission.BIND_TELECOM_CONNECTION_SERVICE" />
+    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
+    <uses-permission android:name="android.permission.CHANGE_NETWORK_STATE" />
+    <uses-permission android:name="android.permission.USE_FULL_SCREEN_INTENT" />
+    <uses-permission android:name="android.permission.MANAGE_OWN_CALLS" />
+    <uses-feature android:name="android.hardware.audio.output" />
+    <uses-feature android:name="android.hardware.microphone" />
+
     <!-- android 13 notifications -->
     <uses-permission android:name="android.permission.POST_NOTIFICATIONS" />
 
@@ -104,6 +116,35 @@
         <meta-data
             android:name="com.bugsnag.android.API_KEY"
             android:value="${BugsnagAPIKey}" />
+
+        <activity
+            android:name="chat.rocket.reactnative.voip.IncomingCallActivity"
+            android:exported="false"
+            android:launchMode="singleInstance"
+            android:showOnLockScreen="true"
+            android:turnScreenOn="true"
+            android:showWhenLocked="true"
+            android:theme="@style/Theme.IncomingCall"
+            android:excludeFromRecents="true"
+            android:taskAffinity="chat.rocket.reactnative.voip" />
+
+        <receiver
+            android:name="chat.rocket.reactnative.voip.VoipNotification$DeclineReceiver"
+            android:enabled="true"
+            android:exported="false" />
+
+        <service android:name="io.wazo.callkeep.VoiceConnectionService"
+            android:label="Wazo"
+            android:permission="android.permission.BIND_TELECOM_CONNECTION_SERVICE"
+            android:exported="true"
+            android:foregroundServiceType="microphone"
+            >
+            <intent-filter>
+                <action android:name="android.telecom.ConnectionService" />
+            </intent-filter>
+        </service>
+
+        <service android:name="io.wazo.callkeep.RNCallKeepBackgroundMessagingService" />
     </application>
 
     <queries>

android/app/src/main/java/chat/rocket/reactnative/MainActivity.kt

@@ -29,20 +29,20 @@ class MainActivity : ReactActivity() {
   override fun onCreate(savedInstanceState: Bundle?) {
     RNBootSplash.init(this, R.style.BootTheme)
     super.onCreate(null)
-    
+
     // Handle notification intents
     intent?.let { NotificationIntentHandler.handleIntent(this, it) }
   }
 
   public override fun onNewIntent(intent: Intent) {
     super.onNewIntent(intent)
     setIntent(intent)
-    
+
     // Handle notification intents when activity is already running
     NotificationIntentHandler.handleIntent(this, intent)
   }
 
   override fun invokeDefaultOnBackPressed() {
     moveTaskToBack(true)
   }
-}
+}

android/app/src/main/java/chat/rocket/reactnative/MainApplication.kt

@@ -20,6 +20,7 @@ import chat.rocket.reactnative.storage.MMKVKeyManager;
 import chat.rocket.reactnative.storage.SecureStoragePackage;
 import chat.rocket.reactnative.notification.VideoConfTurboPackage
 import chat.rocket.reactnative.notification.PushNotificationTurboPackage
+import chat.rocket.reactnative.VoipTurboPackage
 
 /**
  * Main Application class.
@@ -43,6 +44,7 @@ open class MainApplication : Application(), ReactApplication {
               add(WatermelonDBJSIPackage())
               add(VideoConfTurboPackage())
               add(PushNotificationTurboPackage())
+              add(VoipTurboPackage())
               add(SecureStoragePackage())
             }
 

android/app/src/main/java/chat/rocket/reactnative/notification/Ejson.java

@@ -25,7 +25,7 @@ public class Ejson {
     private static final String TAG = "RocketChat.Ejson";
     private static final String TOKEN_KEY = "reactnativemeteor_usertoken-";
 
-    String host;
+    public String host;
     String rid;
     String type;
     Sender sender;
@@ -57,7 +57,7 @@ private MMKV getMMKV() {
      * Helper method to build avatar URI from avatar path.
      * Validates server URL and credentials, then constructs the full URI.
      */
-    private String buildAvatarUri(String avatarPath, String errorContext) {
+    private String buildAvatarUri(String avatarPath, String errorContext, int sizePx) {
         String server = serverURL();
         if (server == null || server.isEmpty()) {
             Log.w(TAG, "Cannot generate " + errorContext + " avatar URI: serverURL is null");
@@ -67,7 +67,7 @@ private String buildAvatarUri(String avatarPath, String errorContext) {
         String userToken = token();
         String uid = userId();
 
-        String finalUri = server + avatarPath + "?format=png&size=100";
+        String finalUri = server + avatarPath + "?format=png&size=" + sizePx;
         if (!userToken.isEmpty() && !uid.isEmpty()) {
             finalUri += "&rc_token=" + userToken + "&rc_uid=" + uid;
         }
@@ -102,23 +102,45 @@ public String getAvatarUri() {
             }
         }
 
-        return buildAvatarUri(avatarPath, "");
+        return buildAvatarUri(avatarPath, "", 100);
     }
 
     /**
-     * Generates avatar URI for video conference caller.
+     * Factory for building caller avatar URIs from host + username (e.g. VoIP payload).
+     * Caller is package-private, so this is the only way to get avatar URI from outside the package.
+     */
+    public static Ejson forCallerAvatar(String host, String username) {
+        if (host == null || host.isEmpty() || username == null || username.isEmpty()) {
+            return null;
+        }
+        Ejson ejson = new Ejson();
+        ejson.host = host;
+        ejson.caller = new Caller();
+        ejson.caller.username = username;
+        return ejson;
+    }
+
+    /**
+     * Generates avatar URI for video conference caller (default size 100).
      * Returns null if caller username is not available (username is required for avatar endpoint).
      */
     public String getCallerAvatarUri() {
-        // Check if caller exists and has username (required - /avatar/{userId} endpoint doesn't exist)
+        return getCallerAvatarUri(100);
+    }
+
+    /**
+     * Generates avatar URI for video conference caller with custom size.
+     * Returns null if caller username is not available.
+     */
+    public String getCallerAvatarUri(int sizePx) {
         if (caller == null || caller.username == null || caller.username.isEmpty()) {
             Log.w(TAG, "Cannot generate caller avatar URI: caller or username is null");
             return null;
         }
 
         try {
             String avatarPath = "/avatar/" + URLEncoder.encode(caller.username, "UTF-8");
-            return buildAvatarUri(avatarPath, "caller");
+            return buildAvatarUri(avatarPath, "caller", sizePx);
         } catch (UnsupportedEncodingException e) {
             Log.e(TAG, "Failed to encode caller username", e);
             return null;
@@ -242,4 +264,4 @@ static class Content {
         String kid;
         String iv;
     }
-}
+}

android/app/src/main/java/chat/rocket/reactnative/notification/NotificationIntentHandler.kt

@@ -5,6 +5,7 @@ import android.content.Intent
 import android.os.Bundle
 import android.util.Log
 import com.google.gson.GsonBuilder
+import chat.rocket.reactnative.voip.VoipNotification
 
 /**
  * Handles notification Intent processing from MainActivity.
@@ -17,11 +18,15 @@ class NotificationIntentHandler {
 
         /**
          * Handles a notification Intent from MainActivity.
-         * Processes both video conf and regular notification intents.
+         * Processes VoIP, video conf, and regular notification intents.
          */
         @JvmStatic
         fun handleIntent(context: Context, intent: Intent) {
-            // Handle video conf action first
+            if (VoipNotification.handleMainActivityVoipIntent(context, intent)) {
+                return
+            }
+
+            // Handle video conf action
             if (handleVideoConfIntent(context, intent)) {
                 return
             }
@@ -45,7 +50,7 @@ class NotificationIntentHandler {
 
             val rid = intent.getStringExtra("rid") ?: ""
             val callerId = intent.getStringExtra("callerId") ?: ""
-            val callerName = intent.getStringExtra("callerName") ?: ""
+            val caller = intent.getStringExtra("caller") ?: ""
             val host = intent.getStringExtra("host") ?: ""
             val callId = intent.getStringExtra("callId") ?: ""
 
@@ -63,7 +68,7 @@ class NotificationIntentHandler {
                 "callId" to callId,
                 "caller" to mapOf(
                     "_id" to callerId,
-                    "name" to callerName
+                    "name" to caller
                 )
             )
 

android/app/src/main/java/chat/rocket/reactnative/notification/RCFirebaseMessagingService.kt

@@ -4,12 +4,15 @@ import android.os.Bundle
 import android.util.Log
 import com.google.firebase.messaging.FirebaseMessagingService
 import com.google.firebase.messaging.RemoteMessage
+import chat.rocket.reactnative.voip.VoipNotification
+import chat.rocket.reactnative.voip.VoipPayload
 
 /**
  * Custom Firebase Messaging Service for Rocket.Chat.
  *
- * Handles incoming FCM messages and routes them to CustomPushNotification
- * for advanced processing (E2E decryption, MessagingStyle, direct reply, etc.)
+ * Handles incoming FCM messages and routes them to the appropriate handler:
+ * - VoipNotification for VoIP calls (notificationType: "voip")
+ * - CustomPushNotification for regular messages and video conferences
  */
 class RCFirebaseMessagingService : FirebaseMessagingService() {
 
@@ -18,23 +21,29 @@ class RCFirebaseMessagingService : FirebaseMessagingService() {
     }
 
     override fun onMessageReceived(remoteMessage: RemoteMessage) {
-        Log.d(TAG, "FCM message received from: ${remoteMessage.from}")
+        // TODO: remove data
+        Log.d(TAG, "FCM message received from: ${remoteMessage.from} data: ${remoteMessage.data}")
 
         val data = remoteMessage.data
         if (data.isEmpty()) {
             Log.w(TAG, "FCM message has no data payload, ignoring")
             return
         }
 
-        // Convert FCM data to Bundle for processing
-        val bundle = Bundle().apply {
-            data.forEach { (key, value) ->
-                putString(key, value)
-            }
+        val voipPayload = VoipPayload.fromMap(data)
+        if (voipPayload != null) {
+            Log.d(TAG, "Detected VoIP payload of type ${voipPayload.type}, routing to VoipNotification handler")
+            VoipNotification(this).onMessageReceived(voipPayload)
+            return
         }
 
-        // Process the notification
+        // Process regular notifications via CustomPushNotification
         try {
+            val bundle = Bundle().apply {
+                data.forEach { (key, value) ->
+                    putString(key, value)
+                }
+            }
             val notification = CustomPushNotification(this, bundle)
             notification.onReceived()
         } catch (e: Exception) {