trav/custo-viewer
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

whitespace

Browse Source
This commit is contained in:
cel
2018-04-15 20:41:44 -10:00
parent 08321fdd28
commit 728dd36ef6
1 changed files with 89 additions and 93 deletions
Download Patch File Download Diff File Expand all files Collapse all files
index.js
+88 -92
View File
@@ -153,34 +153,34 @@ exports.init = function (sbot, config) {
getAbout(feedId, function (err, about) { getAbout(feedId, function (err, about) {
pull( pull(
sbot.createUserStream({ id: feedId }), sbot.createUserStream({ id: feedId }),
pull.filter((msg) => { pull.filter((msg) => {
return !msg.value || return !msg.value ||
msg.value.content.type == 'contact' || msg.value.content.type == 'contact' ||
(msg.value.content.type == 'channel' && (msg.value.content.type == 'channel' &&
typeof msg.value.content.subscribed != 'undefined') typeof msg.value.content.subscribed != 'undefined')
}), }),
pull.collect(function (err, msgs) { pull.collect(function (err, msgs) {
msgs.forEach((msg) => { msgs.forEach((msg) => {
if (msg.value.content.type == 'contact') if (msg.value.content.type == 'contact')
{ {
if (msg.value.content.following) if (msg.value.content.following)
following[msg.value.content.contact] = 1 following[msg.value.content.contact] = 1
else else
delete following[msg.value.content.contact] delete following[msg.value.content.contact]
} }
else // channel subscription else // channel subscription
{ {
if (msg.value.content.subscribed) if (msg.value.content.subscribed)
channelSubscriptions[msg.value.content.channel] = 1 channelSubscriptions[msg.value.content.channel] = 1
else else
delete channelSubscriptions[msg.value.content.channel] delete channelSubscriptions[msg.value.content.channel]
} }
}) })
serveFeeds(req, res, following, channelSubscriptions, feedId, serveFeeds(req, res, following, channelSubscriptions, feedId,
'user feed ' + (about ? about.name : "")) 'user feed ' + (about ? about.name : ""))
}) })
) )
}) })
} }
@@ -195,27 +195,27 @@ exports.init = function (sbot, config) {
pull( pull(
sbot.createLogStream({ reverse: true, limit: 5000 }), sbot.createLogStream({ reverse: true, limit: 5000 }),
pull.filter((msg) => { pull.filter((msg) => {
return !msg.value || return !msg.value ||
(msg.value.author in following || (msg.value.author in following ||
msg.value.content.channel in channelSubscriptions) msg.value.content.channel in channelSubscriptions)
}), }),
pull.take(150), pull.take(150),
pull.collect(function (err, logs) { pull.collect(function (err, logs) {
if (err) return respond(res, 500, err.stack || err) if (err) return respond(res, 500, err.stack || err)
res.writeHead(200, { res.writeHead(200, {
'Content-Type': ctype("html") 'Content-Type': ctype("html")
}) })
pull( pull(
pull.values(logs), pull.values(logs),
paramap(addAuthorAbout, 8), paramap(addAuthorAbout, 8),
paramap(addFollowAbout, 8), paramap(addFollowAbout, 8),
paramap(addVoteMessage, 8), paramap(addVoteMessage, 8),
paramap(addGitLinks, 8), paramap(addGitLinks, 8),
pull(renderThread(feedOpts), wrapPage(name)), pull(renderThread(feedOpts), wrapPage(name)),
toPull(res, function (err) { toPull(res, function (err) {
if (err) console.error('[viewer]', err) if (err) console.error('[viewer]', err)
}) })
) )
}) })
) )
} }
@@ -229,21 +229,21 @@ exports.init = function (sbot, config) {
pull( pull(
sbot.query.read({ limit: showAll ? 300 : 10, reverse: true, query: [{$filter: { value: { content: { channel: channelId }}}}]}), sbot.query.read({ limit: showAll ? 300 : 10, reverse: true, query: [{$filter: { value: { content: { channel: channelId }}}}]}),
pull.collect(function (err, logs) { pull.collect(function (err, logs) {
if (err) return respond(res, 500, err.stack || err) if (err) return respond(res, 500, err.stack || err)
res.writeHead(200, { res.writeHead(200, {
'Content-Type': ctype("html") 'Content-Type': ctype("html")
}) })
pull( pull(
pull.values(logs), pull.values(logs),
paramap(addAuthorAbout, 8), paramap(addAuthorAbout, 8),
paramap(addVoteMessage, 8), paramap(addVoteMessage, 8),
pull(renderThread(defaultOpts, '', pull(renderThread(defaultOpts, '',
renderShowAll(showAll, req.url)), renderShowAll(showAll, req.url)),
wrapPage('#' + channelId)), wrapPage('#' + channelId)),
toPull(res, function (err) { toPull(res, function (err) {
if (err) console.error('[viewer]', err) if (err) console.error('[viewer]', err)
}) })
) )
}) })
) )
} }
@@ -318,9 +318,9 @@ exports.init = function (sbot, config) {
function addFollowAbout(msg, cb) { function addFollowAbout(msg, cb) {
if (msg.value.content.contact) if (msg.value.content.contact)
getAbout(msg.value.content.contact, function (err, about) { getAbout(msg.value.content.contact, function (err, about) {
if (err) return cb(err) if (err) return cb(err)
msg.value.content.contactAbout = about msg.value.content.contactAbout = about
cb(null, msg) cb(null, msg)
}) })
else else
cb(null, msg) cb(null, msg)
@@ -329,9 +329,9 @@ exports.init = function (sbot, config) {
function addVoteMessage(msg, cb) { function addVoteMessage(msg, cb) {
if (msg.value.content.type == 'vote' && msg.value.content.vote.link[0] == '%') if (msg.value.content.type == 'vote' && msg.value.content.vote.link[0] == '%')
getMsg(msg.value.content.vote.link, function (err, linkedMsg) { getMsg(msg.value.content.vote.link, function (err, linkedMsg) {
if (linkedMsg) if (linkedMsg)
msg.value.content.vote.linkedText = linkedMsg.value.content.text msg.value.content.vote.linkedText = linkedMsg.value.content.text
cb(null, msg) cb(null, msg)
}) })
else else
cb(null, msg) cb(null, msg)
@@ -348,15 +348,15 @@ exports.init = function (sbot, config) {
function addGitLinks(msg, cb) { function addGitLinks(msg, cb) {
if (msg.value.content.type == 'git-update') if (msg.value.content.type == 'git-update')
getMsg(msg.value.content.repo, function (err, gitRepo) { getMsg(msg.value.content.repo, function (err, gitRepo) {
if (gitRepo) if (gitRepo)
msg.value.content.repoName = gitRepo.value.content.name msg.value.content.repoName = gitRepo.value.content.name
cb(null, msg) cb(null, msg)
}) })
else if (msg.value.content.type == 'issue') else if (msg.value.content.type == 'issue')
getMsg(msg.value.content.project, function (err, gitRepo) { getMsg(msg.value.content.project, function (err, gitRepo) {
if (gitRepo) if (gitRepo)
msg.value.content.repoName = gitRepo.value.content.name msg.value.content.repoName = gitRepo.value.content.name
cb(null, msg) cb(null, msg)
}) })
else else
cb(null, msg) cb(null, msg)
@@ -444,24 +444,20 @@ function serveFile(req, res, file) {
}) })
} }
//function prepend(fn, arg) { function prepend(fn, arg) {
// return function (read) { return function (read) {
// return function (abort, cb) { return function (abort, cb) {
// if (fn && !abort) { if (fn && !abort) {
// var _fn = fn var _fn = fn
// fn = null fn = null
// return _fn(arg, function (err, value) { return _fn(arg, function (err, value) {
// if (err) return read(err, function (err) { if (err) return read(err, function (err) {
// cb(err || true) cb(err || true)
// }) })
// cb(null, value) cb(null, value)
// }) })
// } }
// read(abort, cb) read(abort, cb)
// } }
// } }
//} }