Commit 60ea2a8f16d4a0a20cfabcb154eaf98c4e370387
remove ssb-query fork, as we use ssb-query now
Ev Bogue committed on 10/11/2018, 6:35:09 PMParent: 15fad1b5904057929eb70d9931b1b2f3339cc87c
Files changed
| query/index.js | deleted |
| query/index.js | ||
|---|---|---|
| @@ -1,68 +1,0 @@ | ||
| 1 | -var pull = require('pull-stream') | |
| 2 | -var path = require('path') | |
| 3 | -var FlumeQuery = require('flumeview-query') | |
| 4 | -var explain = require('explain-error') | |
| 5 | - | |
| 6 | -function isString(s) { | |
| 7 | - return 'string' === typeof s | |
| 8 | -} | |
| 9 | - | |
| 10 | -exports.name = 'query' | |
| 11 | -exports.version = '1.0.0' | |
| 12 | -exports.manifest = { | |
| 13 | - read: 'source', | |
| 14 | - explain: 'sync' | |
| 15 | -} | |
| 16 | - | |
| 17 | -//what are links used for? | |
| 18 | -//query follows | |
| 19 | -//query replies | |
| 20 | -//query mentions (backlinks & mentions) | |
| 21 | -//query votes | |
| 22 | - | |
| 23 | - | |
| 24 | -var INDEX_VERSION = 8 | |
| 25 | -var indexes = [ | |
| 26 | - {key: 'log', value: ['timestamp']}, | |
| 27 | - {key: 'clk', value: [['value', 'author'], ['value', 'sequence']] }, | |
| 28 | - {key: 'typ', value: [['value', 'content', 'type'], ['timestamp']] }, | |
| 29 | - {key: 'tya', value: [['value', 'content', 'type'], ['value', 'timestamp']] }, | |
| 30 | - {key: 'cha', value: [['value', 'content', 'channel'], ['timestamp']] }, | |
| 31 | - {key: 'aty', value: [['value', 'author'], ['value', 'content', 'type'], ['timestamp']]}, | |
| 32 | - {key: 'ata', value: [['value', 'author'], ['value', 'content', 'type'], ['value', 'timestamp']]}, | |
| 33 | - {key: 'art', value: [['value', 'content', 'root'], ['value', 'timestamp']]}, | |
| 34 | - {key: 'lor', value: [['value', 'timestamp' ]]} | |
| 35 | -] | |
| 36 | - | |
| 37 | -//createHistoryStream( id, seq ) | |
| 38 | -//[{$filter: {author: <id>, sequence: {$gt: <seq>}}}, {$map: true}] | |
| 39 | - | |
| 40 | -//messagesByType (type) | |
| 41 | - | |
| 42 | -//[{$filter: {content: {type: <type>}}}, {$map: true}] | |
| 43 | - | |
| 44 | -exports.init = function (ssb, config) { | |
| 45 | - var s = ssb._flumeUse('query', FlumeQuery(INDEX_VERSION, {indexes: indexes})) | |
| 46 | - var read = s.read | |
| 47 | - var explain = s.explain | |
| 48 | - s.explain = function (opts) { | |
| 49 | - if(!opts) opts = {} | |
| 50 | - if(isString(opts)) | |
| 51 | - opts = {query: JSON.parse(opts)} | |
| 52 | - else if(isString(opts.query)) | |
| 53 | - opts.query = JSON.parse(opts.query) | |
| 54 | - return explain(opts) | |
| 55 | - } | |
| 56 | - | |
| 57 | - s.read = function (opts) { | |
| 58 | - if(!opts) opts = {} | |
| 59 | - if(isString(opts)) | |
| 60 | - opts = {query: JSON.parse(opts)} | |
| 61 | - else if(isString(opts.query)) | |
| 62 | - opts.query = JSON.parse(opts.query) | |
| 63 | - return read(opts) | |
| 64 | - } | |
| 65 | - return s | |
| 66 | -} | |
| 67 | - | |
| 68 | - | |
Built with git-ssb-web