Add MakeAsyncCallback utility function to TurboModuleTestFixture.h (#53284)

Summary:
Pull Request resolved: #53284

Changelog: [Internal]

Reviewed By: lenaic

Differential Revision: D80280615

fbshipit-source-id: eca82072fdfa74e70e9c327f9a1379f0ddf9a8c4

Author: christophpurrer

packages/react-native/ReactCommon/callinvoker/ReactCommon/tests/TestCallInvoker.h

@@ -35,6 +35,10 @@ class TestCallInvoker : public CallInvoker {
     }
   }
 
+  size_t queueSize() {
+    return queue_.size();
+  }
+
  private:
   std::list<CallFunc> queue_{};
   std::shared_ptr<facebook::jsi::Runtime> runtime_{};

packages/react-native/ReactCommon/react/nativemodule/core/tests/TurboModuleTestFixture.h

@@ -16,12 +16,17 @@
 #include <optional>
 
 namespace facebook::react {
+class TurboModule;
 
 template <typename T, typename... Args>
 class TurboModuleTestFixture : public ::testing::Test {
+  static_assert(
+      std::is_base_of<TurboModule, T>::value,
+      "T must be derived from TurboModule");
+
  public:
   explicit TurboModuleTestFixture(Args... args)
-      : runtime_(facebook::hermes::makeHermesRuntime()),
+      : runtime_(hermes::makeHermesRuntime()),
         jsInvoker_(std::make_shared<TestCallInvoker>(runtime_)),
         module_(std::make_shared<T>(jsInvoker_, std::forward<Args>(args)...)) {}
 
@@ -94,6 +99,33 @@ class TurboModuleTestFixture : public ::testing::Test {
     return message;
   }
 
+  template <typename TEvent>
+  AsyncCallback<TEvent> makeAsyncCallback(
+      std::function<void(TEvent)>&& callback) {
+    auto func = jsi::Function::createFromHostFunction(
+        *runtime_,
+        jsi::PropNameID::forAscii(*runtime_, "callback"),
+        1,
+        [jsInvoker = jsInvoker_, callback = std::move(callback)](
+            jsi::Runtime& rt,
+            [[maybe_unused]] const jsi::Value& thisVal,
+            const jsi::Value* args,
+            size_t count) {
+          if (count < 1) {
+            throw jsi::JSINativeException("callback: Missing argument");
+          }
+          callback(
+              Bridging<TEvent>::fromJs(rt, args[0].asObject(rt), jsInvoker));
+          return jsi::Value::undefined();
+        });
+    return {*runtime_, std::move(func), jsInvoker_};
+  }
+
+  void expectAndFlushQueue(size_t queueSize) {
+    EXPECT_EQ(jsInvoker_->queueSize(), queueSize);
+    jsInvoker_->flushQueue();
+  }
+
  protected:
   std::shared_ptr<jsi::Runtime> runtime_{};
   std::shared_ptr<TestCallInvoker> jsInvoker_{};