summaryrefslogtreecommitdiffstats
path: root/lib/output/callHook.js
blob: 1ff1a4165e805bfabf49568e72749462d1ee9461 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
var Promise = require('../utils/promise');
var Api = require('../api');

function defaultGetArgument() {
    return undefined;
}

function defaultHandleResult(output, result) {
    return output;
}

/**
    Call a "global" hook for an output

    @param {String} name
    @param {Function(Output) -> Mixed} getArgument
    @param {Function(Output, result) -> Output} handleResult
    @param {Output} output
    @return {Promise<Output>}
*/
function callHook(name, getArgument, handleResult, output) {
    getArgument = getArgument || defaultGetArgument;
    handleResult = handleResult || defaultHandleResult;

    var logger = output.getLogger();
    var plugins = output.getPlugins();

    logger.debug.ln('calling hook "' + name + '"');

    // Create the JS context for plugins
    var context = Api.encodeGlobal(output);

    // Get the arguments
    return Promise(getArgument(output))

    // Call the hooks in serie
    .then(function(arg) {
        return Promise.reduce(plugins, function(prev, plugin) {
            var hook = plugin.getHook(name);
            if (!hook) {
                return prev;
            }

            return hook.call(context, prev);
        }, arg);
    })

    // Handle final result
    .then(function(result) {
        output = Api.decodeGlobal(output, context);
        return handleResult(output, result);
    });
}

module.exports = callHook;