var Get = require('./get') var paramap = require('pull-paramap') var pull = require('pull-stream') var u = require('yap-util') module.exports = function (sbot) { return function (use) { use('event', function (opts, apply, req) { opts.id = opts.id || "%eFzw9Qca1MUppBgyGG0e2AwzlwonvwDk2GDyxM9B37c=.sha256" return function (cb) { Get(sbot, opts, function (err, thread) { cb(null, require('./render')(apply, thread)) }) } }) use('all', function (opts, apply, req) { console.log(opts) return pull( sbot.query.read( u.createQuery(Object.assign({ type: 'gathering'}, opts)) ), // sbot.messagesByType({ // type: 'gathering', // limit: 10, // reverse: true // }), pull.map(function (e) { return apply('/gatherings/event', {id: e.key, private: true}) }) ) }) use.map('messages', 'gathering', 'event') // use.list(' } }