aboutsummaryrefslogtreecommitdiff
path: root/lib/app.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/app.js')
-rw-r--r--lib/app.js36
1 files changed, 4 insertions, 32 deletions
diff --git a/lib/app.js b/lib/app.js
index 643b317..fc395a2 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -8,6 +8,7 @@ var multicb = require('multicb')
var paramap = require('pull-paramap')
var Contacts = require('ssb-contact')
var About = require('./about')
+var Follows = require('./follows')
var Serve = require('./serve')
var Render = require('./render')
var Git = require('./git')
@@ -49,7 +50,6 @@ function App(sbot, config) {
this.reverseEmojiNameCache = lru(500)
this.getBlobSize = memo({cache: this.blobSizeCache = lru(100)},
sbot.blobs.size.bind(sbot.blobs))
- this.getFollows = memo(this._getFollows.bind(this))
this.getVotes = memo({cache: lru(100)}, this._getVotes.bind(this))
this.unboxMsg = this.unboxMsg.bind(this)
@@ -57,6 +57,7 @@ function App(sbot, config) {
this.render = new Render(this, this.opts)
this.git = new Git(this)
this.contacts = new Contacts(this.sbot)
+ this.follows = new Follows(this.sbot, this.contacts)
this.monitorBlobWants()
}
@@ -690,7 +691,7 @@ App.prototype.filterMsg = function (msg, opts, cb) {
|| author === myId
|| author === opts.feed
|| msg.key === opts.msgId) return cb(null, show)
- self.getFollows(myId, function (err, follows) {
+ self.follows.getFollows(myId, function (err, follows) {
if (err) return cb(err)
if (follows[author]) return cb(null, show)
self.getVotes(msg.key, function (err, votes) {
@@ -707,41 +708,12 @@ App.prototype.filterMsg = function (msg, opts, cb) {
App.prototype.isFollowing = function (src, dest, cb) {
var self = this
- self.getFollows(src, function (err, follows) {
+ self.follows.getFollows(src, function (err, follows) {
if (err) return cb(err)
return cb(null, follows[dest])
})
}
-App.prototype._getFollows = function (id, cb) {
- var follows = {}
- function ready(err) {
- if (!cb) return
- var _cb = cb
- cb = null
- _cb(err, follows)
- }
- pull(
- this.sbot.links2.read({
- live: true,
- query: [
- {$filter: {
- source: id,
- rel: [{$prefix: 'contact'}]
- }},
- {$map: {
- following: ['rel', 1],
- feed: 'dest'
- }}
- ]
- }),
- pull.drain(function (link) {
- if (link.sync) return ready()
- follows[link.feed] = link.following
- }, ready)
- )
-}
-
App.prototype._getVotes = function (id, cb) {
var votes = {}
pull(