Wire up Fusebox InspectorPackagerConnection

Using the same inspector thread initialized in ReactNativeHost, this
change wires up the InspectorPackagerConnectionDelegate to use when
initializatng the InspectorPackagerConnection from ReactCommon and
conditionally sets it for Hermes direct debugging when the appropriate
feature flag is set.

Author: rozele

vnext/Microsoft.ReactNative/ReactHost/ReactInstanceWin.cpp

@@ -619,7 +619,10 @@ void ReactInstanceWin::InitializeBridgeless() noexcept {
 
               if (devSettings->useDirectDebugger) {
                 ::Microsoft::ReactNative::GetSharedDevManager()->EnsureHermesInspector(
-                    devSettings->sourceBundleHost, devSettings->sourceBundlePort, DebugBundlePath());
+                    devSettings->sourceBundleHost,
+                    devSettings->sourceBundlePort,
+                    DebugBundlePath(),
+                    m_options.HostTargetSettings.InspectorThread);
               }
 
               m_jsiRuntimeHolder = std::make_shared<Microsoft::ReactNative::HermesRuntimeHolder>(

vnext/Shared/DevSupportManager.cpp

@@ -9,12 +9,14 @@
 #include <Shared/DevSettings.h>
 
 #include <Executors/WebSocketJSExecutor.h>
+#include "FuseboxInspectorPackagerConnectionDelegate.h"
 #include "PackagerConnection.h"
 
 #include "Unicode.h"
 #include "Utilities.h"
 
 #include <Utils/CppWinrtLessExceptions.h>
+#include <jsinspector-modern/InspectorFlags.h>
 #include <winrt/Windows.Foundation.h>
 #include <winrt/Windows.Security.Cryptography.Core.h>
 #include <winrt/Windows.Security.Cryptography.h>
@@ -257,9 +259,10 @@ void DevSupportManager::StopPollingLiveReload() {
 void DevSupportManager::EnsureHermesInspector(
     [[maybe_unused]] const std::string &packagerHost,
     [[maybe_unused]] const uint16_t packagerPort,
-    [[maybe_unused]] const std::string &jsBundleName) noexcept {
+    [[maybe_unused]] const std::string &jsBundleName,
+    [[maybe_unused]] const std::shared_ptr<Mso::DispatchQueue> &inspectorThread) noexcept {
   static std::once_flag once;
-  std::call_once(once, [this, &packagerHost, packagerPort, &jsBundleName]() {
+  std::call_once(once, [this, &packagerHost, packagerPort, &jsBundleName, &inspectorThread]() {
     // TODO: should we use the bundleAppId as the app param if available?
     std::string packageName("RNW");
     wchar_t fullName[PACKAGE_FULL_NAME_MAX_LENGTH]{};
@@ -276,11 +279,22 @@ void DevSupportManager::EnsureHermesInspector(
     }
 
     const auto deviceId = GetDeviceId(jsBundleName);
-    m_inspectorPackagerConnection = std::make_shared<InspectorPackagerConnection>(
-        facebook::react::DevServerHelper::get_InspectorDeviceUrl(
-            packagerHost, packagerPort, deviceName, packageName, deviceId),
-        m_BundleStatusProvider);
-    m_inspectorPackagerConnection->connectAsync();
+    auto inspectorUrl = facebook::react::DevServerHelper::get_InspectorDeviceUrl(
+        packagerHost, packagerPort, deviceName, packageName, deviceId);
+    auto &inspectorFlags = jsinspector_modern::InspectorFlags::getInstance();
+    if (inspectorFlags.getEnableCxxInspectorPackagerConnection()) {
+      m_fuseboxInspectorPackagerConnection = std::make_unique<jsinspector_modern::InspectorPackagerConnection>(
+          inspectorUrl,
+          std::string{jsBundleName},
+          std::make_unique<Microsoft::ReactNative::FuseboxInspectorPackagerConnectionDelegate>(inspectorThread));
+      m_fuseboxInspectorPackagerConnection->connect();
+    } else {
+      m_inspectorPackagerConnection = std::make_shared<InspectorPackagerConnection>(
+          facebook::react::DevServerHelper::get_InspectorDeviceUrl(
+              packagerHost, packagerPort, deviceName, packageName, deviceId),
+          m_BundleStatusProvider);
+      m_inspectorPackagerConnection->connectAsync();
+    }
   });
 }
 

vnext/Shared/DevSupportManager.h

@@ -15,6 +15,7 @@
 #include <string>
 
 #include <InspectorPackagerConnection.h>
+#include <jsinspector-modern/InspectorPackagerConnection.h>
 
 namespace facebook {
 namespace react {
@@ -52,13 +53,15 @@ class DevSupportManager final : public facebook::react::IDevSupportManager {
   virtual void EnsureHermesInspector(
       const std::string &packagerHost,
       const uint16_t packagerPort,
-      const std::string &jsBundleName) noexcept override;
+      const std::string &jsBundleName,
+      const std::shared_ptr<Mso::DispatchQueue> &inspectorThread) noexcept override;
   virtual void UpdateBundleStatus(bool isLastDownloadSuccess, int64_t updateTimestamp) noexcept override;
 
  private:
   std::atomic_bool m_cancellation_token;
 
   std::shared_ptr<InspectorPackagerConnection> m_inspectorPackagerConnection;
+  std::unique_ptr<facebook::react::jsinspector_modern::InspectorPackagerConnection> m_fuseboxInspectorPackagerConnection;
 
   struct BundleStatusProvider : public InspectorPackagerConnection::IBundleStatusProvider {
     virtual InspectorPackagerConnection::BundleStatus getBundleStatus() {

vnext/Shared/IDevSupportManager.h

@@ -4,6 +4,7 @@
 #pragma once
 
 #include <cxxreact/JSExecutor.h>
+#include <dispatchQueue/dispatchQueue.h>
 #include <functional>
 #include <memory>
 #include <string>
@@ -27,7 +28,8 @@ struct IDevSupportManager {
   virtual void EnsureHermesInspector(
       const std::string &packagerHost,
       const uint16_t packagerPort,
-      const std::string &bundleName) noexcept = 0;
+      const std::string &bundleName,
+      const std::shared_ptr<Mso::DispatchQueue> &inspectorThread) noexcept = 0;
   virtual void UpdateBundleStatus(bool isLastDownloadSuccess, int64_t updateTimestamp) noexcept = 0;
 };
 

vnext/Shared/OInstance.cpp

@@ -121,7 +121,11 @@ void LoadRemoteUrlScript(
 
   const auto bundlePath = devSettings->debugBundlePath.empty() ? jsBundleRelativePath : devSettings->debugBundlePath;
   if (facebook::react::shouldStartHermesInspector(*devSettings)) {
-    devManager->EnsureHermesInspector(devSettings->sourceBundleHost, devSettings->sourceBundlePort, bundlePath);
+    devManager->EnsureHermesInspector(
+        devSettings->sourceBundleHost,
+        devSettings->sourceBundlePort,
+        bundlePath,
+        devSettings->hostTargetSettings.InspectorThread);
   }
 
   auto [jsBundleString, success] = GetJavaScriptFromServer(