WebSocket = require("ws");
WebSocketServer = WebSocket.Server;
MessageCenter = require("message-center");
 
mcClientSide = new MessageCenter();
mcServerSide = new MessageCenter();
 
server = new WebSocketServer({hostname:"localhost",port:12345})
server.on("connection",function(conn){
    mcServerSide.setConnection(conn);
    mcServerSide.invoke("whoAreYou",{key:"Any data",time:new Date(),buffer:new Buffer("hehe")},function(err,res){
        console.log(res);
    })
})
 
connection = new WebSocket("ws://localhost:12345/");
connection.on("open",function(){
    mcClientSide.setConnection(connection);
})
connection.on("close",function(){
    mcClientSide.unsetConnection();
})
 
mcClientSide.registerApi("whoAreYou",function(data,callback){
    console.log("Date is reserved",data.time);
    console.log("Buffer is reserved",data.buffer);
    console.log("It's time to ask who YOU are")
    callback(null,"I'm client and I got your data "+JSON.stringify(data));
    mcClientSide.invoke("areYouServer",null,function(err,data){
        console.log("get response from server:",data);
    })
})
mcServerSide.registerApi("areYouServer",function(data,callback){
    callback(null,"I'm server and I got your data "+JSON.stringify(data));
})
 

var invoke = mcClientSide.invoke("delayReturn",5000,function(err,data){
    console.error(err,data);
    console.assert(err.message === "timeout");
})
invoke.timeout(3000);
//or set for all invokes
mcClientSide.timeout = 3000;
//every request has a 3000 timeout.

mcServerSide.fireEvent("archive/update",{content:"Lorem Ipsum"})
//Note here we have a "event/" prefix so we don't always conflict with local events by accidents.
mcClientSide.on("event/archive/update",function(data){
    console.log("get data",data,"from event archive/update");
})

mcServerSide.registerApi("anyApi",function(_,callback){
    var stream = mcServerSide.createStream();
    // transfer just like normal object
    callback(null,stream)
    stream.write("can you get me?");
    stream.end("bye!");
})
mcClientSide.invoke("anyApi",{},function(err,stream){
    var result = [];
    stream.on("data",function(data){
        result.push(data);
    })
    stream.on("end",function(){
        console.log("stream end");
        console.log(result.join("\n"));
    });
    return;
})