File Explorer

1'use strict'2 3const Client = require('./lib/dispatcher/client')4const Dispatcher = require('./lib/dispatcher/dispatcher')5const Pool = require('./lib/dispatcher/pool')6const BalancedPool = require('./lib/dispatcher/balanced-pool')7const RoundRobinPool = require('./lib/dispatcher/round-robin-pool')8const Agent = require('./lib/dispatcher/agent')9const ProxyAgent = require('./lib/dispatcher/proxy-agent')10const Socks5ProxyAgent = require('./lib/dispatcher/socks5-proxy-agent')11const EnvHttpProxyAgent = require('./lib/dispatcher/env-http-proxy-agent')12const RetryAgent = require('./lib/dispatcher/retry-agent')13const H2CClient = require('./lib/dispatcher/h2c-client')14const errors = require('./lib/core/errors')15const util = require('./lib/core/util')16const { InvalidArgumentError } = errors17const api = require('./lib/api')18const buildConnector = require('./lib/core/connect')19const MockClient = require('./lib/mock/mock-client')20const { MockCallHistory, MockCallHistoryLog } = require('./lib/mock/mock-call-history')21const MockAgent = require('./lib/mock/mock-agent')22const MockPool = require('./lib/mock/mock-pool')23const SnapshotAgent = require('./lib/mock/snapshot-agent')24const mockErrors = require('./lib/mock/mock-errors')25const RetryHandler = require('./lib/handler/retry-handler')26const { getGlobalDispatcher, setGlobalDispatcher } = require('./lib/global')27const DecoratorHandler = require('./lib/handler/decorator-handler')28const RedirectHandler = require('./lib/handler/redirect-handler')29 30Object.assign(Dispatcher.prototype, api)31 32module.exports.Dispatcher = Dispatcher33module.exports.Client = Client34module.exports.Pool = Pool35module.exports.BalancedPool = BalancedPool36module.exports.RoundRobinPool = RoundRobinPool37module.exports.Agent = Agent38module.exports.ProxyAgent = ProxyAgent39module.exports.Socks5ProxyAgent = Socks5ProxyAgent40module.exports.EnvHttpProxyAgent = EnvHttpProxyAgent41module.exports.RetryAgent = RetryAgent42module.exports.H2CClient = H2CClient43module.exports.RetryHandler = RetryHandler44 45module.exports.DecoratorHandler = DecoratorHandler46module.exports.RedirectHandler = RedirectHandler47module.exports.interceptors = {48  redirect: require('./lib/interceptor/redirect'),49  responseError: require('./lib/interceptor/response-error'),50  retry: require('./lib/interceptor/retry'),51  dump: require('./lib/interceptor/dump'),52  dns: require('./lib/interceptor/dns'),53  cache: require('./lib/interceptor/cache'),54  decompress: require('./lib/interceptor/decompress'),55  deduplicate: require('./lib/interceptor/deduplicate')56}57 58module.exports.cacheStores = {59  MemoryCacheStore: require('./lib/cache/memory-cache-store')60}61 62const SqliteCacheStore = require('./lib/cache/sqlite-cache-store')63module.exports.cacheStores.SqliteCacheStore = SqliteCacheStore64 65module.exports.buildConnector = buildConnector66module.exports.errors = errors67module.exports.util = {68  parseHeaders: util.parseHeaders,69  headerNameToString: util.headerNameToString70}71 72function makeDispatcher (fn) {73  return (url, opts, handler) => {74    if (typeof opts === 'function') {75      handler = opts76      opts = null77    }78 79    if (!url || (typeof url !== 'string' && typeof url !== 'object' && !(url instanceof URL))) {80      throw new InvalidArgumentError('invalid url')81    }82 83    if (opts != null && typeof opts !== 'object') {84      throw new InvalidArgumentError('invalid opts')85    }86 87    if (opts && opts.path != null) {88      if (typeof opts.path !== 'string') {89        throw new InvalidArgumentError('invalid opts.path')90      }91 92      let path = opts.path93      if (!opts.path.startsWith('/')) {94        path = `/${path}`95      }96 97      url = new URL(util.parseOrigin(url).origin + path)98    } else {99      if (!opts) {100        opts = typeof url === 'object' ? url : {}101      }102 103      url = util.parseURL(url)104    }105 106    const { agent, dispatcher = getGlobalDispatcher() } = opts107 108    if (agent) {109      throw new InvalidArgumentError('unsupported opts.agent. Did you mean opts.client?')110    }111 112    return fn.call(dispatcher, {113      ...opts,114      origin: url.origin,115      path: url.search ? `${url.pathname}${url.search}` : url.pathname,116      method: opts.method || (opts.body ? 'PUT' : 'GET')117    }, handler)118  }119}120 121module.exports.setGlobalDispatcher = setGlobalDispatcher122module.exports.getGlobalDispatcher = getGlobalDispatcher123 124const fetchImpl = require('./lib/web/fetch').fetch125 126// Capture __filename at module load time for stack trace augmentation.127// This may be undefined when bundled in environments like Node.js internals.128const currentFilename = typeof __filename !== 'undefined' ? __filename : undefined129 130function appendFetchStackTrace (err, filename) {131  if (!err || typeof err !== 'object') {132    return133  }134 135  const stack = typeof err.stack === 'string' ? err.stack : ''136  const normalizedFilename = filename.replace(/\\/g, '/')137 138  if (stack && (stack.includes(filename) || stack.includes(normalizedFilename))) {139    return140  }141 142  const capture = {}143  Error.captureStackTrace(capture, appendFetchStackTrace)144 145  if (!capture.stack) {146    return147  }148 149  const captureLines = capture.stack.split('\n').slice(1).join('\n')150 151  err.stack = stack ? `${stack}\n${captureLines}` : capture.stack152}153 154module.exports.fetch = function fetch (init, options = undefined) {155  return fetchImpl(init, options).catch(err => {156    if (currentFilename) {157      appendFetchStackTrace(err, currentFilename)158    } else if (err && typeof err === 'object') {159      Error.captureStackTrace(err, module.exports.fetch)160    }161    throw err162  })163}164module.exports.Headers = require('./lib/web/fetch/headers').Headers165module.exports.Response = require('./lib/web/fetch/response').Response166module.exports.Request = require('./lib/web/fetch/request').Request167module.exports.FormData = require('./lib/web/fetch/formdata').FormData168 169const { setGlobalOrigin, getGlobalOrigin } = require('./lib/web/fetch/global')170 171module.exports.setGlobalOrigin = setGlobalOrigin172module.exports.getGlobalOrigin = getGlobalOrigin173 174const { CacheStorage } = require('./lib/web/cache/cachestorage')175const { kConstruct } = require('./lib/core/symbols')176 177module.exports.caches = new CacheStorage(kConstruct)178 179const { deleteCookie, getCookies, getSetCookies, setCookie, parseCookie } = require('./lib/web/cookies')180 181module.exports.deleteCookie = deleteCookie182module.exports.getCookies = getCookies183module.exports.getSetCookies = getSetCookies184module.exports.setCookie = setCookie185module.exports.parseCookie = parseCookie186 187const { parseMIMEType, serializeAMimeType } = require('./lib/web/fetch/data-url')188 189module.exports.parseMIMEType = parseMIMEType190module.exports.serializeAMimeType = serializeAMimeType191 192const { CloseEvent, ErrorEvent, MessageEvent } = require('./lib/web/websocket/events')193const { WebSocket, ping } = require('./lib/web/websocket/websocket')194module.exports.WebSocket = WebSocket195module.exports.CloseEvent = CloseEvent196module.exports.ErrorEvent = ErrorEvent197module.exports.MessageEvent = MessageEvent198module.exports.ping = ping199 200module.exports.WebSocketStream = require('./lib/web/websocket/stream/websocketstream').WebSocketStream201module.exports.WebSocketError = require('./lib/web/websocket/stream/websocketerror').WebSocketError202 203module.exports.request = makeDispatcher(api.request)204module.exports.stream = makeDispatcher(api.stream)205module.exports.pipeline = makeDispatcher(api.pipeline)206module.exports.connect = makeDispatcher(api.connect)207module.exports.upgrade = makeDispatcher(api.upgrade)208 209module.exports.MockClient = MockClient210module.exports.MockCallHistory = MockCallHistory211module.exports.MockCallHistoryLog = MockCallHistoryLog212module.exports.MockPool = MockPool213module.exports.MockAgent = MockAgent214module.exports.SnapshotAgent = SnapshotAgent215module.exports.mockErrors = mockErrors216 217const { EventSource } = require('./lib/web/eventsource/eventsource')218 219module.exports.EventSource = EventSource220 221function install () {222  globalThis.fetch = module.exports.fetch223  globalThis.Headers = module.exports.Headers224  globalThis.Response = module.exports.Response225  globalThis.Request = module.exports.Request226  globalThis.FormData = module.exports.FormData227  globalThis.WebSocket = module.exports.WebSocket228  globalThis.CloseEvent = module.exports.CloseEvent229  globalThis.ErrorEvent = module.exports.ErrorEvent230  globalThis.MessageEvent = module.exports.MessageEvent231  globalThis.EventSource = module.exports.EventSource232}233 234module.exports.install = install235