fix(feed_url): ✨merge redirected url

Author: fengkx

controlers/rss.js

@@ -78,6 +78,7 @@ ctrl.rss = async (ctx, next) => {
         throw new Error('NOT_SUB');
     }
     let builder = [];
+
     builder.push(`<strong>${i18n['SUB_LIST']}</strong>`);
     if (raw) {
         feeds.forEach((feed) => {

middlewares/test-url.js

@@ -12,6 +12,8 @@ module.exports = async (ctx, next) => {
     } else {
         try {
             const res = await got.get(url);
+            // handle redirect
+            ctx.state.feedUrl = decodeURI(res.url);
             const parser = new Parser();
             let feed = await parser.parseString(res.body);
             delete feed.items;

proxies/rssFeed.js

@@ -220,4 +220,31 @@ px.getAllFeedsCount = async () => {
     }
 };
 
+px.handleRedirect = async (url, realUrl) => {
+    try {
+        const db = await dbPomise;
+        const oldFeed = await db.get(`SELECT * FROM rss_feed WHERE url=?`, url);
+        const realFeed = await db.get(
+            `SELECT * FROM rss_feed WHERE url=?`,
+            realUrl
+        );
+        if (realFeed) {
+            await db.run(
+                `UPDATE subscribes SET feed_id=? WHERE feed_id=?`,
+                realFeed.feed_id,
+                oldFeed.feed_id
+            );
+            await db.run(`DELETE FROM rss_feed WHERE url=?`, oldFeed.url);
+        } else {
+            await db.run(
+                `UPDATE rss_feed SET url=? WHERE url=?`,
+                realUrl,
+                oldFeed.url
+            );
+        }
+    } catch (e) {
+        throw new Error('DB_ERROR');
+    }
+};
+
 module.exports = px;

utils/fetch.js

@@ -10,7 +10,8 @@ const {
     updateHashList,
     failAttempt,
     getFeedByUrl,
-    resetErrorCount
+    resetErrorCount,
+    handleRedirect
 } = require('../proxies/rssFeed');
 const {
     notify_error_count,
@@ -23,6 +24,10 @@ const fetch = async (feedUrl) => {
     try {
         logger.debug(`fetching ${feedUrl}`);
         const res = await got.get(encodeURI(feedUrl));
+        // handle redirect
+        if (encodeURI(feedUrl) !== res.url) {
+            await handleRedirect(feedUrl, decodeURI(res.url));
+        }
         const parser = new Parser();
         const feed = await parser.parseString(res.body);
         const items = feed.items.slice(0, item_num);