From 96bf78636345702e3972bdaf12cbfc1e9a918607 Mon Sep 17 00:00:00 2001 From: schneefux Date: Mon, 10 Apr 2017 18:40:47 +0200 Subject: send points_update notification to web --- worker.js | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'worker.js') diff --git a/worker.js b/worker.js index 656e312..0c78e2d 100644 --- a/worker.js +++ b/worker.js @@ -165,6 +165,11 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI, console.error(err); await Promise.all(msgs.map((m) => ch.nack(m, true)) ); // requeue } + + await Promise.all(player_records.map(async (p) => + await ch.publish("amq.topic", "player." + p.name, new Buffer("points_update")) )); + if (global_records.length > 0) + await ch.publish("amq.topic", "global", new Buffer("points_update")); } async function calculate_global_point() { @@ -207,6 +212,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI, if (stats != undefined) { stats.created_at = seq.fn("NOW"); stats.updated_at = seq.fn("NOW"); + stats.name = player.name; console.log("inserting stats for player", player.name); Object.assign(stats, where_links); await model.PlayerPoint.upsert(stats); -- cgit v1.3.1