From 07d1f78debbe5e7e89a81d0b3c7300e950976ed2 Mon Sep 17 00:00:00 2001
From: cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519>
Date: Wed, 8 Feb 2017 11:43:41 -0800
Subject: Allow sorting by timestamp

---
 lib/app.js   | 7 +++++++
 lib/serve.js | 6 ++++--
 2 files changed, 11 insertions(+), 2 deletions(-)

(limited to 'lib')

diff --git a/lib/app.js b/lib/app.js
index cb9ad6d..faed5fc 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -111,3 +111,10 @@ function getAbout(sbot, src, id, cb) {
     cb(null, about)
   })
 }
+
+App.prototype.createLogStream = function (opts) {
+  opts = opts || {}
+  return opts.sortByTimestamp
+    ? this.sbot.createFeedStream(opts)
+    : this.sbot.createLogStream(opts)
+}
diff --git a/lib/serve.js b/lib/serve.js
index f850302..9809696 100644
--- a/lib/serve.js
+++ b/lib/serve.js
@@ -145,13 +145,14 @@ Serve.prototype.public = function (ext) {
   var q = this.query
   var opts = {
     reverse: !q.forwards,
+    sortByTimestamp: q.sort === 'claimed',
     lt: Number(q.lt) || Date.now(),
     gt: Number(q.gt) || -Infinity,
     limit: Number(q.limit) || 12
   }
 
   pull(
-    this.app.sbot.createLogStream(opts),
+    this.app.createLogStream(opts),
     this.renderThreadPaginated(opts, null, q),
     this.wrapMessages(),
     this.wrapPublic(),
@@ -166,13 +167,14 @@ Serve.prototype.private = function (ext) {
   var q = this.query
   var opts = {
     reverse: !q.forwards,
+    sortByTimestamp: q.sort === 'claimed',
     lt: Number(q.lt) || Date.now(),
     gt: Number(q.gt) || -Infinity,
   }
   var limit = Number(q.limit) || 12
 
   pull(
-    this.app.sbot.createLogStream(opts),
+    this.app.createLogStream(opts),
     pull.filter(isMsgEncrypted),
     paramap(this.app.unboxMsg, 4),
     pull.filter(isMsgReadable),
-- 
cgit v1.2.3