git ssb - get should fallback to ooo if we do not have the massage locally

Dominic Tarr committed on 11/8/2017, 12:44:42 AM
Parent: 01fc1dd4552fcb7a246dc2551b28a35e2b68d7f3

changed

index.jsView
		@@ -39,9 +39,9 @@
39	39 …	check: function (key, cb) {
40	40 …	store.keys.get(key, function (err, data) {
41	41 …	if(data) cb(null, data.value)
42	42 …	else
43		- sbot.get(key, function (err, msg) {
	43 …	+ sbot.get({id:key, raw: true}, function (err, msg) {
44	44 …	cb(null, msg)
45	45 …	})
46	46 …	})
47	47 …	},
		@@ -51,8 +51,29 @@
51	51 …	else cb(null, msg)
52	52 …	}
53	53 …	})
54	54 …
	55 …	+ function get (id, cb) {
	56 …	+ gq.query(id, function (err, msg) {
	57 …	+ if(err) return cb(err)
	58 …	+ store.add(msg, function (err, data) {
	59 …	+ cb(null, data)
	60 …	+ })
	61 …	+ })
	62 …	+ }
	63 …	+
	64 …	+ sbot.get.hook(function (fn, args) {
	65 …	+ var id = args[0]
	66 …	+ var cb = args[1]
	67 …	+ if(id.raw) fn(id.id, cb)
	68 …	+ else
	69 …	+ fn(id, function (err, value) {
	70 …	+ console.log("GOT", id, err, value)
	71 …	+ if(!err) cb(null, value)
	72 …	+ else get(id, cb)
	73 …	+ })
	74 …	+ })
	75 …	+
55	76 …	sbot.on('rpc:connect', function (rpc, isClient) {
56	77 …	console.log('CONNECT...', id.substring(0, 5), rpc.id.substring(0, 5))
57	78 …	if(isClient) {
58	79 …	var stream = gq.createStream(rpc.id)
		@@ -64,15 +85,8 @@
64	85 …	stream: function () {
65	86 …	//called by muxrpc, so remote id is set as this.id
66	87 …	return gq.createStream(this.id)
67	88 …	},
68		- get: function (id, cb) {
69		- gq.query(id, function (err, msg) {
70		- if(err) return cb(err)
71		- store.add(msg, function (err, data) {
72		- cb(null, data)
73		- })
74		- })
75		- }
	89 …	+ get: get
76	90 …	}
77	91 …	}
78	92 …

Dominic / ssb-ooo