RSS feeds for threads

Author: duxovni

src/routes/rss.nim

@@ -133,3 +133,34 @@ proc createRssRouter*(cfg: Config) =
 
       await cacheRss(key, rss)
       respRss(rss)
+
+    get "/@name/status/@id/rss":
+      cond '.' notin @"name"
+      let name = @"name"
+      let id = @"id"
+
+      var key = name & "/" & id
+
+      var rss = await getCachedRss(key)
+      if rss.cursor.len > 0:
+        respRss(rss)
+
+      var conv = await getTweet(id)
+      if conv == nil or conv.tweet == nil or conv.tweet.id == 0:
+        var error = "Tweet not found"
+        if conv != nil and conv.tweet != nil and conv.tweet.tombstone.len > 0:
+          error = conv.tweet.tombstone
+        resp Http404, showError(error, cfg)
+
+      while conv.after.more != 0:
+        let newer_conv = await getTweet($conv.after.content[^1].id)
+        if newer_conv == nil or newer_conv.tweet == nil or newer_conv.tweet.id == 0:
+          break
+        conv = newer_conv
+
+      let lastThreadTweets = conv.before.content & @[conv.tweet] & conv.after.content
+      let feed = compress renderThreadRss(lastThreadTweets, name, id, cfg)
+      rss = Rss(feed: feed, cursor: $lastThreadTweets[0].id)
+
+      await cacheRss(key, rss)
+      respRss(rss)

src/routes/status.nim

@@ -53,9 +53,11 @@ proc createStatusRouter*(cfg: Config) =
         elif card.video.isSome():
           images = @[card.video.get().thumb]
 
+
+      let rss = "/$1/status/$2/rss" % [@"name", @"id"]
       let html = renderConversation(conv, prefs, getPath() & "#m")
       resp renderMain(html, request, cfg, prefs, title, desc, ogTitle,
-                      images=images, video=video)
+                      images=images, video=video, rss=rss)
 
     get "/@name/@s/@id/@m/?@i?":
       cond @"s" in ["status", "statuses"]

src/views/rss.nimf

@@ -136,3 +136,21 @@ ${renderRssTweets(tweets, prefs, cfg)}
   </channel>
 </rss>
 #end proc
+#
+#proc renderThreadRss*(tweets: seq[Tweet]; username, tweetId: string; cfg: Config): string =
+#let prefs = Prefs(replaceTwitter: cfg.hostname, replaceYouTube: cfg.replaceYouTube)
+#let urlPrefix = getUrlPrefix(cfg)
+#result = ""
+<?xml version="1.0" encoding="UTF-8"?>
+<rss xmlns:atom="http://www.w3.org/2005/Atom" xmlns:dc="http://purl.org/dc/elements/1.1/" version="2.0">
+  <channel>
+    <atom:link href="${urlPrefix}/${username}/status/${tweetId}/rss" rel="self" type="application/rss+xml" />
+    <title>Thread for ${urlPrefix}/${username}/status/${tweetId}</title>
+    <link>${urlPrefix}/${username}/status/${tweetId}</link>
+    <description>${getDescription("Thread for " & urlPrefix & "/" & username & "/status/" & tweetId, cfg)}</description>
+    <language>en-us</language>
+    <ttl>40</ttl>
+${renderRssTweets(tweets, prefs, cfg)}
+  </channel>
+</rss>
+#end proc