git ssb - Fix bugs · ansuz/dnssb@f1f274f0

cel committed on 11/1/2016, 1:07:24 AM
Parent: 4db28fa74d1966cfd674440c08a8bf2eb36f7c79

lib/server.js	changed
lib/ssb-dns.js	changed

lib/server.jsView
		@@ -28,16 +28,17 @@
28	28 …	res.end();
29	29 …	return;
30	30 …	}
31	31 …
32		- var qMap = q.reduce(function (map, q) {
33		- map[q.name.toLowerCase() + ':' + q.type] = true;
34		- }, {});
	32 …	+ var qMap = {}
	33 …	+ q.forEach(function (q) {
	34 …	+ qMap[q.name.toLowerCase() + ':' + q.type] = true;
	35 …	+ });
35	36 …
36	37 …	Pull(sbot.messagesByType({
37	38 …	type: 'ssb-dns',
38	39 …	}),
39		- pull.filter(function (msg) {
	40 …	+ Pull.filter(function (msg) {
40	41 …	var c = msg.value.content;
41	42 …	var record = c && c.record;
42	43 …	return record && qMap[record.name + ':' + record.type];
43	44 …	}),
		@@ -47,12 +48,8 @@
47	48 …	var types = records.map(function (r) { return r.type }).join(', ');
48	49 …	var vals = records.map(function (r) { return r.value }).join(', ');
49	50 …	console.log("%s (%s) => %s", names, types, vals);
50	51 …	}
51		- records.forEach(function (r) {
52		- if (!r.ttl) r.ttl = 500;
53		- if (!r.class) r.class = "IN";
54		- })
55	52 …	res.answer = records;
56	53 …	res.end();
57	54 …	}));
58	55 …	};

lib/ssb-dns.jsView
		@@ -1,7 +1,13 @@
1	1 …	var Pull = require("pull-stream");
2	2 …	var KVSet = require("kvset");
3	3 …
	4 …	+function fixRecord(r) {
	5 …	+ if (!r.ttl) r.ttl = 500;
	6 …	+ if (!r.class) r.class = "IN";
	7 …	+ if (r.value) r.data = r.value, delete r.value
	8 …	+}
	9 …	+
4	10 …	module.exports = function SsbDns(cb) {
5	11 …	var set = new KVSet()
6	12 …	return Pull.drain(function (msg) {
7	13 …	var c = msg.value.content;
		@@ -12,9 +18,11 @@
12	18 …	for (var key in set.heads) {
13	19 …	var value = set.heads[key];
14	20 …	var c = value.content;
15	21 …	var record = c && c.record;
16		- if (record) records.push(record);
	22 …	+ if (!record) continue;
	23 …	+ fixRecord(record);
	24 …	+ records.push(record);
17	25 …	}
18	26 …	cb(err, records);
19	27 …	});
20	28 …	};

ansuz / dnssb