Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement