Demandware Controller -> Pipeline passthrough service

PassthroughService.js

/*
  Run with:

  PassthroughService.pass(exports, "MyPipelineName", [
    "myPipelineMethod",
    ...
  ]);
*/

var Pipeline = require('dw/system/Pipeline');

function PassthroughService() {
  function pass(exports, pipelineName, nodeArray) {
    for (var i = 0; i < nodeArray.length; i++) {
      var node = nodeArray[i];
      exports[node] = executePipeline(pipelineName, node);
      exports[node].public = true;
    }
  }

  function executePipeline(pipelineName, node) {
    return function() {
      Pipeline.execute(pipelineName + "-" + node);
    };
  }

  return {
    pass: pass
  };
}

module.exports = new PassthroughService();