X-Git-Url: http://git.pjr.cc/?p=random_node_code.git;a=blobdiff_plain;f=bgpfake%2Fbf.js;fp=bgpfake%2Fbf.js;h=f90a42fd6391a05c06fd1f7a6fa3030883f9c64f;hp=0000000000000000000000000000000000000000;hb=1ea948ff48a7a490c199e4402a7050acd892b1ad;hpb=008863e49aed995e8b05ef846350b9dcf3187dd1

diff --git a/bgpfake/bf.js b/bgpfake/bf.js
new file mode 100644
index 0000000..f90a42f
--- /dev/null
+++ b/bgpfake/bf.js
@@ -0,0 +1,270 @@
+var myas=1234;
+var myip="10.99.99.1";
+
+var net = require('net');
+
+var scon;
+
+
+function createentry(i) {
+	// split into octets
+	var a = 16;
+	var b = 0;
+
+	// c is easy...
+	var c = (i%255)+1;
+	//console.log("i is now: "+i);
+
+	// if we're above 256....
+	if(i>255) {
+		i = i >> 8;
+		//console.log("i is now: "+i);
+		b = i%255;
+	}
+
+	// if we're still above 256....
+	if(i>255) {
+		i = i >> 8;
+		//console.log("i is now: "+i);
+		a+=((i<<8)%255);
+	}
+	return a+"."+b+"."+c;
+}
+
+function createaspath(i) {
+	var n=(i%5)+2;
+	var as = 1024;
+	var ret = new Array();
+
+	for(var t=0; t<n; t++) {
+		i = i << 1;
+		as = 1024 + (i%30000);
+		ret[t] = as;
+	}
+	return ret;
+}
+
+console.log("startup....");
+
+
+var num_to_create = 200000;
+
+var data = new Array();
+
+console.log("start construction");
+for(var t=0; t<num_to_create; t++) {
+	var thisdata = new Array();
+	thisdata[0] = createentry(t);
+	//console.log("create entry from "+thisdata[0]+" with " + t);
+	thisdata[1] = createaspath(t);
+	// we construct the update messages while we do this
+
+	// ok, that was dumb
+	thisdata[2] = constructUpdateMessage(thisdata);
+	data[t] = thisdata;
+
+}
+console.log("finish construction");
+
+
+//console.log("data: " + data.toString());
+//console.log("Done!: " + data.length);
+
+function parseBuffer(b, c) {
+	var len = b.readUInt16BE(16);
+	var type = b.readUInt8(18);
+
+	console.log("got input: " + len + ", type: " + type);
+
+	if(type == 1) {
+		var vers = b.readUInt8(19);
+		var as = b.readUInt16BE(20);
+		var ht = b.readUInt16BE(22);
+		var ot1 = b.readUInt8(24);
+		var ot2 = b.readUInt8(25);
+		var ot3 = b.readUInt8(26);
+		var ot4 = b.readUInt8(27);
+		var opl = b.readUInt8(28);
+		console.log("got open type, vers: "+vers+", as: " + as);
+		console.log("ht: " + ht + ", id: "+ot1+"."+ot2+"."+ot3+"."+ot4+", opl: "+opl);
+
+
+		console.log("sending our open type");
+		var out = new Buffer(29);
+
+
+		out.fill(0xff, 0, 16);
+		out.writeUInt16BE(29, 16);
+		out.writeUInt8(1, 18);
+		out.writeUInt8(4, 19);
+		out.writeUInt16BE(myas, 20);
+		out.writeUInt16BE(90, 22);
+		out.writeUInt8(10, 24);
+		out.writeUInt8(99, 25);
+		out.writeUInt8(99, 26);
+		out.writeUInt8(1,27);
+		out.writeUInt8(0,28);
+
+		c.write(out);
+	} else if(type == 4) {
+		console.log("writing keepalive - exact as sent");
+		c.write(b);
+	} else if(type == 2) {
+		console.log("got update...");
+		beginUpdateSend(c);
+	} else {
+		console.log("sending end...");
+		c.end();
+	}
+
+	
+}
+
+// this function gets prefix t from data[] and then
+// creates an update message for it
+function constructUpdateMessage(localdata) {
+	//console.log("Construction update for "+t);
+	var bsize = 0;
+
+	//console.log("localdata0: " + localdata[0]);
+	//console.log("localdata1: " + localdata[1]);
+	//console.log("localdata0 - : " + typeof localdata[1]);
+	//console.log("localdata1 - : " + typeof localdata[1]);
+
+	// first the header components
+	bsize += 16;
+
+	// next the length component
+	bsize += 2;
+
+	// next the n unfeasible
+	bsize += 2;
+
+	// next, path attr length
+	bsize += 2;
+
+
+	// now we begin the path attrs
+	// first origin - simple
+	var aspathn = 4;
+
+	// next as path - hard, flag + type + len + aspath segment
+	aspathn += 3;
+
+	// as path segment size = 1 (type), + 1 (len) + as's*2
+	var aspathlen = ((localdata[1].length+1)*2)+1+1;
+	aspathn += aspathlen;
+	
+	// now next hop attrs = flag (1) + type (1) + len (1) + octets (4);
+	aspathn += 7;
+	bsize += aspathn;
+
+	// now nlri = prefix len (1) + prefix fixed in our case (3)
+	bsize += 4;
+
+	// fudge
+	bsize+=1;
+
+	//console.log("size: " + bsize + ", an: " + aspathn + " al:" + aspathlen);
+	var buf = new Buffer(bsize);
+	var bp = 0;
+
+	// now lets create the buffer
+	buf.fill(0xff, bp, bp+16);
+	bp+=16;
+	buf.writeUInt16BE(bsize, bp);
+	bp+=2;
+	buf.writeUInt8(2, bp);
+	bp++;
+	buf.writeUInt16BE(0, bp);
+	bp+=2;
+	buf.writeUInt16BE(aspathn, bp);
+	bp+=2;
+
+	// path attr
+	// origin
+	buf.writeUInt8(0x40, bp);
+	bp++;
+	buf.writeUInt8(1, bp);
+	bp++;
+	buf.writeUInt8(1, bp);
+	bp++;
+	buf.writeUInt8(0, bp);
+	bp++;
+
+	// as path
+	buf.writeUInt8(0x40, bp);
+	bp++;
+	buf.writeUInt8(2, bp);
+	bp++;
+	buf.writeUInt8(aspathlen, bp);
+	bp++;
+	buf.writeUInt8(2, bp);
+	bp++;
+	buf.writeUInt8(localdata[1].length+1, bp);
+	bp++;
+	//console.log("writing in my aspath: "+myas);
+	buf.writeUInt16BE(myas, bp);
+	bp+=2;
+	localdata[1].forEach(function (ed) {
+		//console.log("writing in aspath: "+ed);
+		buf.writeUInt16BE(ed, bp);
+		bp+=2;
+	});
+
+	// next hop
+	buf.writeUInt8(0x40, bp);
+	bp++;
+	buf.writeUInt8(3, bp);
+	bp++;
+	buf.writeUInt8(4, bp);
+	bp++;
+	myip.split(".").forEach(function (ed) {
+		//console.log("writing in next hop info: " + ed);
+		buf.writeUInt8(parseInt(ed), bp);
+		bp++;
+	}); 
+
+	// last, nlri
+	buf.writeUInt8(24, bp);
+	bp++;
+	localdata[0].split(".").forEach(function(ed){
+		//console.log("Writing in nlri: "+ed);
+		buf.writeUInt8(parseInt(ed), bp);
+		bp++;
+	});
+
+	return buf;
+}
+
+// start sending updates messages
+function beginUpdateSend(c) {
+	data.forEach(function(led) {
+		c.write(led[2]);
+	});
+}
+
+function serverconnection(c) {
+
+	scon = c;
+
+	c.on("end", function() {
+		console.log("Server disconnected");
+	});
+
+	c.on("data", function(buffer) {
+		parseBuffer(buffer, c);
+	});
+
+	console.log("Service connected from: " + c.remoteAddress);
+
+	//c.write("hello\r\n");
+}
+
+console.log("Prefixes created, starting server");
+
+var server = net.createServer(serverconnection);
+
+server.listen(179, function() {
+	console.log("Server bound");
+});