| mvd/views.jsView |
|---|
| 1 | | -var pull = require('pull-stream') |
| 1 … | +var {pull, filter} = require('pull-stream') |
| 2 … | +var para = require('pull-paramap') |
| 2 | 3 … | var human = require('human-time') |
| 3 | 4 … | var sbot = require('./scuttlebot') |
| 4 | 5 … | var hyperscroll = require('hyperscroll') |
| 5 | 6 … | var hyperfile = require('hyperfile') |
| 77 | 78 … | pull.filter(function (msg) { |
| 78 | 79 … | return ((msg.value.private == true) || ('string' == typeof msg.value.content)) |
| 79 | 80 … | }), |
| 80 | 81 … | pull.map(function (msg) { |
| 81 | | - |
| 82 | | - var unboxed = ssbKeys.unbox(msg.value.content, keys) |
| 83 | | - if (unboxed) { |
| 84 | | - msg.value.content = unboxed |
| 85 | | - msg.value.private = true |
| 86 | | - return render(msg) |
| 87 | | - } else { |
| 88 | | - return render(msg) |
| 89 | | - } |
| 90 | | - } else {return render(msg)}*/ |
| 91 | | - return render(msg) |
| 82 … | + return render(msg) |
| 92 | 83 … | }) |
| 93 | 84 … | ) |
| 94 | 85 … | } |
| 95 | 86 … | |
| 101 | 92 … | query: [ |
| 102 | 93 … | { |
| 103 | 94 … | $filter: { |
| 104 | 95 … | value: { |
| 105 | | - content: {type: 'post'}, |
| 96 … | + content: {type: 'post'}, |
| 106 | 97 … | timestamp: { |
| 107 | 98 … | $gt: 0 |
| 108 | 99 … | } |
| 109 | 100 … | } |
| 117 | 108 … | createStream({ |
| 118 | 109 … | limit: 100, |
| 119 | 110 … | old: false, |
| 120 | 111 … | live: true, |
| 121 | | - query: [{$filter: { value: { timestamp: { $gt: 0 }}}}] |
| 112 … | + query: [{$filter: { value: { content: {type: 'post'}, timestamp: { $gt: 0 }}}}] |
| 122 | 113 … | }), |
| 123 | 114 … | stream.top(content) |
| 124 | 115 … | ) |
| 125 | | - |
| 126 | | - |
| 127 | | - |
| 128 | | - return pull( |
| 129 | | - Next(sbot.query, opts, ['value', 'timestamp']), |
| 130 | | - pull.map(function (msg) { |
| 131 | | - if (msg.value) { |
| 132 | | - if (msg.value.timestamp > Date.now()) { |
| 133 | | - return h('div.future') |
| 134 | | - } else { |
| 135 | | - return render(msg) |
| 136 | | - } |
| 137 | | - } |
| 138 | | - }) |
| 139 | | - ) |
| 140 | | - } |
| 141 | | - |
| 142 | | - pull( |
| 143 | | - createStream({ |
| 144 | | - limit: 10, |
| 145 | | - reverse: true, |
| 146 | | - live: false, |
| 147 | | - query: [{$filter: { value: { private: true, timestamp: { $gt: 0 }}}}] |
| 148 | | - }), |
| 149 | | - stream.bottom(content) |
| 150 | | - ) |
| 151 | | - |
| 152 | | - pull( |
| 153 | | - createStream({ |
| 154 | | - limit: 10, |
| 155 | | - old: false, |
| 156 | | - live: true, |
| 157 | | - query: [{$filter: { value: { private: true, timestamp: { $gt: 0 }}}}] |
| 158 | | - }), |
| 159 | | - stream.top(content) |
| 160 | | - )*/ |
| 161 | | - |
| 162 | | - |
| 163 | | - |
| 164 | | - return pull( |
| 165 | | - More(sbot.createLogStream, opts), |
| 166 | | - pull.filter(function (msg) { |
| 167 | | - return 'string' == typeof msg.value.content |
| 168 | | - }), |
| 169 | | - pull.filter(function (msg) { |
| 170 | | - var unboxed = ssbKeys.unbox(msg.value.content, keys) |
| 171 | | - if (unboxed) { |
| 172 | | - msg.value.content = unboxed |
| 173 | | - msg.value.private = true |
| 174 | | - return msg |
| 175 | | - } else { |
| 176 | | - return msg |
| 177 | | - } |
| 178 | | - }), |
| 179 | | - pull.map(function (msg) { |
| 180 | | - return render(msg) |
| 181 | | - }) |
| 182 | | - ) |
| 183 | | - } |
| 184 | | - |
| 185 | | - pull( |
| 186 | | - createStream({old: false, limit: 1000}), |
| 187 | | - stream.top(content) |
| 188 | | - ) |
| 189 | | - |
| 190 | | - pull( |
| 191 | | - createStream({reverse: true, live: false, limit: 1000}), |
| 192 | | - stream.bottom(content) |
| 193 | | - )*/ |
| 194 | 116 … | } |
| 195 | 117 … | |
| 196 | 118 … | var queueStream = function () { |
| 197 | 119 … | var content = h('div.content') |
| 572 | 494 … | |
| 573 | 495 … | function createStream (opts) { |
| 574 | 496 … | return pull( |
| 575 | 497 … | Next(sbot.query, opts, ['value', 'timestamp']), |
| 576 | | - pull.map(function (msg) { |
| 498 … | + para(function (msg, cb) { |
| 577 | 499 … | sbot.friends.get({source: src, dest: msg.value.author}, function (err, data) { |
| 500 … | + if (err) cb(err) |
| 578 | 501 … | if (data === true) { |
| 579 | | - return content.appendChild(render(msg)) |
| 580 | | - console.log(msg) |
| 502 … | + return cb(null, render(msg)) |
| 581 | 503 … | } else { |
| 582 | | - return content.appendChild(h('div')) |
| 504 … | + return cb(null, false) |
| 583 | 505 … | } |
| 584 | 506 … | }) |
| 507 … | + }), |
| 508 … | + filter(function (data) { |
| 509 … | + return data !== false |
| 585 | 510 … | }) |
| 586 | 511 … | ) |
| 587 | 512 … | } |
| 588 | 513 … | |
| 612 | 537 … | if (msg.value) { |
| 613 | 538 … | if (msg.value.timestamp > Date.now()) { |
| 614 | 539 … | return h('div.future') |
| 615 | 540 … | } else { |
| 616 | | - return render(msg) |
| 541 … | + var node = render(msg) |
| 542 … | + return node |
| 617 | 543 … | } |
| 618 | 544 … | } |
| 619 | 545 … | }) |
| 620 | 546 … | ) |