Skip to content

Instantly share code, notes, and snippets.

@rezoner
Created June 4, 2016 19:00
Show Gist options
  • Save rezoner/c28239f4932fe6ab46b666b5a4a229d9 to your computer and use it in GitHub Desktop.
Save rezoner/c28239f4932fe6ab46b666b5a4a229d9 to your computer and use it in GitHub Desktop.
Time delta between websocket messages
var client = new WebSocket("ws://IP:1337");
var last = Date.now();
client.addEventListener("message", function(event) {
var delta = Date.now() - last;
console.log("Time since last message ", delta, "ms");
if(delta < 40) console.log("SPIKE");
last = Date.now();
});
/* Error handler */
function foo() {}
/* List of connected sockets */
var clients = new Set;
/* Server */
var WebSocketServer = require('uws').Server;
var server = new WebSocketServer({
port: 1337,
perMessageDeflate: false
});
server.on('connection', function(socket) {
clients.add(socket);
socket.on("close", function() {
clients.delete(this);
});
});
setInterval(function() {
var data = "";
for (var i = 0; i < 1024; i++) data += String.fromCharCode(Math.random() * 128 | 0);
for (var socket of clients) {
socket.send(data, {
compress: false
}, foo);
}
}, 1000 / 20);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment