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(ops){
		if (!ops){
			throw new Error("mungedb Aggregator requires a pipeline!");
		}
		if (typeof ops.length !== "number"){
			ops = [ops];
		}
		this.pipeline = new PipelineCommand(ops);
	};
	proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});

	// PROTOTYPE MEMBERS
	proto.execute = function execute(inputs){
		var result = {};
		result.ok = this.pipeline.run(inputs, result);
		//return result;	//TODO: figure out if we want mongo style result or a simpler one.
		return result.result;
	};

	var accumulators = require("./pipeline/accumulators"),
		documentSources = require("./pipeline/documentSources"),
		expressions = require("./pipeline/expressions");

	//Expose these so that mungedb-aggregate can be extended.
	klass.accumulators = accumulators;
	klass.documentSources = documentSources;
	klass.expressions = expressions;

	return klass;
})();