/*
 * Copyright (c) Meta Platforms, Inc. and affiliates.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 */

#include "JInspectorNetworkReporter.h"

#include <react/networking/NetworkReporter.h>

#include <cstddef>
#include <string>
#ifdef REACT_NATIVE_DEBUGGER_ENABLED
#include <unordered_map>
#endif

using namespace facebook::jni;

namespace facebook::react::jsinspector_modern {

namespace {

Headers convertJavaMapToHeaders(
    jni::alias_ref<jni::JMap<jstring, jstring>> headers) {
  Headers responseHeaders;

  for (auto it : *headers) {
    auto key = it.first->toStdString();
    auto value = it.second->toStdString();
    responseHeaders[key] = value;
  }

  return responseHeaders;
}

std::string limitRequestBodySize(std::string requestBody) {
  const size_t maxBodySize = 1024 * 1024; // 1MB
  auto bodyLength = requestBody.size();
  auto bytesToRead = std::min(bodyLength, maxBodySize);

  requestBody.resize(bytesToRead);

  if (bytesToRead < bodyLength) {
    requestBody += "\n... [truncated, showing " + std::to_string(bytesToRead) +
        " of " + std::to_string(bodyLength) + " bytes]";
  }

  return requestBody;
}

} // namespace

#ifdef REACT_NATIVE_DEBUGGER_ENABLED

// Dictionary to buffer incremental response bodies (CDP debugging active only)
static std::unordered_map<std::string, std::string> responseBuffers;

#endif

/* static */ jboolean JInspectorNetworkReporter::isDebuggingEnabled(
    jni::alias_ref<jclass> /*unused*/) {
  return static_cast<jboolean>(
      NetworkReporter::getInstance().isDebuggingEnabled());
}

/* static */ void JInspectorNetworkReporter::reportRequestStart(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> requestId,
    jni::alias_ref<jstring> requestUrl,
    jni::alias_ref<jstring> requestMethod,
    jni::alias_ref<jni::JMap<jstring, jstring>> requestHeaders,
    jni::alias_ref<jstring> requestBody,
    jlong encodedDataLength) {
  RequestInfo requestInfo;
  requestInfo.url = requestUrl->toStdString();
  requestInfo.httpMethod = requestMethod->toStdString();
  requestInfo.headers = convertJavaMapToHeaders(requestHeaders);
  requestInfo.httpBody = limitRequestBodySize(requestBody->toStdString());

  NetworkReporter::getInstance().reportRequestStart(
      requestId->toStdString(), requestInfo, encodedDataLength, std::nullopt);
}

/* static */ void JInspectorNetworkReporter::reportConnectionTiming(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> requestId,
    jni::alias_ref<jni::JMap<jstring, jstring>> headers) {
  NetworkReporter::getInstance().reportConnectionTiming(
      requestId->toStdString(), convertJavaMapToHeaders(headers));
}

/* static */ void JInspectorNetworkReporter::reportResponseStart(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> requestId,
    jni::alias_ref<jstring> requestUrl,
    jint responseStatus,
    jni::alias_ref<jni::JMap<jstring, jstring>> responseHeaders,
    jlong encodedDataLength) {
  ResponseInfo responseInfo;
  responseInfo.url = requestUrl->toStdString();
  responseInfo.statusCode = responseStatus;
  responseInfo.headers = convertJavaMapToHeaders(responseHeaders);

  NetworkReporter::getInstance().reportResponseStart(
      requestId->toStdString(),
      responseInfo,
      static_cast<std::int64_t>(encodedDataLength));
}

/* static */ void JInspectorNetworkReporter::reportDataReceivedImpl(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> requestId,
    jint dataLength) {
  NetworkReporter::getInstance().reportDataReceived(
      requestId->toStdString(), dataLength, std::nullopt);
}

/* static */ void JInspectorNetworkReporter::reportResponseEnd(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> requestId,
    jlong encodedDataLength) {
  auto requestIdStr = requestId->toStdString();
  NetworkReporter::getInstance().reportResponseEnd(
      requestIdStr, static_cast<std::int64_t>(encodedDataLength));

#ifdef REACT_NATIVE_DEBUGGER_ENABLED
  // Debug build: Check for buffered response body and flush to NetworkReporter
  auto it = responseBuffers.find(requestIdStr);
  if (it != responseBuffers.end() && !it->second.empty()) {
    NetworkReporter::getInstance().storeResponseBody(
        requestIdStr, it->second, false);
    responseBuffers.erase(it);
  }
#endif
}

/* static */ void JInspectorNetworkReporter::reportRequestFailed(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> requestId,
    jboolean cancelled) {
  NetworkReporter::getInstance().reportRequestFailed(
      requestId->toStdString(), cancelled != 0u);
}

/* static */ void JInspectorNetworkReporter::maybeStoreResponseBodyImpl(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> requestId,
    jni::alias_ref<jstring> body,
    jboolean base64Encoded) {
#ifdef REACT_NATIVE_DEBUGGER_ENABLED
  // Debug build: Process response body and report to NetworkReporter
  auto& networkReporter = NetworkReporter::getInstance();
  if (!networkReporter.isDebuggingEnabled()) {
    return;
  }

  networkReporter.storeResponseBody(
      requestId->toStdString(), body->toStdString(), base64Encoded != 0u);
#endif
}

/* static */ void
JInspectorNetworkReporter::maybeStoreResponseBodyIncrementalImpl(
    jni::alias_ref<jclass> /*unused*/,
    jni::alias_ref<jstring> 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 requestIdStr = requestId->toStdString();
  auto& buffer = responseBuffers[requestIdStr];
  buffer += data->toStdString();
#endif
}

/* static */ void JInspectorNetworkReporter::registerNatives() {
  javaClassLocal()->registerNatives({
      makeNativeMethod(
          "isDebuggingEnabled", JInspectorNetworkReporter::isDebuggingEnabled),
      makeNativeMethod(
          "reportRequestStart", JInspectorNetworkReporter::reportRequestStart),
      makeNativeMethod(
          "reportResponseStart",
          JInspectorNetworkReporter::reportResponseStart),
      makeNativeMethod(
          "reportConnectionTiming",
          JInspectorNetworkReporter::reportConnectionTiming),
      makeNativeMethod(
          "reportDataReceivedImpl",
          JInspectorNetworkReporter::reportDataReceivedImpl),
      makeNativeMethod(
          "reportResponseEnd", JInspectorNetworkReporter::reportResponseEnd),
      makeNativeMethod(
          "reportRequestFailed",
          JInspectorNetworkReporter::reportRequestFailed),
      makeNativeMethod(
          "maybeStoreResponseBodyImpl",
          JInspectorNetworkReporter::maybeStoreResponseBodyImpl),
      makeNativeMethod(
          "maybeStoreResponseBodyIncrementalImpl",
          JInspectorNetworkReporter::maybeStoreResponseBodyIncrementalImpl),
  });
}

} // namespace facebook::react::jsinspector_modern