main.all('/get_all', function(req, res) {
setHeaders(res);
if (!Array.isArray(req.body)) {
res.end(JSON.stringify({
error: "add validation and error later"
}));
return;
}
getCounts(req, res);
});
async function getCounts(req, res) {
let results = {};
req.body.forEach(function(q) {
let the_key = q.id;
let pr = await countAllKeys(the_key).then(function(value) {
q.count = value;
results[] = q;
});
});
res.end(JSON.stringify(results))
}
async function countAllKeys(the_key) {
let promise = await new Promise(function(resolve, reject) {
redisClient.hlen(the_key, function(err, value) {
if (err) {
reject(err);
} else {
resolve(value);
}
});
});
return promise;
}