summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-07-26 20:34:27 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-07-26 20:34:27 +0200
commit78a114a0702207d8bfd5412bf59dea67df63c006 (patch)
tree3211a8dc2f9a63361091cbc07279db6de7fadabc
parent7c78c7dacd397a35456fc76195fef5d1aadb5f12 (diff)
downloadprocessor-78a114a0702207d8bfd5412bf59dea67df63c006.tar.gz
processor-78a114a0702207d8bfd5412bf59dea67df63c006.zip
add hotfix for web not listening to match_dupe
-rw-r--r--worker.js8
1 files changed, 6 insertions, 2 deletions
diff --git a/worker.js b/worker.js
index 108f870..7af0e98 100644
--- a/worker.js
+++ b/worker.js
@@ -172,11 +172,15 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
if (msg.properties.headers.notify) {
await ch.publish("amq.topic",
msg.properties.headers.notify,
- new Buffer("matches_dupe"))
+ new Buffer("matches_dupe"));
// send match_dupe to web player.ign.api_id
await ch.publish("amq.topic",
msg.properties.headers.notify + "." + match.id,
- new Buffer("match_dupe"))
+ new Buffer("match_dupe"));
+ // HOTFIX TODO remove me, web should listen to match_dupe
+ await ch.publish("amq.topic",
+ msg.properties.headers.notify,
+ new Buffer("match_update"));
}
await ch.nack(msg, false, false);
} else if (match.rosters.length < 2 || match.rosters[0].id == "null") {