Commit df94322b7fbb68520643eed377fd4bbc72294bfa
validate your local log
Dominic Tarr committed on 4/11/2017, 5:36:08 AMParent: 9cfdc7fee9e0cb2d8ab16496dbf8c093c8051379
Files changed
example.js | changed |
example.js | ||
---|---|---|
@@ -1,33 +1,32 @@ | ||
1 | 1 … | var pull = require('pull-stream') |
2 … | + | |
2 | 3 … | var v = require('./') |
3 | 4 … | var state = { |
4 | 5 … | queue: [], |
5 | 6 … | feeds: {}, |
6 | 7 … | error: null |
7 | 8 … | } |
9 … | + | |
8 | 10 … | var c = 0, e = 0, start = Date.now(), l = 0 |
9 | 11 … | require('ssb-client')(function (err, sbot) { |
10 | 12 … | if(err) throw err |
11 | 13 … | pull( |
12 | - sbot.createLogStream({keys: false}), | |
14 … | + sbot.createLogStream(), | |
13 | 15 … | pull.drain(function (msg) { |
14 | - state = v.append(state, msg) | |
15 | - l += JSON.stringify(msg, null, 2).length | |
16 … | + state = v.append(state, msg.value) | |
16 | 17 … | if(state.error) { |
17 | - // console.log(msg) | |
18 | - // console.log(state.feeds[msg.author]) | |
19 | - console.log(state.error.message) | |
20 | 18 … | e++ |
19 … | + var err = state.error | |
20 … | + state.error = null | |
21 … | + console.log(err.message) | |
22 … | + return false | |
21 | 23 … | } |
22 | 24 … | state.queue.shift() |
23 | 25 … | var s = ((Date.now() - start)/1000) |
24 | 26 … | if(!(c++%100)) { |
25 | - console.log(s, e, c, c / s, l, l / s) | |
27 … | + console.log(s, e, c, c / s) | |
26 | 28 … | } |
29 … | + return true | |
27 | 30 … | }, sbot.close) |
28 | 31 … | ) |
29 | 32 … | }) |
30 | - | |
31 | - | |
32 | - | |
33 | - |
Built with git-ssb-web