| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175 | 
							- /*
 
- 	MIT License http://www.opensource.org/licenses/mit-license.php
 
- 	Author Tobias Koppers @sokra
 
- */
 
- "use strict";
 
- const util = require("util");
 
- const deprecateContext = util.deprecate(() => {},
 
- "Hook.context is deprecated and will be removed");
 
- const CALL_DELEGATE = function(...args) {
 
- 	this.call = this._createCall("sync");
 
- 	return this.call(...args);
 
- };
 
- const CALL_ASYNC_DELEGATE = function(...args) {
 
- 	this.callAsync = this._createCall("async");
 
- 	return this.callAsync(...args);
 
- };
 
- const PROMISE_DELEGATE = function(...args) {
 
- 	this.promise = this._createCall("promise");
 
- 	return this.promise(...args);
 
- };
 
- class Hook {
 
- 	constructor(args = [], name = undefined) {
 
- 		this._args = args;
 
- 		this.name = name;
 
- 		this.taps = [];
 
- 		this.interceptors = [];
 
- 		this._call = CALL_DELEGATE;
 
- 		this.call = CALL_DELEGATE;
 
- 		this._callAsync = CALL_ASYNC_DELEGATE;
 
- 		this.callAsync = CALL_ASYNC_DELEGATE;
 
- 		this._promise = PROMISE_DELEGATE;
 
- 		this.promise = PROMISE_DELEGATE;
 
- 		this._x = undefined;
 
- 		this.compile = this.compile;
 
- 		this.tap = this.tap;
 
- 		this.tapAsync = this.tapAsync;
 
- 		this.tapPromise = this.tapPromise;
 
- 	}
 
- 	compile(options) {
 
- 		throw new Error("Abstract: should be overridden");
 
- 	}
 
- 	_createCall(type) {
 
- 		return this.compile({
 
- 			taps: this.taps,
 
- 			interceptors: this.interceptors,
 
- 			args: this._args,
 
- 			type: type
 
- 		});
 
- 	}
 
- 	_tap(type, options, fn) {
 
- 		if (typeof options === "string") {
 
- 			options = {
 
- 				name: options.trim()
 
- 			};
 
- 		} else if (typeof options !== "object" || options === null) {
 
- 			throw new Error("Invalid tap options");
 
- 		}
 
- 		if (typeof options.name !== "string" || options.name === "") {
 
- 			throw new Error("Missing name for tap");
 
- 		}
 
- 		if (typeof options.context !== "undefined") {
 
- 			deprecateContext();
 
- 		}
 
- 		options = Object.assign({ type, fn }, options);
 
- 		options = this._runRegisterInterceptors(options);
 
- 		this._insert(options);
 
- 	}
 
- 	tap(options, fn) {
 
- 		this._tap("sync", options, fn);
 
- 	}
 
- 	tapAsync(options, fn) {
 
- 		this._tap("async", options, fn);
 
- 	}
 
- 	tapPromise(options, fn) {
 
- 		this._tap("promise", options, fn);
 
- 	}
 
- 	_runRegisterInterceptors(options) {
 
- 		for (const interceptor of this.interceptors) {
 
- 			if (interceptor.register) {
 
- 				const newOptions = interceptor.register(options);
 
- 				if (newOptions !== undefined) {
 
- 					options = newOptions;
 
- 				}
 
- 			}
 
- 		}
 
- 		return options;
 
- 	}
 
- 	withOptions(options) {
 
- 		const mergeOptions = opt =>
 
- 			Object.assign({}, options, typeof opt === "string" ? { name: opt } : opt);
 
- 		return {
 
- 			name: this.name,
 
- 			tap: (opt, fn) => this.tap(mergeOptions(opt), fn),
 
- 			tapAsync: (opt, fn) => this.tapAsync(mergeOptions(opt), fn),
 
- 			tapPromise: (opt, fn) => this.tapPromise(mergeOptions(opt), fn),
 
- 			intercept: interceptor => this.intercept(interceptor),
 
- 			isUsed: () => this.isUsed(),
 
- 			withOptions: opt => this.withOptions(mergeOptions(opt))
 
- 		};
 
- 	}
 
- 	isUsed() {
 
- 		return this.taps.length > 0 || this.interceptors.length > 0;
 
- 	}
 
- 	intercept(interceptor) {
 
- 		this._resetCompilation();
 
- 		this.interceptors.push(Object.assign({}, interceptor));
 
- 		if (interceptor.register) {
 
- 			for (let i = 0; i < this.taps.length; i++) {
 
- 				this.taps[i] = interceptor.register(this.taps[i]);
 
- 			}
 
- 		}
 
- 	}
 
- 	_resetCompilation() {
 
- 		this.call = this._call;
 
- 		this.callAsync = this._callAsync;
 
- 		this.promise = this._promise;
 
- 	}
 
- 	_insert(item) {
 
- 		this._resetCompilation();
 
- 		let before;
 
- 		if (typeof item.before === "string") {
 
- 			before = new Set([item.before]);
 
- 		} else if (Array.isArray(item.before)) {
 
- 			before = new Set(item.before);
 
- 		}
 
- 		let stage = 0;
 
- 		if (typeof item.stage === "number") {
 
- 			stage = item.stage;
 
- 		}
 
- 		let i = this.taps.length;
 
- 		while (i > 0) {
 
- 			i--;
 
- 			const x = this.taps[i];
 
- 			this.taps[i + 1] = x;
 
- 			const xStage = x.stage || 0;
 
- 			if (before) {
 
- 				if (before.has(x.name)) {
 
- 					before.delete(x.name);
 
- 					continue;
 
- 				}
 
- 				if (before.size > 0) {
 
- 					continue;
 
- 				}
 
- 			}
 
- 			if (xStage > stage) {
 
- 				continue;
 
- 			}
 
- 			i++;
 
- 			break;
 
- 		}
 
- 		this.taps[i] = item;
 
- 	}
 
- }
 
- Object.setPrototypeOf(Hook.prototype, null);
 
- module.exports = Hook;
 
 
  |