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

Make an attempt at being able to render rss

Browse Source
This commit is contained in:
Angelo DiNardi
2017-06-04 23:37:14 -07:00
parent 8c420a8d3b
commit 8ee270f04f
2 changed files with 149 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
index.js
+43 -22
View File
@@ -16,7 +16,10 @@ var {
formatMsgs,
wrapPage,
renderThread,
renderAbout
renderAbout,
renderItem,
wrapRss,
renderRssContent,
} = require('./render');
var appHash = hash([fs.readFileSync(__filename)])
@@ -90,7 +93,7 @@ exports.init = function (sbot, config) {
}
}
function serveFeed(req, res, feedId) {
function serveFeed(req, res, feedId, ext) {
console.log("serving feed: " + feedId)
var showAll = req.url.endsWith("?showAll")
@@ -99,26 +102,43 @@ exports.init = function (sbot, config) {
getAbout(feedId, function (err, about) {
if (err) return respond(res, 500, err.stack || err)
pull(
sbot.createUserStream({ id: feedId, reverse: true, limit: showAll ? -1 : 10 }),
pull.collect(function (err, logs) {
if (err) return respond(res, 500, err.stack || err)
res.writeHead(200, {
'Content-Type': ctype("html")
})
pull(
pull.values(logs),
paramap(addAuthorAbout, 8),
paramap(addFollowAbout, 8),
paramap(addVoteMessage, 8),
paramap(addGitLinks, 8),
pull(renderAbout(defaultOpts, about, showAllHTML), wrapPage(about.name)),
toPull(res, function (err) {
if (err) console.error('[viewer]', err)
})
)
})
)
function render() {
switch (ext) {
case 'rss':
return pull(
// formatMsgs(feedId, ext, defaultOpts)
pull.filter( (msg) => {
return !!renderRssContent(defaultOpts, msg.value.content || {});
}),
renderItem(defaultOpts), wrapRss(about.name, defaultOpts)
);
default:
return pull(
renderAbout(defaultOpts, about, showAllHTML), wrapPage(about.name)
);
}
}
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)
})
)
})
)
})
}
@@ -363,6 +383,7 @@ function ctype(name) {
case 'js': return 'text/javascript'
case 'css': return 'text/css'
case 'json': return 'application/json'
case 'rss': return 'text/xml'
}
}
render.js
+106
View File
@@ -13,6 +13,9 @@ exports.renderEmoji = renderEmoji;
exports.formatMsgs = formatMsgs;
exports.renderThread = renderThread;
exports.renderAbout = renderAbout;
exports.renderItem = renderItem;
exports.wrapRss = wrapRss;
exports.renderRssContent = renderRssContent;
function MdRenderer(opts) {
marked.Renderer.call(this, {});
@@ -84,6 +87,8 @@ function formatMsgs(id, ext, opts) {
return pull(renderThread(opts), wrapJSEmbed(opts));
case "json":
return wrapJSON();
case "rss":
return pull(renderItem(opts), wrapRss(id, opts));
default:
return null;
}
@@ -136,6 +141,12 @@ function renderThread(opts, showAllHTML = "") {
);
}
function renderItem(opts) {
return pull(
pull.map(renderRss.bind(this, opts))
);
}
function wrapPage(id) {
return wrap(
"<!doctype html><html><head>" +
@@ -150,6 +161,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 = `
<style>
html { background-color: #f1f3f5; }
@@ -340,6 +363,89 @@ function renderMsg(opts, msg) {
);
}
function renderRssContent(opts, c) {
var base = opts.base;
if (c.type === "post") {
return (c.channel ? `Posted in #${c.channel}:\n\n` : '') + c.text;
} else if (c.type == "vote" && c.vote.expression == "Dig") {
var linkedText = "a post";
if (typeof c.vote.linkedText != "undefined") {
linkedText = c.vote.linkedText.substring(0, 75);
}
return `Liked ${linkedText}`;
} else if (c.type == "vote") {
var linkedText = "a post";
if (typeof c.vote.linkedText != "undefined") {
linkedText = c.vote.linkedText.substring(0, 75);
}
return `Voted ${linkedText}`;
} else if (c.type == "contact" && c.following) {
var name = c.contact;
if (typeof c.contactAbout != "undefined") {
name = c.contactAbout.name;
}
return `Followed ${name}`;
} else if (c.type == "contact" && !c.following) {
var name = c.contact;
if (typeof c.contactAbout != "undefined") {
name = c.contactAbout.name;
}
return `Unfollowed ${name}`;
} else if (typeof c == "string") {
// Don't show private messages in RSS.
}
else if (c.type == "about") {
// Don't show about messages in RSS.
}
else if (c.type == "issue") {
return `Created a git issue ${(c.repoName != undefined ? " in repo " + c.repoName : "")}`;
}
else if (c.type == "git-update") {
return `Did a git update ${(c.repoName != undefined ? " in repo " + c.repoName : "")}
${(c.commits != undefined ? c.commits.map(com => { return "-" +com.title; }).join("\n") : "")}
`;
}
else if (c.type == "ssb-dns") {
// Don't show for RSS.
}
else if (c.type == "pub") {
return `Connected to the pub ${c.address.host}`;
}
else if (c.type == "channel" && c.subscribed) {
return `Subscribed to channel #${c.channel}`;
}
else if (c.type == "channel" && !c.subscribed) {
return `Unsubscribed from channel #${c.channel}`;
}
}
function renderRss(opts, msg) {
var c = msg.value.content || {};
var name = encodeURIComponent(msg.key);
let content = renderRssContent(opts, c);
if (!content) {
return null;
}
return (
'<item>' +
'<title>' + msg.author.name + ' - ' + formatDate(new Date(msg.value.timestamp)) + '</title>' +
'<description><![CDATA[' + content + ']]></description>' +
'<link>' + opts.base + escape(name) + '</link>' +
'<pubDate>' + new Date(msg.value.timestamp).toUTCString() + '</pubDate>' +
'<guid>' + msg.key + '</guid>' +
'</item>'
);
}
function msgTimestamp(msg, name) {
var date = new Date(msg.value.timestamp);
var isoStr = date.toISOString();