| index.jsView |
|---|
| 8 | 8 … | get: 'async' |
| 9 | 9 … | } |
| 10 | 10 … | |
| 11 | 11 … | exports.init = function (ssb, config) { |
| 12 | | - return ssb._flumeUse('about', FlumeReduce(0, reduce, map)) |
| 12 … | + return ssb._flumeUse('about', FlumeReduce(1, reduce, map)) |
| 13 | 13 … | } |
| 14 | 14 … | |
| 15 | 15 … | function reduce (result, item) { |
| 16 | 16 … | if (!result) result = {} |
| 20 | 20 … | for (var key in item[target]) { |
| 21 | 21 … | var valuesForKey = valuesForId[key] = valuesForId[key] || {} |
| 22 | 22 … | for (var author in item[target][key]) { |
| 23 | 23 … | var value = item[target][key][author] |
| 24 | | - if (!valuesForKey[author] || value.lastSeq > valuesForKey[author].lastSeq) { |
| 24 … | + if (!valuesForKey[author] || value[1] > valuesForKey[author][1]) { |
| 25 | 25 … | valuesForKey[author] = value |
| 26 | 26 … | } |
| 27 | 27 … | } |
| 28 | 28 … | } |
| 39 | 39 … | |
| 40 | 40 … | for (var key in msg.value.content) { |
| 41 | 41 … | if (key !== 'about' && key !== 'type') { |
| 42 | 42 … | values[key] = { |
| 43 | | - [author]: { |
| 44 | | - value: msg.value.content[key], |
| 45 | | - lastSeq: msg.value.sequence |
| 46 | | - } |
| 43 … | + [author]: [msg.value.content[key], msg.value.timestamp] |
| 47 | 44 … | } |
| 48 | 45 … | } |
| 49 | 46 … | } |
| 50 | 47 … | |