dynamodb scan all items

dynamodb-scan-all.js

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

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

	var params = {
		TableName: tableName
	};

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

	var scanResult = yield docClient.scan(params).promise();

	items = items.concat(scanResult.Items);

	if (typeof scanResult.LastEvaluatedKey != "undefined") {
		console.log("SCAN FOR MORE");

		return yield scanAll(tableName, items, scanResult.LastEvaluatedKey);
	} else {
		console.log("OK - NUM OF ITEMS:" + items.length);

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

module.exports = scanAll;