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

update Di 26. Mai 18:01:01 CEST 2020

Browse Source
This commit is contained in:
Robert Richter 2020-05-26 18:01:01 +02:00
parent 73ba6855df
commit 6e31ad712a
3 changed files with 36 additions and 68 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

96
server/api.js
View File

@ -1,17 +1,21 @@
module.exports = function (io, io_api, sql, app_cfg, waip) { module.exports = function (io, sql, app_cfg, waip) {
// Module laden // Module laden
const io_api = require('socket.io-client'); const io_api = require('socket.io-client');
// Socket.IO API (anderer Server stellt Verbindung her und sendet Daten) // Namespace API festlegen
var nsp_api = io.of('/api');
// Socket.IO Empfangs-API (anderer Server stellt Verbindung her und sendet Daten)
if (app_cfg.api.enabled) { if (app_cfg.api.enabled) {
// Namespace API
var nsp_api = io.of('/api');
nsp_api.on('connection', function (socket) { nsp_api.on('connection', function (socket) {
// versuche Remote-IP zu ermitteln // versuche Remote-IP zu ermitteln
var remote_ip = socket.handshake.headers["x-real-ip"] || socket.handshake.headers['x-forwarded-for'] || socket.request.connection.remoteAddress; var remote_ip = socket.handshake.headers["x-real-ip"] || socket.handshake.headers['x-forwarded-for'] || socket.request.connection.remoteAddress;
// TODO Connect loggen
//TODO pruefen ob Verbindung mit passendem Geheimnis und aus IP-Bereich //TODO pruefen ob Verbindung mit passendem Geheimnis und aus IP-Bereich
// in Liste der Clients mit aufnehmen // in Liste der Clients mit aufnehmen
@ -40,75 +44,41 @@ module.exports = function (io, io_api, sql, app_cfg, waip) {
}); });
}; };
// Socket.IO Sende-API (Daten an Server senden, die Verbindung hergestellt haben)
if (app_cfg.endpoint.enabled) {
// Endpoint-API var remote_api = io_api.connect(app_cfg.endpoint.host, {
if (app_cfg.endpoint.enabled) { reconnect: true
const remote_api = io_api.connect(app_cfg.global.remoteapi, { });
reconnect: true
});
} else {
const remote_api;
};
// Module laden
//client.js
// Add a connect listener // Add a connect listener
remote_api.on('connect', function (remote_api) { remote_api.on('connect', function () {
console.log('Connected!'); console.log('Connected!');
}); });
socket.on('connect_error', function (err) { remote_api.on('connect_error', function (err) {
$('#waipModalTitle').html('FEHLER'); console.log('Fehler! ' + err);
$('#waipModalBody').html('Verbindung zum Server getrennt!');
$('#waipModal').modal('show');
}); });
remote_api.emit('CH01', 'me', 'test msg');
// Funktio daraus machen
remote_api.emit('new_waip', data);
// Funktion um zu pruefen, ob Nachricht im JSON-Format ist //send_mission_type: ['Brandeinsatz', 'Hilfeleistung'],
function isValidJSON(text) { //send_data_type: ['uuid', 'n
try { // data so wie bei udp
JSON.parse(text); remote_api.emit('new_rmld', data);
return true; // gibts nur im routing
} catch (error) {
return false; } else {
} const remote_api;
}; };
//client.js
// Add a connect listener
remote_api.on('connect', function (remote_api) {
console.log('Connected!');
});
socket.on('connect_error', function (err) {
$('#waipModalTitle').html('FEHLER');
$('#waipModalBody').html('Verbindung zum Server getrennt!');
$('#waipModal').modal('show');
});
remote_api.emit('CH01', 'me', 'test msg');
return {
einsatz_speichern: einsatz_speichern,
waip_verteilen: waip_verteilen,
dbrd_verteilen: dbrd_verteilen,
rmld_verteilen_for_one_client: rmld_verteilen_for_one_client,
rmld_verteilen_by_uuid: rmld_verteilen_by_uuid
};
return {
send_new_waip: send_new_waip,
send_new_rmld: send_new_rmld
};
}; };

4
server/app_cfg.js
View File

@ -47,9 +47,7 @@ app_cfg.api = {
// Daten an andere Server senden // Daten an andere Server senden
app_cfg.endpoint = { app_cfg.endpoint = {
enabled: true, enabled: true,
host: '192.168.1.25', host: 'https://192.168.1.25:8090/api',
port: '8090',
nsp: '/api',
secret: 'asdfwert1234567890#', secret: 'asdfwert1234567890#',
send_mission_type: ['Brandeinsatz', 'Hilfeleistung'], send_mission_type: ['Brandeinsatz', 'Hilfeleistung'],
send_data_type: ['uuid', 'nummer', 'alarmzeit', 'art', 'stichwort', 'sondersignal', 'ort', 'ortsteil', 'wgs84_area'] send_data_type: ['uuid', 'nummer', 'alarmzeit', 'art', 'stichwort', 'sondersignal', 'ort', 'ortsteil', 'wgs84_area']

2
server/sql_qry.js
View File

@ -923,7 +923,7 @@ module.exports = function (db, uuidv4, app_cfg) {
function db_get_vmtl_list(waip_id, callback) { function db_get_vmtl_list(waip_id, callback) {
// Pruefen ob fuer eine Wache in diesem Einsatz ein Twitter-Account mit Liste hinterlegt ist // Pruefen ob fuer eine Wache in diesem Einsatz ein Twitter-Account mit Liste hinterlegt ist
db.get(`select t.waip_wachen_id, t.tw_account_id, t.tw_account_list from waip_twitter_wachen t db.get(`select t.waip_wachen_id, t.tw_account_id, t.tw_account_list from waip_vmlt_tw_wachen t
where waip_wachen_id = (select distinct w.id wachen_id from waip_wachen w left join waip_einsatzmittel em on em.wachenname = w.name_wache where waip_wachen_id = (select distinct w.id wachen_id from waip_wachen w left join waip_einsatzmittel em on em.wachenname = w.name_wache
where em.waip_einsaetze_ID = ?)`, [waip_id], function (err, twitter_liste) { where em.waip_einsaetze_ID = ?)`, [waip_id], function (err, twitter_liste) {
if (err == null && twitter_liste) { if (err == null && twitter_liste) {