Gecko [ c.stage.kornherr.net ]

Linux v69820.1blu.de 4.15.0 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64
Apache/2.4.58
Server IP : 195.90.215.149 & Your IP : 216.73.216.250
Domains : Cant Read [ /etc/named.conf ]
User : www-data

Name	Size	Permission	Date
mock-agent.js	4.63 KB	-rw-r--r--	2023-10-14 10:49
mock-client.js	1.46 KB	-rw-r--r--	2023-10-14 10:49
mock-errors.js	439 B	-rw-r--r--	2023-10-14 10:49
mock-interceptor.js	6.54 KB	-rw-r--r--	2023-10-14 10:49
mock-pool.js	1.45 KB	-rw-r--r--	2023-10-14 10:49
mock-symbols.js	769 B	-rw-r--r--	2023-10-14 10:49
mock-utils.js	10.05 KB	-rw-r--r--	2023-10-14 10:49
pending-interceptors-formatter.js	1.02 KB	-rw-r--r--	2023-10-14 10:49
pluralizer.js	495 B	-rw-r--r--	2023-10-14 10:49

Rename

'use strict'

const { promisify } = require('util')
const Client = require('../client')
const { buildMockDispatch } = require('./mock-utils')
const {
  kDispatches,
  kMockAgent,
  kClose,
  kOriginalClose,
  kOrigin,
  kOriginalDispatch,
  kConnected
} = require('./mock-symbols')
const { MockInterceptor } = require('./mock-interceptor')
const Symbols = require('../core/symbols')
const { InvalidArgumentError } = require('../core/errors')

/**
 * MockClient provides an API that extends the Client to influence the mockDispatches.
 */
class MockClient extends Client {
  constructor (origin, opts) {
    super(origin, opts)

if (!opts || !opts.agent || typeof opts.agent.dispatch !== 'function') {
      throw new InvalidArgumentError('Argument opts.agent must implement Agent')
    }

this[kMockAgent] = opts.agent
    this[kOrigin] = origin
    this[kDispatches] = []
    this[kConnected] = 1
    this[kOriginalDispatch] = this.dispatch
    this[kOriginalClose] = this.close.bind(this)

this.dispatch = buildMockDispatch.call(this)
    this.close = this[kClose]
  }

get [Symbols.kConnected] () {
    return this[kConnected]
  }

/**
   * Sets up the base interceptor for mocking replies from undici.
   */
  intercept (opts) {
    return new MockInterceptor(opts, this[kDispatches])
  }

async [kClose] () {
    await promisify(this[kOriginalClose])()
    this[kConnected] = 0
    this[kMockAgent][Symbols.kClients].delete(this[kOrigin])
  }
}

module.exports = MockClient