Commit ada2e9cac25f910004c85ab51e8d6b3ece0805b4
expose status
Dominic Tarr committed on 11/9/2017, 12:25:47 AMParent: b77b50b17bad4787bb16fa8c11a4d2eefabdf0b9
Files changed
| index.js | changed |
| index.js | ||
|---|---|---|
| @@ -55,8 +55,9 @@ | ||
| 55 | 55 … | function get (id, cb) { |
| 56 | 56 … | gq.query(id, function (err, msg) { |
| 57 | 57 … | if(err) return cb(err) |
| 58 | 58 … | store.add(msg, function (err, data) { |
| 59 … | + data.ooo = true | |
| 59 | 60 … | cb(null, data) |
| 60 | 61 … | }) |
| 61 | 62 … | }) |
| 62 | 63 … | } |
| @@ -67,12 +68,23 @@ | ||
| 67 | 68 … | if(id.raw) fn(id.id, cb) |
| 68 | 69 … | else |
| 69 | 70 … | fn(id, function (err, value) { |
| 70 | 71 … | if(!err) cb(null, value) |
| 71 | - else get(id, cb) | |
| 72 … | + else get(id, function (err, data) { | |
| 73 … | + if(err) cb(err) | |
| 74 … | + else cb(null, data.value) | |
| 75 … | + }) | |
| 72 | 76 … | }) |
| 73 | 77 … | }) |
| 74 | 78 … | |
| 79 … | + sbot.status.hook(function (fn, args) { | |
| 80 … | + var status = fn() | |
| 81 … | + status.ooo = {} | |
| 82 … | + for(var id in gq.state) | |
| 83 … | + status.ooo[id] = gq.state[id] | |
| 84 … | + return status | |
| 85 … | + }) | |
| 86 … | + | |
| 75 | 87 … | sbot.on('rpc:connect', function (rpc, isClient) { |
| 76 | 88 … | if(isClient) { |
| 77 | 89 … | var stream = gq.createStream(rpc.id) |
| 78 | 90 … | pull(stream, rpc.ooo.stream(function () {}), stream) |
| @@ -87,6 +99,4 @@ | ||
| 87 | 99 … | get: get |
| 88 | 100 … | } |
| 89 | 101 … | } |
| 90 | 102 … | |
| 91 | - | |
| 92 | - | |
Built with git-ssb-web