feat(functions): turbo modules implementation

eslint.config.mjs

@@ -38,7 +38,7 @@ export default [
       '**/type-test.ts',
       'packages/**/modular/dist/**/*',
       'packages/vertexai/__tests__/test-utils',
-      'packages/vertexai/dist',
+      'packages/**/dist',
     ],
   },
   ...compat

package.json

@@ -8,6 +8,7 @@
     "lerna:clean": "lerna clean",
     "build:all:clean": "lerna run build:clean",
     "build:all:build": "lerna run build",
+    "codegen:all": "lerna run codegen",
     "lint": "yarn lint:js && yarn lint:android && yarn lint:ios:check",
     "lint:js": "eslint packages/* --max-warnings=0",
     "lint:android": "(google-java-format --set-exit-if-changed --replace --glob=\"packages/*/android/src/**/*.java\" || (echo \"\n\nandroid formatting error - please re-run\n\n\" && exit 1)) && (git diff --exit-code packages/*/android/src || (echo \"\n\nandroid files changed from linting, please examine and commit result\n\n\" && exit 1))",
@@ -69,6 +70,7 @@
     "@firebase/rules-unit-testing": "^4.0.1",
     "@inquirer/prompts": "^7.4.1",
     "@octokit/core": "^6.1.5",
+    "@react-native-community/cli": "latest",
     "@tsconfig/node-lts": "^22.0.1",
     "@types/react": "^19.0.0",
     "@types/react-native": "^0.73.0",

packages/app/android/src/main/java/io/invertase/firebase/common/UniversalFirebaseModule.java

@@ -29,7 +29,7 @@ public class UniversalFirebaseModule {
   private final Context context;
   private final String serviceName;
 
-  protected UniversalFirebaseModule(Context context, String serviceName) {
+  public UniversalFirebaseModule(Context context, String serviceName) {
     this.context = context;
     this.serviceName = serviceName;
     this.executorService = new TaskExecutorService(getName());
@@ -43,7 +43,7 @@ public Context getApplicationContext() {
     return getContext().getApplicationContext();
   }
 
-  protected ExecutorService getExecutor() {
+  public ExecutorService getExecutor() {
     return executorService.getExecutor();
   }
 

packages/app/lib/internal/nativeModuleAndroidIos.js

@@ -1,5 +1,6 @@
 /* eslint-disable no-console */
 import { NativeModules } from 'react-native';
+import { TurboModuleRegistry } from 'react-native';
 
 /**
  * This is used by Android and iOS to get a native module.
@@ -8,7 +9,7 @@ import { NativeModules } from 'react-native';
  * @param moduleName
  */
 export function getReactNativeModule(moduleName) {
-  const nativeModule = NativeModules[moduleName];
+  const nativeModule = NativeModules[moduleName] || TurboModuleRegistry.get(moduleName);
   if (!globalThis.RNFBDebug) {
     return nativeModule;
   }

packages/app/lib/internal/registry/nativeModule.js

@@ -40,7 +40,8 @@ function nativeModuleKey(module) {
  */
 function nativeModuleMethodWrapped(namespace, method, argToPrepend) {
   return (...args) => {
-    const possiblePromise = method(...[...argToPrepend, ...args]);
+    const allArgs = [...argToPrepend, ...args];
+    const possiblePromise = method(...allArgs);
 
     if (possiblePromise && possiblePromise.then) {
       const jsStack = new Error().stack;

packages/app/lib/modular/index.d.ts

@@ -1,6 +1,8 @@
 import { ReactNativeFirebase } from '..';
 
-import FirebaseApp = ReactNativeFirebase.FirebaseApp;
+type FirebaseApp = ReactNativeFirebase.FirebaseApp & {
+  functions(regionOrCustomDomain?: string): Functions;
+};
 import FirebaseAppOptions = ReactNativeFirebase.FirebaseAppOptions;
 import LogLevelString = ReactNativeFirebase.LogLevelString;
 

packages/functions/RNFBFunctions.podspec

@@ -27,11 +27,20 @@ Pod::Spec.new do |s|
   s.ios.deployment_target = firebase_ios_target
   s.macos.deployment_target = firebase_macos_target
   s.tvos.deployment_target = firebase_tvos_target
-  s.source_files        = 'ios/**/*.{h,m}'
+  s.source_files        = 'ios/**/*.{h,m,mm,cpp}'
+  s.exclude_files       = 'ios/generated/RCTThirdPartyComponentsProvider.*', 'ios/generated/RCTAppDependencyProvider.*', 'ios/generated/RCTModuleProviders.*', 'ios/generated/RCTModulesConformingToProtocolsProvider.*', 'ios/generated/RCTUnstableModulesRequiringMainQueueSetupProvider.*'
+  # Turbo modules require these compiler flags
+  s.compiler_flags      = '-DFOLLY_NO_CONFIG -DFOLLY_MOBILE=1 -DFOLLY_USE_LIBCPP=1 -DFOLLY_CFG_NO_COROUTINES=1'
 
   # React Native dependencies
   s.dependency          'React-Core'
   s.dependency          'RNFBApp'
+  # Turbo module code generated podspecs
+  s.dependency          'ReactCodegen'
+  s.dependency          'ReactAppDependencyProvider'
+  # Turbo modules requires these dependencies
+  s.dependency          'RCT-Folly'
+  s.dependency          'React-Fabric'
 
   if defined?($FirebaseSDKVersion)
     Pod::UI.puts "#{s.name}: Using user specified Firebase SDK version '#{$FirebaseSDKVersion}'"

packages/functions/__tests__/functions.test.ts

@@ -1,6 +1,6 @@
 import { afterAll, beforeAll, beforeEach, describe, expect, it, jest } from '@jest/globals';
 
-import functions, {
+import {
   firebase,
   getFunctions,
   connectFunctionsEmulator,
@@ -9,12 +9,13 @@ import functions, {
   HttpsErrorCode,
 } from '../lib';
 
+import functions from '../lib/namespaced';
 import {
   createCheckV9Deprecation,
-  CheckV9DeprecationFunction,
+  type CheckV9DeprecationFunction,
 } from '../../app/lib/common/unitTestUtils';
 
-import { getApp } from '../../app';
+import { getApp } from '@react-native-firebase/app';
 
 // @ts-ignore test
 import FirebaseModule from '../../app/lib/internal/FirebaseModule';

packages/functions/android/build.gradle

@@ -80,9 +80,11 @@ android {
     }
   }
 
-  sourceSets {
+        sourceSets {
     main {
       java.srcDirs = ['src/main/java', 'src/reactnative/java']
+      // Exclude generated JNI files from compilation
+      java.excludes = ['**/generated/jni/**']
     }
   }
 }

packages/functions/android/src/main/java/io/invertase/firebase/functions/NativeFunctionsModule.java

@@ -0,0 +1,138 @@
+package io.invertase.firebase.functions;
+
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+import static io.invertase.firebase.functions.UniversalFirebaseFunctionsModule.CODE_KEY;
+import static io.invertase.firebase.functions.UniversalFirebaseFunctionsModule.DATA_KEY;
+import static io.invertase.firebase.functions.UniversalFirebaseFunctionsModule.DETAILS_KEY;
+import static io.invertase.firebase.functions.UniversalFirebaseFunctionsModule.MSG_KEY;
+
+import com.facebook.fbreact.specs.NativeFunctionsModuleSpec;
+import com.facebook.react.bridge.Arguments;
+import com.facebook.react.bridge.Promise;
+import com.facebook.react.bridge.ReactApplicationContext;
+import com.facebook.react.bridge.ReadableMap;
+import com.facebook.react.bridge.WritableMap;
+import com.google.android.gms.tasks.Task;
+import com.google.firebase.functions.FirebaseFunctionsException;
+import io.invertase.firebase.common.RCTConvertFirebase;
+import io.invertase.firebase.common.UniversalFirebaseModule;
+import java.io.IOException;
+
+public class NativeFunctionsModule extends NativeFunctionsModuleSpec {
+  private static final String SERVICE_NAME = "Functions";
+  private final UniversalFirebaseFunctionsModule module;
+  private final UniversalFirebaseModule universalFirebaseModule;
+
+  public NativeFunctionsModule(ReactApplicationContext reactContext) {
+    super(reactContext);
+    // cannot have multiple inheritance so we make this a property rather than extending it
+    universalFirebaseModule = new UniversalFirebaseModule(reactContext, SERVICE_NAME);
+    this.module = new UniversalFirebaseFunctionsModule(reactContext, SERVICE_NAME);
+  }
+
+  @Override
+  public void httpsCallable(
+      String appName,
+      String region,
+      String emulatorHost,
+      double emulatorPort,
+      String name,
+      ReadableMap data,
+      ReadableMap options,
+      Promise promise) {
+
+    Object callableData = data.toHashMap().get(DATA_KEY);
+
+    // Convert emulatorPort to Integer (null if not using emulator)
+    Integer port = emulatorHost != null ? (int) emulatorPort : null;
+
+    Task<Object> callMethodTask = module.httpsCallable(
+        appName, region, emulatorHost, port, name, callableData, options);
+
+    // resolve
+    callMethodTask.addOnSuccessListener(
+      universalFirebaseModule.getExecutor(),
+        result -> {
+          promise.resolve(RCTConvertFirebase.mapPutValue(DATA_KEY, result, Arguments.createMap()));
+        });
+
+    // reject
+    callMethodTask.addOnFailureListener(
+      universalFirebaseModule.getExecutor(),
+        exception -> handleFunctionsException(exception, promise));
+  }
+
+  @Override
+  public void httpsCallableFromUrl(
+      String appName,
+      String region,
+      String emulatorHost,
+      double emulatorPort,
+      String url,
+      ReadableMap data,
+      ReadableMap options,
+      Promise promise) {
+
+    Object callableData = data.toHashMap().get(DATA_KEY);
+
+    // Convert emulatorPort to Integer (null if not using emulator)
+    Integer port = emulatorHost != null ? (int) emulatorPort : null;
+
+    Task<Object> callMethodTask = module.httpsCallableFromUrl(
+        appName, region, emulatorHost, port, url, callableData, options);
+
+    callMethodTask.addOnSuccessListener(
+      universalFirebaseModule.getExecutor(),
+        result -> {
+          promise.resolve(RCTConvertFirebase.mapPutValue(DATA_KEY, result, Arguments.createMap()));
+        });
+
+    callMethodTask.addOnFailureListener(
+      universalFirebaseModule.getExecutor(),
+        exception -> handleFunctionsException(exception, promise));
+  }
+
+  private void handleFunctionsException(Exception exception, Promise promise) {
+    Object details = null;
+    String code = "UNKNOWN";
+    String message = exception.getMessage();
+    WritableMap userInfo = Arguments.createMap();
+
+    if (exception.getCause() != null) {
+      FirebaseFunctionsException functionsException =
+          (FirebaseFunctionsException) exception.getCause();
+      details = functionsException.getDetails();
+      code = functionsException.getCode().name();
+      message = functionsException.getMessage();
+      String timeout = FirebaseFunctionsException.Code.DEADLINE_EXCEEDED.name();
+      Boolean isTimeout = code.contains(timeout);
+
+      if (functionsException.getCause() instanceof IOException && !isTimeout) {
+        // return UNAVAILABLE for network io errors, to match iOS
+        code = FirebaseFunctionsException.Code.UNAVAILABLE.name();
+        message = FirebaseFunctionsException.Code.UNAVAILABLE.name();
+      }
+    }
+
+    RCTConvertFirebase.mapPutValue(CODE_KEY, code, userInfo);
+    RCTConvertFirebase.mapPutValue(MSG_KEY, message, userInfo);
+    RCTConvertFirebase.mapPutValue(DETAILS_KEY, details, userInfo);
+    promise.reject(code, message, exception, userInfo);
+  }
+}

packages/functions/android/src/main/java/io/invertase/firebase/functions/NativeFunctionsPackage.java

@@ -0,0 +1,44 @@
+package io.invertase.firebase.functions;
+
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+import com.facebook.react.ReactPackage;
+import com.facebook.react.bridge.NativeModule;
+import com.facebook.react.bridge.ReactApplicationContext;
+import com.facebook.react.uimanager.ViewManager;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import javax.annotation.Nonnull;
+
+@SuppressWarnings("unused")
+public class NativeFunctionsPackage implements ReactPackage {
+  @Nonnull
+  @Override
+  public List<NativeModule> createNativeModules(@Nonnull ReactApplicationContext reactContext) {
+    List<NativeModule> modules = new ArrayList<>();
+    modules.add(new NativeFunctionsModule(reactContext));
+    return modules;
+  }
+
+  @Nonnull
+  @Override
+  public List<ViewManager> createViewManagers(@Nonnull ReactApplicationContext reactContext) {
+    return Collections.emptyList();
+  }
+}

packages/functions/android/src/main/java/io/invertase/firebase/functions/generated/java/com/facebook/fbreact/specs/NativeFunctionsModuleSpec.java

@@ -0,0 +1,44 @@
+
+/**
+ * This code was generated by [react-native-codegen](https://www.npmjs.com/package/react-native-codegen).
+ *
+ * Do not edit this file as changes may cause incorrect behavior and will be lost
+ * once the code is regenerated.
+ *
+ * @generated by codegen project: GenerateModuleJavaSpec.js
+ *
+ * @nolint
+ */
+
+package com.facebook.fbreact.specs;
+
+import com.facebook.proguard.annotations.DoNotStrip;
+import com.facebook.react.bridge.Promise;
+import com.facebook.react.bridge.ReactApplicationContext;
+import com.facebook.react.bridge.ReactContextBaseJavaModule;
+import com.facebook.react.bridge.ReactMethod;
+import com.facebook.react.bridge.ReadableMap;
+import com.facebook.react.turbomodule.core.interfaces.TurboModule;
+import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
+
+public abstract class NativeFunctionsModuleSpec extends ReactContextBaseJavaModule implements TurboModule {
+  public static final String NAME = "NativeFunctionsModule";
+
+  public NativeFunctionsModuleSpec(ReactApplicationContext reactContext) {
+    super(reactContext);
+  }
+
+  @Override
+  public @Nonnull String getName() {
+    return NAME;
+  }
+
+  @ReactMethod
+  @DoNotStrip
+  public abstract void httpsCallable(String appName, String region, @Nullable String emulatorHost, double emulatorPort, String name, ReadableMap data, ReadableMap options, Promise promise);
+
+  @ReactMethod
+  @DoNotStrip
+  public abstract void httpsCallableFromUrl(String appName, String region, @Nullable String emulatorHost, double emulatorPort, String url, ReadableMap data, ReadableMap options, Promise promise);
+}