From 278419f46139681e50cc8b4cf40d6d5cb9cdb563 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Wed, 14 Jun 2017 13:12:18 +0200
Subject: apply workaround for match_pending notifications

---
 server.js | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

(limited to 'server.js')

diff --git a/server.js b/server.js
index 78fd95b..68c9a80 100644
--- a/server.js
+++ b/server.js
@@ -155,7 +155,10 @@ async function grabPlayer(name, region, last_match_created_date, id, category) {
                 new Buffer(JSON.stringify(payload)), {
             persistent: true,
             type: "matches",
-            headers: { notify: "player." + name }
+            headers: {
+                donotify: true,  // TODO backwards compat
+                notify: "player." + name
+            }
         });
 
         part_start = part_end;
@@ -183,7 +186,10 @@ async function grabPlayers(names, region, grabstart, category) {
             new Buffer(JSON.stringify(payload)), {
         persistent: true,
         type: "matches",
-        headers: { notify: "player." + names }
+        headers: {
+            donotify: true,  // TODO
+            notify: "player." + names
+        }
     });
 }
 
@@ -234,7 +240,10 @@ async function searchPlayerInRegion(region, name, id) {
             await ch.sendToQueue(PLAYER_PROCESS_QUEUE,
                 new Buffer(JSON.stringify(player)), {
                     persistent: true, type: "player",
-                    headers: { notify: "player." + player.name }
+                    headers: {
+                        donotify: true,  // TODO
+                        notify: "player." + player.name
+                    }
                 });
             return player;
         }
-- 
cgit v1.3.1