dynamodb query all items

dynamodb-query-all.js

var docClient = require("../aws").docClient;
var co = require("co");

var queryAll = co.wrap(function*(
	params,
	previousItems,
	lastEvaluatedKey
) {
	var items = previousItems || [];

	if (lastEvaluatedKey) {
		params["ExclusiveStartKey"] = lastEvaluatedKey;
	}

	var queryResult = yield docClient.query(params).promise();

	items = items.concat(queryResult.Items);

	if (typeof queryResult.LastEvaluatedKey != "undefined") {
		// console.log("QUERY FOR MORE");

		return yield queryAll(params, items, queryResult.LastEvaluatedKey);
	} else {
		// console.log("OK - NUM OF ITEMS:" + items.length);

		return yield Promise.resolve(items);
	}
});

module.exports = queryAll;