dj7nt/mqtsream
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

With CAT

Browse Source
This commit is contained in:
DJ7NT
2025-04-02 16:48:23 +00:00
parent 4e035cf6b2
commit f754418782
1 changed files with 19 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
mqtt.js
View File

@@ -43,9 +43,15 @@ mqttC.on('message', function (topic, message) { // Handler, wenn mqtt-message ko
} else { } else {
msg.content=message.toString(); // Ist nix json? dann ab in "content" damit msg.content=message.toString(); // Ist nix json? dann ab in "content" damit
} }
tobrowser=parse_msg(msg.content); if (topic.startsWith('wavelog/qso/logged')) {
io.emit("mqtt",tobrowser); // und raus an den Browser (nur fuer DIESES Socket, nicht fuer alle Clients) damit tobrowser=parse_qso_msg(msg.content);
console.log('QSO from: '+tobrowser.station_call+' with '+tobrowser.call+' in Mode: '+tobrowser.mode+' at '+tobrowser.qso_time); io.emit("mqtt",tobrowser); // und raus an den Browser (nur fuer DIESES Socket, nicht fuer alle Clients) damit
console.log(topic+' / QSO from: '+tobrowser.station_call+' with '+tobrowser.call+' in Mode: '+tobrowser.mode+' at '+tobrowser.qso_time);
} else {
tobrowser=parse_cat_msg(topic,msg.content);
io.emit("cat",tobrowser); // und raus an den Browser (nur fuer DIESES Socket, nicht fuer alle Clients) damit
console.log(topic+' / CAT for User '+tobrowser.user_id+' at '+tobrowser.qrg+' in Mode '+tobrowser.mode);
}
// socket.emit("mqtt",parse_msg(msg)); // und raus an den Browser (nur fuer DIESES Socket, nicht fuer alle Clients) damit // socket.emit("mqtt",parse_msg(msg)); // und raus an den Browser (nur fuer DIESES Socket, nicht fuer alle Clients) damit
}); });
@@ -57,7 +63,16 @@ io.on('connection', (socket) => { // Neue socket.io Connection?
}); });
function parse_msg(msg) { function parse_cat_msg(topic,msg) {
let retmsg={};
retmsg.user_id=topic.substring(topic.lastIndexOf('/') + 1)
retmsg.qrg=msg.frequency;
retmsg.mode=msg.mode;
retmsg.time=msg.timestamp;
return retmsg;
}
function parse_qso_msg(msg) {
let retmsg={}; let retmsg={};
retmsg.call=msg.COL_CALL; retmsg.call=msg.COL_CALL;
retmsg.station_call=msg.COL_STATION_CALLSIGN; retmsg.station_call=msg.COL_STATION_CALLSIGN;