#!/usr/bin/env -S node 
const config = require("./config.js");		// Configfile einbinden
var mqttserver=config.mqttserver.host;		// mqtt-host aus json im configfile holen (ginge auch direkt)
var mqtt = require('mqtt');			// mqtt-module einbinden
const path = require('path');
const express = require('express');
const app = express();		// http-express framework laden (macht routing, etc.)
const http = require('http').Server(app);	// http-server module laden
const io = require('socket.io')(http);		// socket.io einbinden

app.use('/jquery', express.static(path.join(__dirname, 'node_modules', 'jquery', 'dist')));

app.get('/', (req, res) => {			// Routing fuer index.html
	res.sendFile(__dirname + '/index.html');	// index.html rauspusten
});

const mqttC=mqtt.connect(mqttserver);
mqttC.on('connect', () => {
	console.log('Connected to MQTT broker');
	mqttC.subscribe('wavelog/#', (err) => {
		if (!err) {
			console.log(`Subscribed to topic`);
		} else {
			console.log('Error');
			console.log(err);
		}
	});
});

mqttC.on('message', function (topic, message) {	// Handler, wenn mqtt-message kommt
	date=new Date();					// Timestamp in date merken
	msg={};							// msg-object initialisieren
	if (message.toString().substring(0,1)=='{') {		// JSON-String? Dann aufbereiten
		try {
			messagex=JSON.parse(message);		// Versuchen mqtt-nachricht durch den jsonparser zu parsen
			msg.content=messagex;			// ergebnis in content haemmern
		} catch(e) {
			console.log("No JSON");
		}
	} else {
		msg.content=message.toString();			// Ist nix json? dann ab in "content" damit
	}
	if (topic.startsWith('wavelog/qso/logged')) {
		tobrowser=parse_qso_msg(msg.content);
		io.emit("mqtt",tobrowser);				// und raus an den Browser 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 damit
		console.log(topic+' / CAT for User '+tobrowser.user_id+' at '+tobrowser.qrg+' in Mode '+tobrowser.mode);
	}
});

io.on('connection', (socket) => {			// Neue socket.io Connection?
	console.log(socket.id + " connected");		// Debug
	socket.on("disconnect", (reason) => {		
		console.log(socket.id + " disconnected");
	});

});

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={};
	retmsg.call=msg.COL_CALL;
	retmsg.station_call=msg.COL_STATION_CALLSIGN;
	retmsg.station_grid=msg.COL_MY_GRIDSQUARE;
	retmsg.grid=msg.COL_GRIDSQUARE;
	retmsg.band=msg.COL_BAND;
	retmsg.mode=msg.COL_MODE
	retmsg.qrg=msg.COL_FREQ/1000;
	retmsg.RST_RCVD=msg.COL_RST_RCVD;
	retmsg.RST_SENT=msg.COL_RST_SENT;
	retmsg.qso_time=msg.COL_TIME_ON;
	return retmsg;
}

http.listen(8000,'127.0.0.1', () => {						// Webserver starten
	console.log(`Socket.IO server running at http://localhost:8000/`);	// debug
});