diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-21 19:49:42 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-21 19:49:42 +0200 |
| commit | 670d4df1194412e2e5c85aa4d955aa5dd6b975cf (patch) | |
| tree | a1c76535a4431756b9ba52739d76a5a60b059fdd | |
| parent | 3346d1635e1b261648e90bae0146f70c4c60a634 (diff) | |
| download | processor-670d4df1194412e2e5c85aa4d955aa5dd6b975cf.tar.gz processor-670d4df1194412e2e5c85aa4d955aa5dd6b975cf.zip | |
remove match_update hotfix, send match_invalid
| -rw-r--r-- | worker.js | 7 |
1 files changed, 3 insertions, 4 deletions
@@ -185,14 +185,13 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { await ch.publish("amq.topic", msg.properties.headers.notify + "." + match.id, 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") { logger.info("invalid match", match.id); + await ch.publish("amq.topic", + msg.properties.headers.notify + "." + match.id, + new Buffer("match_invalid")); // it is really `"null"`. // reject invalid matches (handling API bugs) await ch.nack(msg, false, false); |
