Gecko [ c.stage.kornherr.net ]

Name	Size	Permission	Date
api	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
cache	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
compat	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
cookies	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
core	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
fetch	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
fileapi	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
handler	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
interceptor	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
llhttp	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
mock	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
node	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
websocket	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
agent.js	4.51 KB	-rw-r--r--	2023-10-14 10:49
balanced-pool.js	5.13 KB	-rw-r--r--	2023-10-14 10:49
client.js	60.06 KB	-rw-r--r--	2023-10-14 10:49
dispatcher-base.js	4.48 KB	-rw-r--r--	2023-10-14 10:49
dispatcher.js	300 B	-rw-r--r--	2023-10-14 10:49
global.js	860 B	-rw-r--r--	2023-10-14 10:49
pool-base.js	4.45 KB	-rw-r--r--	2023-10-14 10:49
pool-stats.js	552 B	-rw-r--r--	2023-10-14 10:49
pool.js	2.47 KB	-rw-r--r--	2023-10-14 10:49
proxy-agent.js	5.23 KB	-rw-r--r--	2023-10-14 10:49
timers.js	1.83 KB	-rw-r--r--	2023-10-14 10:49

Rename

'use strict'

const {
  PoolBase,
  kClients,
  kNeedDrain,
  kAddClient,
  kGetDispatcher
} = require('./pool-base')
const Client = require('./client')
const {
  InvalidArgumentError
} = require('./core/errors')
const util = require('./core/util')
const { kUrl, kInterceptors } = require('./core/symbols')
const buildConnector = require('./core/connect')

const kOptions = Symbol('options')
const kConnections = Symbol('connections')
const kFactory = Symbol('factory')

function defaultFactory (origin, opts) {
  return new Client(origin, opts)
}

class Pool extends PoolBase {
  constructor (origin, {
    connections,
    factory = defaultFactory,
    connect,
    connectTimeout,
    tls,
    maxCachedSessions,
    socketPath,
    autoSelectFamily,
    autoSelectFamilyAttemptTimeout,
    allowH2,
    ...options
  } = {}) {
    super()

if (connections != null && (!Number.isFinite(connections) || connections < 0)) {
      throw new InvalidArgumentError('invalid connections')
    }

if (typeof factory !== 'function') {
      throw new InvalidArgumentError('factory must be a function.')
    }

if (connect != null && typeof connect !== 'function' && typeof connect !== 'object') {
      throw new InvalidArgumentError('connect must be a function or an object')
    }

if (typeof connect !== 'function') {
      connect = buildConnector({
        ...tls,
        maxCachedSessions,
        allowH2,
        socketPath,
        timeout: connectTimeout == null ? 10e3 : connectTimeout,
        ...(util.nodeHasAutoSelectFamily && autoSelectFamily ? { autoSelectFamily, autoSelectFamilyAttemptTimeout } : undefined),
        ...connect
      })
    }

this[kInterceptors] = options.interceptors && options.interceptors.Pool && Array.isArray(options.interceptors.Pool)
      ? options.interceptors.Pool
      : []
    this[kConnections] = connections || null
    this[kUrl] = util.parseOrigin(origin)
    this[kOptions] = { ...util.deepClone(options), connect, allowH2 }
    this[kOptions].interceptors = options.interceptors
      ? { ...options.interceptors }
      : undefined
    this[kFactory] = factory
  }

[kGetDispatcher] () {
    let dispatcher = this[kClients].find(dispatcher => !dispatcher[kNeedDrain])

if (dispatcher) {
      return dispatcher
    }

if (!this[kConnections] || this[kClients].length < this[kConnections]) {
      dispatcher = this[kFactory](this[kUrl], this[kOptions])
      this[kAddClient](dispatcher)
    }

return dispatcher
  }
}

module.exports = Pool