summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--worker.js8
1 files changed, 6 insertions, 2 deletions
diff --git a/worker.js b/worker.js
index d0bfa22..11253d0 100644
--- a/worker.js
+++ b/worker.js
@@ -37,7 +37,10 @@ function snakeCaseKeys(obj) {
while (true) {
try {
- seq = new Seq(DATABASE_URI, { logging: () => {} });
+ seq = new Seq(DATABASE_URI, {
+ logging: false,
+ max: 10
+ });
rabbit = await amqp.connect(RABBITMQ_URI, { heartbeat: 120 });
ch = await rabbit.createChannel();
await ch.assertQueue("process", {durable: true});
@@ -439,13 +442,14 @@ function snakeCaseKeys(obj) {
if (roster.hero_kills == 0) p_s.kill_participation = 0;
else p_s.kill_participation = (p_s.kills + p_s.assists) / roster.hero_kills;
+ /* example
p_s.sustain_score = participant.items.reduce((score, item) => {
// items[], itemGrants{}, itemUse{}, itemSells{} are the API objects
// old item names to clean names need to be mapped via `item_name_map[oldname]`
if (["Eve of Harvest", "Serpent Mask"].indexOf(item_name_map[item]) != -1)
return score + 20;
return score;
- }, 0);
+ }, 0);*/
return [p, p_s];
}