new function() { var ws = null; var connected = false; var serverUrl; var connectionStatus; var sendMessage; var connectButton; var disconnectButton; var sendButton; var open = function() { var url = serverUrl.val(); ws = new WebSocket(url); ws.onopen = onOpen; ws.onclose = onClose; ws.onmessage = onMessage; ws.onerror = onError; localStorage.setItem("server", url); connectionStatus.text('OPENING ...'); serverUrl.attr('disabled', 'disabled'); connectButton.hide(); disconnectButton.show(); }; var close = function() { if (ws) { console.log('CLOSING ...'); ws.close(); } connected = false; connectionStatus.text('CLOSED'); serverUrl.removeAttr('disabled'); connectButton.show(); disconnectButton.hide(); sendMessage.attr('disabled', 'disabled'); sendButton.attr('disabled', 'disabled'); loginName.attr('disabled', 'disabled'); loginPass.attr('disabled', 'disabled'); loginButton.attr('disabled', 'disabled'); }; var clearLog = function() { $('#messages').html(''); }; var login = function(event) { var name = loginName.val(); var password = loginPass.val(); if(name!= "" && password != ""){ var msg= "login|"+ name + "|"+ password; ws.send(msg); localStorage.setItem("name", name); localStorage.setItem("password", password); }else{ alert("name and password cant't be empty!") } }; var doLogin= function(msg){ if(msg.substr(0, 5)== "login"){ sendMessage.removeAttr('disabled'); sendButton.removeAttr('disabled'); loginName.attr('disabled', 'disabled'); loginPass.attr('disabled', 'disabled'); loginButton.attr('disabled', 'disabled'); return "login success!" }else if(msg.substr(0, 3)== "msg"){ return msg.substr(4) }else{ } return "" }; var onOpen = function() { console.log('OPENED: ' + serverUrl.val()); connected = true; connectionStatus.text('OPENED'); //sendMessage.removeAttr('disabled'); //sendButton.removeAttr('disabled'); loginName.removeAttr('disabled'); loginPass.removeAttr('disabled'); loginButton.removeAttr('disabled'); }; var onClose = function() { console.log('CLOSED: ' + serverUrl.val()); ws = null; }; var onMessage = function(event) { var data = event.data; //login data= doLogin(data) //todo if(data){ addMessage(data); //$('#messages').val(""); //getLog(); db.transaction(function (tx) { tx.executeSql('INSERT INTO LOGS (content) VALUES ("'+ data+ '")'); }); } }; var onError = function(event) { alert("error, maybe socket closed!") //alert(event.data); }; var addMessage = function(data, type) { var msg = $('<pre>').text(data); if (type === 'SENT') { msg.addClass('sent'); } var messages = $('#messages'); messages.append(msg); messages.append($("<br>")); var msgBox = messages.get(0); while (msgBox.childNodes.length > 10000) { msgBox.removeChild(msgBox.firstChild); } msgBox.scrollTop = msgBox.scrollHeight; }; var getLog= function(start, limit){ if(typeof(start) == undefined || !start){ start= 0 } if(typeof(limit) == undefined || !limit){ limit= 10000 } //log db.transaction(function (tx) { tx.executeSql('SELECT * FROM LOGS limit ?, ?', [start, limit], function (tx, results) { var len = results.rows.length, i; for (i = 0; i < len; i++){ msg = results.rows.item(i).content; //document.querySelector('#status').innerHTML += msg; //alert(msg) addMessage(msg); } }, null); }); }; WebSocketClient = { init: function() { serverUrl = $('#serverUrl'); connectionStatus = $('#connectionStatus'); sendMessage = $('#sendMessage'); connectButton = $('#connectButton'); disconnectButton = $('#disconnectButton'); sendButton = $('#sendButton'); loginName= $('#name'); loginPass= $('#password'); loginButton= $('#loginButton'); if(cache_server!= null)serverUrl.val(cache_server) if(cache_name!= null)loginName.val(cache_name) if(cache_password!= null)loginPass.val(cache_password) getLog(); loginButton.click(function(e) { login(); }); connectButton.click(function(e) { close(); open(); }); disconnectButton.click(function(e) { close(); }); sendButton.click(function(e) { var msg = $('#sendMessage').val(); if(msg== "" ){ alert("You must say something!") }else{ ws.send("msg|"+ msg); $('#sendMessage').val("") } }); $('#clearMessage').click(function(e) { clearLog(); }); var isCtrl; sendMessage.keyup(function (e) { if(e.which == 17) isCtrl=false; }).keydown(function (e) { if(e.which == 17) isCtrl=true; if(e.which == 13 && isCtrl == true) { sendButton.click(); return false; } }); } }; } $(function(){ cache_server= localStorage.getItem("server") cache_name= localStorage.getItem("name") cache_password= localStorage.getItem("password") db = openDatabase('mydb', '1.0', 'Test DB', 5 * 1024 * 1024); db.transaction(function (tx){ tx.executeSql("CREATE TABLE IF NOT EXISTS LOGS ('id' integer primary key autoincrement,'content' text)"); }); WebSocketClient.init(); });