Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-09 15:35:47 +01:00
Code Issues Packages Projects Releases Wiki Activity

interim commit for new feed refactor

Browse Source
This commit is contained in:
Julian Lam
2013-09-03 23:18:25 -04:00
parent 418700ce3f
commit b6fbfcc814
1 changed files with 52 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

118
src/feed.js
View File

@@ -4,106 +4,92 @@
posts = require('./posts.js'), posts = require('./posts.js'),
topics = require('./topics.js'), topics = require('./topics.js'),
fs = require('fs'), fs = require('fs'),
rss = require('node-rss'), rss = require('rss'),
winston = require('winston'), winston = require('winston'),
path = require('path'); path = require('path');
function saveFeed(location, feed) { Feed.defaults = {
ttl: 60,
basePath: path.join(__dirname, '../', 'feeds'),
baseUrl: nconf.get('url') + 'feeds'
};
Feed.saveFeed = function(location, feed) {
var savePath = path.join(__dirname, '../', location); var savePath = path.join(__dirname, '../', location);
fs.writeFile(savePath, rss.getFeedXML(feed), function (err) { fs.writeFile(savePath, feed.xml(), function (err) {
if(err) { if(err) {
winston.err(err); winston.err(err);
} }
}); });
} }
function createFeed(title, description, feed_url, xml_url, author, urn) {
return rss.createNewFeed(
title,
feed_url,
description,
author,
xml_url,
{
'urn' : urn
}
);
}
Feed.updateTopic = function(tid, cid) { Feed.updateTopic = function(tid, cid) {
winston.info('[RSS] Updating RSS feeds for topic ' + tid); if (process.env.NODE_ENV === 'development') winston.info('[rss] Updating RSS feeds for topic ' + tid);
var cache_time_in_seconds = 60;
topics.getTopicWithPosts(tid, 0, 0, -1, function(err, topicData) { topics.getTopicWithPosts(tid, 0, 0, -1, function(err, topicData) {
if (err) winston.error('Problem saving topic RSS feed', err.stack); if (err) return winston.error('Problem saving topic RSS feed', err.stack);
var location = '/topic/' + topicData.slug, var feed = new rss({
xml_url = '/topic/' + tid + '.rss'; title: topicData.topic_name,
description: topicData.main_posts[0].content,
var post = topicData.main_posts[0]; feed_url: Feed.defaults.baseUrl + '/topics/' + tid + '.rss',
var urn = 'urn:' + cid + ':' + tid; site_url: nconf.get('url') + 'topic/' + topicData.slug,
image_url: topicData.main_posts[0].picture,
var feed = createFeed(topicData.topic_name, '', location, xml_url, post.username, urn); author: topicData.main_posts[0].username,
var title; pubDate: new Date(parseInt(topicData.main_posts[0].timestamp, 10)).toUTCString(),
ttl: Feed.defaults.ttl
var topic_posts = topicData.main_posts.concat(topicData.posts); }),
topic_posts = topicData.main_posts.concat(topicData.posts),
title, postData;
for (var i = 0, ii = topic_posts.length; i < ii; i++) { for (var i = 0, ii = topic_posts.length; i < ii; i++) {
urn = 'urn:' + cid + ':' + tid + ':' + topic_posts[i].pid;
title = 'Reply to ' + topicData.topic_name + ' on ' + (new Date(parseInt(topic_posts[i].timestamp, 10)).toUTCString()); title = 'Reply to ' + topicData.topic_name + ' on ' + (new Date(parseInt(topic_posts[i].timestamp, 10)).toUTCString());
postData = topic_posts[i];
feed.addNewItem( feed.item({
title, title: title,
location, description: postData.content,
topic_posts[i].timestamp, url: nconf.get('url') + 'topic/' + topicData.slug + '#' + postData.pid,
topic_posts[i].content, author: postData.username,
{ date: new Date(parseInt(postData.edited === 0 ? postData.timestamp : postData.edited, 10)).toUTCString()
'urn' : urn, });
'username' : topic_posts[i].username
}
);
} }
saveFeed('feeds/topics/' + tid + '.rss', feed); Feed.saveFeed('feeds/topics/' + tid + '.rss', feed);
}); });
}; };
Feed.updateCategory = function(cid) { Feed.updateCategory = function(cid) {
if (process.env.NODE_ENV === 'development') winston.info('[rss] Updating RSS feeds for category ' + cid);
categories.getCategoryById(cid, 0, function(err, categoryData) { categories.getCategoryById(cid, 0, function(err, categoryData) {
if (err) { if (err) return winston.error('Could not update RSS feed for category ' + cid, err.stack);
winston.error('Could not update RSS feed for category ' + cid, err.stack);
return;
}
var location = '/category/' + categoryData.category_id + '/' + categoryData.category_name, var feed = new rss({
xml_url = '/category' + cid + '.rss'; title: categoryData.category_name,
description: categoryData.category_description,
var urn = 'urn:' + cid; feed_url: Feed.defaults.baseUrl + '/categories/' + cid + '.rss',
var feed = createFeed(categoryData.category_name, '', location, xml_url, 'NodeBB', urn); // not exactly sure if author for a category should be site_title? site_url: nconf.get('url') + 'category/' + categoryData.category_id,
pubDate: new Date(parseInt(categoryData.topics[0].lastposttime, 10)).toUTCString(),
var title; ttl: Feed.defaults.ttl
var topics = categoryData.topics; }),
topics = categoryData.topics,
title, topicData;
for (var i = 0, ii = topics.length; i < ii; i++) { for (var i = 0, ii = topics.length; i < ii; i++) {
urn = 'urn:' + cid + ':' + topics[i].tid;
title = topics[i].title + '. Posted on ' + (new Date(parseInt(topics[i].timestamp, 10)).toUTCString()); title = topics[i].title + '. Posted on ' + (new Date(parseInt(topics[i].timestamp, 10)).toUTCString());
topicData = topics[i];
feed.addNewItem( feed.item({
title, title: title,
location, url: nconf.get('url') + 'topic/' + topicData.slug,
topics[i].timestamp, author: topicData.username,
topics[i].teaser_text, date: new Date(parseInt(topicData.lastposttime, 10)).toUTCString()
{ });
'urn' : urn,
'username' : topics[i].username
}
);
} }
saveFeed('feeds/categories/' + cid + '.rss', feed); Feed.saveFeed('feeds/categories/' + cid + '.rss', feed);
}); });
}; };