git ssb - filter out requests that are not valid

Dominic Tarr committed on 11/12/2017, 9:42:51 PM
Parent: 9268b78bc5cd805a89d0c37d82c87f25b03e1a09

changed

index.jsView
		@@ -1,8 +1,8 @@
1	1 …	var pull = require('pull-stream')
2	2 …	var GQ = require('gossip-query')
3	3 …	var hash = require('ssb-keys/util').hash
4		-
	4 …	+var ref = require('ssb-ref')
5	5 …	function getId(msg) {
6	6 …	return '%'+hash(JSON.stringify(msg, null, 2))
7	7 …	}
8	8 …
		@@ -35,8 +35,15 @@
35	35 …
36	36 …	store = Store(config)
37	37 …
38	38 …	var gq = GQ({
	39 …	+ isQuery: ref.isMsg,
	40 …	+ isRequest: function (n) {
	41 …	+ return Number.isInteger(n) && n < 0
	42 …	+ },
	43 …	+ isResponse: function (o) {
	44 …	+ return o && isObject(o)
	45 …	+ },
39	46 …	check: function (key, cb) {
40	47 …	store.keys.get(key, function (err, data) {
41	48 …	if(data) cb(null, data.value)
42	49 …	else
		@@ -83,8 +90,15 @@
83	90 …	status.ooo[id] = gq.state[id]
84	91 …	return status
85	92 …	})
86	93 …
	94 …	+ sbot.progress.hook(function (fn, args) {
	95 …	+ var prog = fn()
	96 …	+ prog.ooo = gq.progress()
	97 …	+ return prog
	98 …	+ })
	99 …	+
	100 …	+
87	101 …	sbot.on('rpc:connect', function (rpc, isClient) {
88	102 …	if(isClient) {
89	103 …	var stream = gq.createStream(rpc.id)
90	104 …	pull(stream, rpc.ooo.stream(function () {}), stream)

Dominic / ssb-ooo