Support CDP response previews for chunked data (#52582)

Summary:
Pull Request resolved: #52582

Continues integration of `NetworkReporter` (jsinspector-modern) on Android, to enable the Network panel in React Native DevTools.

NOTE: As with iOS, all changes are gated behind the `enableNetworkEventReporting` and `fuseboxNetworkInspectionEnabled` feature flags.

**This diff**

Updates the Android inputs to `NetworkReporter` to support incremental string data HTTP responses (`Transfer-Encoding: chunked`).

Implemented:

- Incremental response case for `Network.getResponseBody` (fetch response previews).
- `Network.dataReceived` (incremental response update event).

This means that incremental responses, such as Metro bundle requests, can be displayed as previews in React Native DevTools.

Changelog: [Internal]

Reviewed By: cortinico

Differential Revision: D77927896

fbshipit-source-id: 6eff2e7b94d3f784bbc33b1fecdc20242f98b39f

Author: huntie

packages/react-native/ReactAndroid/src/main/java/com/facebook/react/modules/network/InspectorNetworkReporter.kt

@@ -58,6 +58,13 @@ internal object InspectorNetworkReporter {
       expectedDataLength: Long
   )
 
+  /**
+   * Report when additional chunks of the response body have been received.
+   *
+   * Corresponds to `Network.dataReceived` in CDP.
+   */
+  @JvmStatic external fun reportDataReceived(requestId: Int, dataLength: Int)
+
   /**
    * Report when a network request is complete and we are no longer receiving response data.
    * - Corresponds to `Network.loadingFinished` in CDP.
@@ -71,4 +78,13 @@ internal object InspectorNetworkReporter {
    */
   @JvmStatic
   external fun maybeStoreResponseBody(requestId: Int, body: String, base64Encoded: Boolean)
+
+  /**
+   * Incrementally store a response body preview, when a string response is received in chunks.
+   * Buffered contents will be flushed to `NetworkReporter` with `reportResponseEnd`.
+   *
+   * As with `maybeStoreResponseBody`, calling this method is optional and a no-op if CDP debugging
+   * is disabled.
+   */
+  @JvmStatic external fun maybeStoreResponseBodyIncremental(requestId: Int, data: String)
 }

packages/react-native/ReactAndroid/src/main/java/com/facebook/react/modules/network/NetworkEventUtil.kt

@@ -66,6 +66,10 @@ internal object NetworkEventUtil {
       progress: Long,
       total: Long
   ) {
+    if (ReactNativeFeatureFlags.enableNetworkEventReporting() && data != null) {
+      InspectorNetworkReporter.reportDataReceived(requestId, data.encodeToByteArray().size)
+      InspectorNetworkReporter.maybeStoreResponseBodyIncremental(requestId, data)
+    }
     reactContext?.emitDeviceEvent(
         "didReceiveNetworkIncrementalData",
         buildReadableArray {

packages/react-native/ReactAndroid/src/main/jni/react/jni/InspectorNetworkReporter.cpp

@@ -11,6 +11,9 @@
 
 #include <cstddef>
 #include <string>
+#ifdef REACT_NATIVE_DEBUGGER_ENABLED
+#include <unordered_map>
+#endif
 
 using namespace facebook::jni;
 using namespace facebook::react::jsinspector_modern;
@@ -49,6 +52,13 @@ std::string limitRequestBodySize(std::string requestBody) {
 
 } // namespace
 
+#ifdef REACT_NATIVE_DEBUGGER_ENABLED
+
+// Dictionary to buffer incremental response bodies (CDP debugging active only)
+static std::unordered_map<int, std::string> responseBuffers;
+
+#endif
+
 /* static */ void InspectorNetworkReporter::reportRequestStart(
     const jni::alias_ref<jclass> /*unused*/,
     jint requestId,
@@ -93,12 +103,30 @@ std::string limitRequestBodySize(std::string requestBody) {
       static_cast<std::int64_t>(encodedDataLength));
 }
 
+/* static */ void InspectorNetworkReporter::reportDataReceived(
+    jni::alias_ref<jclass> /*unused*/,
+    jint requestId,
+    jint dataLength) {
+  NetworkReporter::getInstance().reportDataReceived(
+      std::to_string(requestId), dataLength, std::nullopt);
+}
+
 /* static */ void InspectorNetworkReporter::reportResponseEnd(
     jni::alias_ref<jclass> /*unused*/,
     jint requestId,
     jlong encodedDataLength) {
   NetworkReporter::getInstance().reportResponseEnd(
       std::to_string(requestId), static_cast<std::int64_t>(encodedDataLength));
+
+#ifdef REACT_NATIVE_DEBUGGER_ENABLED
+  // Debug build: Check for buffered response body and flush to NetworkReporter
+  auto buffer = responseBuffers[requestId];
+  if (!buffer.empty()) {
+    NetworkReporter::getInstance().storeResponseBody(
+        std::to_string(requestId), buffer, false);
+    responseBuffers.erase(requestId);
+  }
+#endif
 }
 
 /* static */ void InspectorNetworkReporter::maybeStoreResponseBody(
@@ -118,20 +146,41 @@ std::string limitRequestBodySize(std::string requestBody) {
 #endif
 }
 
+/* static */ void InspectorNetworkReporter::maybeStoreResponseBodyIncremental(
+    jni::alias_ref<jclass> /*unused*/,
+    jint requestId,
+    jni::alias_ref<jstring> data) {
+#ifdef REACT_NATIVE_DEBUGGER_ENABLED
+  // Debug build: Buffer incremental response body contents
+  auto& networkReporter = NetworkReporter::getInstance();
+  if (!networkReporter.isDebuggingEnabled()) {
+    return;
+  }
+
+  auto& buffer = responseBuffers[requestId];
+  buffer += data->toStdString();
+#endif
+}
+
 /* static */ void InspectorNetworkReporter::registerNatives() {
   javaClassLocal()->registerNatives({
       makeNativeMethod(
           "reportRequestStart", InspectorNetworkReporter::reportRequestStart),
       makeNativeMethod(
           "reportResponseStart", InspectorNetworkReporter::reportResponseStart),
-      makeNativeMethod(
-          "reportResponseEnd", InspectorNetworkReporter::reportResponseEnd),
       makeNativeMethod(
           "reportConnectionTiming",
           InspectorNetworkReporter::reportConnectionTiming),
+      makeNativeMethod(
+          "reportDataReceived", InspectorNetworkReporter::reportDataReceived),
+      makeNativeMethod(
+          "reportResponseEnd", InspectorNetworkReporter::reportResponseEnd),
       makeNativeMethod(
           "maybeStoreResponseBody",
           InspectorNetworkReporter::maybeStoreResponseBody),
+      makeNativeMethod(
+          "maybeStoreResponseBodyIncremental",
+          InspectorNetworkReporter::maybeStoreResponseBodyIncremental),
   });
 }
 

packages/react-native/ReactAndroid/src/main/jni/react/jni/InspectorNetworkReporter.h

@@ -39,6 +39,11 @@ class InspectorNetworkReporter
       jni::alias_ref<jni::JMap<jstring, jstring>> responseHeaders,
       jlong encodedDataLength);
 
+  static void reportDataReceived(
+      jni::alias_ref<jclass> /*unused*/,
+      jint requestId,
+      jint dataLength);
+
   static void reportResponseEnd(
       jni::alias_ref<jclass> /*unused*/,
       jint requestId,
@@ -50,6 +55,11 @@ class InspectorNetworkReporter
       jni::alias_ref<jstring> body,
       jboolean base64Encoded);
 
+  static void maybeStoreResponseBodyIncremental(
+      jni::alias_ref<jclass> /*unused*/,
+      jint requestId,
+      jni::alias_ref<jstring> data);
+
   static void registerNatives();
 
  private: