Add InspectorPackagerConnectionDelegate implementation

This adds an implementation of InspectorPackagerConnectionDelegate for react-native-windows.

Author: rozele

vnext/Shared/FuseboxInspectorPackagerConnectionDelegate.cpp

@@ -0,0 +1,71 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+#include "FuseboxInspectorPackagerConnectionDelegate.h"
+#include <winrt/Microsoft.ReactNative.h>
+
+namespace Microsoft::ReactNative {
+
+FuseboxInspectorPackagerConnectionDelegate::WebSocket::WebSocket(
+    std::string const &url,
+    std::weak_ptr<facebook::react::jsinspector_modern::IWebSocketDelegate> delegate)
+    : m_weakDelegate{delegate} {
+  std::vector<winrt::Windows::Security::Cryptography::Certificates::ChainValidationResult> certExceptions;
+
+  m_packagerWebSocketConnection =
+      std::make_shared<Microsoft::React::Networking::WinRTWebSocketResource>(std::move(certExceptions));
+
+  m_packagerWebSocketConnection->SetOnMessage([delegate](auto &&, const std::string &message, bool isBinary) {
+    if (const auto strongDelegate = delegate.lock()) {
+      strongDelegate->didReceiveMessage(message);
+    }
+  });
+  m_packagerWebSocketConnection->SetOnError(
+      [delegate](const Microsoft::React::Networking::IWebSocketResource::Error &error) {
+        if (const auto strongDelegate = delegate.lock()) {
+          strongDelegate->didFailWithError(std::nullopt, error.Message);
+        }
+      });
+  // TODO: validate that this is called
+  m_packagerWebSocketConnection->SetOnClose([delegate](auto &&...) {
+    if (const auto strongDelegate = delegate.lock()) {
+      strongDelegate->didClose();
+    }
+  });
+
+  Microsoft::React::Networking::IWebSocketResource::Protocols protocols;
+  Microsoft::React::Networking::IWebSocketResource::Options options;
+  m_packagerWebSocketConnection->Connect(std::string{url}, protocols, options);
+}
+
+void FuseboxInspectorPackagerConnectionDelegate::WebSocket::send(std::string_view message) {
+  m_packagerWebSocketConnection->Send(std::string{message});
+}
+
+FuseboxInspectorPackagerConnectionDelegate::WebSocket::~WebSocket() {
+  std::string reason{"Explicit close"};
+  m_packagerWebSocketConnection->Close(
+      Microsoft::React::Networking::WinRTWebSocketResource::CloseCode::GoingAway, reason);
+}
+
+std::unique_ptr<facebook::react::jsinspector_modern::IWebSocket>
+FuseboxInspectorPackagerConnectionDelegate::connectWebSocket(
+    const std::string &url,
+    std::weak_ptr<facebook::react::jsinspector_modern::IWebSocketDelegate> delegate) {
+  return std::make_unique<WebSocket>(url, delegate);
+}
+
+winrt::fire_and_forget FuseboxInspectorPackagerConnectionDelegate::RunWithDelayAsync(
+    std::function<void(void)> callback,
+    std::chrono::milliseconds delayMs) {
+  co_await winrt::resume_after(delayMs);
+  m_inspectorThread->InvokeElsePost([callback]() { callback(); });
+}
+
+void FuseboxInspectorPackagerConnectionDelegate::scheduleCallback(
+    std::function<void(void)> callback,
+    std::chrono::milliseconds delayMs) {
+  RunWithDelayAsync(callback, delayMs);
+}
+
+} // namespace Microsoft::ReactNative

vnext/Shared/FuseboxInspectorPackagerConnectionDelegate.h

@@ -0,0 +1,40 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+#pragma once
+
+#include <Networking/WinRTWebSocketResource.h>
+#include <dispatchQueue/dispatchQueue.h>
+#include <jsinspector-modern/InspectorPackagerConnection.h>
+
+namespace Microsoft::ReactNative {
+
+class FuseboxInspectorPackagerConnectionDelegate final
+    : public facebook::react::jsinspector_modern::InspectorPackagerConnectionDelegate {
+  class WebSocket : public facebook::react::jsinspector_modern::IWebSocket {
+   public:
+    WebSocket(std::string const &url, std::weak_ptr<facebook::react::jsinspector_modern::IWebSocketDelegate> delegate);
+    virtual void send(std::string_view message) override;
+    virtual ~WebSocket() override;
+
+   private:
+    std::shared_ptr<Microsoft::React::Networking::WinRTWebSocketResource> m_packagerWebSocketConnection;
+    std::weak_ptr<facebook::react::jsinspector_modern::IWebSocketDelegate> m_weakDelegate;
+  };
+
+ public:
+  FuseboxInspectorPackagerConnectionDelegate(std::shared_ptr<Mso::DispatchQueue> const &inspectorThread)
+      : m_inspectorThread{inspectorThread} {}
+
+  virtual std::unique_ptr<facebook::react::jsinspector_modern::IWebSocket> connectWebSocket(
+      const std::string &url,
+      std::weak_ptr<facebook::react::jsinspector_modern::IWebSocketDelegate> delegate) override;
+
+  virtual void scheduleCallback(std::function<void(void)> callback, std::chrono::milliseconds delayMs) override;
+
+ private:
+  winrt::fire_and_forget RunWithDelayAsync(std::function<void(void)> callback, std::chrono::milliseconds delayMs);
+
+  std::shared_ptr<Mso::DispatchQueue> m_inspectorThread;
+};
+} // namespace Microsoft::ReactNative

vnext/Shared/Shared.vcxitems

@@ -218,6 +218,7 @@
     <ClCompile Include="$(MSBuildThisFileDirectory)Hasher.cpp" />
     <ClCompile Include="$(MSBuildThisFileDirectory)HermesRuntimeHolder.cpp" />
     <ClCompile Include="$(MSBuildThisFileDirectory)HermesSamplingProfiler.cpp" />
+    <ClCompile Include="$(MSBuildThisFileDirectory)FuseboxInspectorPackagerConnectionDelegate.cpp" />
     <ClCompile Include="$(MSBuildThisFileDirectory)InspectorPackagerConnection.cpp" />
     <ClCompile Include="$(MSBuildThisFileDirectory)InstanceManager.cpp" />
     <ClCompile Include="$(MSBuildThisFileDirectory)JSBigAbiString.cpp" />
@@ -415,6 +416,7 @@
     <ClInclude Include="$(MSBuildThisFileDirectory)FuseboxHostTargetSettings.h" />
     <ClInclude Include="$(MSBuildThisFileDirectory)Executors\WebSocketJSExecutor.h" />
     <ClInclude Include="$(MSBuildThisFileDirectory)HermesRuntimeHolder.h" />
+    <ClInclude Include="$(MSBuildThisFileDirectory)FuseboxInspectorPackagerConnectionDelegate.h" />
     <ClInclude Include="$(MSBuildThisFileDirectory)InspectorPackagerConnection.h" />
     <ClInclude Include="$(MSBuildThisFileDirectory)IDevSupportManager.h" />
     <ClInclude Include="$(MSBuildThisFileDirectory)InstanceManager.h" />

vnext/Shared/Shared.vcxitems.filters

@@ -94,6 +94,9 @@
     <ClCompile Include="$(MSBuildThisFileDirectory)JSI\JSExecutorFactorySettings.cpp">
       <Filter>Source Files\JSI</Filter>
     </ClCompile>
+    <ClCompile Include="$(MSBuildThisFileDirectory)FuseboxInspectorPackagerConnectionDelegate.cpp">
+      <Filter>Source Files</Filter>
+    </ClCompile>
     <ClCompile Include="$(MSBuildThisFileDirectory)InspectorPackagerConnection.cpp">
       <Filter>Source Files</Filter>
     </ClCompile>
@@ -613,6 +616,9 @@
       <Filter>Header Files\JSI</Filter>
     </ClInclude>
     <ClInclude Include="$(MSBuildThisFileDirectory)..\include\Shared\cdebug.h" />
+    <ClInclude Include="$(MSBuildThisFileDirectory)FuseboxInspectorPackagerConnectionDelegate.h">
+      <Filter>Header Files</Filter>
+    </ClInclude>    
     <ClInclude Include="$(MSBuildThisFileDirectory)InspectorPackagerConnection.h">
       <Filter>Header Files</Filter>
     </ClInclude>