Merge remote-tracking branches 'origin/hyperscript' and 'angelo/render_rss'

This commit is contained in:
cel
2017-06-10 14:31:49 -10:00
3 changed files with 219 additions and 172 deletions
+45 -26
View File
@@ -16,7 +16,10 @@ var {
formatMsgs, formatMsgs,
wrapPage, wrapPage,
renderThread, renderThread,
renderAbout renderAbout,
renderShowAll,
renderRssItem,
wrapRss,
} = require('./render'); } = require('./render');
var appHash = hash([fs.readFileSync(__filename)]) var appHash = hash([fs.readFileSync(__filename)])
@@ -90,35 +93,49 @@ exports.init = function (sbot, config) {
} }
} }
function serveFeed(req, res, feedId) { function serveFeed(req, res, feedId, ext) {
console.log("serving feed: " + feedId) console.log("serving feed: " + feedId)
var showAll = req.url.endsWith("?showAll") var showAll = req.url.endsWith("?showAll");
var showAllHTML = showAll ? '' : '<br/><a href="' + req.url + '?showAll">Show whole feed</a>'
getAbout(feedId, function (err, about) { getAbout(feedId, function (err, about) {
if (err) return respond(res, 500, err.stack || err) if (err) return respond(res, 500, err.stack || err)
pull( function render() {
sbot.createUserStream({ id: feedId, reverse: true, limit: showAll ? -1 : 10 }), switch (ext) {
pull.collect(function (err, logs) { case 'rss':
if (err) return respond(res, 500, err.stack || err) return pull(
res.writeHead(200, { // formatMsgs(feedId, ext, defaultOpts)
'Content-Type': ctype("html") renderRssItem(defaultOpts), wrapRss(about.name, defaultOpts)
}) );
pull( default:
pull.values(logs), return pull(
paramap(addAuthorAbout, 8), renderAbout(defaultOpts, about,
paramap(addFollowAbout, 8), renderShowAll(showAll, req.url)), wrapPage(about.name)
paramap(addVoteMessage, 8), );
paramap(addGitLinks, 8), }
pull(renderAbout(defaultOpts, about, showAllHTML), wrapPage(about.name)), }
toPull(res, function (err) {
if (err) console.error('[viewer]', err) pull(
}) sbot.createUserStream({ id: feedId, reverse: true, limit: showAll ? -1 : (ext == 'rss' ? 25 :10) }),
) pull.collect(function (err, logs) {
}) if (err) return respond(res, 500, err.stack || err)
) res.writeHead(200, {
'Content-Type': ctype(ext)
})
pull(
pull.values(logs),
paramap(addAuthorAbout, 8),
paramap(addFollowAbout, 8),
paramap(addVoteMessage, 8),
paramap(addGitLinks, 8),
render(),
toPull(res, function (err) {
if (err) console.error('[viewer]', err)
})
)
})
)
}) })
} }
@@ -196,7 +213,6 @@ exports.init = function (sbot, config) {
console.log("serving channel: " + channelId) console.log("serving channel: " + channelId)
var showAll = req.url.endsWith("?showAll") var showAll = req.url.endsWith("?showAll")
var showAllHTML = showAll ? '' : '<br/><a href="' + req.url + '?showAll">Show whole feed</a>'
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 }}}}]}),
@@ -209,7 +225,9 @@ exports.init = function (sbot, config) {
pull.values(logs), pull.values(logs),
paramap(addAuthorAbout, 8), paramap(addAuthorAbout, 8),
paramap(addVoteMessage, 8), paramap(addVoteMessage, 8),
pull(renderThread(defaultOpts, showAllHTML), wrapPage('#' + channelId)), pull(renderThread(defaultOpts,
renderShowAll(showAll, req.url)),
wrapPage('#' + channelId)),
toPull(res, function (err) { toPull(res, function (err) {
if (err) console.error('[viewer]', err) if (err) console.error('[viewer]', err)
}) })
@@ -363,6 +381,7 @@ function ctype(name) {
case 'js': return 'text/javascript' case 'js': return 'text/javascript'
case 'css': return 'text/css' case 'css': return 'text/css'
case 'json': return 'application/json' case 'json': return 'application/json'
case 'rss': return 'text/xml'
} }
} }
+1
View File
@@ -9,6 +9,7 @@
"emoji-named-characters": "^1.0.2", "emoji-named-characters": "^1.0.2",
"emoji-server": "^1.0.0", "emoji-server": "^1.0.0",
"human-time": "^0.0.1", "human-time": "^0.0.1",
"hyperscript": "2.0.2",
"lrucache": "^1.0.2", "lrucache": "^1.0.2",
"pull-cat": "^1.1.11", "pull-cat": "^1.1.11",
"pull-paramap": "^1.2.1", "pull-paramap": "^1.2.1",
+173 -146
View File
@@ -4,6 +4,7 @@ var marked = require("ssb-marked");
var htime = require("human-time"); var htime = require("human-time");
var emojis = require("emoji-named-characters"); var emojis = require("emoji-named-characters");
var cat = require("pull-cat"); var cat = require("pull-cat");
var h = require('hyperscript');
var emojiDir = path.join(require.resolve("emoji-named-characters"), "../pngs"); var emojiDir = path.join(require.resolve("emoji-named-characters"), "../pngs");
@@ -13,6 +14,9 @@ exports.renderEmoji = renderEmoji;
exports.formatMsgs = formatMsgs; exports.formatMsgs = formatMsgs;
exports.renderThread = renderThread; exports.renderThread = renderThread;
exports.renderAbout = renderAbout; exports.renderAbout = renderAbout;
exports.renderShowAll = renderShowAll;
exports.renderRssItem = renderRssItem;
exports.wrapRss = wrapRss;
function MdRenderer(opts) { function MdRenderer(opts) {
marked.Renderer.call(this, {}); marked.Renderer.call(this, {});
@@ -39,17 +43,11 @@ MdRenderer.prototype.urltransform = function(href) {
}; };
MdRenderer.prototype.image = function(href, title, text) { MdRenderer.prototype.image = function(href, title, text) {
return ( return h('img',
'<img src="' + { src: this.opts.img_base + href,
this.opts.img_base + alt: text,
escape(href) + title: title
'"' + }).outerHTML;
' alt="' +
text +
'"' +
(title ? ' title="' + title + '"' : "") +
(this.options.xhtml ? "/>" : ">")
);
}; };
function renderEmoji(emoji) { function renderEmoji(emoji) {
@@ -59,16 +57,12 @@ function renderEmoji(emoji) {
? opts.blob_base + encodeURIComponent(mentions[emoji]) ? opts.blob_base + encodeURIComponent(mentions[emoji])
: emoji in emojis && opts.emoji_base + escape(emoji) + '.png'; : emoji in emojis && opts.emoji_base + escape(emoji) + '.png';
return url return url
? '<img src="' + ? h('img.ssb-emoji',
url + { src: url,
'"' + alt: ':' + escape(emoji) + ':',
' alt=":' + title: ':' + escape(emoji) + ':',
escape(emoji) + height: 16, width: 16
':"' + }).outerHTML
' title=":' +
escape(emoji) +
':"' +
' class="ssb-emoji" height="16" width="16">'
: ":" + emoji + ":"; : ":" + emoji + ":";
} }
@@ -88,6 +82,8 @@ function formatMsgs(id, ext, opts) {
return pull(renderThread(opts), wrapJSEmbed(opts)); return pull(renderThread(opts), wrapJSEmbed(opts));
case "json": case "json":
return wrapJSON(); return wrapJSON();
case "rss":
return pull(renderRssItem(opts), wrapRss(id, opts));
default: default:
return null; return null;
} }
@@ -99,44 +95,52 @@ function wrap(before, after) {
}; };
} }
function callToAction() {
return h('a.call-to-action',
{ href: 'https://www.scuttlebutt.nz' },
'Join Scuttlebutt now').outerHTML;
}
function toolTipTop() {
return h('span.top-tip',
'You are reading content from ',
h('a', { href: 'https://www.scuttlebutt.nz' },
'Scuttlebutt')).outerHTML;
}
function renderAbout(opts, about, showAllHTML = "") { function renderAbout(opts, about, showAllHTML = "") {
var figCaption = h('figcaption');
figCaption.innerHTML = 'Feed of ' + about.name + '<br>' +
(about.description != undefined ?
marked(about.description, opts.marked) : '');
return pull( return pull(
pull.map(renderMsg.bind(this, opts)), pull.map(renderMsg.bind(this, opts)),
wrap( wrap(toolTipTop() + '<main>' +
'<span class="top-tip">You are reading content from ' + h('article',
'<a href="https://www.scuttlebutt.nz">Scuttlebutt</a>' + h('header',
'</span>' + h('figure',
'<main>' + h('img',
'<article><header><figure>' + { src: opts.img_base + about.image,
'<img src="' + opts.img_base + escape(about.image) + '" ' + height: 200,
'height="200" width="200"><figcaption>' + width: 200
'Feed of ' + about.name + '<br/>' + }),
(about.description != undefined ? figCaption)
marked(about.description, opts.marked) : '') + )).outerHTML,
'</figcaption></figure></header></article>', showAllHTML + '</main>' + callToAction())
showAllHTML + '</main>' +
'<a class="call-to-action" href="https://www.scuttlebutt.nz">' +
'Join Scuttlebutt now' +
'</a>'
)
); );
} }
function renderThread(opts, showAllHTML = "") { function renderThread(opts, showAllHTML = "") {
return pull( return pull(
pull.map(renderMsg.bind(this, opts)), pull.map(renderMsg.bind(this, opts)),
wrap( wrap(toolTipTop() + '<main>',
'<span class="top-tip">You are reading content from ' + showAllHTML + '</main>' + callToAction())
'<a href="https://www.scuttlebutt.nz">Scuttlebutt</a>' + );
'</span>' + }
'<main>',
showAllHTML + '</main>' + function renderRssItem(opts) {
'<a class="call-to-action" href="https://www.scuttlebutt.nz">' + return pull(
'Join Scuttlebutt now' + pull.map(renderRss.bind(this, opts))
'</a>'
)
); );
} }
@@ -154,6 +158,18 @@ function wrapPage(id) {
); );
} }
function wrapRss(id, opts) {
return wrap(
'<?xml version="1.0" encoding="UTF-8" ?>' +
'<rss version="2.0">' +
'<channel>' +
'<title>' + id + ' | ssb-viewer</title>',
'</channel>'+
'</rss>'
);
}
var styles = ` var styles = `
<style> <style>
html { background-color: #f1f3f5; } html { background-color: #f1f3f5; }
@@ -320,45 +336,53 @@ function docWrite(str) {
function renderMsg(opts, msg) { function renderMsg(opts, msg) {
var c = msg.value.content || {}; var c = msg.value.content || {};
var name = encodeURIComponent(msg.key); var name = encodeURIComponent(msg.key);
return h('article#' + name,
h('header',
h('figure',
h('img', { alt: '',
src: opts.img_base + msg.author.image,
height: 50, width: 50 }),
h('figcaption',
h('a.ssb-avatar-name',
{ href: opts.base + escape(msg.value.author) },
msg.author.name),
msgTimestamp(msg, opts.base + name)))),
render(opts, c)).outerHTML;
}
function renderRss(opts, msg) {
var c = msg.value.content || {};
var name = encodeURIComponent(msg.key);
let content = render(opts, c);
if (!content) {
return null;
}
return ( return (
'<article id="' + '<item>' +
name + '<title>' + msg.author.name + ' | ' + c.type + '</title>' +
'">' + '<description><![CDATA[' + content + ']]></description>' +
'<header>' + '<link>' + opts.base + escape(name) + '</link>' +
'<figure>' + '<pubDate>' + new Date(msg.value.timestamp).toUTCString() + '</pubDate>' +
'<img alt="" ' + '<guid>' + msg.key + '</guid>' +
'src="' + opts.img_base + escape(msg.author.image) + '" ' + '</item>'
'height="50" width="50">' +
'<figcaption>' +
'<a class="ssb-avatar-name"' +
' href="' + opts.base +
escape(msg.value.author) +
'"' +
">" + msg.author.name + "</a>" +
msgTimestamp(msg, opts.base + name) +
'</figcaption>' +
'</figure>' +
'</header>' +
render(opts, c) +
"</article>"
); );
} }
function msgTimestamp(msg, link) { function msgTimestamp(msg, link) {
var date = new Date(msg.value.timestamp); var date = new Date(msg.value.timestamp);
var isoStr = date.toISOString(); var isoStr = date.toISOString();
return ( return h('time.ssb-timestamp',
'<time class="ssb-timestamp" datetime="' + isoStr + '">' + { datetime: isoStr },
'<a ' + h('a',
'href="' + link + '" ' + { href: link,
'title="' + isoStr + '" ' + title: isoStr },
'>' + formatDate(date) + '</a>' + formatDate(date)));
'</time>'
);
} }
function formatDate(date) { function formatDate(date) {
// return date.toISOString().replace('T', ' ')
return htime(date); return htime(date);
} }
@@ -366,106 +390,109 @@ function render(opts, c) {
var base = opts.base; var base = opts.base;
if (c.type === "post") { if (c.type === "post") {
var channel = c.channel var channel = c.channel
? '<div class="top-right"><a href="' + base + 'channel/' + c.channel + '">#' + c.channel + "</a></div>" ? h('div.top-right',
: ""; h('a',
return channel + renderPost(opts, c); { href: base + 'channel/' + c.channel },
'#' + c.channel))
: "";
return [channel, renderPost(opts, c)];
} else if (c.type == "vote" && c.vote.expression == "Dig") { } else if (c.type == "vote" && c.vote.expression == "Dig") {
var channel = c.channel var channel = c.channel
? ' in <a href="' + base + 'channel/' + c.channel + '">#' + c.channel + "</a>" ? [' in ',
: ""; h('a',
{ href: base + 'channel/' + c.channel },
'#' + c.channel)]
: "";
var linkedText = "this"; var linkedText = "this";
if (typeof c.vote.linkedText != "undefined") if (typeof c.vote.linkedText != "undefined")
linkedText = c.vote.linkedText.substring(0, 75); linkedText = c.vote.linkedText.substring(0, 75);
return ('<span class="status">' + return h('span.status',
'Liked ' + ['Liked ',
'<a href="' + base + h('a', { href: base + c.vote.link }, linkedText),
c.vote.link + channel]);
'">' +
linkedText +
"</a>" +
channel +
'</span>'
);
} else if (c.type == "vote") { } else if (c.type == "vote") {
var linkedText = "this"; var linkedText = "this";
if (typeof c.vote.linkedText != "undefined") if (typeof c.vote.linkedText != "undefined")
linkedText = c.vote.linkedText.substring(0, 75); linkedText = c.vote.linkedText.substring(0, 75);
return '<span class="status">' + return h('span.status',
'Voted <a href="' + base + c.vote.link + '">' + linkedText + "</a>" + ['Voted ',
'</span>'; h('a', { href: base + c.vote.link }, linkedText)]);
} else if (c.type == "contact" && c.following) { } else if (c.type == "contact" && c.following) {
var name = c.contact; var name = c.contact;
if (typeof c.contactAbout != "undefined") name = c.contactAbout.name; if (typeof c.contactAbout != "undefined")
return '<span class="status">' + name = c.contactAbout.name;
'Followed <a href="' + base + c.contact + '">' + name + "</a>" + return h('span.status',
'</span>'; ['Followed ',
h('a', { href: base + c.contact }, name)]);
} else if (c.type == "contact" && !c.following) { } else if (c.type == "contact" && !c.following) {
var name = c.contact; var name = c.contact;
if (typeof c.contactAbout != "undefined") name = c.contactAbout.name; if (typeof c.contactAbout != "undefined")
return '<span class="status">' + name = c.contactAbout.name;
'Unfollowed <a href="' + base + c.contact + '">' + name + "</a>" + return h('span.status',
'</span>'; ['Unfollowed ',
h('a', { href: base + c.contact }, name)]);
} else if (typeof c == "string") { } else if (typeof c == "string") {
return '<span class="status">' + return h('span.status', 'Wrote something private')
"Wrote something private" +
'</span>';
} }
else if (c.type == "about") { else if (c.type == "about") {
return '<span class="status">' + return [h('span.status', 'Changed something in about'),
"Changed something in about" + renderDefault(c)];
'</span>' +
renderDefault(c);
} }
else if (c.type == "issue") { else if (c.type == "issue") {
return '<span class="status">' + return [h('span.status',
"Created a git issue" + (c.repoName != undefined ? " in repo " + c.repoName : "") + renderPost(opts, c) + "Created a git issue" +
'</span>'; (c.repoName != undefined ? " in repo " + c.repoName : ""),
renderPost(opts, c))];
} }
else if (c.type == "git-update") { else if (c.type == "git-update") {
return '<span class="status">' + return h('span.status',
"Did a git update " + (c.repoName != undefined ? " in repo " + c.repoName : "") + "Did a git update " +
"<br/>" + (c.repoName != undefined ? " in repo " + c.repoName : "") +
(c.commits != undefined ? c.commits.map(com => { return "-" +com.title; }).join("<br/>") : "") + '<br>' +
'</span>' (c.commits != undefined ?
c.commits.map(com => { return "-" +com.title; }).join('<br>') : ""));
} }
else if (c.type == "ssb-dns") { else if (c.type == "ssb-dns") {
return '<span class="status">' + return [h('span.status', 'Updated DNS'), renderDefault(c)];
"Updated DNS" +
'</span>' +
renderDefault(c);
} }
else if (c.type == "pub") { else if (c.type == "pub") {
return '<span class="status">' + return h('span.status', 'Connected to the pub ' + c.address.host);
"Connected to the pub " + c.address.host +
'</span>'
} }
else if (c.type == "channel" && c.subscribed) else if (c.type == "channel" && c.subscribed)
return '<span class="status">' + return h('span.status',
'Subscribed to channel <a href="' + base + 'channel/' + 'Subscribed to channel ',
c.channel + h('a',
'">#' + { href: base + 'channel/' + c.channel },
c.channel + '#' + c.channel));
"</a>" +
'</span>';
else if (c.type == "channel" && !c.subscribed) else if (c.type == "channel" && !c.subscribed)
return '<span class="status">' + return h('span.status',
'Unsubscribed from channel <a href="' + base + 'channel/' + 'Unsubscribed from channel ',
c.channel + h('a',
'">#' + { href: base + 'channel/' + c.channel },
c.channel + '#' + c.channel))
"</a>" +
'</span>';
else return renderDefault(c); else return renderDefault(c);
} }
function renderPost(opts, c) { function renderPost(opts, c) {
opts.mentions = {}; opts.mentions = {};
if (Array.isArray(c.mentions)) c.mentions.forEach(function (link) { if (Array.isArray(c.mentions)) {
if (link && link.name && link.link) opts.mentions[link.name] = link.link; c.mentions.forEach(function (link) {
}); if (link && link.name && link.link)
return '<section>' + marked(String(c.text), opts.marked) + "</section>"; opts.mentions[link.name] = link.link;
});
}
var s = h('section');
s.innerHTML = marked(String(c.text), opts.marked);
return s;
} }
function renderDefault(c) { function renderDefault(c) {
return "<pre>" + JSON.stringify(c, 0, 2) + "</pre>"; return h('pre', JSON.stringify(c, 0, 2));
}
function renderShowAll(showAll, url) {
if (showAll)
return '';
else
return '<br>' + h('a', { href : url + '?showAll' }, 'Show whole feed').outerHTML;
} }