var wss = new Object();

MF.log = function(msg) {
    console.log(msg);
    app.ports.websocketIn.send(msg);
}

MF.url = function(data) {
    var wsProtocol = 'ws';
    if (window.location.protocol == 'https:') {
        wsProtocol = 'wss'
    }
    return wsProtocol + '://' + window.location.hostname + '/ws/channels/' + data.channelid + '/messages?authorization=' + data.thingkey
}

app.ports.connectWebsocket.subscribe(function(data) {
    var url = MF.url(data);
    if (wss[url]) {
        MF.log('Websocket already open. URL: ' + url );
        return;
    }

    var ws = new WebSocket(url);
    
    ws.onopen = function (event) {
        MF.log('Websocket opened. URL: ' + url);
        wss[url] = ws;          
    }

    ws.onerror = function (event) {
        console.log(event);
    }
    
    ws.onmessage = function(message) {
        app.ports.websocketIn.send(JSON.stringify({data: message.data, timestamp: message.timeStamp}));
    };
    
    ws.onclose = function (event) {
        MF.log('Websocket closed. URL: ' + url);
        delete wss[ws.url];
    };
});

if (typeof app.ports.websocketOut !== 'undefined') {
    app.ports.websocketOut.subscribe(function(data) {
        var url = MF.url(data);
        if (wss[url]) {
            wss[url].send(data.message);
        } else {
            MF.log('Message not sent. Websocket is not open. URL: ' + url);
        }
    })
}

app.ports.disconnectWebsocket.subscribe(function(data) {
    var url = MF.url(data);
    if (wss[url]) {
        wss[url].close();
    } else {
        MF.log('Websocket not disconnected. Websocket is not open. URL: ' + url);
    }
})

if (typeof app.ports.queryWebsocket !== 'undefined') {
    app.ports.queryWebsocket.subscribe(function(data) {
        var url = MF.url(data);
        if (wss[url]) {
            app.ports.retrieveWebsocket.send({url: url, readyState : wss[url].readyState});
        } else {
            app.ports.retrieveWebsocket.send({url: '', readyState : -1})
        }
    })
}

if (typeof app.ports.queryWebsockets !== 'undefined') {
    app.ports.queryWebsockets.subscribe(function(data) {
        var wssList = []
        data.forEach(function(item, index){
            var url = MF.url(item);
            if (wss[url]) {
                wssList.push({url: url, readyState : wss[url].readyState})
            }
        })
        app.ports.retrieveWebsockets.send(wssList);
    })
}