aboutsummaryrefslogtreecommitdiff
path: root/lib/serve.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/serve.js')
-rw-r--r--lib/serve.js50
1 files changed, 50 insertions, 0 deletions
diff --git a/lib/serve.js b/lib/serve.js
index fe2ab39..5c73d46 100644
--- a/lib/serve.js
+++ b/lib/serve.js
@@ -225,6 +225,7 @@ Serve.prototype.path = function (url) {
case '/search': return this.search(m[2])
case '/vote': return this.vote(m[2])
case '/peers': return this.peers(m[2])
+ case '/channels': return this.channels(m[2])
}
m = /^(\/?[^\/]*)(\/.*)?$/.exec(url)
switch (m[1]) {
@@ -406,6 +407,40 @@ Serve.prototype.peers = function (ext) {
)
}
+Serve.prototype.channels = function (ext) {
+ var self = this
+
+ pull(
+ self.app.sbot.messagesByType({type: 'channel', reverse: true}),
+ paramap(self.app.unboxMsg, 16),
+ pull.map(function (msg) {
+ var c = msg.value.content
+ return c && c.channel
+ }),
+ pull.unique(),
+ paramap(function (channel, cb) {
+ var subscribed = false
+ cb(null, h('form', {method: 'post', action: ''},
+ h('a', {href: self.app.render.toUrl('#' + channel)}, '#' + channel)
+ /*
+ ' ',
+ h('input', {type: 'hidden', name: 'action', value: 'channel'}),
+ h('input', {type: 'hidden', name: 'channel', value: channel}),
+ h('input', {type: 'hidden', name: 'subscribed', value: !subscribed}),
+ h('input', {type: 'submit', value: subscribed
+ ? 'unsubscribe' : 'subscribe'})
+ */
+ ))
+ }, 8),
+ pull.map(u.toHTML),
+ self.wrapChannels(),
+ self.wrapPage('channels'),
+ self.respondSink(200, {
+ 'Content-Type': ctype(ext)
+ })
+ )
+}
+
Serve.prototype.type = function (path) {
var q = this.query
@@ -793,6 +828,7 @@ Serve.prototype.wrapPage = function (title, searchQ) {
h('a', {href: render.toUrl('/public')}, 'public'), ' ',
h('a', {href: render.toUrl('/private')}, 'private') , ' ',
h('a', {href: render.toUrl('/peers')}, 'peers') , ' ',
+ h('a', {href: render.toUrl('/channels')}, 'channels') , ' ',
render.idLink(self.app.sbot.id, done()), ' ',
h('input.search-input', {name: 'q', value: searchQ,
placeholder: 'search'})
@@ -1047,6 +1083,20 @@ Serve.prototype.wrapPeers = function (opts) {
})
}
+Serve.prototype.wrapChannels = function (opts) {
+ var self = this
+ return u.hyperwrap(function (channels, cb) {
+ cb(null, [
+ h('section',
+ h('h3', 'Channels')
+ ),
+ h('section',
+ channels
+ )
+ ])
+ })
+}
+
function rows(str) {
return String(str).split(/[^\n]{150}|\n/).length
}