From 4dd360a9c7904a93f9e4f256f8dca8b960538b0b Mon Sep 17 00:00:00 2001 From: schneefux Date: Sat, 23 Dec 2017 14:56:42 +0100 Subject: forward all game modes to analyzer --- worker.js | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) (limited to 'worker.js') diff --git a/worker.js b/worker.js index 33dba6a..ed0bf10 100644 --- a/worker.js +++ b/worker.js @@ -290,15 +290,13 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { // notify follow up services if (DOANALYZEMATCH) { await Promise.each(match_objects, async (msg) => { - if (["casual", "ranked"].includes(msg.content.game_mode)) { - await ch.publish("amq.topic", msg.properties.headers.notify, - new Buffer("analyze_pending")); - await ch.sendToQueue(ANALYZE_QUEUE, - new Buffer(msg.content.id), { - persistent: true, - headers: { notify: msg.properties.headers.notify } - }); - } + await ch.publish("amq.topic", msg.properties.headers.notify, + new Buffer("analyze_pending")); + await ch.sendToQueue(ANALYZE_QUEUE, + new Buffer(msg.content.id), { + persistent: true, + headers: { notify: msg.properties.headers.notify } + }); }); } } catch (err) { -- cgit v1.3.1