First pass at listing subscribed channels

1 files changed, 16 insertions, 0 deletions

diff --git a/lib/app.js b/lib/app.js
index b57e5a6..f475bd2 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -282,6 +282,22 @@ App.prototype.streamChannels = function (opts) {
   )
 }
 
+App.prototype.streamMyChannels = function (id, opts) {
+  return pull(
+    this.sbot.createUserStream({id: id, reverse: true}),
+    this.unboxMessages(),
+    pull.filter(function (msg) {
+      if (msg.value.content.type == 'channel') {
+        return msg.value.content.subscribed
+      }
+    }),
+    pull.map(function (msg) {
+      return msg.value.content.channel
+    }),
+    pull.unique()
+  )
+}
+
 App.prototype.createContactStreams = function (id) {
   return new Contacts(this.sbot).createContactStreams(id)
 }