| |
| |
| |
| |
| "use strict"; |
|
|
| const Hook = require("./Hook"); |
| const HookCodeFactory = require("./HookCodeFactory"); |
|
|
| class AsyncSeriesWaterfallHookCodeFactory extends HookCodeFactory { |
| content({ onError, onResult, _onDone }) { |
| return this.callTapsSeries({ |
| onError: (i, err, next, doneBreak) => onError(err) + doneBreak(true), |
| onResult: (i, result, next) => { |
| let code = ""; |
| code += `if(${result} !== undefined) {\n`; |
| code += `${this._args[0]} = ${result};\n`; |
| code += "}\n"; |
| code += next(); |
| return code; |
| }, |
| onDone: () => onResult(this._args[0]) |
| }); |
| } |
| } |
|
|
| const factory = new AsyncSeriesWaterfallHookCodeFactory(); |
|
|
| function COMPILE(options) { |
| factory.setup(this, options); |
| return factory.create(options); |
| } |
|
|
| function AsyncSeriesWaterfallHook(args = [], name = undefined) { |
| if (args.length < 1) { |
| throw new Error("Waterfall hooks must have at least one argument"); |
| } |
| const hook = new Hook(args, name); |
| hook.constructor = AsyncSeriesWaterfallHook; |
| hook.compile = COMPILE; |
| hook._call = undefined; |
| hook.call = undefined; |
| return hook; |
| } |
|
|
| AsyncSeriesWaterfallHook.prototype = null; |
|
|
| module.exports = AsyncSeriesWaterfallHook; |
|
|