From d8f6c6a19274cf53d9967d3597dd582ee7233ca3 Mon Sep 17 00:00:00 2001
From: cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519>
Date: Tue, 9 May 2017 15:17:46 -1000
Subject: Add votes page

---
 lib/app.js | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 60 insertions(+)

(limited to 'lib/app.js')

diff --git a/lib/app.js b/lib/app.js
index b57e5a6..e503443 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -285,3 +285,63 @@ App.prototype.streamChannels = function (opts) {
 App.prototype.createContactStreams = function (id) {
   return new Contacts(this.sbot).createContactStreams(id)
 }
+
+function compareVoted(a, b) {
+  return b.value - a.value
+}
+
+App.prototype.getVoted = function (_opts, cb) {
+  if (isNaN(_opts.limit)) return pull.error(new Error('missing limit'))
+  var self = this
+  var opts = {
+    type: 'vote',
+    limit: _opts.limit * 100,
+    reverse: !!_opts.reverse,
+    gt: _opts.gt || undefined,
+    lt: _opts.lt || undefined,
+  }
+
+  var votedObj = {}
+  var votedArray = []
+  var numItems = 0
+  var firstTimestamp, lastTimestamp
+  pull(
+    self.sbot.messagesByType(opts),
+    self.unboxMessages(),
+    pull.take(function () {
+      return numItems < _opts.limit
+    }),
+    pull.drain(function (msg) {
+      if (!firstTimestamp) firstTimestamp = msg.timestamp
+      lastTimestamp = msg.timestamp
+      var vote = msg.value.content.vote
+      if (!vote) return
+      var target = u.linkDest(vote)
+      var votes = votedObj[target]
+      if (!votes) {
+        numItems++
+        votes = {id: target, value: 0, feedsObj: {}, feeds: []}
+        votedObj[target] = votes
+        votedArray.push(votes)
+      }
+      if (msg.value.author in votes.feedsObj) {
+        if (!opts.reverse) return // leave latest vote value as-is
+        // remove old vote value
+        votes.value -= votes.feedsObj[msg.value.author]
+      } else {
+        votes.feeds.push(msg.value.author)
+      }
+      var value = vote.value > 0 ? 1 : vote.value < 0 ? -1 : 0
+      votes.feedsObj[msg.value.author] = value
+      votes.value += value
+    }, function (err) {
+      if (err) return cb(err)
+      var items = votedArray
+      if (opts.reverse) items.reverse()
+      items.sort(compareVoted)
+      cb(null, {items: items,
+        firstTimestamp: firstTimestamp,
+        lastTimestamp: lastTimestamp})
+    })
+  )
+}
-- 
cgit v1.2.3


From e9b1ee71a12fcd6c15a2f0b06671bc819da98303 Mon Sep 17 00:00:00 2001
From: cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519>
Date: Tue, 6 Jun 2017 20:50:08 -1000
Subject: Don't call blobs.want if we already have the blob

---
 lib/app.js   | 11 +++++++++++
 lib/serve.js | 12 ++++--------
 2 files changed, 15 insertions(+), 8 deletions(-)

(limited to 'lib/app.js')

diff --git a/lib/app.js b/lib/app.js
index d86b4b9..b9e1924 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -172,6 +172,17 @@ App.prototype.publish = function (content, cb) {
   tryPublish(2)
 }
 
+App.prototype.wantSizeBlob = function (id, cb) {
+  var blobs = this.sbot.blobs
+  blobs.size(id, function (err, size) {
+    if (size != null) return cb(null, size)
+    blobs.want(id, function (err) {
+      if (err) return cb(err)
+      blobs.size(id, cb)
+    })
+  })
+}
+
 App.prototype.addBlob = function (cb) {
   var done = multicb({pluck: 1, spread: true})
   var hashCb = done()
diff --git a/lib/serve.js b/lib/serve.js
index 59a09d5..1fe9b37 100644
--- a/lib/serve.js
+++ b/lib/serve.js
@@ -947,22 +947,18 @@ Serve.prototype.blob = function (id) {
   var self = this
   var blobs = self.app.sbot.blobs
   if (self.req.headers['if-none-match'] === id) return self.respond(304)
-  var done = multicb({pluck: 1, spread: true})
-  blobs.want(id, function (err, has) {
+  self.app.wantSizeBlob(id, function (err, size) {
     if (err) {
       if (/^invalid/.test(err.message)) return self.respond(400, err.message)
       else return self.respond(500, err.message || err)
     }
-    if (!has) return self.respond(404, 'Not found')
-    blobs.size(id, done())
     pull(
       blobs.get(id),
       pull.map(Buffer),
-      ident(done().bind(self, null)),
+      ident(gotType),
       self.respondSink()
     )
-    done(function (err, size, type) {
-      if (err) console.trace(err)
+    function gotType(type) {
       type = type && mime.lookup(type)
       if (type) self.res.setHeader('Content-Type', type)
       if (typeof size === 'number') self.res.setHeader('Content-Length', size)
@@ -971,7 +967,7 @@ Serve.prototype.blob = function (id) {
       self.res.setHeader('Cache-Control', 'public, max-age=315360000')
       self.res.setHeader('etag', id)
       self.res.writeHead(200)
-    })
+    }
   })
 }
 
-- 
cgit v1.2.3