Edit in JSFiddle

var socket = new WebSocket("ws://echo.websocket.org/"),
    pubsub = amplify;

socket.onopen = function() {
    pubsub.publish("chat/open")
};

socket.onclose = function() {
    pubsub.publish("chat/close")
};
        
socket.onerror = function() {
    pubsub.publish("chat/error")
};
    
socket.onmessage = function(data) {
    pubsub.publish("chat/message/receive", data)
};

pubsub.subscribe("chat/message/send", function(data) {
    socket.send(data);
});
    
pubsub.subscribe("chat/message/receive", function(data){
    console.log(data);        
});

pubsub.subscribe("chat/open", function() {
    console.log("Socket opened.");
    pubsub.publish("chat/message/send", "Hi, server!");
});