Oinktube/plugin/YPTSocket/script.js

var socketConnectRequested = 0;
var totalDevicesOnline = 0;
function socketConnect() {
    if (socketConnectRequested) {
        return false;
    }
    socketConnectRequested = 1;
    var url = addGetParam(webSocketURL, 'page_title', $(document).find("title").text());
    console.log('Trying to reconnect on socket... ');
    conn = new WebSocket(url);
    conn.onopen = function (e) {
        console.log("Socket onopen");
        return false;
    };
    conn.onmessage = function (e) {
        var json = JSON.parse(e.data);
        parseSocketResponse(json);
        if (json.type == webSocketTypes.ON_VIDEO_MSG) {
            console.log("Socket onmessage ON_VIDEO_MSG", json);
            $('.videoUsersOnline, .videoUsersOnline_' + json.videos_id).text(json.total);
        }
        if (json.type == webSocketTypes.ON_LIVE_MSG) {
            console.log("Socket onmessage ON_LIVE_MSG", json);
            var selector = '#liveViewStatusID_' + json.live_key.key + '_' + json.live_key.live_servers_id;
            if (json.is_live) {
                onlineLabelOnline(selector);
            } else {
                onlineLabelOffline(selector);
            }
        }
        if (json.type == webSocketTypes.NEW_CONNECTION) {
            //console.log("Socket onmessage NEW_CONNECTION", json);
        } else if (json.type == webSocketTypes.NEW_DISCONNECTION) {
            //console.log("Socket onmessage NEW_DISCONNECTION", json);
        } else {
            var myfunc;
            if (json.callback) {
                console.log("Socket onmessage json.callback", json.callback);
                var code = "if(typeof " + json.callback + " == 'function'){myfunc = " + json.callback + ";}else{myfunc = defaultCallback;}";
                //console.log(code);
                eval(code);
            } else {
                console.log("onmessage: callback not found", json);
                myfunc = defaultCallback;
            }
            myfunc(json.msg);
        }
    };
    conn.onclose = function (e) {
        socketConnectRequested = 0;
        console.log('Socket is closed. Reconnect will be attempted in 1 second.', e.reason);
        setTimeout(function () {
            socketConnect();
        }, 1000);
    };

    conn.onerror = function (err) {
        socketConnectRequested = 0;
        console.error('Socket encountered error: ', err.message, 'Closing socket');
        conn.close();
    };
}

function sendSocketMessageToAll(msg, callback) {
    sendSocketMessageToUser(msg, callback, "");
}

function sendSocketMessageToNone(msg, callback) {
    sendSocketMessageToUser(msg, callback, -1);
}

function sendSocketMessageToUser(msg, callback, to_users_id) {
    if (conn.readyState === 1) {
        conn.send(JSON.stringify({msg: msg, webSocketToken: webSocketToken, callback: callback, to_users_id: to_users_id}));
    } else {
        console.log('Socket not ready send message in 1 second');
        setTimeout(function () {
            sendSocketMessageToUser(msg, to_users_id, callback);
        }, 1000);
    }
}

function isSocketActive() {
    return typeof conn != 'undefined' && conn.readyState === 1;
}

function defaultCallback(json) {
    //console.log('defaultCallback', json);
}

function parseSocketResponse(json) {
    console.log("parseSocketResponse", json);
    if(json.isAdmin && webSocketServerVersion>json.webSocketServerVersion){
        if(typeof avideoToastWarning == 'funciton'){
            avideoToastWarning("Please restart your socket server. You are running (v"+json.webSocketServerVersion+") and your client is expecting (v"+webSocketServerVersion+")");
        }
    }
    if (json && typeof json.autoUpdateOnHTML !== 'undefined') {
        $('.total_on').text(0);
        $('.total_on').parent().removeClass('text-success');
        //console.log("parseSocketResponse", json.autoUpdateOnHTML);
        for (var prop in json.autoUpdateOnHTML) {
            if (json.autoUpdateOnHTML[prop] === false) {
                continue;
            }
            var val = json.autoUpdateOnHTML[prop];
            $('.' + prop).text(val);
            if(parseInt(val)>0){
                $('.' + prop).parent().addClass('text-success');
            }
        }
    }

    if (json && typeof json.autoEvalCodeOnHTML !== 'undefined') {
        for (var prop in json.autoEvalCodeOnHTML) {
            if (json.autoEvalCodeOnHTML[prop] === false) {
                continue;
            }
            //console.log("autoEvalCodeOnHTML", json.autoEvalCodeOnHTML[prop]);
            eval(json.autoEvalCodeOnHTML[prop]);
        }
    }

    $('#socketUsersURI').empty();
    if (json && typeof json.users_uri !== 'undefined' && $('#socket_info_container').length) {
        for (var prop in json.users_uri) {
            if (json.users_uri[prop] === false) {
                continue;
            }

            for (var prop2 in json.users_uri[prop]) {
                if (json.users_uri[prop][prop2] === false || typeof json.users_uri[prop][prop2] !== 'object') {
                    continue;
                }
                for (var prop3 in json.users_uri[prop][prop2]) {
                    if (json.users_uri[prop][prop2][prop3] === false || typeof json.users_uri[prop][prop2][prop3] !== 'object') {
                        continue;
                    }
                    
                    var socketUserDivID = 'socketUser'+json.users_uri[prop][prop2][prop3].users_id;
                    
                    if(!$('#'+socketUserDivID).length){
                        var html = '<div class="socketUserDiv" id="'+socketUserDivID+'" >';
                        html += '<div class="socketUserName" onclick="socketUserNameToggle(\'#'+socketUserDivID+'\');">';
                        html += '<i class="fas fa-caret-down"></i><i class="fas fa-caret-up"></i> <img src="'+webSiteRootURL+'user/' + json.users_uri[prop][prop2][prop3].users_id + '/foto.png" class="img img-circle img-responsive">' + json.users_uri[prop][prop2][prop3].user_name + '</div>';
                        html += '<div class="socketUserPages"></div></div>';
                        $('#socketUsersURI').append(html);
                    }
                    
                    var text = '';
                    if(json.ResourceID == json.users_uri[prop][prop2][prop3].resourceId){
                        text += '<stcong>(YOU)</strong>' ;
                    }
                    text = ' ' + json.users_uri[prop][prop2][prop3].page_title;
                    text += '<br><small>' + json.users_uri[prop][prop2][prop3].ip+'</small>' ;
                    if(json.users_uri[prop][prop2][prop3].location){
                        text += '<br><i class="flagstrap-icon flagstrap-'+json.users_uri[prop][prop2][prop3].location.country_code+'" style="margin-right: 10px;"></i>';
                        text += ' '+json.users_uri[prop][prop2][prop3].location.country_name;
                    }
                    html = '<a href="' + json.users_uri[prop][prop2][prop3].selfURI + '" target="_blank" class="btn btn-xs btn-default btn-block"><i class="far fa-compass"></i> '+text+'</a>';
                    $('#'+socketUserDivID+' .socketUserPages').append(html);
                    var isVisible = Cookies.get('#'+socketUserDivID);
                    if(isVisible && isVisible !== 'false'){
                        $('#'+socketUserDivID).addClass('visible')
                    }
                }
            }

        }
    }
}

$(function () {
    console.log('Getting webSocketToken ...');
    var getWebSocket = webSiteRootURL + 'plugin/YPTSocket/getWebSocket.json.php';
    getWebSocket = addGetParam(getWebSocket, 'webSocketSelfURI', webSocketSelfURI);
    getWebSocket = addGetParam(getWebSocket, 'webSocketVideos_id', webSocketVideos_id);
    getWebSocket = addGetParam(getWebSocket, 'webSocketLiveKey', webSocketLiveKey);
    $.ajax({
        url: getWebSocket,
        success: function (response) {
            if(response.error){
                console.log('Getting webSocketToken ERROR '+response.msg);
                if(typeof avideoToastError == 'funciton'){
                    avideoToastError(response.msg);
                }
            }else{
                console.log('Getting webSocketToken SUCCESS ', response);
                webSocketToken = response.webSocketToken;
                webSocketURL = response.webSocketURL;
                socketConnect();
            }
        }
    });
});