Files: c6837aafbbd284d8fbf9d6e5612e78a2ccf84286 / feed / pull / private.js
933 bytesRaw
1 | const nest = require('depnest') |
2 | const defer = require('pull-defer') |
3 | const onceTrue = require('mutant/once-true') |
4 | |
5 | exports.gives = nest('feed.pull.private') |
6 | exports.needs = nest({ |
7 | 'sbot.obs.connection': 'first' |
8 | }) |
9 | |
10 | exports.create = function (api) { |
11 | return nest('feed.pull.private', function (opts) { |
12 | // handle last item passed in as lt |
13 | var lt = typeof opts.lt === 'object' |
14 | ? opts.lt.timestamp |
15 | : opts.lt |
16 | delete opts.lt |
17 | |
18 | // HACK: needed to select correct index and handle lt |
19 | opts.query = [ |
20 | {$filter: { |
21 | timestamp: lt |
22 | ? {$lt: lt, $gt: 0} |
23 | : {$gt: 0} |
24 | }} |
25 | ] |
26 | |
27 | return StreamWhenConnected(api.sbot.obs.connection, (sbot) => { |
28 | return sbot.private.read(opts) |
29 | }) |
30 | }) |
31 | } |
32 | |
33 | function StreamWhenConnected (connection, fn) { |
34 | var stream = defer.source() |
35 | onceTrue(connection, function (connection) { |
36 | stream.resolve(fn(connection)) |
37 | }) |
38 | return stream |
39 | } |
40 |
Built with git-ssb-web