1 files changed, 30 insertions, 0 deletions
diff --git a/lib/app.js b/lib/app.js
index d1f76f3..6e182bf 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -471,3 +471,33 @@ App.prototype.streamEmojis = function () {
     pull.unique('link')
   )
 }
+
+App.prototype.streamChannel = function (opts) {
+  if (this.sbot.backlinks) return this.sbot.backlinks.read(u.mergeOpts(opts, {
+    query: [{$filter: {
+      dest: '#' + opts.channel,
+      value: {
+        content: {
+          type: 'post'
+        }
+      },
+      timestamp: {
+        $gt: opts.gt,
+        $lt: opts.lt,
+      }
+    }}]
+  }))
+
+  if (this.sbot.query) return this.sbot.query.read(u.mergeOpts(opts, {
+    query: [{$filter: {
+      value: {content: {channel: opts.channel}},
+      timestamp: {
+        $gt: opts.gt,
+        $lt: opts.lt,
+      }
+    }}]
+  }))
+
+  return pull.error(new Error(
+    'Viewing channels/tags requires the ssb-backlinks or ssb-query plugin'))
+}