File Explorer

1'use strict'2 3const Dispatcher = require('./dispatcher')4const {5  ClientDestroyedError,6  ClientClosedError,7  InvalidArgumentError8} = require('../core/errors')9const { kDestroy, kClose, kClosed, kDestroyed, kDispatch, kInterceptors } = require('../core/symbols')10 11const kOnDestroyed = Symbol('onDestroyed')12const kOnClosed = Symbol('onClosed')13const kInterceptedDispatch = Symbol('Intercepted Dispatch')14const kWebSocketOptions = Symbol('webSocketOptions')15 16class DispatcherBase extends Dispatcher {17  constructor (opts) {18    super()19 20    this[kDestroyed] = false21    this[kOnDestroyed] = null22    this[kClosed] = false23    this[kOnClosed] = []24    this[kWebSocketOptions] = opts?.webSocket ?? {}25  }26 27  get webSocketOptions () {28    return {29      maxPayloadSize: this[kWebSocketOptions].maxPayloadSize ?? 128 * 1024 * 102430    }31  }32 33  get destroyed () {34    return this[kDestroyed]35  }36 37  get closed () {38    return this[kClosed]39  }40 41  get interceptors () {42    return this[kInterceptors]43  }44 45  set interceptors (newInterceptors) {46    if (newInterceptors) {47      for (let i = newInterceptors.length - 1; i >= 0; i--) {48        const interceptor = this[kInterceptors][i]49        if (typeof interceptor !== 'function') {50          throw new InvalidArgumentError('interceptor must be an function')51        }52      }53    }54 55    this[kInterceptors] = newInterceptors56  }57 58  close (callback) {59    if (callback === undefined) {60      return new Promise((resolve, reject) => {61        this.close((err, data) => {62          return err ? reject(err) : resolve(data)63        })64      })65    }66 67    if (typeof callback !== 'function') {68      throw new InvalidArgumentError('invalid callback')69    }70 71    if (this[kDestroyed]) {72      queueMicrotask(() => callback(new ClientDestroyedError(), null))73      return74    }75 76    if (this[kClosed]) {77      if (this[kOnClosed]) {78        this[kOnClosed].push(callback)79      } else {80        queueMicrotask(() => callback(null, null))81      }82      return83    }84 85    this[kClosed] = true86    this[kOnClosed].push(callback)87 88    const onClosed = () => {89      const callbacks = this[kOnClosed]90      this[kOnClosed] = null91      for (let i = 0; i < callbacks.length; i++) {92        callbacks[i](null, null)93      }94    }95 96    // Should not error.97    this[kClose]()98      .then(() => this.destroy())99      .then(() => {100        queueMicrotask(onClosed)101      })102  }103 104  destroy (err, callback) {105    if (typeof err === 'function') {106      callback = err107      err = null108    }109 110    if (callback === undefined) {111      return new Promise((resolve, reject) => {112        this.destroy(err, (err, data) => {113          return err ? /* istanbul ignore next: should never error */ reject(err) : resolve(data)114        })115      })116    }117 118    if (typeof callback !== 'function') {119      throw new InvalidArgumentError('invalid callback')120    }121 122    if (this[kDestroyed]) {123      if (this[kOnDestroyed]) {124        this[kOnDestroyed].push(callback)125      } else {126        queueMicrotask(() => callback(null, null))127      }128      return129    }130 131    if (!err) {132      err = new ClientDestroyedError()133    }134 135    this[kDestroyed] = true136    this[kOnDestroyed] = this[kOnDestroyed] || []137    this[kOnDestroyed].push(callback)138 139    const onDestroyed = () => {140      const callbacks = this[kOnDestroyed]141      this[kOnDestroyed] = null142      for (let i = 0; i < callbacks.length; i++) {143        callbacks[i](null, null)144      }145    }146 147    // Should not error.148    this[kDestroy](err).then(() => {149      queueMicrotask(onDestroyed)150    })151  }152 153  [kInterceptedDispatch] (opts, handler) {154    if (!this[kInterceptors] || this[kInterceptors].length === 0) {155      this[kInterceptedDispatch] = this[kDispatch]156      return this[kDispatch](opts, handler)157    }158 159    let dispatch = this[kDispatch].bind(this)160    for (let i = this[kInterceptors].length - 1; i >= 0; i--) {161      dispatch = this[kInterceptors][i](dispatch)162    }163    this[kInterceptedDispatch] = dispatch164    return dispatch(opts, handler)165  }166 167  dispatch (opts, handler) {168    if (!handler || typeof handler !== 'object') {169      throw new InvalidArgumentError('handler must be an object')170    }171 172    try {173      if (!opts || typeof opts !== 'object') {174        throw new InvalidArgumentError('opts must be an object.')175      }176 177      if (this[kDestroyed] || this[kOnDestroyed]) {178        throw new ClientDestroyedError()179      }180 181      if (this[kClosed]) {182        throw new ClientClosedError()183      }184 185      return this[kInterceptedDispatch](opts, handler)186    } catch (err) {187      if (typeof handler.onError !== 'function') {188        throw new InvalidArgumentError('invalid onError method')189      }190 191      handler.onError(err)192 193      return false194    }195  }196}197 198module.exports = DispatcherBase199