Function wrapFetchWithX402

src/services/x402/paymentFetch.ts:33–101

(
  innerFetch: typeof globalThis.fetch,
)

 * @returns A fetch-compatible function with x402 payment handling
 */
export function wrapFetchWithX402(
  innerFetch: typeof globalThis.fetch,
): typeof globalThis.fetch {
  return async (
    input: RequestInfo | URL,
    init?: RequestInit,
  ): Promise<Response> => {
    // Make the initial request
    const response = await innerFetch(input, init)

    // If not a 402, pass through
    if (response.status !== 402) {
      return response
    }

    // Check if x402 is enabled
    if (!isX402Enabled()) {
      logForDebugging('[x402] Received 402 but x402 payments are not enabled')
      return response
    }

    // Check for the x402 payment requirement header
    const paymentRequiredHeader = response.headers.get(
      X402_HEADERS.PAYMENT_REQUIRED,
    )
    if (!paymentRequiredHeader) {
      logForDebugging(
        '[x402] Received 402 but no X-Payment-Required header present',
      )
      return response
    }

    logForDebugging(`[x402] Received 402 Payment Required, processing...`)

    // Handle the payment
    const result = handlePaymentRequired(
      paymentRequiredHeader,
      getX402SessionSpentUSD(),
    )

    if (!result) {
      logForDebugging('[x402] Payment handling failed, returning original 402')
      return response
    }

    // Retry with payment header
    logForDebugging('[x402] Retrying request with payment header')

    const retryHeaders = new Headers(init?.headers)
    retryHeaders.set(X402_HEADERS.PAYMENT, result.paymentHeader)

    const retryResponse = await innerFetch(input, {
      ...init,
      headers: retryHeaders,
    })

    if (retryResponse.status === 402) {
      logForDebugging(