Files: a82d9b053001af225a6db818036079f377f481d0 / modules / notifications.js
3961 bytesRaw
1 | |
2 | var h = require('hyperscript') |
3 | var u = require('../util') |
4 | var pull = require('pull-stream') |
5 | var Scroller = require('pull-scroll') |
6 | var paramap = require('pull-paramap') |
7 | var cont = require('cont') |
8 | var ref = require('ssb-ref') |
9 | var log = require('./scuttlebot').log |
10 | var get = require('./scuttlebot').get |
11 | var userstream = require('./scuttlebot').userstream |
12 | |
13 | exports.needs = { |
14 | message_render: 'first' |
15 | } |
16 | |
17 | exports.gives = { |
18 | builtin_tabs: true, |
19 | screen_view: true |
20 | } |
21 | |
22 | exports.create = function (api) { |
23 | |
24 | function notifications(ourIds) { |
25 | |
26 | function linksToUs(link) { |
27 | return link && link.link in ourIds |
28 | } |
29 | |
30 | function isOurMsg(id, cb) { |
31 | if (!id) return cb(null, false) |
32 | if (typeof id === 'object' && typeof id.link === 'string') id = id.link |
33 | if (!ref.isMsg(id)) return cb(null, false) |
34 | get(id, function (err, msg) { |
35 | if (err && err.name == 'NotFoundError') cb(null, false) |
36 | else if (err) cb(err) |
37 | else if (msg.content.type === 'issue' || msg.content.type === 'pull-request') |
38 | isOurMsg(msg.content.repo || msg.content.project, cb) |
39 | else cb(err, msg.author in ourIds) |
40 | }) |
41 | } |
42 | |
43 | function isAnyOurMessage(msg, ids, cb) { |
44 | cont.para(ids.map(function (id) { |
45 | return function (cb) { isOurMsg(id, cb) } |
46 | })) |
47 | (function (err, results) { |
48 | if (err) cb(err) |
49 | else if (results.some(Boolean)) cb(null, msg) |
50 | else cb() |
51 | }) |
52 | } |
53 | |
54 | return paramap(function (msg, cb) { |
55 | var c = msg.value && msg.value.content |
56 | if (!c || typeof c !== 'object') return cb() |
57 | if (msg.value.author in ourIds) return cb() |
58 | |
59 | if (c.mentions && Array.isArray(c.mentions) && c.mentions.some(linksToUs)) |
60 | return cb(null, msg) |
61 | |
62 | if (msg.private) |
63 | return cb(null, msg) |
64 | |
65 | switch (c.type) { |
66 | case 'post': |
67 | if (c.branch || c.root) |
68 | return isAnyOurMessage(msg, [].concat(c.branch, c.root), cb) |
69 | else return cb() |
70 | |
71 | case 'contact': |
72 | return cb(null, c.contact in ourIds ? msg : null) |
73 | |
74 | case 'vote': |
75 | if (c.vote && c.vote.link) |
76 | return isOurMsg(c.vote.link, function (err, isOurs) { |
77 | cb(err, isOurs ? msg : null) |
78 | }) |
79 | else return cb() |
80 | |
81 | case 'issue': |
82 | case 'pull-request': |
83 | return isOurMsg(c.project || c.repo, function (err, isOurs) { |
84 | cb(err, isOurs ? msg : null) |
85 | }) |
86 | |
87 | case 'issue-edit': |
88 | return isAnyOurMessage(msg, [c.issue].concat(c.issues), cb) |
89 | |
90 | default: |
91 | cb() |
92 | } |
93 | }, 4) |
94 | } |
95 | |
96 | function getFirstMessage(feedId, cb) { |
97 | userstream({id: feedId, gte: 0, limit: 1})(null, cb) |
98 | } |
99 | |
100 | return { |
101 | builtin_tabs: function () { |
102 | return ['Mentions'] |
103 | }, |
104 | |
105 | screen_view: function (path) { |
106 | if(path === 'Mentions') { |
107 | var ids = {} |
108 | var oldest |
109 | |
110 | var id = require('../keys').id |
111 | ids[id] = true |
112 | getFirstMessage(id, function (err, msg) { |
113 | if (err) return console.error(err) |
114 | if (!oldest || msg.value.timestamp < oldest) { |
115 | oldest = msg.value.timestamp |
116 | } |
117 | }) |
118 | |
119 | var content = h('div.column.scroller__content') |
120 | var div = h('div.column.scroller', |
121 | {style: {'overflow':'auto'}}, |
122 | h('div.scroller__wrapper', |
123 | content |
124 | ) |
125 | ) |
126 | |
127 | pull( |
128 | u.next(log, {old: false, limit: 100}), |
129 | notifications(ids), |
130 | pull.filter(), |
131 | Scroller(div, content, api.message_render, true, false) |
132 | ) |
133 | |
134 | pull( |
135 | u.next(log, {reverse: true, limit: 100, live: false}), |
136 | notifications(ids), |
137 | pull.filter(), |
138 | pull.take(function (msg) { |
139 | return !oldest ? true : msg.value.timestamp > oldest |
140 | }), |
141 | Scroller(div, content, api.message_render, false, false) |
142 | ) |
143 | |
144 | return div |
145 | } |
146 | } |
147 | } |
148 | } |
149 | |
150 |
Built with git-ssb-web