Reference
Table of Contents
Specification
The protocol is still under active development and it's not easy to maintain both reference implementation and specification document. Accordingly for now the reference implementation takes the place of the specification document.
Reference Implementation
To help understand and implement the protocol, reference implementation is provided. It is written in easy-to-read JavaScript with a lot of detailed notes you should be aware of. Also you can use it to verify your implementation casually and as the counterpart in your examples. See annotated source codes:
vibe
vibe.open
vibe.createServer
vibe.transport.createHttpStreamTransport
vibe.transport.createHttpLongpollTransport
vibe.transport.createHttpServer
vibe.transport.createWebSocketTransport
vibe.transport.createWebSocketServer
Note
- They are not for production use.
Installation
First you need to install Node.js. Then type the following to install the reference implementation:
npm install vibe-protocol
Interactive Mode
JavaScript is a dynamic language so you can deal with both client and server in an interactive mode. Open two Node consoles, copy the following scripts and paste into the each console.
Server
var vibe = require("vibe-protocol");
var server = vibe.createServer();
var httpTransportServer = vibe.transport.createHttpServer().on("transport", server.handle);
var wsTransportServer = vibe.transport.createWebSocketServer().on("transport", server.handle);
var httpServer = require("http").createServer();
httpServer.on("request", httpTransportServer.handle);
httpServer.on("upgrade", wsTransportServer.handle);
httpServer.listen(8080);
var sockets = [];
server.on("socket", function(socket) {
console.log("sockets[", sockets.push(socket) - 1, "]");
});
Once sockets[ 0 ]
have been logged, you can access the opened socket by sockets[0]
in the console.
sockets[0].send("greeting", "Hello World");
Client
var vibe = require("vibe-protocol");
var socket = vibe.open("http://localhost:8080");
socket.on("open", function() {
console.log("socket");
});
Once socket
have been logged, you can access the opened socket by socket
in the console.
socket.on("greeting", function(data) {
console.log("greetings from the server", data);
});
Example
This echo and chat example is very simple but demonstrates essential functionalities of the protocol.
To run example, write server.js
and client.js
by copy and paste to the folder where you have installed vibe-protocol
module. Then, open two consoles, type node server
and node client
respectively.
- URI is
http://localhost:8080/vibe
. echo
event is sent back to the client that sent the event.chat
event is broadcasted to every client that connected to the server.
server.js
var http = require("http");
var url = require("url");
var vibe = require("vibe-protocol");
// Consumes transport and produces socket
var server = vibe.createServer();
var sockets = [];
server.on("socket", function(socket) {
console.log("The connection is established successfully and communication is possible");
// To provide a repository of opened socket
sockets.push(socket);
socket.on("close", function() {
// Equal to sockets.remove(socket);
sockets.splice(sockets.indexOf(socket), 1);
console.log("The connection has been closed");
});
// Actions for echo and chat events
socket.on("error", function(error) {
console.log("An error happens on the socket", error);
})
.on("echo", function(data) {
console.log("on echo event", data);
socket.send("echo", data);
})
.on("chat", function(data) {
console.log("on chat event", data);
sockets.forEach(function(socket) {
socket.send("chat", data);
});
});
});
// Consumes HTTP request-response exchange and produces transport
var httpTransportServer = vibe.transport.createHttpServer().on("transport", server.handle);
// Consumes WebSocket connection and produces transport
var wsTransportServer = vibe.transport.createWebSocketServer().on("transport", server.handle);
http.createServer().on("request", function(req, res) {
if (url.parse(req.url).pathname === "/vibe") {
httpTransportServer.handle(req, res);
}
})
.on("upgrade", function(req, sock, head) {
if (url.parse(req.url).pathname === "/vibe") {
wsTransportServer.handle(req, sock, head);
}
})
.listen(8080);
client.js
var vibe = require("vibe-protocol");
var socket = vibe.open("http://localhost:8080/vibe");
socket.on("open", function() {
console.log("The connection is established successfully and communication is possible");
socket.send("echo", "An echo message");
socket.send("chat", "A chat message");
})
.on("error", function(error) {
console.error("An error happens on the socket", error);
})
.on("close", function() {
console.log("The connection has been closed, has been regarded as closed or could not be opened");
})
.on("chat", function(data) {
console.log("on chat event", data);
})
.on("echo", function(data) {
console.log("on echo event", data);
});
Test Suite
Test suite is provided to help write and verify implementation. Tests are written in JavaScript with the help of reference implementation and runs by Mocha, JavaScript test framework, in Node.js.
Testee
To run the test suite, you need to write a testee, a web server which brokers between test and your implementation to be tested. Because through writing testee, you will use most API of your implementation, showing your testee is good for explaining how to use your implementation.
The reference implementation is still under active development and it's not easy to maintain documentation. If you want to try out though, please see server testee and client testee.
Running Test
First you need to install Node.js. Then create a package.json
in an empty directory:
{
"devDependencies": {
"vibe-protocol": "3.0.0-Alpha10",
"mocha": "2.1.0",
"chai": "1.10.0",
"minimist": "1.1.0"
}
}
And type npm install
to install modules locally and npm install mocha -g
to install Mocha globally for convenience. Then, run your testee and execute mocha
passing the following arguments:
--vibe.transports
- A set of transport to be tested in a comma-separated value. As transport name,
ws
,httpstream
andhttplongpoll
are available.
- A set of transport to be tested in a comma-separated value. As transport name,
Testing a client which implements ws
transport only.
mocha ./node_modules/vibe-protocol/test/client.js --vibe.transports ws
Note
- Because Node.js is small and can be installed locally, you can automate the protocol test programmatically by downloading and installing Node.js, installing modules through npm, running tests through spawning a process and checking that process' exit code that is the number of failed tests.