git ssb

0+

mixmix / ssb-meme



Tree: bbaaa1c60c26a697ba2488dce104d17c1d016c5b

Files: bbaaa1c60c26a697ba2488dce104d17c1d016c5b / test / index.js

1343 bytesRaw
1const pull = require('pull-stream')
2const Server = require('scuttlebot')
3const { isBlobId } = require('ssb-ref')
4const fileType = require('file-type')
5
6const config = require('./config')
7// console.log('config:', config)
8
9console.log('*** installing ssb-server plugins ***')
10Server
11 .use(require('scuttlebot/plugins/master'))
12 .use(require('ssb-blobs'))
13 .use(require('../index.js'))
14
15console.log('*** starting ssb-server ***')
16const server = Server(config)
17
18const opts = {
19 query: 'herm',
20 // limit: 10
21}
22
23pull(
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