Почему у React Native больше нет моста

// модель очереди из MessageQueue.js — в react-native 0.86 файл помечен @deprecated
type Callback = (...args: unknown[]) => void;
type Queue = [number[], number[], unknown[][], number];

let queue: Queue = [[], [], [], 0];
let callID = 0;
const successCallbacks = new Map<number, Callback>();
const failureCallbacks = new Map<number, Callback>();

function enqueueNativeCall(moduleID: number, methodID: number, params: unknown[], onFail?: Callback, onSucc?: Callback): void {
  // функцию в очередь не положить: вместо неё едет номер, младший бит — «ошибка» или «успех»
  if (onFail) params.push(callID << 1);
  if (onSucc) params.push((callID << 1) | 1);
  if (onFail) failureCallbacks.set(callID, onFail);
  if (onSucc) successCallbacks.set(callID, onSucc);
  callID++;
  queue[0].push(moduleID);
  queue[1].push(methodID);
  queue[2].push(params);
}

// очередь натив забирал сам — в тот момент, когда JS возвращал ему управление
function flushedQueue(): Queue {
  const batch = queue;
  queue = [[], [], [], callID];
  return batch;
}

function invokeCallback(cbID: number, args: unknown[]): void {
  const id = cbID >>> 1;
  const callback = cbID & 1 ? successCallbacks.get(id) : failureCallbacks.get(id);
  successCallbacks.delete(id);
  failureCallbacks.delete(id);
  callback?.(...args);
}

// модуль и методы едут номерами: имена мост раздал при старте, в __fbBatchedBridgeConfig
const RestTimer = {
  elapsedMs(onSucc: Callback): void {
    enqueueNativeCall(7, 0, [], undefined, onSucc);
  },
  exportCsv(csv: string): Promise<unknown> {
    return new Promise((resolve, reject) => enqueueNativeCall(7, 1, [csv], reject, resolve));
  },
};

console.log("вызов вернул:", RestTimer.elapsedMs((ms) => console.log("прошло мс:", ms)));
RestTimer.exportCsv("жим;80;5").then((uri) => console.log("файл:", uri));
console.log("по мосту уехало:", JSON.stringify(flushedQueue()));

// ответы натив присылал отдельным сообщением в обратную сторону — когда закончит
setTimeout(() => {
  invokeCallback(1, [93000]);
  invokeCallback(3, ["file:///export.csv"]);
}, 0);

// react-native 0.86.0 · ReactCommon/jsi/jsi/jsi.h, строки 222–251; комментарии свои
class JSI_EXPORT HostObject {
 public:
  virtual ~HostObject();

  // JS читает свойство — зовётся get; по умолчанию undefined
  virtual Value get(Runtime&, const PropNameID& name);

  // JS записывает свойство — зовётся set; по умолчанию TypeError, как у замороженного объекта
  virtual void set(Runtime&, const PropNameID& name, const Value& value);

  // JS спрашивает список имён; по умолчанию он пуст
  virtual std::vector<PropNameID> getPropertyNames(Runtime& rt);
};

// react-native 0.86.0 · ReactCommon/react/nativemodule/core/ReactCommon/TurboModuleBinding.cpp
// класс BridgelessNativeModuleProxy, сокращено
jsi::Value get(jsi::Runtime& runtime, const jsi::PropNameID& name) override {
  std::string moduleName = name.utf8(runtime);
  if (moduleName == "__esModule") {
    return {false};
  }

  auto turboModule = turboBinding_.getModule(runtime, moduleName);
  if (turboModule.isObject()) {
    return turboModule;
  }
  // … затем модули старого формата — через legacyBinding_

  return jsi::Value::null();
}

void set(
    jsi::Runtime& runtime,
    const jsi::PropNameID& /*name*/,
    const jsi::Value& /*value*/) override {
  throw jsi::JSError(
      runtime,
      "Tried to insert a NativeModule into the bridge's NativeModule proxy.");
}

// jsi::HostObject — объект, у которого get и set написаны на C++. В JS ближе всего к нему Proxy
type NativeModuleObject = Record<string, (...args: any[]) => unknown>;
type Provider = () => NativeModuleObject;
declare var nativeModuleProxy: Record<string, NativeModuleObject | null>;

function installNativeModuleProxy(providers: Record<string, Provider>): void {
  // кеш по имени: на телефоне его держат TurboModuleManager и jsRepresentation
  const cache = new Map<string, NativeModuleObject>();
  globalThis.nativeModuleProxy = new Proxy<Record<string, NativeModuleObject | null>>({}, {
    get(_target, name) {
      if (typeof name !== "string") return undefined;
      if (name === "__esModule") return false;
      if (!cache.has(name)) {
        const provider = providers[name];
        if (!provider) return null;
        cache.set(name, provider());
      }
      return cache.get(name);
    },
    set() {
      throw new Error("Tried to insert a NativeModule into the bridge's NativeModule proxy.");
    },
    // getPropertyNames в BridgelessNativeModuleProxy не переопределён
    ownKeys() {
      return [];
    },
  });
}

installNativeModuleProxy({
  RestTimer: () => {
    console.log("натив: создаю RestTimer");
    return { elapsedMs: () => 93000 };
  },
  Haptics: () => {
    console.log("натив: создаю Haptics");
    return { tap: () => undefined };
  },
});

console.log("имена в реестре:", Object.keys(nativeModuleProxy));
const timer = nativeModuleProxy.RestTimer!;
console.log("прошло мс:", timer.elapsedMs());
console.log("тот же объект:", nativeModuleProxy.RestTimer === timer);
console.log("ExpoSecureStore:", nativeModuleProxy.ExpoSecureStore);
nativeModuleProxy.Fake = { tap: () => undefined };

declare function installNativeModuleProxy(providers: Record<string, () => object>): void;
declare function requireNativeModule<T>(name: string): T;

interface RestTimerModule {
  exportCsvSync(csv: string): string;
  exportCsv(csv: string): Promise<string>;
}

// 300 мс работы натива: записать файл, сжать, спросить базу
function busy(ms: number): void {
  const end = Date.now() + ms;
  while (Date.now() < end) {}
}

installNativeModuleProxy({
  RestTimer: () => ({
    exportCsvSync(csv: string) {
      busy(300);
      return "file:///export.csv";
    },
    // поток в песочнице один, и «другой поток» здесь изображает таймер
    exportCsv(csv: string) {
      return new Promise((resolve) => setTimeout(() => resolve("file:///export.csv"), 300));
    },
  }),
});
const RestTimer = requireNativeModule<RestTimerModule>("RestTimer");

// тик таймера отдыха: если JS-поток свободен, он приходит сразу
function tick(label: string): void {
  const planned = Date.now();
  setTimeout(() => console.log(label, Date.now() - planned > 200 ? "опоздал" : "вовремя"), 0);
}

tick("тик при синхронном вызове:");
console.log("sync:", RestTimer.exportCsvSync("жим;80;5"));

setTimeout(() => {
  tick("тик при Promise:");
  RestTimer.exportCsv("жим;80;5").then((uri) => console.log("async:", uri));
  console.log("exportCsv вернул управление");
}, 500);

// react-native 0.86.0 · ReactCommon/react/nativemodule/core/platform/ios/ReactCommon/RCTTurboModule.mm
bool ObjCTurboModule::isMethodSync(TurboModuleMethodValueKind returnType)
{
  if (isSyncModule_) {
    return true;
  }

  return returnType != VoidKind && returnType != PromiseKind;
}

// react-native 0.86.0 · ReactCommon/react/nativemodule/core/platform/android/ReactCommon/JavaTurboModule.cpp
bool isMethodSync = valueKind != VoidKind && valueKind != PromiseKind;

// expo-secure-store 57.0.1 · ios/SecureStoreModule.swift, строки 19–25
AsyncFunction("getValueWithKeyAsync") { (key: String, options: SecureStoreOptions) -> String? in
  return try get(with: key, options: options)
}

Function("getValueWithKeySync") { (key: String, options: SecureStoreOptions) -> String? in
  return try get(with: key, options: options)
}

import type { TurboModule } from "react-native";
import { TurboModuleRegistry } from "react-native";

export interface Spec extends TurboModule {
  elapsedMs(): number;
  keepAwake(on: boolean): void;
  exportCsv(csv: string): Promise<string>;
}

export default TurboModuleRegistry.getEnforcing<Spec>("RestTimer");

{
  "name": "podhod",
  "version": "1.0.0",
  "private": true,
  "codegenConfig": {
    "name": "PodhodSpec",
    "type": "modules",
    "jsSrcsDir": "specs"
  }
}

$ node node_modules/react-native/scripts/generate-codegen-artifacts.js -p . -t ios -o .

// build/generated/ios/ReactCodegen/PodhodSpecJSI.h — класс целиком,
// без шапки файла и пространства имён facebook::react
template <typename T>
class JSI_EXPORT NativeRestTimerCxxSpec : public TurboModule {
public:
  static constexpr std::string_view kModuleName = "RestTimer";

protected:
  NativeRestTimerCxxSpec(std::shared_ptr<CallInvoker> jsInvoker) : TurboModule(std::string{NativeRestTimerCxxSpec::kModuleName}, jsInvoker) {
    methodMap_["elapsedMs"] = MethodMetadata {.argCount = 0, .invoker = __elapsedMs};
    methodMap_["keepAwake"] = MethodMetadata {.argCount = 1, .invoker = __keepAwake};
    methodMap_["exportCsv"] = MethodMetadata {.argCount = 1, .invoker = __exportCsv};
  }

private:
  static jsi::Value __elapsedMs(jsi::Runtime &rt, TurboModule &turboModule, const jsi::Value* /*args*/, size_t /*count*/) {
    static_assert(
      bridging::getParameterCount(&T::elapsedMs) == 1,
      "Expected elapsedMs(...) to have 1 parameters");
    return bridging::callFromJs<double>(rt, &T::elapsedMs,  static_cast<NativeRestTimerCxxSpec*>(&turboModule)->jsInvoker_, static_cast<T*>(&turboModule));
  }

  static jsi::Value __keepAwake(jsi::Runtime &rt, TurboModule &turboModule, const jsi::Value* args, size_t count) {
    static_assert(
      bridging::getParameterCount(&T::keepAwake) == 2,
      "Expected keepAwake(...) to have 2 parameters");
    bridging::callFromJs<void>(rt, &T::keepAwake,  static_cast<NativeRestTimerCxxSpec*>(&turboModule)->jsInvoker_, static_cast<T*>(&turboModule),
      count <= 0 ? throw jsi::JSError(rt, "Expected argument in position 0 to be passed") : args[0].asBool());return jsi::Value::undefined();
  }

  static jsi::Value __exportCsv(jsi::Runtime &rt, TurboModule &turboModule, const jsi::Value* args, size_t count) {
    static_assert(
      bridging::getParameterCount(&T::exportCsv) == 2,
      "Expected exportCsv(...) to have 2 parameters");
    return bridging::callFromJs<jsi::Value>(rt, &T::exportCsv,  static_cast<NativeRestTimerCxxSpec*>(&turboModule)->jsInvoker_, static_cast<T*>(&turboModule),
      count <= 0 ? throw jsi::JSError(rt, "Expected argument in position 0 to be passed") : args[0].asString(rt));
  }
};

// build/generated/ios/ReactCodegen/PodhodSpec/PodhodSpec.h — протокол для модуля на Objective-C
@protocol NativeRestTimerSpec <RCTBridgeModule, RCTTurboModule>

- (NSNumber *)elapsedMs;
- (void)keepAwake:(BOOL)on;
- (void)exportCsv:(NSString *)csv
          resolve:(RCTPromiseResolveBlock)resolve
           reject:(RCTPromiseRejectBlock)reject;

@end

// PodhodSpec/PodhodSpec-generated.mm — вид метода записан прямо в вызове, сокращено
invokeObjCMethod(rt, NumberKind, "elapsedMs", @selector(elapsedMs), args, count);
invokeObjCMethod(rt, VoidKind, "keepAwake", @selector(keepAwake:), args, count);
invokeObjCMethod(rt, PromiseKind, "exportCsv", @selector(exportCsv:resolve:reject:), args, count);

// тот же запуск с -t android: …/codegen/java/com/facebook/fbreact/specs/NativeRestTimerSpec.java
@ReactMethod(isBlockingSynchronousMethod = true)
@DoNotStrip
public abstract double elapsedMs();

@ReactMethod
@DoNotStrip
public abstract void keepAwake(boolean on);

@ReactMethod
@DoNotStrip
public abstract void exportCsv(String csv, Promise promise);

declare function installNativeModuleProxy(providers: Record<string, () => object>): void;
declare function requireNativeModule<T>(name: string): T;
type TurboModule = import("react-native").TurboModule;

// та же спецификация, что ушла в кодогенератор
interface Spec extends TurboModule {
  elapsedMs(): number;
  keepAwake(on: boolean): void;
  exportCsv(csv: string): Promise<string>;
}

// «натив» песочницы — обычный JS: по спецификации его никто не собирал
installNativeModuleProxy({
  RestTimer: () => ({
    elapsedMs: () => 93000,
    keepAwake: (on: unknown) => console.log("натив получил:", typeof on, on),
    exportCsv: async () => "file:///export.csv",
  }),
});

const RestTimer = requireNativeModule<Spec>("RestTimer");
RestTimer.keepAwake(true);
RestTimer.keepAwake("да");
RestTimer.keepAwake();