etnbrd/flx-compiler

var zmq = require('zmq')
  , input = zmq.socket('pull')
  , output = zmq.socket('pub');

output.identity = "router";

var nid = 0;
var nodes = {};
var fx = {};
function default_node() {
  return {
    addrs : []
  };
}

function s(id) { // TODO te be deleted, not used anymore
  return ('' + id)[0];
}

input.bind('tcp://127.0.0.1:3000');
output.bind('tcp://127.0.0.1:3001');
console.log('Router bound to port 3000/3001');

input.on('message', function(id, blank, msg){

  id = '' + id;
  var type = id[0];
  var addr = id.substring(1); //Array.prototype;
  msg = msg ? JSON.parse(msg) : undefined;

  msg = ( msg && msg != "undefined" ) ? JSON.parse(msg) : undefined;

  switch(type) {
    case 'R': register(id, msg); break;
    case 'N': ackNode(id, msg); break;
    case 'M': postMsg(addr, msg); break;
  }
});

function register(id, msg) {
  console.log("registering :: N" + nid);
  output.send([id + msg, ' ', nid++]);
}

function ackNode(id, msg) {
  if (!nodes[id]) {
    nodes[id] = default_node();
    setTimeout(registered, 0, id);
  }

  if (msg) {
    for (var i = 0; i < msg.length; i++) { var addr = msg[i];
      registerFx(addr, undefined, id);
      nodes[id].addrs.push(addr);
    };

    setTimeout(acknowledged, 0, id, msg);
  }
}

function postMsg(addr, body) {
  console.log("msg received ", addr, body);
}







// var state = false;
// setInterval(function(){
//   console.log((state = !state) ? "tic" : "toc");
// }, 1000);

// TODO make the messages structures VERY CLEAR
// not embedded inside tons of logic code

function registerFx(addr, fn, node) {
  if (fx[addr]) {
    fx[addr].fn = fn || fx[addr].fn;
    fx[addr].node = node || fx[addr].node;

    if (fx[addr].transition) {
      fx[addr].postMoveCallback(node, addr);
      fx[addr].transition = false;
    }
  } else {
    fx[addr] = {fn: fn, node: node};
  }
}

function moveFx(addr, n, callback) {

  output.send([n, ' ', JSON.stringify({
    addr: addr,
    fn: fx[addr].fn.toString()
  })]);
  fx[addr].transition = true;
  fx[addr].postMoveCallback = callback;
}

function post(addr, msg) {
  output.send(["M"+addr, ' ', JSON.stringify(msg)]);
}

function registered(id) {
  console.log("registered " + id);

  registerFx("tic", function(test){return {addr: "tac"}});
  registerFx("tac", function(test){return {addr: "tic"}});

  moveFx("tic", id, function(id, addr){console.log("function moved ", id, addr)});
}

function acknowledged(id, msg) {
  console.log(id + " acknowledged " + msg);

  post("tic", "this is a test");
}