(function(Feed) { var RDB = require('./redis.js'), schema = require('./schema.js'), posts = require('./posts.js'), topics = require('./topics.js'), config = require('../config.js'); function saveFeed(feed, xml) { feed.endEntry(); console.log(xml.toString()) } function createFeed(xml, urn, title, feed_url, author) { var ATOMWriter = require('atom-writer'), feed = new ATOMWriter(xml); return feed .startFeed(urn) .writeStartIndex(1) .writeItemsPerPage(20) .writeTotalResults(20) .writeTitle(title) .writeLink(feed_url, 'application/atom+xml', 'self'); } function createEntry(feed, urn, title, content, url, author) { return feed .startEntry(urn) .writeTitle('Reply #' + title) .writeLink(url, 'text/html') .writeContent(content, 'text', 'en') .writeAuthorRAW(author) .endEntry(); } Feed.updateTopic = function(tid, cid) { var cache_time_in_seconds = 60, XMLWriter = require('xml-writer'); xml = new XMLWriter(true); function getTopicData(next) { topics.getTopicById(tid, 0, function(topicData) { next(null, topicData); }); } function getPostsData(next) { posts.getPostsByTid(tid, 0, -20, -1, function(postsData) { next(null, postsData); }); } async.parallel([getTopicData, getPostsData], function(err, results) { var topicData = results[0], postsData = results[1].postData, userData = results[1].userData, url = topicData.category_slug + '/' + topicData.slug; var post = topicData.main_posts[0]; var urn = 'urn:' + cid + ':' + tid; var feed = createFeed(xml, urn, topicData.topic_name, url, post.username); for (var i = 0, ii = postsData.pid.length; i < ii; i++) { urn = 'urn:' + cid + ':' + tid + ':' + postsData.pid[i]; feed = createEntry(feed, urn, postsData.pid[i], postsData.content[i], url, userData[postsData.uid[i]].username); } saveFeed(feed, xml); }); }; Feed.updateCategory = function(params) { }; }(exports));