import { FetchInstrumentation } from '@opentelemetry/instrumentation-fetch';
import { XMLHttpRequestInstrumentation } from '@opentelemetry/instrumentation-xml-http-request';

import { logger } from '../../utils';
import { OTEL_IGNORE_URLS } from '../../config';
import { type TracerReactNativeConfig } from '../../types';
import {
  extractResponseBody,
  headersToObject,
  processHttpPayload,
} from '../helpers';

export function getInstrumentations(config: TracerReactNativeConfig) {
  const instrumentations = [];

  // Fetch instrumentation
  try {
    instrumentations.push(
      new FetchInstrumentation({
        clearTimingResources: false,
        ignoreUrls: [...OTEL_IGNORE_URLS, ...(config.ignoreUrls || [])],
        propagateTraceHeaderCorsUrls: config.propagateTraceHeaderCorsUrls,
        applyCustomAttributesOnSpan: async (span, request, response) => {
          if (!config) return;

          const { captureBody, captureHeaders } = config;

          try {
            if (!captureBody && !captureHeaders) {
              return;
            }

            // Try to get data from our fetch wrapper first
            // @ts-ignore
            const networkRequest = response?.networkRequest;

            let requestBody: any = null;
            let responseBody: string | null = null;
            let requestHeaders: Record<string, string> = {};
            let responseHeaders: Record<string, string> = {};

            if (networkRequest) {
              // Use data captured by our fetch wrapper
              requestBody = networkRequest.requestBody;
              responseBody = networkRequest.responseBody;
              requestHeaders = networkRequest.requestHeaders || {};
              responseHeaders = networkRequest.responseHeaders || {};
            } else {
              // Fallback to original OpenTelemetry approach
              requestBody = request.body;
              requestHeaders = headersToObject(request.headers);
              responseHeaders = headersToObject(
                response instanceof Response ? response.headers : undefined
              );

              if (response instanceof Response && response.body) {
                responseBody = await extractResponseBody(response);
              }
            }

            const payload = {
              requestBody,
              responseBody,
              requestHeaders,
              responseHeaders,
            };
            processHttpPayload(payload, config, span);
          } catch (error) {
            // eslint-disable-next-line
            logger.error('DEBUGGER_LIB', 'Failed to capture fetch payload', error)
          }
        },
      })
    );
  } catch (error) {
    logger.warn('DEBUGGER_LIB', 'Fetch instrumentation not available', error);
  }

  // XMLHttpRequest instrumentation
  try {
    instrumentations.push(
      new XMLHttpRequestInstrumentation({
        clearTimingResources: false,
        ignoreUrls: [...OTEL_IGNORE_URLS, ...(config.ignoreUrls || [])],
        propagateTraceHeaderCorsUrls: config.propagateTraceHeaderCorsUrls,
        applyCustomAttributesOnSpan: (span, xhr) => {
          if (!config) return;

          const { captureBody, captureHeaders } = config;

          try {
            if (!captureBody && !captureHeaders) {
              return;
            }

            // @ts-ignore
            const networkRequest = xhr.networkRequest;
            let requestBody: any = null;
            let responseBody: string | null = null;
            let requestHeaders: Record<string, string> = {};
            let responseHeaders: Record<string, string> = {};

            if (networkRequest) {
              requestBody = networkRequest.requestBody;
              responseBody = networkRequest.responseBody;
              requestHeaders = networkRequest.requestHeaders || {};
              responseHeaders = networkRequest.responseHeaders || {};
            }

            const payload = {
              requestBody,
              responseBody,
              requestHeaders,
              responseHeaders,
            };
            processHttpPayload(payload, config, span);
          } catch (error) {
            // eslint-disable-next-line
            logger.error('DEBUGGER_LIB', 'Failed to capture xml-http payload', error)
          }
        },
      })
    );
  } catch (error) {
    logger.warn(
      'DEBUGGER_LIB',
      'XMLHttpRequest instrumentation not available',
      error
    );
  }

  // Custom React Native instrumentations
  // try {
  //   instrumentations.push(new ReactNativeInstrumentation())
  // } catch (error) {
  //   console.warn('React Native instrumentation not available:', error)
  // }

  return instrumentations;
}