node.js function access to libmill


go style concurrency for node.

an experiment

``bash
#install libmill and libsodium dependencies
$ git clone https://github.com/sustrik/libmill.git
$ cd libmill && ./autogen.sh && ./configure && make -j 8 && sudo make install
$ sudo /sbin/ldconfig # linux only

$ git clone https://github.com/jedisct1/libsodium.git
$ cd libsodium && ./autogen.sh && ./configure && make -j 8 && sudo make install
$ sudo /sbin/ldconfig # linux only

$ npm i && npm t
`

tcp library

for msgs over tcp/ip, a server can use tcplisten(). once a client connects, the server can use tcpaccept() to establish bidirectional tcp streams.

$3


`js
var lib = require('libmill');

/ create an ipaddr /
var ipaddr = lib.iplocal(5555);

/ listen on the ipaddr /
var ls = lib.tcplisten(ipaddr);
console.log('listening on port %s', lib.tcpport(ls));

while(1){
/ accept and establish tcp connection /
var as = lib.tcpaccept(ls);
console.log('\nnew connection\nmsg recvd: ' + lib.tcprecvuntil(as));

/ close tcp connection /
lib.tcpclose(as);
}
`


$3


`js
var lib = require('libmill');

/ create an ipaddr /
var ipaddr = lib.iplocal(5555);

/ connect over the ipaddr /
var cs = lib.tcpconnect(ipaddr);
var str = 'go style concurrency for node', num = 1;

/ send a few msg before tcpflush /
/ delimiter is set to '\r', tells tcprecvuntil when to finish /
send('msg # ', str);
send('msg # ', str);
send('msg #', str+'\r');
function send(n, msg){
n+= num+++msg+'\n';
lib.tcpsend(cs, new Buffer(n));
}

/ tcpsend() stores data in user space and tcpflush() pushes it to kernel /
lib.tcpflush(cs);
`

udp library

$3

`js
var lib = require('libmill');

/ create an ipaddr /
var ipaddr = lib.iplocal(4444);

/ listen on ipaddr /
var ls = lib.udplisten(ipaddr);
process.stdout.write('udp socket listening on port: ' + lib.udpport(ls) + '\n');

/* next, to get udp msgs, use udprecv
if you pass a cb function as the 3rd param, the call will use libuv async
the callback's param will contain your msg

otherwise w/out a cb, it will block and udprecv's return value is your msg */


/ the non-blocking way (a for async) /
lib.udprecv(ls, 255, function (msg) {
var buf = String(msg.buf) / msg.buf is a node buffer of the packet body /
var addr = msg.addr / string address of packet origin /
});

/ the blocking way /
while (1) {
var sz = 13;
var deadline = 10;

var msg = lib.udprecv(ls, sz, deadline); / deadline is optional param /
process.stdout.write(msg.buf + '\n');
}
`

$3


`js
var s = lib.udplisten(ipaddr);
var buf = new Buffer('Hello, world!');

lib.udpsend(s, ipaddr, buf);
`


test


see test` directory

license

MIT

_{tested on circleci linux and osx.}