| views.jsView |
|---|
| 36 | 36 … | screen.appendChild(hyperscroll(content)) |
| 37 | 37 … | } |
| 38 | 38 … | |
| 39 | 39 … | var privateStream = function () { |
| 40 … | + var screen = document.getElementById('screen') |
| 40 | 41 … | var content = h('div.content') |
| 41 | | - var screen = document.getElementById('screen') |
| 42 … | + |
| 42 | 43 … | screen.appendChild(hyperscroll(content)) |
| 43 | 44 … | |
| 44 | 45 … | function createStream (opts) { |
| 45 | 46 … | return pull( |
| 46 | 47 … | Next(sbot.query, opts, ['value', 'timestamp']), |
| 48 … | + pull.filter(function (msg) { |
| 49 … | + return ((msg.value.private == true) || ('string' == typeof msg.value.content)) |
| 50 … | + }), |
| 47 | 51 … | pull.map(function (msg) { |
| 52 … | + |
| 53 … | + var unboxed = ssbKeys.unbox(msg.value.content, keys) |
| 54 … | + if (unboxed) { |
| 55 … | + msg.value.content = unboxed |
| 56 … | + msg.value.private = true |
| 57 … | + return render(msg) |
| 58 … | + } else { |
| 59 … | + return render(msg) |
| 60 … | + } |
| 61 … | + } else {return render(msg)}*/ |
| 62 … | + return render(msg) |
| 63 … | + }) |
| 64 … | + ) |
| 65 … | + } |
| 66 … | + |
| 67 … | + pull( |
| 68 … | + createStream({ |
| 69 … | + limit: 100, |
| 70 … | + reverse: true, |
| 71 … | + live: false, |
| 72 … | + query: [{$filter: { value: { timestamp: { $gt: 0 }}}}] |
| 73 … | + }), |
| 74 … | + stream.bottom(content) |
| 75 … | + ) |
| 76 … | + |
| 77 … | + pull( |
| 78 … | + createStream({ |
| 79 … | + limit: 100, |
| 80 … | + old: false, |
| 81 … | + live: true, |
| 82 … | + query: [{$filter: { value: { timestamp: { $gt: 0 }}}}] |
| 83 … | + }), |
| 84 … | + stream.top(content) |
| 85 … | + ) |
| 86 … | + |
| 87 … | + |
| 88 … | + |
| 89 … | + return pull( |
| 90 … | + Next(sbot.query, opts, ['value', 'timestamp']), |
| 91 … | + pull.map(function (msg) { |
| 48 | 92 … | if (msg.value) { |
| 49 | 93 … | if (msg.value.timestamp > Date.now()) { |
| 50 | 94 … | return h('div.future') |
| 51 | 95 … | } else { |
| 73 | 117 … | live: true, |
| 74 | 118 … | query: [{$filter: { value: { private: true, timestamp: { $gt: 0 }}}}] |
| 75 | 119 … | }), |
| 76 | 120 … | stream.top(content) |
| 77 | | - ) |
| 121 … | + )*/ |
| 78 | 122 … | |
| 79 | 123 … | |
| 80 | 124 … | |
| 81 | 125 … | return pull( |
| 88 | 132 … | if (unboxed) { |
| 89 | 133 … | msg.value.content = unboxed |
| 90 | 134 … | msg.value.private = true |
| 91 | 135 … | return msg |
| 136 … | + } else { |
| 137 … | + return msg |
|
| 92 | 138 … | } |
| 93 | 139 … | }), |
| 94 | 140 … | pull.map(function (msg) { |
| 95 | 141 … | return render(msg) |
| 550 | 596 … | query: [{$filter: { value: { timestamp: { $gt: 0 }}}}] |
| 551 | 597 … | }), |
| 552 | 598 … | stream.top(content) |
| 553 | 599 … | ) |
| 554 | | - |
| 555 | | - |
| 556 | | - |
| 557 | 600 … | } |
| 558 | 601 … | |
| 559 | 602 … | |
| 560 | 603 … | |