weseek__growi/lib/util/interceptorManager.js

const debug = require('debug')('crowi:InterceptorManager')

/**
 * the manager class of Interceptor
 */
class InterceptorManager {

  constructor(crowi) {
    this.interceptors = [];
  }

  /**
   * add an Interceptor
   * @param {BasicInterceptor} interceptor
   */
  addInterceptor(interceptor) {
    this.addInterceptors([interceptor]);
  }

  /**
   * add Interceptors
   * @param {BasicInterceptor[]} interceptors
   */
  addInterceptors(interceptors) {
    this.interceptors = this.interceptors.concat(interceptors);
  }

  /**
   * process Interceptors
   *
   * @param {string} contextName
   * @param {any} args
   */
  process(contextName, ...args) {
    debug(`processing context '${contextName}'`);

    // filter only contexts matches to specified 'contextName'
    const matchInterceptors = this.interceptors.filter((i) => i.isInterceptWhen(contextName));

    const parallels = matchInterceptors.filter((i) => i.isProcessableParallel());
    const sequentials = matchInterceptors.filter((i) => !i.isProcessableParallel());

    debug(`${parallels.length} parallel interceptors found.`);
    debug(`${sequentials.length} sequencial interceptors found.`);

    return Promise.all(
      // parallel
      parallels.map((interceptor) => {
        return this.doProcess(interceptor, contextName, ...args);
      })
      // sequential
      .concat([
        sequentials.reduce((prevPromise, nextInterceptor) => {
          return prevPromise.then((...results) => this.doProcess(nextInterceptor, contextName, ...results));
        }, Promise.resolve(...args)/* initial Promise */)
      ])
    ).then(() => {
      debug(`end processing context '${contextName}'`);
      return;
    });
  }

  doProcess(interceptor, contextName, ...args) {
    return interceptor.process(contextName, ...args)
      .then((...results) => {
        debug(`processing '${interceptor.id}' in context '${contextName}'`);
        return Promise.resolve(...results);
      })
      .catch((reason) => {
        debug(`failed when processing '${interceptor.id}' in context '${contextName}'`);
        debug(reason);
        return Promise.resolve(...args);
      });
  }
}

module.exports = (crowi) => {
  return new InterceptorManager(crowi);
}