Refs #1879: Fixed jshint and pkg rename issues

index.js

@@ -1 +0,0 @@
-module.exports = require("./munge");

lib/munge.js → lib/Aggregator.js

@@ -1,10 +1,11 @@
+"use strict";
 var PipelineCommand = require('./commands/PipelineCommand');
 
-var Munger = (function(){
+var Aggregator = module.exports = (function(){
 	// CONSTRUCTOR
-	var base = Object, proto, klass = function Munger(ops){
+	var base = Object, proto, klass = function Aggregator(ops){
 		if (!ops){
-			throw new Error("munge requires a pipeline!");
+			throw new Error("mungedb Aggregator requires a pipeline!");
 		}
 		if (typeof ops.length !== "number"){
 			ops = [ops];
@@ -23,11 +24,3 @@ var Munger = (function(){
 
 	return klass;
 })();
-
-
-module.exports = function munge(ops, inputs) {
-	var munger = new Munger(ops);
-	if(inputs)
-		return munger.execute(inputs);
-	return munger.execute.bind(munger);
-};

lib/Cursor.js

@@ -1,3 +1,4 @@
+"use strict";
 var Cursor = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
@@ -33,7 +34,6 @@ var Cursor = module.exports = (function(){
 	
 	var su = require("stream-utils");
 
-
 	proto.ok = function ok(){
 		if (this.throughStream && this.throughStream.readable){
 			return true;
@@ -41,7 +41,6 @@ var Cursor = module.exports = (function(){
 		return this.cachedData.length > 0 || this.hasOwnProperty("curr");
 	};
 
-
 	proto.advance = function advance(){
 		if (this.cachedData.length === 0){
 			delete this.curr;
@@ -65,6 +64,5 @@ var Cursor = module.exports = (function(){
 		return this.curr;
 	};
 	
-	
 	return klass;
-})();
+})();

lib/commands/PipelineCommand.js

@@ -1,8 +1,16 @@
+"use strict";
 var PipelineCommand = module.exports = (function(){
 	// CONSTRUCTOR
+	/**
+	 * Represents a Pipeline Command
+	 *
+	 * @class PipelineCommand
+	 * @namespace mungedb.aggregate.pipeline
+	 * @module mungedb-aggregate
+	 * @constructor
+	 **/
 	var klass = function PipelineCommand(cmdObj){
         /* try to parse the command; if this fails, then we didn't run */
-        
         //NOTE: this is different from the mongo implementation.  It used to be in the 'run' method that we would parse the pipeline, 
         //but we decided it would be better to be able to save the parsed command
         this.pPipeline = Pipeline.parseCommand(cmdObj);
@@ -13,15 +21,16 @@ var PipelineCommand = module.exports = (function(){
 
 	/**
 	 * Execute the pipeline.
-	**/
+	 * @method executePipeline
+	 **/
 	proto.executePipeline = function executePipeline(result, pPipeline, pSource){
 		return pPipeline.run(result, pSource);
 	};
 	
 	/**
-	 * Documents are retrieved until the
-	 * cursor is exhausted (or another termination condition occurs).
-	**/
+	 * Documents are retrieved until the cursor is exhausted (or another termination condition occurs).
+	 * @method runExecute
+	 **/
 	proto.runExecute = function runExecute(result, db){
 		var pSource = PipelineD.prepareCursorSource(this.pPipeline, db);
         return this.executePipeline(result, this.pPipeline, pSource);
@@ -29,7 +38,8 @@ var PipelineCommand = module.exports = (function(){
 	
 	/**
 	 * run the command
-	**/
+	 * @method run
+	 **/
 	proto.run = function run(db, result){
 		if (!this.pPipeline){
 			return false;
@@ -38,4 +48,4 @@ var PipelineCommand = module.exports = (function(){
 	};
 
 	return klass;
-})();
+})();

lib/index.js

@@ -0,0 +1,13 @@
+"use strict";
+var Aggregator = require("./Aggregator");
+
+module.exports = (function(){
+	function aggregate(ops, inputs) {
+		var aggregator = new Aggregator(ops);
+		if(inputs)
+			return aggregator.execute(inputs);
+		return aggregator.execute.bind(aggregator);
+	}
+	aggregate.Aggregator = Aggregator;
+	return aggregate;
+})();

lib/pipeline/Document.js

@@ -1,13 +1,14 @@
+"use strict";
 var Document = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
-	* Represents a `Document` (i.e., an `Object`) in `mongo` but in `munge` this is only a set of static helpers since we treat all `Object`s like `Document`s.
-	*
-	* @class Document
-	* @namespace munge.pipeline
-	* @module munge
-	* @constructor
-	**/
+	 * Represents a `Document` (i.e., an `Object`) in `mongo` but in `munge` this is only a set of static helpers since we treat all `Object`s like `Document`s.
+	 *
+	 * @class Document
+	 * @namespace mungedb.aggregate.pipeline
+	 * @module mungedb-aggregate
+	 * @constructor
+	 **/
 	var klass = function Document(){
 		if(this.constructor == Document) throw new Error("Never create instances! Use static helpers only.");
 	}, base = Object, proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
@@ -17,24 +18,24 @@ var Document = module.exports = (function(){
 
 	// STATIC MEMBERS
 	/**
-	* Shared "_id"
-	*
-	* @static
-	* @property ID_PROPERTY_NAME
-	**/
+	 * Shared "_id"
+	 * @static
+	 * @property ID_PROPERTY_NAME
+	 **/
 	klass.ID_PROPERTY_NAME = "_id";
 
 	/**
-	* Compare two documents.
-	* BSON document field order is significant, so this just goes through the fields in order.
-	* The comparison is done in roughly the same way as strings are compared, but comparing one field at a time instead of one character at a time.
-	*
-	* @static
-	* @method compare
-	* @param rL left document
-	* @param rR right document
-	* @returns an integer less than zero, zero, or an integer greater than zero, depending on whether rL < rR, rL == rR, or rL > rR
-	**/
+	 * Compare two documents.
+	 *
+	 * BSON document field order is significant, so this just goes through the fields in order.
+	 * The comparison is done in roughly the same way as strings are compared, but comparing one field at a time instead of one character at a time.
+	 *
+	 * @static
+	 * @method compare
+	 * @param rL left document
+	 * @param rR right document
+	 * @returns an integer less than zero, zero, or an integer greater than zero, depending on whether rL < rR, rL == rR, or rL > rR
+	 **/
 	klass.compare = function compare(l, r){	//TODO: might be able to replace this with a straight compare of docs using JSON.stringify()
 		var lPropNames = Object.getOwnPropertyNames(l),
 			lPropNamesLength = lPropNames.length,
@@ -61,6 +62,13 @@ var Document = module.exports = (function(){
 		throw new Error("This should never happen");	//verify(false)
 //		return 0;
 	};
+
+	/**
+	 * Clone a document
+	 * @static
+	 * @method clone
+	 * @param document
+	 **/
 	klass.clone = function(document){
 		var obj = {};
 		for(var key in document){

lib/pipeline/FieldPath.js

@@ -1,17 +1,18 @@
+"use strict";
 var FieldPath = module.exports = FieldPath = (function(){
 	// CONSTRUCTOR
 	/**
-	* Constructor for field paths.
-	*
-	* The constructed object will have getPathLength() > 0.
-	* Uassert if any component field names do not pass validation.
-	*
-	* @class FieldPath
-	* @namespace munge.pipeline
-	* @module munge
-	* @constructor
-	* @param fieldPath the dotted field path string or non empty pre-split vector.
-	**/
+	 * Constructor for field paths.
+	 *
+	 * The constructed object will have getPathLength() > 0.
+	 * Uassert if any component field names do not pass validation.
+	 *
+	 * @class FieldPath
+	 * @namespace mungedb.aggregate.pipeline
+	 * @module mungedb-aggregate
+	 * @constructor
+	 * @param fieldPath the dotted field path string or non empty pre-split vector.
+	 **/
 	var klass = function FieldPath(path){
 		var fields = typeof(path) === "object" && typeof(path.length) === "number" ? path : path.split(".");
 		if(fields.length === 0) throw new Error("FieldPath cannot be constructed from an empty vector (String or Array).; code 16409");
@@ -31,46 +32,45 @@ var FieldPath = module.exports = FieldPath = (function(){
 
 	// PROTOTYPE MEMBERS
 	/**
-	* Get the full path.
-	*
-	* @method getPath
-	* @param fieldPrefix whether or not to include the field prefix
-	* @returns the complete field path
-	*/
+	 * Get the full path.
+	 *
+	 * @method getPath
+	 * @param fieldPrefix whether or not to include the field prefix
+	 * @returns the complete field path
+	 **/
 	proto.getPath = function getPath(withPrefix) {
 		return ( !! withPrefix ? FieldPath.PREFIX : "") + this.fields.join(".");
 	};
 
 	/**
-	* A FieldPath like this but missing the first element (useful for recursion). Precondition getPathLength() > 1.
-	*
-	* @method tail
-	**/
+	 * A FieldPath like this but missing the first element (useful for recursion). Precondition getPathLength() > 1.
+	 *
+	 * @method tail
+	 **/
 	proto.tail = function tail() {
 		return new FieldPath(this.fields.slice(1));
 	};
 
 	/**
-	* Get a particular path element from the path.
-	*
-	* @method getFieldName
-	* @param i the zero based index of the path element.
-	* @returns the path element
-	*/
+	 * Get a particular path element from the path.
+	 *
+	 * @method getFieldName
+	 * @param i the zero based index of the path element.
+	 * @returns the path element
+	 **/
 	proto.getFieldName = function getFieldName(i){	//TODO: eventually replace this with just using .fields[i] directly
 		return this.fields[i];
 	};
 
 	/**
-	* Get the number of path elements in the field path.
-	*
-	* @method getPathLength
-	* @returns the number of path elements
-	**/
+	 * Get the number of path elements in the field path.
+	 *
+	 * @method getPathLength
+	 * @returns the number of path elements
+	 **/
 	proto.getPathLength = function getPathLength() {
 		return this.fields.length;
 	};
 
-
 	return klass;
 })();

lib/pipeline/Pipeline.js

@@ -1,13 +1,13 @@
+"use strict";
 var Pipeline = module.exports = (function(){
-	// CONSTRUCTOR
 	// CONSTRUCTOR
 	/**
-	* mongodb "commands" (sent via db.$cmd.findOne(...)) subclass to make a command.  define a singleton object for it.
-	* @class Pipeline
-	* @namespace munge.pipeline
-	* @module munge
-	* @constructor
-	**/
+	 * mongodb "commands" (sent via db.$cmd.findOne(...)) subclass to make a command.  define a singleton object for it.
+	 * @class Pipeline
+	 * @namespace mungedb.aggregate.pipeline
+	 * @module mungedb-aggregate
+	 * @constructor
+	 **/
 	var klass = function Pipeline(/*theCtx*/){
 		this.sourceVector = [];//should be provate?
 	}, base = Object, proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
@@ -138,6 +138,7 @@ var Pipeline = module.exports = (function(){
 
 		return pipelineInstance;
 	};
+
 	/**
 	 * Run the pipeline
 	 *

lib/pipeline/PipelineD.js

@@ -1,3 +1,4 @@
+"use strict";
 var PipelineD = module.exports = (function(){
 	// CONSTRUCTOR
 	var klass = function PipelineD(){

lib/pipeline/Value.js

@@ -1,14 +1,14 @@
+"use strict";
 var Value = module.exports = Value = (function(){
-
 	// CONSTRUCTOR
 	/**
-	* Represents a `Value` (i.e., an `Object`) in `mongo` but in `munge` this is only a set of static helpers since we treat all `Object`s like `Value`s.
-	*
-	* @class Value
-	* @namespace munge.pipeline
-	* @module munge
-	* @constructor
-	**/
+	 * Represents a `Value` (i.e., an `Object`) in `mongo` but in `munge` this is only a set of static helpers since we treat all `Object`s like `Value`s.
+	 *
+	 * @class Value
+	 * @namespace mungedb.aggregate.pipeline
+	 * @module mungedb-aggregate
+	 * @constructor
+	 **/
 	var klass = function Value(){
 		if(this.constructor == Value) throw new Error("Never create instances of this! Use the static helpers only.");
 	}, base = Object, proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
@@ -74,14 +74,15 @@ var Value = module.exports = Value = (function(){
 //TODO:	klass.coerceToTimestamp = ...?
 
 	/**
-	* Compare two Values.
-	*
-	* @static
-	* @method compare
-	* @param rL left value
-	* @param rR right value
-	* @returns an integer less than zero, zero, or an integer greater than zero, depending on whether rL < rR, rL == rR, or rL > rR
-	**/
+	 * Compare two Values.
+	 *
+	 * @static
+	 * @method compare
+	 * @param rL left value
+	 * @param rR right value
+	 * @returns an integer less than zero, zero, or an integer greater than zero, depending on whether rL < rR, rL == rR, or rL > rR
+	 **/
+	var Document;  // loaded lazily below //TODO: a dirty hack; need to investigate and clean up
 	klass.compare = function compare(l, r) {
 		var lt = typeof(l),
 			rt = typeof(r);
@@ -134,6 +135,7 @@ var Value = module.exports = Value = (function(){
 			}
 			if (l instanceof Date) return l < r ? -1 : l > r ? 1 : 0;
 			if (l instanceof RegExp) return l < r ? -1 : l > r ? 1 : 0;
+			if(Document === undefined) Document = require("./Document");	//TODO: a dirty hack; need to investigate and clean up
 			return Document.compare(l, r);
 		default:
 			throw new Error("unhandled left hand type:" + lt);

lib/pipeline/accumulators/Accumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var Accumulator = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -42,12 +43,12 @@ var Accumulator = module.exports = (function(){
 	*   @param {String} opName the operator name
 	*   @param {Boolean} requireExpression pass down if the expression is needed
 	**/
-	proto.opToBson = function opToBson(pBuilder, opName, fieldName, requireExpression) {
-		if (this.operands.length == 1) throw new Error("this should never happen");
-		var builder = new BSONObjBuilder();
-		this.operands[0].addToBsonObj(builder, opName, requireExpression);
-		pBuilder.append(fieldName, builder.done());
-	};
+//	proto.opToBson = function opToBson(pBuilder, opName, fieldName, requireExpression) {
+//		if (this.operands.length == 1) throw new Error("this should never happen");
+//		var builder = new BSONObjBuilder();
+//		this.operands[0].addToBsonObj(builder, opName, requireExpression);
+//		pBuilder.append(fieldName, builder.done());
+//	};
 
 	/**
 	*   Wrapper around opToBson
@@ -56,9 +57,9 @@ var Accumulator = module.exports = (function(){
 	*   @param {String} fieldName the projected name
 	*   @param {Boolean} requireExpression pass down if the expression is needed
 	**/
-	proto.addToBsonObj = function addToBsonObj(pBuilder, fieldName, requireExpression) {
-		this.opToBson(pBuilder, this.getOpName(), fieldName, requireExpression);
-	};
+//	proto.addToBsonObj = function addToBsonObj(pBuilder, fieldName, requireExpression) {
+//		this.opToBson(pBuilder, this.getOpName(), fieldName, requireExpression);
+//	};
 
 	/**
 	*   Make sure that nobody adds an accumulator to an array

lib/pipeline/accumulators/AddToSetAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var AddToSetAccumulator = module.exports = (function(){
 
 	// DEPENDENCIES

lib/pipeline/accumulators/AvgAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var AvgAccumulator = module.exports = (function(){
 
 	// Constructor

lib/pipeline/accumulators/FirstAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var FirstAccumulator = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 

lib/pipeline/accumulators/LastAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var LastAccumulator = module.exports = (function(){
 
 	// Constructor

lib/pipeline/accumulators/MinMaxAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var MinMaxAccumulator = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 

lib/pipeline/accumulators/PushAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var PushAccumulator = module.exports = (function(){
 
 	// Constructor

lib/pipeline/accumulators/SingleValueAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var SingleValueAccumulator = module.exports = (function(){
 
 	// Constructor

lib/pipeline/accumulators/SumAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var SumAccumulator = module.exports = (function(){
 
 	// Constructor

lib/pipeline/accumulators/index.js

@@ -1,11 +1,12 @@
+"use strict";
 module.exports = {
-	AddToSet:require("./AddToSetAccumulator"),
-	Avg:require("./AvgAccumulator"),
-	First:require("./FirstAccumulator"),
-	Last:require("./LastAccumulator"),
-	MinMax:require("./MinMaxAccumulator"),
-	Push:require("./PushAccumulator"),
-	Sum:require("./SumAccumulator")
+	AddToSet: require("./AddToSetAccumulator"),
+	Avg: require("./AvgAccumulator"),
+	First: require("./FirstAccumulator"),
+	Last: require("./LastAccumulator"),
+	MinMax: require("./MinMaxAccumulator"),
+	Push: require("./PushAccumulator"),
+	Sum: require("./SumAccumulator")
 };
 
 

lib/pipeline/documentSources/CursorDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var CursorDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
     /**

lib/pipeline/documentSources/DocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var DocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/documentSources/FilterBaseDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var FilterBaseDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/documentSources/GroupDocumentSource.js

@@ -1,10 +1,13 @@
+"use strict";
 var DocumentSource = require("./DocumentSource"),
 	Accumulators = require("../accumulators/"),
 	Document = require("../Document"),
 	Expression = require("../expressions/Expression"),
 	ConstantExpression = require("../expressions/ConstantExpression"),
-	FieldPathExpression = require("../expressions/FieldPathExpression"),
-	GroupDocumentSource = module.exports = (function(){
+	FieldPathExpression = require("../expressions/FieldPathExpression");
+
+
+var GroupDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
 	 * A class for grouping documents together

lib/pipeline/documentSources/LimitDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var LimitDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/documentSources/MatchDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var MatchDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/documentSources/ProjectDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var ProjectDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/documentSources/SkipDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var SkipDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/documentSources/SortDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var SortDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/documentSources/SplitDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var SplitDocumentSource = module.exports = (function(){
 	// CONSTRUCTOR
 	/**

lib/pipeline/expressions/AddExpression.js

@@ -1,13 +1,14 @@
+"use strict";
 var AddExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
 	 * Create an expression that finds the sum of n operands. 
 	 *
 	 * @class AddExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = module.exports = function AddExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -26,9 +27,9 @@ var AddExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes an array of one or more numbers and adds them together, returning the sum.
-	* @method @evaluate
-	**/
+	 * Takes an array of one or more numbers and adds them together, returning the sum.
+	 * @method @evaluate
+	 **/
 	proto.evaluate = function evaluate(doc) {
 		var total = 0;
 		for (var i = 0, n = this.operands.length; i < n; ++i) {

lib/pipeline/expressions/AndExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var AndExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -7,10 +8,10 @@ var AndExpression = module.exports = (function(){
 	 * returns false on the first operand that evaluates to false.
 	 *
 	 * @class AndExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = module.exports = function AndExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -31,9 +32,9 @@ var AndExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes an array one or more values and returns true if all of the values in the array are true. Otherwise $and returns false.
-	* @method evaluate
-	**/
+	 * Takes an array one or more values and returns true if all of the values in the array are true. Otherwise $and returns false.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc) {
 		for (var i = 0, n = this.operands.length; i < n; ++i) {
 			var value = this.operands[i].evaluate(doc);

lib/pipeline/expressions/CoerceToBoolExpression.js

@@ -1,13 +1,14 @@
+"use strict";
 var CoerceToBoolExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
 	 * internal expression for coercing things to booleans 
 	 *
 	 * @class CoerceToBoolExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = module.exports = function CoerceToBoolExpression(expression){
 		if(arguments.length !== 1) throw new Error("args expected: expression");
 		this.expression = expression;

lib/pipeline/expressions/CompareExpression.js

@@ -1,13 +1,14 @@
+"use strict";
 var CompareExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
 	 * Generic comparison expression that gets used for $eq, $ne, $lt, $lte, $gt, $gte, and $cmp. 
 	 *
 	 * @class CompareExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = module.exports = CompareExpression = function CompareExpression(cmpOp) {
 		if(arguments.length !== 1) throw new Error("args expected: cmpOp");
 		this.cmpOp = cmpOp;
@@ -23,12 +24,12 @@ var CompareExpression = module.exports = (function(){
 
 	// NESTED CLASSES
 	/**
-	* Lookup table for truth value returns
-	*
-	* @param truthValues	truth value for -1, 0, 1
-	* @param reverse		reverse comparison operator
-	* @param name			string name
-	**/
+	 * Lookup table for truth value returns
+	 *
+	 * @param truthValues	truth value for -1, 0, 1
+	 * @param reverse		reverse comparison operator
+	 * @param name			string name
+	 **/
 	var CmpLookup = (function(){	// emulating a struct
 		// CONSTRUCTOR
 		var klass = function CmpLookup(truthValues, reverse, name) {
@@ -42,9 +43,9 @@ var CompareExpression = module.exports = (function(){
 
 	// PRIVATE STATIC MEMBERS
 	/**
-	* a table of cmp type lookups to truth values
-	* @private
-	**/
+	 * a table of cmp type lookups to truth values
+	 * @private
+	 **/
 	var cmpLookupMap = [	//NOTE: converted from this Array to a Dict/Object below using CmpLookup#name as the key
 		//              -1      0      1      reverse             name     (taking advantage of the fact that our 'enums' are strings below)
 		new CmpLookup([false, true, false], Expression.CmpOp.EQ, Expression.CmpOp.EQ),

lib/pipeline/expressions/CondExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var CondExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
@@ -6,10 +7,10 @@ var CondExpression = module.exports = (function(){
 	 * @see evaluate 
 	 *
 	 * @class AndExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = module.exports = function CondExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -29,8 +30,9 @@ var CondExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Use the $cond operator with the following syntax:  { $cond: [ <boolean-expression>, <true-case>, <false-case> ] } 
-	**/
+	 * Use the $cond operator with the following syntax:  { $cond: [ <boolean-expression>, <true-case>, <false-case> ] } 
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(3);
 		var pCond = this.operands[0].evaluate(doc),

lib/pipeline/expressions/ConstantExpression.js

@@ -1,13 +1,14 @@
+"use strict";
 var ConstantExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
 	 * Internal expression for constant values 
 	 *
 	 * @class ConstantExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function ConstantExpression(value){
 		if(arguments.length !== 1) throw new Error("args expected: value");
 		this.value = value;	//TODO: actually make read-only in terms of JS?
@@ -20,10 +21,11 @@ var ConstantExpression = module.exports = (function(){
 	};
 
 	/**
-	* Get the constant value represented by this Expression.
-	*
-	* @returns the value
-	**/
+	 * Get the constant value represented by this Expression.
+	 *
+	 * @method getValue
+	 * @returns the value
+	 **/
 	proto.getValue = function getValue(){	//TODO: convert this to an instance field rather than a property
 		return this.value;
 	};
@@ -33,9 +35,9 @@ var ConstantExpression = module.exports = (function(){
 	};
 
 	/**
-	* Get the constant value represented by this Expression.
-	* @method evaluate
-	**/
+	 * Get the constant value represented by this Expression.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		return this.value;
 	};

lib/pipeline/expressions/DayOfMonthExpression.js

@@ -1,13 +1,14 @@
+"use strict";
 var DayOfMonthExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
 	 * Get the DayOfMonth from a date.
 	 *
 	 * @class DayOfMonthExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function DayOfMonthExpression(){
 		if (arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -24,9 +25,9 @@ var DayOfMonthExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes a date and returns the day of the month as a number between 1 and 31.
-	* @method evaluate
-	**/
+	 * Takes a date and returns the day of the month as a number between 1 and 31.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc);

lib/pipeline/expressions/DayOfWeekExpression.js

@@ -1,13 +1,14 @@
+"use strict";
 var DayOfWeekExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
 	 * Get the DayOfWeek from a date.
 	 *
 	 * @class DayOfWeekExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function DayOfWeekExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -24,9 +25,9 @@ var DayOfWeekExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes a date and returns the day of the week as a number between 1 (Sunday) and 7 (Saturday.)
-	* @method evaluate
-	**/
+	 * Takes a date and returns the day of the week as a number between 1 (Sunday) and 7 (Saturday.)
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc);

lib/pipeline/expressions/DayOfYearExpression.js

@@ -1,13 +1,14 @@
+"use strict";
 var DayOfYearExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
 	 * Get the DayOfYear from a date.
 	 *
 	 * @class DayOfYearExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function DayOfYearExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -24,9 +25,9 @@ var DayOfYearExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes a date and returns the day of the year as a number between 1 and 366.
-	* @method evaluate
-	**/
+	 * Takes a date and returns the day of the year as a number between 1 and 366.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		//NOTE: the below silliness is to deal with the leap year scenario when we should be returning 366
 		this.checkArgCount(1);

lib/pipeline/expressions/DivideExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var DivideExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -5,10 +6,10 @@ var DivideExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class DivideExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function DivideExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -28,9 +29,9 @@ var DivideExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes an array that contains a pair of numbers and returns the value of the first number divided by the second number.
-	* @method evaluate
-	**/
+	 * Takes an array that contains a pair of numbers and returns the value of the first number divided by the second number.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc) {
 		this.checkArgCount(2);
 		var left = this.operands[0].evaluate(doc),

lib/pipeline/expressions/Expression.js

@@ -1,18 +1,19 @@
+"use strict";
 var Expression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
-	* A base class for all pipeline expressions; Performs common expressions within an Op.
-	*
-	* NOTE: An object expression can take any of the following forms:
-	*
-	*	f0: {f1: ..., f2: ..., f3: ...}
-	*	f0: {$operator:[operand1, operand2, ...]}
-	*
-	* @class Expression
-	* @namespace munge.pipeline.expressions
-	* @module munge
-	* @constructor
-	**/
+	 * A base class for all pipeline expressions; Performs common expressions within an Op.
+	 *
+	 * NOTE: An object expression can take any of the following forms:
+	 *
+	 *	f0: {f1: ..., f2: ..., f3: ...}
+	 *	f0: {$operator:[operand1, operand2, ...]}
+	 *
+	 * @class Expression
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
+	 * @constructor
+	 **/
 	var klass = module.exports = Expression = function Expression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 	}, base = Object, proto = klass.prototype = Object.create(base.prototype, {constructor:{value:klass}});
@@ -22,26 +23,26 @@ var Expression = module.exports = (function(){
 
 	// NESTED CLASSES
 	/**
-	* Reference to the `munge.pipeline.expressions.Expression.ObjectCtx` class
-	* @static
-	* @property ObjectCtx
-	**/
+	 * Reference to the `munge.pipeline.expressions.Expression.ObjectCtx` class
+	 * @static
+	 * @property ObjectCtx
+	 **/
 	var ObjectCtx = Expression.ObjectCtx = (function(){
 		// CONSTRUCTOR
 		/**
-		* Utility class for parseObject() below. isDocumentOk indicates that it is OK to use a Document in the current context.
-		*
-		* NOTE: deviation from Mongo code: accepts an `Object` of settings rather than a bitmask to help simplify the interface a little bit
-		*
-		* @class ObjectCtx
-		* @namespace munge.pipeline.expressions.Expression
-		* @module munge
-		* @constructor
-		* @param opts
-		*	@param [opts.isDocumentOk]	{Boolean}
-		*	@param [opts.isTopLevel]	{Boolean}
-		*	@param [opts.isInclusionOk]	{Boolean}
-		**/
+		 * Utility class for parseObject() below. isDocumentOk indicates that it is OK to use a Document in the current context.
+		 *
+		 * NOTE: deviation from Mongo code: accepts an `Object` of settings rather than a bitmask to help simplify the interface a little bit
+		 *
+		 * @class ObjectCtx
+		 * @namespace mungedb.aggregate.pipeline.expressions.Expression
+		 * @module mungedb-aggregate
+		 * @constructor
+		 * @param opts
+		 *	@param [opts.isDocumentOk]	{Boolean}
+		 *	@param [opts.isTopLevel]	{Boolean}
+		 *	@param [opts.isInclusionOk]	{Boolean}
+		 **/
 		var klass = function ObjectCtx(opts /*= {isDocumentOk:..., isTopLevel:..., isInclusionOk:...}*/){
 			if(!(opts instanceof Object && opts.constructor == Object)) throw new Error("opts is required and must be an Object containing named args");
 			for (var k in opts) { // assign all given opts to self so long as they were part of klass.prototype as undefined properties
@@ -58,24 +59,24 @@ var Expression = module.exports = (function(){
 	})();
 
 	/**
-	* Reference to the `munge.pipeline.expressions.Expression.OpDesc` class
-	* @static
-	* @property OpDesc
-	**/
+	 * Reference to the `munge.pipeline.expressions.Expression.OpDesc` class
+	 * @static
+	 * @property OpDesc
+	 **/
 	var OpDesc = Expression.OpDesc = (function(){
 		// CONSTRUCTOR
 		/**
-		* Decribes how and when to create an Op instance
-		*
-		* @class OpDesc
-		* @namespace munge.pipeline.expressions.Expression
-		* @module munge
-		* @constructor
-		* @param name
-		* @param factory
-		* @param flags
-		* @param argCount
-		**/
+		 * Decribes how and when to create an Op instance
+		 *
+		 * @class OpDesc
+		 * @namespace mungedb.aggregate.pipeline.expressions.Expression
+		 * @module mungedb-aggregate
+		 * @constructor
+		 * @param name
+		 * @param factory
+		 * @param flags
+		 * @param argCount
+		 **/
 		var klass = function OpDesc(name, factory, flags, argCount){
 			var firstArg = arguments[0];
 			if (firstArg instanceof Object && firstArg.constructor == Object) { //TODO: using this?
@@ -102,10 +103,10 @@ var Expression = module.exports = (function(){
 		proto.argCount = undefined;
 
 		/**
-		* internal `OpDesc#name` comparer
-		* @method cmp
-		* @param that the other `OpDesc` instance
-		**/
+		 * internal `OpDesc#name` comparer
+		 * @method cmp
+		 * @param that the other `OpDesc` instance
+		 **/
 		proto.cmp = function cmp(that) {
 			return this.name < that.name ? -1 : this.name > that.name ? 1 : 0;
 		};
@@ -114,10 +115,10 @@ var Expression = module.exports = (function(){
 	})();
 	// END OF NESTED CLASSES
 	/**
-	* @class Expression
-	* @namespace munge.pipeline.expressions
-	* @module munge
-	**/
+	 * @class Expression
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
+	 **/
 
 	var kinds = {
 		UNKNOWN: "UNKNOWN",
@@ -128,11 +129,11 @@ var Expression = module.exports = (function(){
 
 	// STATIC MEMBERS
 	/**
-	* Enumeration of comparison operators.  These are shared between a few expression implementations, so they are factored out here.
-	*
-	* @static
-	* @property CmpOp
-	**/
+	 * Enumeration of comparison operators.  These are shared between a few expression implementations, so they are factored out here.
+	 *
+	 * @static
+	 * @property CmpOp
+	 **/
 	klass.CmpOp = {
 		EQ: "$eq",		// return true for a == b, false otherwise
 		NE: "$ne",		// return true for a != b, false otherwise
@@ -151,11 +152,11 @@ var Expression = module.exports = (function(){
 
 	// DEFERRED DEPENDENCIES
 	/**
-	* Expressions, as exposed to users
-	*
-	* @static
-	* @property opMap
-	**/
+	 * Expressions, as exposed to users
+	 *
+	 * @static
+	 * @property opMap
+	 **/
 	process.nextTick(function(){ // Even though `opMap` is deferred, force it to load early rather than later to prevent even *more* potential silliness
 		Object.defineProperty(klass, "opMap", {value:klass.opMap});
 	});
@@ -202,19 +203,19 @@ var Expression = module.exports = (function(){
 	});
 
 	/**
-	* Parse an Object.  The object could represent a functional expression or a Document expression.
-	*
-	* An object expression can take any of the following forms:
-	*
-	*	f0: {f1: ..., f2: ..., f3: ...}
-	*	f0: {$operator:[operand1, operand2, ...]}
-	*
-	* @static
-	* @method parseObject
-	* @param obj	the element representing the object
-	* @param ctx	a MiniCtx representing the options above
-	* @returns the parsed Expression
-	**/
+	 * Parse an Object.  The object could represent a functional expression or a Document expression.
+	 *
+	 * An object expression can take any of the following forms:
+	 *
+	 *	f0: {f1: ..., f2: ..., f3: ...}
+	 *	f0: {$operator:[operand1, operand2, ...]}
+	 *
+	 * @static
+	 * @method parseObject
+	 * @param obj	the element representing the object
+	 * @param ctx	a MiniCtx representing the options above
+	 * @returns the parsed Expression
+	 **/
 	klass.parseObject = function parseObject(obj, ctx){
 		if(!(ctx instanceof ObjectCtx)) throw new Error("ctx must be ObjectCtx");
 		var kind = kinds.UNKNOWN,
@@ -272,14 +273,14 @@ var Expression = module.exports = (function(){
 	};
 
 	/**
-	* Parse a BSONElement Object which has already been determined to be functional expression.
-	*
-	* @static
-	* @method parseExpression
-	* @param opName	the name of the (prefix) operator
-	* @param obj	the BSONElement to parse
-	* @returns the parsed Expression
-	**/
+	 * Parse a BSONElement Object which has already been determined to be functional expression.
+	 *
+	 * @static
+	 * @method parseExpression
+	 * @param opName	the name of the (prefix) operator
+	 * @param obj	the BSONElement to parse
+	 * @returns the parsed Expression
+	 **/
 	klass.parseExpression = function parseExpression(opName, obj) {
 		// look for the specified operator
 		if (opName === "$const") return new ConstantExpression(obj); //TODO: createFromBsonElement was here, not needed since this isn't BSON?
@@ -313,12 +314,12 @@ var Expression = module.exports = (function(){
 	};
 
 	/**
-	* Parse a BSONElement which is an operand in an Expression.
-	*
-	* @static
-	* @param pBsonElement the expected operand's BSONElement
-	* @returns the parsed operand, as an Expression
-	**/
+	 * Parse a BSONElement which is an operand in an Expression.
+	 *
+	 * @static
+	 * @param pBsonElement the expected operand's BSONElement
+	 * @returns the parsed operand, as an Expression
+	 **/
 	klass.parseOperand = function parseOperand(obj){
 		var t = typeof(obj);
 		if (t === "string" && obj[0] == "$") { //if we got here, this is a field path expression
@@ -330,13 +331,13 @@ var Expression = module.exports = (function(){
 	};
 
 	/**
-	* Produce a field path string with the field prefix removed.
-	* Throws an error if the field prefix is not present.
-	*
-	* @static
-	* @param prefixedField the prefixed field
-	* @returns the field path with the prefix removed
-	**/
+	 * Produce a field path string with the field prefix removed.
+	 * Throws an error if the field prefix is not present.
+	 *
+	 * @static
+	 * @param prefixedField the prefixed field
+	 * @returns the field path with the prefix removed
+	 **/
 	klass.removeFieldPrefix = function removeFieldPrefix(prefixedField) {
 		if (prefixedField.indexOf("\0") != -1) throw new Error("field path must not contain embedded null characters; code 16419");
 		if (prefixedField[0] !== "$") throw new Error("field path references must be prefixed with a '$' ('" + prefixedField + "'); code 15982");
@@ -344,12 +345,12 @@ var Expression = module.exports = (function(){
 	};
 
 	/**
-	* returns the signe of a number
-	*
-	* @static
-	* @method signum
-	* @returns the sign of a number; -1, 1, or 0
-	**/
+	 * returns the signe of a number
+	 *
+	 * @static
+	 * @method signum
+	 * @returns the sign of a number; -1, 1, or 0
+	 **/
 	klass.signum = function signum(i) {
 		if (i < 0) return -1;
 		if (i > 0) return 1;
@@ -359,50 +360,50 @@ var Expression = module.exports = (function(){
 
 	// PROTOTYPE MEMBERS
 	/**
-	* Evaluate the Expression using the given document as input.
-	*
-	* @method evaluate
-	* @returns the computed value
-	**/
+	 * Evaluate the Expression using the given document as input.
+	 *
+	 * @method evaluate
+	 * @returns the computed value
+	 **/
 	proto.evaluate = function evaluate(obj) {
 		throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
 	};
 
 	/**
-	* Optimize the Expression.
-	*
-	* This provides an opportunity to do constant folding, or to collapse nested
-	*  operators that have the same precedence, such as $add, $and, or $or.
-	*
-	* The Expression should be replaced with the return value, which may or may
-	*  not be the same object.  In the case of constant folding, a computed
-	*  expression may be replaced by a constant.
-	*
-	* @method optimize
-	* @returns the optimized Expression
-	**/
+	 * Optimize the Expression.
+	 *
+	 * This provides an opportunity to do constant folding, or to collapse nested
+	 *  operators that have the same precedence, such as $add, $and, or $or.
+	 *
+	 * The Expression should be replaced with the return value, which may or may
+	 *  not be the same object.  In the case of constant folding, a computed
+	 *  expression may be replaced by a constant.
+	 *
+	 * @method optimize
+	 * @returns the optimized Expression
+	 **/
 	proto.optimize = function optimize() {
 		throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
 	};
 
 	/**
-	* Add this expression's field dependencies to the set Expressions are trees, so this is often recursive.
-	*
-	* Top-level ExpressionObject gets pointer to empty vector.
-	* If any other Expression is an ancestor, or in other cases where {a:1} inclusion objects aren't allowed, they get NULL.
-	*
-	* @method addDependencies
-	* @param deps	output parameter
-	* @param path	path to self if all ancestors are ExpressionObjects.
-	**/
+	 * Add this expression's field dependencies to the set Expressions are trees, so this is often recursive.
+	 *
+	 * Top-level ExpressionObject gets pointer to empty vector.
+	 * If any other Expression is an ancestor, or in other cases where {a:1} inclusion objects aren't allowed, they get NULL.
+	 *
+	 * @method addDependencies
+	 * @param deps	output parameter
+	 * @param path	path to self if all ancestors are ExpressionObjects.
+	 **/
 	proto.addDependencies = function addDependencies(deps, path) {
 		throw new Error("WAS NOT IMPLEMENTED BY INHERITOR!");
 	};
 
 	/**
-	* simple expressions are just inclusion exclusion as supported by ExpressionObject
-	* @method getIsSimple
-	**/
+	 * simple expressions are just inclusion exclusion as supported by ExpressionObject
+	 * @method getIsSimple
+	 **/
 	proto.getIsSimple = function getIsSimple() {
 		return false;
 	};

lib/pipeline/expressions/FieldPathExpression.js

@@ -1,15 +1,16 @@
+"use strict";
 var FieldPathExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
-	* Create a field path expression. Evaluation will extract the value associated with the given field path from the source document.
-	*
-	* @class FieldPathExpression
-	* @namespace munge.pipeline.expressions
-	* @module munge
-	* @extends munge.pipeline.expressions.Expression
-	* @constructor
-	* @param {String} fieldPath the field path string, without any leading document indicator
-	**/
+	 * Create a field path expression. Evaluation will extract the value associated with the given field path from the source document.
+	 *
+	 * @class FieldPathExpression
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
+	 * @extends munge.pipeline.expressions.Expression
+	 * @constructor
+	 * @param {String} fieldPath the field path string, without any leading document indicator
+	 **/
 	var klass = function FieldPathExpression(path){
 		if(arguments.length !== 1) throw new Error("args expected: path");
 		this.path = new FieldPath(path);
@@ -24,19 +25,19 @@ var FieldPathExpression = module.exports = (function(){
 	};
 
 	/**
-	* Internal implementation of evaluate(), used recursively.
-	*
-	* The internal implementation doesn't just use a loop because of the
-	* possibility that we need to skip over an array.  If the path is "a.b.c",
-	* and a is an array, then we fan out from there, and traverse "b.c" for each
-	* element of a:[...].  This requires that a be an array of objects in order
-	* to navigate more deeply.
-	*
-	* @param index current path field index to extract
-	* @param pathLength maximum number of fields on field path
-	* @param pDocument current document traversed to (not the top-level one)
-	* @returns the field found; could be an array
-	**/
+	 * Internal implementation of evaluate(), used recursively.
+	 *
+	 * The internal implementation doesn't just use a loop because of the
+	 * possibility that we need to skip over an array.  If the path is "a.b.c",
+	 * and a is an array, then we fan out from there, and traverse "b.c" for each
+	 * element of a:[...].  This requires that a be an array of objects in order
+	 * to navigate more deeply.
+	 *
+	 * @param index current path field index to extract
+	 * @param pathLength maximum number of fields on field path
+	 * @param pDocument current document traversed to (not the top-level one)
+	 * @returns the field found; could be an array
+	 **/
 	proto._evaluatePath = function _evaluatePath(obj, i, len){
 		var fieldName = this.path.fields[i],
 			field = obj[fieldName]; // It is possible we won't have an obj (document) and we need to not fail if that is the case

lib/pipeline/expressions/FieldRangeExpression.js

@@ -1,29 +1,30 @@
+"use strict";
 var FieldRangeExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
-	* Create a field range expression.
-	*
-	* Field ranges are meant to match up with classic Matcher semantics, and therefore are conjunctions.
-	*
-	* For example, these appear in mongo shell predicates in one of these forms:
-	*	{ a : C } -> (a == C) // degenerate "point" range
-	*	{ a : { $lt : C } } -> (a < C) // open range
-	*	{ a : { $gt : C1, $lte : C2 } } -> ((a > C1) && (a <= C2)) // closed
-	*
-	* When initially created, a field range only includes one end of the range.  Additional points may be added via intersect().
-	*
-	* Note that NE and CMP are not supported.
-	*
-	* @class FieldRangeExpression
-	* @namespace munge.pipeline.expressions
-	* @module munge
-	* @extends munge.pipeline.expressions.Expression
-	* @constructor
-	* @param pathExpr the field path for extracting the field value
-	* @param cmpOp the comparison operator
-	* @param value the value to compare against
-	* @returns the newly created field range expression
-	**/
+	 * Create a field range expression.
+	 *
+	 * Field ranges are meant to match up with classic Matcher semantics, and therefore are conjunctions.
+	 *
+	 * For example, these appear in mongo shell predicates in one of these forms:
+	 *	{ a : C } -> (a == C) // degenerate "point" range
+	 *	{ a : { $lt : C } } -> (a < C) // open range
+	 *	{ a : { $gt : C1, $lte : C2 } } -> ((a > C1) && (a <= C2)) // closed
+	 *
+	 * When initially created, a field range only includes one end of the range.  Additional points may be added via intersect().
+	 *
+	 * Note that NE and CMP are not supported.
+	 *
+	 * @class FieldRangeExpression
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
+	 * @extends munge.pipeline.expressions.Expression
+	 * @constructor
+	 * @param pathExpr the field path for extracting the field value
+	 * @param cmpOp the comparison operator
+	 * @param value the value to compare against
+	 * @returns the newly created field range expression
+	 **/
 	var klass = function FieldRangeExpression(pathExpr, cmpOp, value){
 		if(arguments.length !== 3) throw new Error("args expected: pathExpr, cmpOp, and value");
 		this.pathExpr = pathExpr;
@@ -37,9 +38,9 @@ var FieldRangeExpression = module.exports = (function(){
 	// NESTED CLASSES
 	var Range = (function(){
 		/**
-		* create a new Range; opts is either {cmpOp:..., value:...} or {bottom:..., isBottomOpen:..., top:..., isTopOpen:...}
-		* @private
-		**/
+		 * create a new Range; opts is either {cmpOp:..., value:...} or {bottom:..., isBottomOpen:..., top:..., isTopOpen:...}
+		 * @private
+		 **/
 		var klass = function Range(opts){
 			this.isBottomOpen = this.isTopOpen = false;
 			this.bottom = this.top = undefined;
@@ -155,18 +156,19 @@ var FieldRangeExpression = module.exports = (function(){
 	};
 
 	/**
-	* Add an intersecting range.
-	*
-	* This can be done any number of times after creation.  The range is
-	* internally optimized for each new addition.  If the new intersection
-	* extends or reduces the values within the range, the internal
-	* representation is adjusted to reflect that.
-	*
-	* Note that NE and CMP are not supported.
-	*
-	* @param cmpOp the comparison operator
-	* @param pValue the value to compare against
-	**/
+	 * Add an intersecting range.
+	 *
+	 * This can be done any number of times after creation.  The range is
+	 * internally optimized for each new addition.  If the new intersection
+	 * extends or reduces the values within the range, the internal
+	 * representation is adjusted to reflect that.
+	 *
+	 * Note that NE and CMP are not supported.
+	 *
+	 * @method intersect
+	 * @param cmpOp the comparison operator
+	 * @param pValue the value to compare against
+	 **/
 	proto.intersect = function intersect(cmpOp, value){
 		this.range = this.range.intersect(new Range({cmpOp:cmpOp, value:value}));
 	};

lib/pipeline/expressions/HourExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var HourExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -5,10 +6,10 @@ var HourExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class HourExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function HourExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -25,8 +26,9 @@ var HourExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Takes a date and returns the hour between 0 and 23. 
-	**/
+	 * Takes a date and returns the hour between 0 and 23. 
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc);

lib/pipeline/expressions/IfNullExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var IfNullExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
@@ -5,10 +6,10 @@ var IfNullExpression = module.exports = (function(){
 	 *
 	 * @see evaluate
 	 * @class IfNullExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function IfNullExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -25,8 +26,9 @@ var IfNullExpression = module.exports = (function(){
 	};
 
 	/**
-	* Use the $ifNull operator with the following syntax: { $ifNull: [ <expression>, <replacement-if-null> ] }
-	**/
+	 * Use the $ifNull operator with the following syntax: { $ifNull: [ <expression>, <replacement-if-null> ] }
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(2);
 		var left = this.operands[0].evaluate(doc);

lib/pipeline/expressions/IndexOfExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var IndexOfExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
@@ -5,10 +6,10 @@ var IndexOfExpression = module.exports = (function(){
 	 *
 	 * @see evaluate
 	 * @class IndexOfExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function IndexOfExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -25,9 +26,9 @@ var IndexOfExpression = module.exports = (function(){
 	};
 
 	/**
-	* Use the $indexOf operator with the following syntax: { $indexOf: [ <needle>, <haystack> ] }
-	* @method evaluate
-	**/
+	 * Use the $indexOf operator with the following syntax: { $indexOf: [ <needle>, <haystack> ] }
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(2);
 

lib/pipeline/expressions/MinuteExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var MinuteExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -5,10 +6,10 @@ var MinuteExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class MinuteExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function MinuteExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -25,8 +26,9 @@ var MinuteExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Takes a date and returns the minute between 0 and 59. 
-	**/
+	 * Takes a date and returns the minute between 0 and 59. 
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc);

lib/pipeline/expressions/ModExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var ModExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -5,10 +6,10 @@ var ModExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class ModExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function ModExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -28,8 +29,9 @@ var ModExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Takes an array that contains a pair of numbers and returns the remainder of the first number divided by the second number. 
-	**/
+	 * Takes an array that contains a pair of numbers and returns the remainder of the first number divided by the second number. 
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(2);
 		var left = this.operands[0].evaluate(doc),

lib/pipeline/expressions/MonthExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var MonthExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -5,10 +6,10 @@ var MonthExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class MonthExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function MonthExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -25,9 +26,9 @@ var MonthExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes a date and returns the month as a number between 1 and 12.
-	* @method evaluate
-	**/
+	 * Takes a date and returns the month as a number between 1 and 12.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc);

lib/pipeline/expressions/MultiplyExpression.js

@@ -1,3 +1,4 @@
+"use strict";
 var MultiplyExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
@@ -5,10 +6,10 @@ var MultiplyExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class MultiplyExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function MultiplyExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -23,8 +24,9 @@ var MultiplyExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Takes an array of one or more numbers and multiples them, returning the resulting product. 
-	**/
+	 * Takes an array of one or more numbers and multiples them, returning the resulting product. 
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		var product = 1;
 		for(var i = 0, n = this.operands.length; i < n; ++i){

lib/pipeline/expressions/NaryExpression.js

@@ -1,14 +1,14 @@
 var NaryExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
-	* The base class for all n-ary `Expression`s
-	*
-	* @class NaryExpression
-	* @namespace munge.pipeline.expressions
-	* @module munge
-	* @extends munge.pipeline.expressions.Expression
-	* @constructor
-	**/
+	 * The base class for all n-ary `Expression`s
+	 *
+	 * @class NaryExpression
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
+	 * @extends munge.pipeline.expressions.Expression
+	 * @constructor
+	 **/
 	var klass = module.exports = function NaryExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		this.operands = [];
@@ -92,11 +92,11 @@ var NaryExpression = module.exports = (function(){
 	};
 
 	/**
-	* Add an operand to the n-ary expression.
-	*
-	* @method addOperand
-	* @param pExpression the expression to add
-	**/
+	 * Add an operand to the n-ary expression.
+	 *
+	 * @method addOperand
+	 * @param pExpression the expression to add
+	 **/
 	proto.addOperand = function addOperand(expr) {
 		this.operands.push(expr);
 	};
@@ -117,23 +117,23 @@ var NaryExpression = module.exports = (function(){
 //TODO: proto.addToBsonArray  ?
 
 	/**
-	* Checks the current size of vpOperand; if the size equal to or greater than maxArgs, fires a user assertion indicating that this operator cannot have this many arguments.
-	* The equal is there because this is intended to be used in addOperand() to check for the limit *before* adding the requested argument.
-	*
-	* @method checkArgLimit
-	* @param maxArgs the maximum number of arguments the operator accepts
-	**/
+	 * Checks the current size of vpOperand; if the size equal to or greater than maxArgs, fires a user assertion indicating that this operator cannot have this many arguments.
+	 * The equal is there because this is intended to be used in addOperand() to check for the limit *before* adding the requested argument.
+	 *
+	 * @method checkArgLimit
+	 * @param maxArgs the maximum number of arguments the operator accepts
+	 **/
 	proto.checkArgLimit = function checkArgLimit(maxArgs) {
 		if (this.operands.length >= maxArgs) throw new Error(this.getOpName() + " only takes " + maxArgs + " operand" + (maxArgs == 1 ? "" : "s") + "; code 15993");
 	};
 
 	/**
-	* Checks the current size of vpOperand; if the size is not equal to reqArgs, fires a user assertion indicating that this must have exactly reqArgs arguments.
-	* This is meant to be used in evaluate(), *before* the evaluation takes place.
-	*
-	* @method checkArgCount
-	* @param reqArgs the number of arguments this operator requires
-	**/
+	 * Checks the current size of vpOperand; if the size is not equal to reqArgs, fires a user assertion indicating that this must have exactly reqArgs arguments.
+	 * This is meant to be used in evaluate(), *before* the evaluation takes place.
+	 *
+	 * @method checkArgCount
+	 * @param reqArgs the number of arguments this operator requires
+	 **/
 	proto.checkArgCount = function checkArgCount(reqArgs) {
 		if (this.operands.length !== reqArgs) throw new Error(this.getOpName() + ":  insufficient operands; " + reqArgs + " required, only got " + this.operands.length + "; code 15997");
 	};

lib/pipeline/expressions/NotExpression.js

@@ -1,14 +1,14 @@
 var NotExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/** 
-	* An $not pipeline expression. 
-	*
-	* @see evaluate 
+	 * An $not pipeline expression. 
+	 *
+	 * @see evaluate 
 	 * @class NotExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function NotExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -28,8 +28,9 @@ var NotExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Returns the boolean opposite value passed to it. When passed a true value, $not returns false; when passed a false value, $not returns true. 
-	**/
+	 * Returns the boolean opposite value passed to it. When passed a true value, $not returns false; when passed a false value, $not returns true. 
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(1);
 		var op = this.operands[0].evaluate(doc);

lib/pipeline/expressions/ObjectExpression.js

@@ -1,14 +1,14 @@
 var ObjectExpression = module.exports = (function(){
 	// CONSTRUCTOR
 	/**
-	* Create an empty expression.  Until fields are added, this will evaluate to an empty document (object).
-	*
-	* @class ObjectExpression
-	* @namespace munge.pipeline.expressions
-	* @module munge
-	* @extends munge.pipeline.expressions.Expression
-	* @constructor
-	**/
+	 * Create an empty expression.  Until fields are added, this will evaluate to an empty document (object).
+	 *
+	 * @class ObjectExpression
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
+	 * @extends munge.pipeline.expressions.Expression
+	 * @constructor
+	 **/
 	var klass = function ObjectExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		this.excludeId = false;	/// <Boolean> for if _id is to be excluded
@@ -22,33 +22,33 @@ var ObjectExpression = module.exports = (function(){
 
 	// INSTANCE VARIABLES
 	/**
-	* <Boolean> for if _id is to be excluded
-	*
-	* @property excludeId
-	**/
+	 * <Boolean> for if _id is to be excluded
+	 *
+	 * @property excludeId
+	 **/
 	proto.excludeId = undefined;
 
 	/**
-	* <Object<Expression>> mapping from fieldname to Expression to generate the value NULL expression means include from source document
-	**/
+	 * <Object<Expression>> mapping from fieldname to Expression to generate the value NULL expression means include from source document
+	 **/
 	proto._expressions = undefined;
 
 	//TODO: might be able to completely ditch _order everywhere in here since `Object`s are mostly ordered anyhow but need to come back and revisit that later
 	/**
-	* <Array<String>> this is used to maintain order for generated fields not in the source document
-	**/
+	 * <Array<String>> this is used to maintain order for generated fields not in the source document
+	 **/
 	proto._order = [];
 
 
 	// PROTOTYPE MEMBERS
 
 	/**
-	* evaluate(), but return a Document instead of a Value-wrapped Document.
-	*
-	* @method evaluateDocument
-	* @param pDocument the input Document
-	* @returns the result document
-	**/
+	 * evaluate(), but return a Document instead of a Value-wrapped Document.
+	 *
+	 * @method evaluateDocument
+	 * @param pDocument the input Document
+	 * @returns the result document
+	 **/
 	proto.evaluateDocument = function evaluateDocument(doc) {
 		// create and populate the result
 		var pResult = {};
@@ -105,13 +105,13 @@ var ObjectExpression = module.exports = (function(){
 	};
 
 	/**
-	* evaluate(), but add the evaluated fields to a given document instead of creating a new one.
-	*
-	* @method addToDocument
-	* @param pResult the Document to add the evaluated expressions to
-	* @param pDocument the input Document for this level
-	* @param rootDoc the root of the whole input document
-	**/
+	 * evaluate(), but add the evaluated fields to a given document instead of creating a new one.
+	 *
+	 * @method addToDocument
+	 * @param pResult the Document to add the evaluated expressions to
+	 * @param pDocument the input Document for this level
+	 * @param rootDoc the root of the whole input document
+	 **/
 	proto.addToDocument = function addToDocument(pResult, pDocument, rootDoc){
 		var atRoot = (pDocument === rootDoc);
 
@@ -199,22 +199,22 @@ var ObjectExpression = module.exports = (function(){
 	};
 
 	/**
-	* estimated number of fields that will be output
-	*
-	* @method getSizeHint
-	**/
+	 * estimated number of fields that will be output
+	 *
+	 * @method getSizeHint
+	 **/
 	proto.getSizeHint = function getSizeHint(){
 		// Note: this can overestimate, but that is better than underestimating
 		return Object.getOwnPropertyNames(this._expressions).length + (this.excludeId ? 0 : 1);
 	};
 
 	/**
-	* Add a field to the document expression.
-	*
-	* @method addField
-	* @param fieldPath the path the evaluated expression will have in the result Document
-	* @param pExpression the expression to evaluate obtain this field's Value in the result Document
-	**/
+	 * Add a field to the document expression.
+	 *
+	 * @method addField
+	 * @param fieldPath the path the evaluated expression will have in the result Document
+	 * @param pExpression the expression to evaluate obtain this field's Value in the result Document
+	 **/
 	proto.addField = function addField(fieldPath, pExpression){
 		if(!(fieldPath instanceof FieldPath)) fieldPath = new FieldPath(fieldPath);
 		var fieldPart = fieldPath.fields[0],
@@ -253,23 +253,23 @@ var ObjectExpression = module.exports = (function(){
 	};
 
 	/**
-	* Add a field path to the set of those to be included.
-	*
-	* Note that including a nested field implies including everything on the path leading down to it.
-	*
-	* @method includePath
-	* @param fieldPath the name of the field to be included
-	**/
+	 * Add a field path to the set of those to be included.
+	 *
+	 * Note that including a nested field implies including everything on the path leading down to it.
+	 *
+	 * @method includePath
+	 * @param fieldPath the name of the field to be included
+	 **/
 	proto.includePath = function includePath(path){
 		this.addField(path, undefined);
 	};
 
 	/**
-	* Get a count of the added fields.
-	*
-	* @method getFieldCount
-	* @returns how many fields have been added
-	**/
+	 * Get a count of the added fields.
+	 *
+	 * @method getFieldCount
+	 * @returns how many fields have been added
+	 **/
 	proto.getFieldCount = function getFieldCount(){
 		return Object.getOwnPropertyNames(this._expressions).length;
 	};

lib/pipeline/expressions/OrExpression.js

@@ -5,10 +5,10 @@ var OrExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class OrExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function OrExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -25,8 +25,8 @@ var OrExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Takes an array of one or more values and returns true if any of the values in the array are true. Otherwise $or returns false. 
-	**/
+	 * Takes an array of one or more values and returns true if any of the values in the array are true. Otherwise $or returns false. 
+	 **/
 	proto.evaluate = function evaluate(doc){
 		for(var i = 0, n = this.operands.length; i < n; ++i){
 			var value = this.operands[i].evaluate(doc);

lib/pipeline/expressions/SecondExpression.js

@@ -5,10 +5,10 @@ var SecondExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class SecondExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function SecondExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -25,9 +25,9 @@ var SecondExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes a date and returns the second between 0 and 59, but can be 60 to account for leap seconds.
-	* @method evaluate
-	**/
+	 * Takes a date and returns the second between 0 and 59, but can be 60 to account for leap seconds.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc){
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc);

lib/pipeline/expressions/StrcasecmpExpression.js

@@ -5,8 +5,8 @@ var StrcasecmpExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class StrcasecmpExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
 	**/
 	var klass = function StrcasecmpExpression(){

lib/pipeline/expressions/SubstrExpression.js

@@ -5,8 +5,8 @@ var SubstrExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class SubstrExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
 	**/
 	var klass = function SubstrExpression(){

lib/pipeline/expressions/SubtractExpression.js

@@ -5,8 +5,8 @@ var SubtractExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class SubtractExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
 	**/
 	var klass = function SubtractExpression(){

lib/pipeline/expressions/ToLowerExpression.js

@@ -5,8 +5,8 @@ var ToLowerExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class ToLowerExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
 	**/
 	var klass = function ToLowerExpression(){

lib/pipeline/expressions/ToUpperExpression.js

@@ -5,8 +5,8 @@ var ToUpperExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class ToUpperExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
 	**/
 	var klass = function ToUpperExpression(){

lib/pipeline/expressions/WeekExpression.js

@@ -5,10 +5,10 @@ var WeekExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class WeekExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function WeekExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -29,11 +29,12 @@ var WeekExpression = module.exports = (function(){
 	};
 
 	/** 
-	* Takes a date and returns the week of the year as a number between 0 and 53. 
-	* Weeks begin on Sundays, and week 1 begins with the first Sunday of the year. 
-	* Days preceding the first Sunday of the year are in week 0. 
-	* This behavior is the same as the “%U” operator to the strftime standard library function.
-	**/
+	 * Takes a date and returns the week of the year as a number between 0 and 53. 
+	 * Weeks begin on Sundays, and week 1 begins with the first Sunday of the year. 
+	 * Days preceding the first Sunday of the year are in week 0. 
+	 * This behavior is the same as the “%U” operator to the strftime standard library function.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc) {
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc),

lib/pipeline/expressions/YearExpression.js

@@ -5,10 +5,10 @@ var YearExpression = module.exports = (function(){
 	 *
 	 * @see evaluate 
 	 * @class YearExpression
-	 * @namespace munge.pipeline.expressions
-	 * @module munge
+	 * @namespace mungedb.aggregate.pipeline.expressions
+	 * @module mungedb-aggregate
 	 * @constructor
-	**/
+	 **/
 	var klass = function YearExpression(){
 		if(arguments.length !== 0) throw new Error("zero args expected");
 		base.call(this);
@@ -29,9 +29,9 @@ var YearExpression = module.exports = (function(){
 	};
 
 	/**
-	* Takes a date and returns the full year.
-	* @method evaluate
-	**/
+	 * Takes a date and returns the full year.
+	 * @method evaluate
+	 **/
 	proto.evaluate = function evaluate(doc) {
 		this.checkArgCount(1);
 		var date = this.operands[0].evaluate(doc);

munge.js

@@ -1 +0,0 @@
-module.exports = require("./lib/munge");

mungedb-aggregate.js

@@ -0,0 +1 @@
+module.exports = require("./lib/");

package.json

@@ -10,7 +10,7 @@
 		"Spencer Rathbun <SRathbun@riverainc.com>",
 		"Charles Ezell <CEzell@riverainc.com>"
 	],
-	"main": "./munge.js",
+	"main": "./mungedb-aggregate.js",
 	"scripts": {
 		"test": "npm_scripts/test/test.sh"
 	},

test/lib/Cursor.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	Cursor = require("../../lib/Cursor");
 
@@ -89,4 +90,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();

test/lib/munge.js → test/lib/aggregate.js

@@ -1,20 +1,21 @@
+"use strict";
 var assert = require("assert"),
-	munge = require("../../");
+	aggregate = require("../../");
 
 module.exports = {
 
-	"munge": {
+	"aggregate": {
 
 		"should be able to use an empty pipeline (no-op)": function(){
 			var i = [1, 2, 3],
 				p = [],
 				e = [1, 2, 3],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 
 
@@ -22,47 +23,47 @@ module.exports = {
 			var i = [{_id:0}, {_id:1}, {_id:2}, {_id:3}, {_id:4}, {_id:5}],
 				p = [{$limit:2}],
 				e = [{_id:0}, {_id:1}],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 
 		"should be able to use a $match operator": function(){
 			var i = [{_id:0, e:1}, {_id:1, e:0}, {_id:2, e:1}, {_id:3, e:0}, {_id:4, e:1}, {_id:5, e:0}],
 				p = [{$match:{e:1}}],
 				e = [{_id:0, e:1}, {_id:2, e:1}, {_id:4, e:1}],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 		
 		"should be able to use a $skip operator": function(){
 			var i = [{_id:0}, {_id:1}, {_id:2}, {_id:3}, {_id:4}, {_id:5}],
 				p = [{$skip:2}, {$skip:1}],	//testing w/ 2 ensures independent state variables
 				e = [{_id:3}, {_id:4}, {_id:5}],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 		"should be able to use a $skip and then a $limit operator together in the same pipeline": function(){
 			var i = [{_id:0, e:1}, {_id:1, e:0}, {_id:2, e:1}, {_id:3, e:0}, {_id:4, e:1}, {_id:5, e:0}],
 				p = [{$skip:2}, {$limit:1}],
 				e = [{_id:2, e:1}],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 
 		"should be able to construct an instance with $unwind operators properly": function(){
@@ -83,12 +84,12 @@ module.exports = {
 					{_id:0,nodes:{one:[1,1],two:22}},
 					{_id:1,nodes:{two:22,three:[333]}}
 				],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 
 
@@ -101,11 +102,11 @@ module.exports = {
 						//TODO: high level test of all other expression operators
 					}}],
 				e = [{_id:0, e:1, b:"not two", a:2}, {_id:2, e:2, b:"two", a:4}, {_id:4, e:3, b:"not two", a:6}],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.deepEqual(munger(i), e, "Reuse of munger should yield the same results!");
-			assert.deepEqual(munge(p, i), e, "Alternate use of munge should yield the same results!");
+			assert.deepEqual(aggregater(i), e, "Reuse of aggregater should yield the same results!");
+			assert.deepEqual(aggregate(p, i), e, "Alternate use of aggregate should yield the same results!");
 		},
 		
 		
@@ -117,11 +118,11 @@ module.exports = {
 						//TODO: high level test of all other expression operators
 					}}],
 				e = [{e:1}, {e:2}, {e:3}],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.deepEqual(munger(i), e, "Reuse of munger should yield the same results!");
-			assert.deepEqual(munge(p, i), e, "Alternate use of munge should yield the same results!");
+			assert.deepEqual(aggregater(i), e, "Reuse of aggregater should yield the same results!");
+			assert.deepEqual(aggregate(p, i), e, "Alternate use of aggregate should yield the same results!");
 		},
 
 		"should be able to construct an instance with $sort operators properly (ascending)": function(){
@@ -135,12 +136,12 @@ module.exports = {
 						{_id:null}, {_id:NaN},
 						{_id:-273.15}, {_id:1}, {_id:3.14159}, {_id:11}, {_id:42}
 					],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			//assert.deepEqual(a, e); //does not work with NaN
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 		"should be able to construct an instance with $group operators properly": function(){
 			var i = [
@@ -190,12 +191,12 @@ module.exports = {
 							push_b:["a", "b", "b", "c"]
 						}
 					],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			//assert.deepEqual(a, e); //does not work with NaN
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 
 		"should be able to use a $split operator": function(){
@@ -203,12 +204,12 @@ module.exports = {
 				p = [{$match:{_id:0}}, {$split:{aX2:[{$project:{a:{$multiply:["$a", 2]}}}], aX3:[{$project:{a:{$multiply:["$a", 3]}}}]}}, {$unwind:"$aX2"}, {$unwind:"$aX3"}],
 				//e = [{aX2:[{_id:0, a:2}], aX3:[{_id:0, a:3}]}],
 				e = [{aX2:{_id:0, a:2}, aX3:{_id:0, a:3}}],
-				munger = munge(p),
-				a = munger(i);
+				aggregater = aggregate(p),
+				a = aggregater(i);
 			assert.equal(JSON.stringify(a), JSON.stringify(e), "Unexpected value!");
 			assert.deepEqual(a, e, "Unexpected value (not deepEqual)!");
-			assert.equal(JSON.stringify(munger(i)), JSON.stringify(e), "Reuse of munger should yield the same results!");
-			assert.equal(JSON.stringify(munge(p, i)), JSON.stringify(e), "Alternate use of munge should yield the same results!");
+			assert.equal(JSON.stringify(aggregater(i)), JSON.stringify(e), "Reuse of aggregater should yield the same results!");
+			assert.equal(JSON.stringify(aggregate(p, i)), JSON.stringify(e), "Alternate use of aggregate should yield the same results!");
 		},
 
 	}

test/lib/pipeline/FieldPath.js

@@ -1,6 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	FieldPath = require("../../../lib/pipeline/FieldPath");
 
+
 module.exports = {
 
 	"FieldPath": {

test/lib/pipeline/Pipeline.js

@@ -1,8 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	Pipeline = require("../../../lib/pipeline/Pipeline");
 
 
-
 module.exports = {
 
 	"Pipeline": {
@@ -118,4 +118,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();

test/lib/pipeline/PipelineD.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	Pipeline = require("../../../lib/pipeline/Pipeline"),
 	PipelineD = require("../../../lib/pipeline/PipelineD"),
@@ -5,7 +6,6 @@ var assert = require("assert"),
 	CursorDocumentSource = require('../../../lib/pipeline/documentSources/CursorDocumentSource');
 
 
-
 module.exports = {
 
 	"Pipeline": {
@@ -105,4 +105,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();

test/lib/pipeline/accumulators/AddToSetAccumulator.js

@@ -1,14 +1,17 @@
+"use strict";
 var assert = require("assert"),
 	AddToSetAccumulator = require("../../../../lib/pipeline/accumulators/AddToSetAccumulator"),
 	ConstantExpression = require("../../../../lib/pipeline/expressions/ConstantExpression"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
 
+
 var createAccumulator = function createAccumulator() {
 	var myAccumulator = new AddToSetAccumulator();
 	myAccumulator.addOperand(new FieldPathExpression("b") );
 	return myAccumulator;
 };
 
+
 //TODO: refactor these test cases using Expression.parseOperand() or something because these could be a whole lot cleaner...
 module.exports = {
 

test/lib/pipeline/accumulators/AvgAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	AvgAccumulator = require("../../../../lib/pipeline/accumulators/AvgAccumulator"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
@@ -114,4 +115,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/accumulators/FirstAccumulator.js

@@ -1,13 +1,16 @@
+"use strict";
 var assert = require("assert"),
 	FirstAccumulator = require("../../../../lib/pipeline/accumulators/FirstAccumulator"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
 
+
 function createAccumulator(){
 	var firstAccumulator = new FirstAccumulator();
 	firstAccumulator.addOperand(new FieldPathExpression("a") );
 	return firstAccumulator;
 }
 
+
 module.exports = {
 
 	"FirstAccumulator": {
@@ -78,4 +81,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/accumulators/LastAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	LastAccumulator = require("../../../../lib/pipeline/accumulators/LastAccumulator"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");

test/lib/pipeline/accumulators/MaxAccumulator.js

@@ -1,13 +1,16 @@
+"use strict";
 var assert = require("assert"),
 	MaxAccumulator = require("../../../../lib/pipeline/accumulators/MinMaxAccumulator"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
 
+
 function createAccumulator(){
 	var maxAccumulator = MaxAccumulator.createMax();
 	maxAccumulator.addOperand(new FieldPathExpression("a") );
 	return maxAccumulator;
 }
 
+
 module.exports = {
 
 	"MaxAccumulator": {
@@ -77,4 +80,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/accumulators/MinAccumulator.js

@@ -1,13 +1,16 @@
+"use strict";
 var assert = require("assert"),
 	MinAccumulator = require("../../../../lib/pipeline/accumulators/MinMaxAccumulator"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
 
+
 function createAccumulator(){
 	var minAccumulator = MinAccumulator.createMin();
 	minAccumulator.addOperand(new FieldPathExpression("a") );
 	return minAccumulator;
 }
 
+
 module.exports = {
 
 	"MinAccumulator": {
@@ -77,4 +80,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/accumulators/PushAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	PushAccumulator = require("../../../../lib/pipeline/accumulators/PushAccumulator"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
@@ -68,5 +69,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-
-

test/lib/pipeline/accumulators/SingleValueAccumulator.js

@@ -1,6 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	SingleValueAccumulator = require("../../../../lib/pipeline/accumulators/SingleValueAccumulator");
 
+
 //TODO: refactor these test cases using Expression.parseOperand() or something because these could be a whole lot cleaner...
 module.exports = {
 

test/lib/pipeline/accumulators/SumAccumulator.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	SumAccumulator = require("../../../../lib/pipeline/accumulators/SumAccumulator"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
@@ -114,4 +115,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/documentSources/CursorDocumentSource.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),
 	Cursor = require("../../../../lib/Cursor");
 
+
 module.exports = {
 
 	"CursorDocumentSource": {
@@ -95,4 +97,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run();

test/lib/pipeline/documentSources/FilterBaseDocumentSource.js

@@ -1,11 +1,7 @@
+"use strict";
 var assert = require("assert"),
 	FilterBaseDocumentSource = require("../../../../lib/pipeline/documentSources/FilterBaseDocumentSource");
 
-function createSource(){
-	var fbds = new FilterBaseDocumentSource();
-	fbds.addOperand(new FieldPathExpression("a") );
-	return fbds;
-}
 
 /**
  * none of the rest of this class can be tested, since all the methods depend on 
@@ -53,4 +49,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/documentSources/GroupDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),
 	Cursor = require("../../../../lib/Cursor"),
@@ -32,9 +33,9 @@ function assertExpectedResult(args) {
 				GroupDocumentSource.createFromJson(args.spec);
 			});
 	}
-
 }
 
+
 module.exports = {
 
 	"GroupDocumentSource": {
@@ -192,5 +193,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-
-

test/lib/pipeline/documentSources/LimitDocumentSource.js

@@ -1,6 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	LimitDocumentSource = require("../../../../lib/pipeline/documentSources/LimitDocumentSource");
 
+
 module.exports = {
 
 	"LimitDocumentSource": {
@@ -157,4 +159,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/documentSources/MatchDocumentSource.js

@@ -1,6 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	MatchDocumentSource = require("../../../../lib/pipeline/documentSources/MatchDocumentSource");
 
+
 module.exports = {
 
 	"MatchDocumentSource": {
@@ -72,4 +74,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/documentSources/ProjectDocumentSource.js

@@ -1,9 +1,10 @@
-
+"use strict";
 var assert = require("assert"),
-DocumentSource = require("../../../../lib/pipeline/documentSources/DocumentSource"),
-ProjectDocumentSource = require("../../../../lib/pipeline/documentSources/ProjectDocumentSource"),
-CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),
-Cursor = require("../../../../lib/Cursor");
+	DocumentSource = require("../../../../lib/pipeline/documentSources/DocumentSource"),
+	ProjectDocumentSource = require("../../../../lib/pipeline/documentSources/ProjectDocumentSource"),
+	CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),
+	Cursor = require("../../../../lib/Cursor");
+
 
 //HELPERS
 var assertExhausted = function assertExhausted(pds) {
@@ -33,6 +34,7 @@ var createProject = function createProject(projection) {
     return project;
 };
 
+
 //TESTS
 module.exports = {
 

test/lib/pipeline/documentSources/SkipDocumentSource.js

@@ -1,6 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	SkipDocumentSource = require("../../../../lib/pipeline/documentSources/SkipDocumentSource");
 
+
 module.exports = {
 
 	"SkipDocumentSource": {
@@ -155,4 +157,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/documentSources/SortDocumentSource.js

@@ -1,9 +1,11 @@
+"use strict";
 var assert = require("assert"),
 	SortDocumentSource = require("../../../../lib/pipeline/documentSources/SortDocumentSource"),
 	CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),
 	Cursor = require("../../../../lib/Cursor"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
 
+
 module.exports = {
 
 	"SortDocumentSource": {
@@ -347,4 +349,3 @@ module.exports = {
 };
 
 if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
-

test/lib/pipeline/documentSources/SplitDocumentSource.js

@@ -1,3 +1,4 @@
+"use strict";
 var assert = require("assert"),
 	SplitDocumentSource = require("../../../../lib/pipeline/documentSources/SplitDocumentSource"),
 	CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),

test/lib/pipeline/documentSources/UnwindDocumentSource.js

@@ -1,9 +1,10 @@
-
+"use strict";
 var assert = require("assert"),
-DocumentSource = require("../../../../lib/pipeline/documentSources/DocumentSource"),
-UnwindDocumentSource = require("../../../../lib/pipeline/documentSources/UnwindDocumentSource"),
-CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),
-Cursor = require("../../../../lib/Cursor");
+	DocumentSource = require("../../../../lib/pipeline/documentSources/DocumentSource"),
+	UnwindDocumentSource = require("../../../../lib/pipeline/documentSources/UnwindDocumentSource"),
+	CursorDocumentSource = require("../../../../lib/pipeline/documentSources/CursorDocumentSource"),
+	Cursor = require("../../../../lib/Cursor");
+
 
 //HELPERS
 var assertExhausted = function assertExhausted(pds) {
@@ -71,6 +72,7 @@ var throwsException = function throwsException(data, path, expectedResults){
 	});
 };
 
+
 //TESTS
 module.exports = {
 

test/lib/pipeline/expressions/AddExpression.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	AddExpression = require("../../../../lib/pipeline/expressions/AddExpression"),
 	ConstantExpression = require("../../../../lib/pipeline/expressions/ConstantExpression");
 
+
 //TODO: refactor these test cases using Expression.parseOperand() or something because these could be a whole lot cleaner...
 module.exports = {
 
@@ -130,4 +132,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);

test/lib/pipeline/expressions/AndExpression.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	AndExpression = require("../../../../lib/pipeline/expressions/AndExpression"),
 	Expression = require("../../../../lib/pipeline/expressions/Expression");
 
+
 module.exports = {
 
 	"AndExpression": {
@@ -136,4 +138,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);

test/lib/pipeline/expressions/CoerceToBoolExpression.js

@@ -1,8 +1,10 @@
+"use strict";
 var assert = require("assert"),
 	CoerceToBoolExpression = require("../../../../lib/pipeline/expressions/CoerceToBoolExpression"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression"),
 	ConstantExpression = require("../../../../lib/pipeline/expressions/ConstantExpression");
 
+
 module.exports = {
 
 	"CoerceToBoolExpression": {

test/lib/pipeline/expressions/CompareExpression.js

@@ -1,8 +1,10 @@
+"use strict";
 var assert = require("assert"),
 	CompareExpression = require("../../../../lib/pipeline/expressions/CompareExpression"),
 	Expression = require("../../../../lib/pipeline/expressions/Expression"),
 	FieldRangeExpression = require("../../../../lib/pipeline/expressions/FieldRangeExpression");
 
+
 module.exports = {
 
 	"CompareExpression": {
@@ -304,4 +306,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);

test/lib/pipeline/expressions/CondExpression.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	CondExpression = require("../../../../lib/pipeline/expressions/CondExpression"),
 	Expression = require("../../../../lib/pipeline/expressions/Expression");
 
+
 module.exports = {
 
 	"CondExpression": {

test/lib/pipeline/expressions/ConstantExpression.js

@@ -1,6 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	ConstantExpression = require("../../../../lib/pipeline/expressions/ConstantExpression");
 
+
 module.exports = {
 
 	"ConstantExpression": {
@@ -50,4 +52,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);

test/lib/pipeline/expressions/DayOfMonthExpression.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	DayOfMonthExpression = require("../../../../lib/pipeline/expressions/DayOfMonthExpression"),
 	Expression = require("../../../../lib/pipeline/expressions/Expression");
 
+
 module.exports = {
 
 	"DayOfMonthExpression": {
@@ -44,4 +46,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);

test/lib/pipeline/expressions/DayOfWeekExpression.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	DayOfWeekExpression = require("../../../../lib/pipeline/expressions/DayOfWeekExpression"),
 	Expression = require("../../../../lib/pipeline/expressions/Expression");
 
+
 module.exports = {
 
 	"DayOfWeekExpression": {
@@ -44,4 +46,4 @@ module.exports = {
 
 };
 
-if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);
+if (!module.parent)(new(require("mocha"))()).ui("exports").reporter("spec").addFile(__filename).run(process.exit);

test/lib/pipeline/expressions/DayOfYearExpression.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	DayOfYearExpression = require("../../../../lib/pipeline/expressions/DayOfYearExpression"),
 	Expression = require("../../../../lib/pipeline/expressions/Expression");
 
+
 module.exports = {
 
 	"DayOfYearExpression": {

test/lib/pipeline/expressions/FieldPathExpression.js

@@ -1,6 +1,8 @@
+"use strict";
 var assert = require("assert"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression");
 
+
 module.exports = {
 
 	"FieldPathExpression": {

test/lib/pipeline/expressions/FieldRangeExpression.js

@@ -1,7 +1,9 @@
+"use strict";
 var assert = require("assert"),
 	FieldPathExpression = require("../../../../lib/pipeline/expressions/FieldPathExpression"),
 	FieldRangeExpression = require("../../../../lib/pipeline/expressions/FieldRangeExpression");
 
+
 module.exports = {
 
 	"FieldRangeExpression": {