Alexandre Lacheze alexstrat

alexstrat / gist:4069162

Created November 13, 2012 23:33

How to launch KadOH UDP DHT and start the debug UI

First of all, clone the repo somewhere :

$ git clone https://github.com/jinroh/kadoh.git
$ cd kadoh

Then, intall the (dev) dependencies :

alexstrat / middle.js

Created August 13, 2012 16:27

Middleware proposal

	var MY_ID = "..";

	reactor.use({
	queried: function (rpc) {
	rpc.quering = new Peer(rpc.queryingAddress, rpc.params.id);

	rpc.onComplete(function(peers) {
	rpc.response = rpc.response \|\| {};

	rpc.response.nodes = peers.toRawArray();

alexstrat / gist:2924553

Created June 13, 2012 14:52

	var assert = require('assert');

	var reg = /\b(?:0x)?([A-Fa-f0-9])+\b/g;

	assert.deepEqual('0x5f ff56'.match(reg), ['0x5f', 'ff56']);
	assert.deepEqual('0x5f plain0x5ftext'.match(reg), ['0x5f']);
	assert.deepEqual('0x5F DD52'.match(reg), ['0x5F', 'DD52']);
	assert.deepEqual('Z4FD'.match(reg), null);

	var Rectangle = function(l,h) {

alexstrat / gist:2923510

Created June 13, 2012 11:20

	case 'FIND_VALUE':
	if(args[1] !== null) {
	html = [
	'<ul>',
	'<i>FOUND</i><br>',
	'<li><b>Value : </b><code>'+args[1].value+'</code></li>',
	'<li><b>Expiration : </b>',
	(args[1].exp<0) ?
	'<i>never</i>':
	'<time rel=\'tooltip\' datetime=\''+(new Date(args[1].exp)).toISOString()+'\' data-placement=\'bottom\'>'+(new Date(args[1].exp).toString())+'</time>',

alexstrat / gist:2917220

Created June 12, 2012 12:28

	queried: function(rcp) {
	switch(rpc.getMethod()) {
	case 'PING':
	rpc.resolve();
	break;
	case 'FIND_NODE':
	rpc.resolve(
	this.routingTable.getClosePeers(
	rpc.getTarget(),
	BETA,

alexstrat / client.js

Created May 23, 2012 15:03

	var util = require('util');
	var events = require('events');
	var io = require('socket.io-client');

	function Socket(type, listener, host, io_options) {
	events.EventEmitter.call(this);

	if (typeof listener === 'function')
	this.on('message', listener);

alexstrat / node.js

Created May 23, 2012 15:03

	var StateEventEmitter = require('./util/state-eventemitter'),
	Deferred = require('./util/deferred'),
	Crypto = require('./util/crypto'),
	PeerArray = require('./util/peerarray'),
	XORSortedPeerArray = require('./util/xorsorted-peerarray'),
	IterativeDeferred = require('./util/iterative-deferred'),

	globals = require('./globals.js'),

	RoutingTable = require('./dht/routing-table'),

alexstrat / gist:2731224

Created May 19, 2012 15:26

Wiki example

	Deferred = require('./util/deferred');

	var linked_list = function(key) {
	return {
	value : key*key,
	nextKey : (key <10) ? (key)+1 : false
	};
	};

	var GetNext = Deferred.extend({

alexstrat / iterative-mapreduce.js

Created May 15, 2012 13:59

Iterative map/reduce

	var Deferred = require('./deferred');

	var IterativeMapReduce = module.exports = Deferred.extend({
	initialize: function() {
	this.supr();
	this._mapOnFly;

	//default finish function
	this.finish_function = function(end_value, reducer_result) {
	this.resolve(reducer_result);

alexstrat / index.js

Created April 26, 2012 13:31

proxy-server

	httpProxy = require('http-proxy');

	httpProxy.createServer({
	router: {
	//UI
	'kadoh.fr.nf' : '127.0.0.1:8080',

	//bosh
	'bosh.kadoh.fr.nf' : '127.0.0.1:5280',