summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-13 13:37:04 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-13 13:37:04 +0200
commitd5e77689203d4337a323810fcfd4221cf54c8b9f (patch)
treedd3cf8fa30fbfc3ca7a3f813183d4b53285bb63a
parent4b718a352f4b78efb25d9a285ccb77bbb0cfdcd3 (diff)
downloadshrinker-d5e77689203d4337a323810fcfd4221cf54c8b9f.tar.gz
shrinker-d5e77689203d4337a323810fcfd4221cf54c8b9f.zip
send the right players to cruncher
-rw-r--r--worker.js6
1 files changed, 3 insertions, 3 deletions
diff --git a/worker.js b/worker.js
index 088ac5f..c7584f1 100644
--- a/worker.js
+++ b/worker.js
@@ -398,9 +398,9 @@ function snakeCaseKeys(obj) {
type: "participant"
})
));
- Promise.all(notify_players.map(async (player) => {
- if (PREMIUM_FEATURES == false || premium_users.indexOf(player.api_id) != -1) {
- await ch.sendToQueue("crunch", new Buffer(player.api_id), {
+ Promise.all(player_objects.map(async (api_player) => {
+ if (PREMIUM_FEATURES == false || premium_users.indexOf(api_player.id) != -1) {
+ await ch.sendToQueue("crunch", new Buffer(api_player.id), {
persistent: true,
type: "player"
})