Files: 85187f4ebcda55555e5b7b2093c9129315c64e0b / test / index.js
1343 bytesRaw
1 | const pull = require('pull-stream') |
2 | const Server = require('scuttlebot') |
3 | const { isBlobId } = require('ssb-ref') |
4 | const fileType = require('file-type') |
5 | |
6 | const config = require('./config') |
7 | // console.log('config:', config) |
8 | |
9 | console.log('*** installing ssb-server plugins ***') |
10 | Server |
11 | .use(require('scuttlebot/plugins/master')) |
12 | .use(require('ssb-blobs')) |
13 | .use(require('../index.js')) |
14 | |
15 | console.log('*** starting ssb-server ***') |
16 | const server = Server(config) |
17 | |
18 | const opts = { |
19 | query: 'herm', |
20 | // limit: 10 |
21 | } |
22 | |
23 | pull( |
24 | server.meme.query(opts), |
25 | pull.map(m => m.value.content.mentions), |
26 | pull.collect((err, data) => { |
27 | var result = data.reduce((soFar, mentions) => { |
28 | mentions |
29 | .filter(m => isBlobId(m.link)) |
30 | .filter(m => m.name.indexOf(opts.query) > -1) |
31 | .forEach(({ link, name }) => { |
32 | if (!soFar[link]) soFar[link] = [name] |
33 | else soFar[link].push(name) |
34 | }) |
35 | |
36 | return soFar |
37 | }, {}) |
38 | |
39 | console.log(result) |
40 | |
41 | pull( |
42 | server.blobs.get('&pwDBdb1KWoLVtaYjIA8p1PUXYcgflIWhsig6ESIIz80=.sha256'), |
43 | pull.drain((buff) => { |
44 | console.log('buff', buff) |
45 | console.log(fileType(buff)) |
46 | }) |
47 | ) |
48 | |
49 | server.close() |
50 | }) |
51 | // pull.drain( |
52 | // (m) => console.log('!', m), |
53 | // () => { |
54 | // console.log('done') |
55 | // server.close() |
56 | // } |
57 | // ) |
58 | ) |
59 | |
60 | |
61 |
Built with git-ssb-web