views.jsView |
---|
78 | 78 … | |
79 | 79 … | content.appendChild(editor) |
80 | 80 … | } |
81 | 81 … | |
82 | | -var queryStream = function () { |
83 | | - var content = h('div.content') |
84 | | - |
85 | | - var screen = document.getElementById('screen') |
86 | | - |
87 | | - screen.appendChild(hyperscroll(content)) |
88 | | - |
89 | | - function createStream (opts) { |
90 | | - return pull( |
91 | | - |
92 | | - sbot.query({query: [{$filter: { value: {content: {type: 'post'}, timestamp: { $gt: 1 }}}}], reverse: true}), |
93 | | - |
94 | | - pull.map(function (msg) { |
95 | | - return render(msg) |
96 | | - }) |
97 | | - ) |
98 | | - } |
99 | | - |
100 | | - pull( |
101 | | - createStream({reverse: true, limit: 10}), |
102 | | - stream.bottom(content) |
103 | | - ) |
104 | | -} |
105 | | - |
106 | 82 … | var mentionsStream = function () { |
107 | 83 … | var content = h('div.content') |
108 | 84 … | |
109 | 85 … | var screen = document.getElementById('screen') |
127 | 103 … | stream.bottom(content) |
128 | 104 … | ) |
129 | 105 … | } |
130 | 106 … | |
131 | | -var logStream = function () { |
132 | | - var content = h('div.content') |
133 | | - var screen = document.getElementById('screen') |
134 | | - screen.appendChild(hyperscroll(content)) |
135 | | - |
136 | | - function createStream (opts) { |
137 | | - return pull( |
138 | | - More(sbot.createLogStream, opts), |
139 | | - pull.map(function (msg) { |
140 | | - return render(msg) |
141 | | - }) |
142 | | - |
143 | | - ) |
144 | | - } |
145 | | - |
146 | | - pull( |
147 | | - createStream({old: false, limit: 10}), |
148 | | - stream.top(content) |
149 | | - ) |
150 | | - |
151 | | - pull( |
152 | | - createStream({reverse: true, live: false, limit: 10}), |
153 | | - stream.bottom(content) |
154 | | - ) |
155 | | -} |
156 | | - |
157 | 107 … | var userStream = function (src) { |
158 | 108 … | var content = h('div.content') |
159 | 109 … | var screen = document.getElementById('screen') |
160 | 110 … | screen.appendChild(hyperscroll(content)) |
254 | 204 … | content.appendChild(rootMsg) |
255 | 205 … | } |
256 | 206 … | }) |
257 | 207 … | |
258 | | - |
259 | | - sbot.backlinks({query: [{$filter: {dest: src}}]}), |
260 | | - pull.drain(function (msg) { |
261 | | - console.log(msg) |
262 | | - content.appendChild(render(msg)) |
263 | | - }) |
264 | | - )*/ |
265 | | - |
266 | 208 … | } |
267 | 209 … | |
268 | | - |
269 | | - var content = h('div.content') |
270 | | - var screen = document.getElementById('screen') |
271 | | - screen.appendChild(hyperscroll(content)) |
272 | | - sbot.get(src, function (err, data) { |
273 | | - if (err) {console.log('could not find message') } |
274 | | - data.value = data |
275 | | - var root = src |
276 | | - if (data.value.content.root) |
277 | | - root = data.value.content.root |
278 | | - sbot.get(root, function (err, data) { |
279 | | - if (err) { console.log('could not find root')} |
280 | | - data.value = data |
281 | | - data.key = root |
282 | | - content.appendChild(render(data)) |
283 | | - pull( |
284 | | - sbot.links({rel: 'root', dest: root, values: true, keys: true, live: true}), |
285 | | - pull.drain(function (msg) { |
286 | | - if (msg.value) |
287 | | - content.appendChild(render(msg)) |
288 | | - }) |
289 | | - ) |
290 | | - }) |
291 | | - }) |
292 | | -}*/ |
293 | | - |
294 | 210 … | var keyPage = function () { |
295 | 211 … | var screen = document.getElementById('screen') |
296 | 212 … | |
297 | 213 … | var importKey = h('textarea.import', {placeholder: 'Import a new public/private key', name: 'textarea', style: 'width: 97%; height: 100px;'}) |
326 | 242 … | |
327 | 243 … | screen.appendChild(hyperscroll(content)) |
328 | 244 … | } |
329 | 245 … | |
| 246 … | +function everythingStream () { |
| 247 … | + var content = h('div.content') |
330 | 248 … | |
| 249 … | + var screen = document.getElementById('screen') |
| 250 … | + |
| 251 … | + screen.appendChild(hyperscroll(content)) |
| 252 … | + |
| 253 … | + function newStream () { |
| 254 … | + return pull( |
| 255 … | + sbot.query({query: [{$filter: { value: { timestamp: { $gt: 0 }}}}], old: false, live: true}), |
| 256 … | + pull.map(function (msg) { |
| 257 … | + return render(msg) |
| 258 … | + }) |
| 259 … | + ) |
| 260 … | + } |
| 261 … | + |
| 262 … | + function oldStream () { |
| 263 … | + return pull( |
| 264 … | + sbot.query({query: [{$filter: { value: { timestamp: { $gt: 0 }}}}], reverse: true, live: false}), |
| 265 … | + pull.map(function (msg) { |
| 266 … | + return render(msg) |
| 267 … | + }) |
| 268 … | + ) |
| 269 … | + } |
| 270 … | + |
| 271 … | + pull( |
| 272 … | + oldStream(), |
| 273 … | + stream.bottom(content) |
| 274 … | + ) |
| 275 … | + |
| 276 … | + pull( |
| 277 … | + newStream(), |
| 278 … | + stream.top(content) |
| 279 … | + ) |
| 280 … | +} |
| 281 … | + |
331 | 282 … | function hash () { |
332 | 283 … | return window.location.hash.substring(1) |
333 | 284 … | } |
334 | 285 … | |
338 | 289 … | if (ref.isFeed(src)) { |
339 | 290 … | userStream(src) |
340 | 291 … | } else if (ref.isMsg(src)) { |
341 | 292 … | msgThread(src) |
342 | | - } else if (src == 'all') { |
343 | | - logStream() |
344 | | - } else if (src == 'posts'){ |
345 | | - queryStream() |
| 293 … | + } else if (src == 'queue') { |
| 294 … | + mentionsStream() |
346 | 295 … | } else if (src == 'about') { |
347 | 296 … | about() |
348 | 297 … | } else if (src == 'edit') { |
349 | 298 … | edit() |
350 | 299 … | } else if (src == 'key') { |
351 | 300 … | keyPage() |
352 | 301 … | } else { |
353 | | - mentionsStream() |
| 302 … | + everythingStream() |
354 | 303 … | } |
355 | 304 … | } |