From d0f15c782ba07a4fad0a538c19b1a33c4a555743 Mon Sep 17 00:00:00 2001 From: Robert Richter Date: Wed, 11 Mar 2020 20:31:01 +0100 Subject: [PATCH] =?UTF-8?q?update=20Mi=2011.=20M=C3=A4r=2020:31:01=20CET?= =?UTF-8?q?=202020?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/waip.js | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/server/waip.js b/server/waip.js index d158035..afbd4fe 100755 --- a/server/waip.js +++ b/server/waip.js @@ -27,6 +27,27 @@ module.exports = function(io, sql, async, app_cfg) { sql.db_log('Fehler-WAIP', 'Fehler: Wache für waip_id ' + waip_id + ' nicht vorhanden!'); }; }); + sql.db_get_twitter_list(waip_id, function(data) { + if (data) { + console.log(data); + data.forEach(function(row) { + // fuer jede Wache(row.room) die verbundenen Sockets(Clients) ermitteln und Einsatz verteilen + var room_sockets = io.sockets.adapter.rooms[row.room]; + //console.log(row); + //console.log(row.room); + //console.log(room_sockets); + //console.log(io.sockets.adapter); + if (typeof room_sockets !== 'undefined') { + Object.keys(room_sockets.sockets).forEach(function(socketId) { + einsatz_verteilen(waip_id, socketId, row.room); + sql.db_log('WAIP', 'Einsatz ' + waip_id + ' wird an ' + socketId + ' (' + row.room + ') gesendet'); + }); + }; + }); + } else { + sql.db_log('Fehler-WAIP', 'Fehler: Wache für waip_id ' + waip_id + ' nicht vorhanden!'); + }; + }); }); };