mkrieger/Wachalarm-IP-Web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update Mo 27. Apr 15:31:01 CEST 2020

Browse Source
This commit is contained in:
Robert Richter 2020-04-27 15:31:01 +02:00
parent c968a3ad00
commit 0aea2a5734
3 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
public/js/client_waip.js
View File

@ -222,7 +222,7 @@ var marker = L.marker(new L.LatLng(0, 0), {
/* ########################### */ /* ########################### */
// Websocket // Websocket
var socket = io.connect(); var socket = io('/waip');
// Wachen-ID bei Connect an Server senden // Wachen-ID bei Connect an Server senden
socket.on('connect', function() { socket.on('connect', function() {

17
server/socket.js
View File

@ -14,14 +14,18 @@ module.exports = function (io, sql, app_cfg, waip) {
socket_api.emit('CH01', 'me', 'test msg'); socket_api.emit('CH01', 'me', 'test msg');
// Socket.IO Server // Socket.IO Server
io.on('connection', function (socket) {
var nsp_waip = io.of('/waip');
nsp_waip.on('connection', function (socket) {
var client_ip = socket.handshake.headers["x-real-ip"] || socket.handshake.headers['x-forwarded-for'] || socket.request.connection.remoteAddress;
//zuerst Server-Version senden, damit der Client diese prueft und die Seite ggf. neu lädt //zuerst Server-Version senden, damit der Client diese prueft und die Seite ggf. neu lädt
//io.sockets.to(socket.id).emit('io.version', app_cfg.global.app_id); //io.sockets.to(socket.id).emit('io.version', app_cfg.global.app_id);
socket.emit('io.version', app_cfg.global.app_id); socket.emit('io.version', app_cfg.global.app_id);
// Aufruf des Alarmmonitors einer bestimmten Wache verarbeiten // Aufruf des Alarmmonitors einer bestimmten Wache verarbeiten
socket.on('WAIP', function (wachen_id) { socket.on('WAIP', function (wachen_id) {
sql.db_log('WAIP', 'Alarmmonitor Nr. ' + wachen_id + ' von ' + socket.request.connection.remoteAddress + ' (' + socket.id + ') aufgerufen');
sql.db_log('WAIP', 'Alarmmonitor Nr. ' + wachen_id + ' von ' + client_ip + ' (' + socket.id + ') aufgerufen');
// prüfen ob Wachenummer in der Datenbank hinterlegt ist // prüfen ob Wachenummer in der Datenbank hinterlegt ist
sql.db_wache_vorhanden(wachen_id, function (result) { sql.db_wache_vorhanden(wachen_id, function (result) {
// wenn die Wachennummer vorhanden/plausibel dann weiter // wenn die Wachennummer vorhanden/plausibel dann weiter
@ -29,7 +33,7 @@ module.exports = function (io, sql, app_cfg, waip) {
// Socket-Room beitreiten // Socket-Room beitreiten
socket.join(wachen_id, function () { socket.join(wachen_id, function () {
// Socket-ID und Client-IP in der Datenbank speichern // Socket-ID und Client-IP in der Datenbank speichern
sql.db_client_save(socket.id, socket.request.connection.remoteAddress, wachen_id); sql.db_client_save(socket.id, client_ip, wachen_id);
// prüfen ob für diese Wache Einsätze vorhanden sind // prüfen ob für diese Wache Einsätze vorhanden sind
sql.db_einsatz_ermitteln(wachen_id, socket.request.user.id, function (result_einsatz) { sql.db_einsatz_ermitteln(wachen_id, socket.request.user.id, function (result_einsatz) {
if (result_einsatz) { if (result_einsatz) {
@ -56,14 +60,15 @@ module.exports = function (io, sql, app_cfg, waip) {
}); });
} else { } else {
sql.db_log('Fehler-WAIP', 'Fehler: Wachnnummer ' + wachen_id + 'nicht vorhanden'); sql.db_log('Fehler-WAIP', 'Fehler: Wachnnummer ' + wachen_id + 'nicht vorhanden');
io.sockets.to(socket.id).emit('io.error', 'Fehler: Wachnnummer \'' + wachen_id + '\' nicht vorhanden!'); // io.sockets.to(socket.id).emit('io.error', 'Fehler: Wachnnummer \'' + wachen_id + '\' nicht vorhanden!');
socket.emit('io.error', 'Fehler: Wachnnummer \'' + wachen_id + '\' nicht vorhanden!');
}; };
}); });
}); });
// disconnect verarbeiten // disconnect verarbeiten
socket.on('disconnect', function () { socket.on('disconnect', function () {
sql.db_log('WAIP', 'Alarmmonitor von ' + socket.request.connection.remoteAddress + ' (' + socket.id + ') geschlossen'); sql.db_log('WAIP', 'Alarmmonitor von ' + client_ip + ' (' + socket.id + ') geschlossen');
sql.db_client_delete(socket.id); sql.db_client_delete(socket);
}); });
}); });
}; };

6
server/sql_qry.js
View File

@ -373,9 +373,9 @@ module.exports = function(db, uuidv4, turf, app_cfg) {
room_name + '\')'); room_name + '\')');
}; };
function db_client_delete(client_id) { function db_client_delete(socket) {
db.run('DELETE FROM waip_clients ' + db.run('DELETE FROM waip_clients ' +
'WHERE socket_id = ?', client_id); 'WHERE socket_id = ?', socket.id);
}; };
// Funkrufname // Funkrufname
@ -414,7 +414,7 @@ module.exports = function(db, uuidv4, turf, app_cfg) {
var user_name = socket.request.user.user; var user_name = socket.request.user.user;
var user_permissions = socket.request.user.permissions; var user_permissions = socket.request.user.permissions;
var user_agent = socket.request.headers['user-agent']; var user_agent = socket.request.headers['user-agent'];
var client_ip = socket.request.connection.remoteAddress; var client_ip = socket.handshake.headers["x-real-ip"] || socket.handshake.headers['x-forwarded-for'] || socket.request.connection.remoteAddress;
var reset_timestamp = socket.request.user.reset_counter; var reset_timestamp = socket.request.user.reset_counter;
if (isNaN(client_status) || client_status == null) { if (isNaN(client_status) || client_status == null) {
client_status = 'Standby'; client_status = 'Standby';