freifunkmanager/webroot/js/socket.js

import * as store from './store';
import config from './config';
import {singelton as notify} from './element/notify';
import {render} from './gui';

const RECONNECT_AFTER = 5000,
	RETRY_QUERY = 300,
	query = [],
	eventMSGID = {},
	eventTo = {};

let connectionID = localStorage.getItem('session'),
	socket = null,
	sessionInit = false,
	connectionEstablished = false;

function newUUID () {
	/* eslint-disable */
	return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, (c) => {
		const r = Math.random() * 16 | 0,
			v = c === 'x' ? r : r & 0x3 | 0x8;
		return v.toString(16);
	});
	/* eslint-enable */
}

function correctMSG (obj) {
	if (!obj.id) {
		obj.id = newUUID();
	}
}

function onerror (err) {
	console.warn(err);
	// eslint-disable-next-line no-magic-numbers
	if (socket.readyState !== 3) {
		notify.send({
			'header': 'Verbindung',
			'type': 'error'
		}, 'Verbindung zum Server unterbrochen!');
	}
	render();
	socket.close();
}

function onopen () {
	connectionEstablished = true;
	sendjson({'subject': 'auth_status'});
	sendjson({'subject': 'connect'});
	render();
}


export function sendjson (obj, callback) {
	if (socket.readyState !== 1 || (!sessionInit && obj.subject !== 'session_init')) {
		query.push({
			'callback': callback,
			'obj': obj
		});
		return;
	}
	correctMSG(obj);
	const socketMSG = JSON.stringify(obj);
	socket.send(socketMSG);
	if (typeof callback === 'function') {
		eventMSGID[obj.id] = callback;
	}
}

function onmessage (raw) {
	const msg = JSON.parse(raw.data),
		msgFunc = eventMSGID[msg.id],
		eventFuncs = eventTo[msg.subject];

	if (msg.subject === 'session_init') {
		if (connectionID === null) {
			connectionID = newUUID();
			localStorage.setItem('session', connectionID);
		}
		msg.id = connectionID;
		sendjson(msg);
		render();
		sessionInit = true;
		return;
	}

	if (msgFunc) {
		msgFunc(msg);
		delete eventMSGID[msg.id];
		render();
		return;
	}

	if (typeof eventFuncs === 'object' && eventFuncs.length > 0) {
		// eslint-disable-next-line guard-for-in
		for (const key in eventFuncs) {
			const func = eventFuncs[key];
			if (func) {
				func(msg);
			}
		}
		render();
		return;
	}

	notify.send('warning', `unable to identify message: ${msg.subject}`);
	render();
}

function onclose () {
	console.log('socket closed by server');
	if (connectionEstablished) {
		notify.send({
			'header': 'Verbindung',
			'type': 'warning'
		}, 'Verbindung zum Server beendet!');
	}
	render();
	connectionEstablished = false;
	// eslint-disable-next-line no-use-before-define
	window.setTimeout(connect, RECONNECT_AFTER);
}

function connect () {
	socket = new window.WebSocket(config.backend);
	socket.onopen = onopen;
	socket.onerror = onerror;
	socket.onmessage = onmessage;
	socket.onclose = onclose;
}

window.setInterval(() => {
	const queryEntry = query.pop();
	if (queryEntry) {
		sendjson(queryEntry.obj, queryEntry.callback);
	}
}, RETRY_QUERY);


export function getStatus () {
	if (socket) {
		return socket.readyState;
	}
	return 0;
}

export function setEvent (to, func) {
	eventTo[to] = [func];
}

export function addEvent (to, func) {
	if (typeof eventTo[to] !== 'object') {
		eventTo[to] = [];
	}
	eventTo[to].push(func);
}

export function delEvent (to, func) {
	if (typeof eventTo[to] === 'object' && eventTo[to].length > 1) {
		eventTo[to].pop(func);
	} else {
		eventTo[to] = [];
	}
}

export function sendnode(node, callback) {
	sendjson({'subject':'node','body': node}, (msg) => {
		if(!msg.body) {
			notify.send({
				'header': 'Speichern',
				'type': 'error',
			}, `Einstellungen für '${node.node_id}' wurden nicht gespeichert.`);
		}
		if (typeof callback === 'function') {
			callback(msg);
		}
	});
}


setEvent('auth_status', (msg) => {
	if (msg.body) {
		store.settings = msg.body
		store.isLogin = true;

		notify.send({
			'header': 'Login',
			'type': 'success'
		},'Willkommen zurück!');
	} else {
		store.isLogin = false;
	}
	render();
});

addEvent('node', (msg) => {
	store.updateNode(msg.body);
});
addEvent('channels_wifi24', (msg) => {
	store.channelsWifi24 = msg.body.sort((a, b) => a - b);
});
addEvent('channels_wifi5', (msg) => {
	store.channelsWifi5 = msg.body.sort((a, b) => a - b);
});
addEvent('ping', (msg) => {
	store.updateNodePing(msg.body);
});
connect();