mungedb-aggregate/lib/Aggregator.js

"use strict";
var PipelineCommand = require('./commands/PipelineCommand');

var Aggregator = module.exports = (function(){
	// CONSTRUCTOR
	var base = Object, proto, klass = function Aggregator(docSrcs, pipelineArgs){
		if (!docSrcs){
			throw new Error("mungedb Aggregator requires a pipeline!");
		}
		if (typeof docSrcs.length !== "number"){
			docSrcs = [docSrcs];
		}
		this.docSrcs = docSrcs;
		this.pipelineArgs = pipelineArgs;
	};
	proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});

	// PROTOTYPE MEMBERS
	proto.execute = function execute(inputs, callback){
		//! @ticket #2266: always create a new PipelineCommand just before we use it.
		var pipeline = new PipelineCommand(this.docSrcs, this.pipelineArgs);

		pipeline.run(inputs,function(err, output){
			if (err) return callback(err);
			return callback(null, output.result);
		});

	};

	//Expose these so that mungedb-aggregate can be extended.
	klass.Pipeline = require("./pipeline/Pipeline");
	klass.accumulators = require("./pipeline/accumulators");
	klass.documentSources = require("./pipeline/documentSources");
	klass.expressions = require("./pipeline/expressions");
	klass.commands = require("./commands");
	klass.Cursor = require("./Cursor");

	return klass;
})();