summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorvainsocial <vainsocial@prod>2017-11-24 17:43:48 +0000
committervainsocial <vainsocial@prod>2017-11-24 17:43:48 +0000
commitd3a18706a979ba7100c92007b5b8f4d8e40d3256 (patch)
tree13637fc2f26c9c926b1a1702960ee12e6b2d0f21
parentd8bf0a949c9badd2ecb31c92f555069149f4cfd1 (diff)
downloadtelesucker-d3a18706a979ba7100c92007b5b8f4d8e40d3256.tar.gz
telesucker-d3a18706a979ba7100c92007b5b8f4d8e40d3256.zip
reduce phases to just draft
-rw-r--r--worker.js17
1 files changed, 4 insertions, 13 deletions
diff --git a/worker.js b/worker.js
index e58c426..9f60241 100644
--- a/worker.js
+++ b/worker.js
@@ -95,22 +95,12 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
// slice does not include end
),
start: start,
- match_start: spawn.time,
end: end
} };
// split into phases
const phases = [
// genious idea to put bans into Telemetry.
- gamePhase(-5 * 60, 0), // draft
- gamePhase(0, 90 * 60), // whole
- gamePhase(0, 1 * 60), // start
- gamePhase(0, 4 * 60), // early game
- gamePhase(0, 8 * 60), // miner full
- gamePhase(0, 12 * 60), // miner full
- gamePhase(0, 15 * 60), // Kraken spawn
- gamePhase(0, 20 * 60), // late mid game
- gamePhase(0, 25 * 60), // late game
- gamePhase(0, 30 * 60) // late game
+ gamePhase(-5 * 60, 0) // draft
];
await Promise.each(phases, async (phase) => {
if (phase.data.length > 0) {
@@ -153,7 +143,8 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
response.body = JSON.parse(hotfix);
} else {
logger.warn("invalid response", { url });
- throw { response };
+ //throw { response.body };
+JSON.parse(response.body);
}
}
return response.body;
@@ -164,7 +155,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
error: err.response.body
});
} else {
- logger.error(err);
+ //logger.error(err);
}
throw err;
} finally {