fix: enhance mqRSSRunParser to handle remote items and enqueue them correctly

Author: mitchdowney

src/functions/mq/rss/runParser.ts

@@ -1,5 +1,7 @@
+import { MQ_QUEUES } from 'podverse-helpers';
 import { parseRSSFeedAndSaveToDatabase } from "podverse-parser";
 import { MQQueueName, ActiveMQArtemisService } from "@queue/services/activeMQArtemis";
+import { mqRSSAdd } from './add';
 
 export const mqRSSRunParser = async (
   activeMQArtemisService: ActiveMQArtemisService,
@@ -14,7 +16,18 @@ export const mqRSSRunParser = async (
 
       const { url, podcast_index_id, options } = receivedMessage;
       if (url || podcast_index_id) {
-        await parseRSSFeedAndSaveToDatabase(url, podcast_index_id, options);
+        const result = await parseRSSFeedAndSaveToDatabase(url, podcast_index_id, options);
+        
+        if (result && Array.isArray(result.remoteItemsToParse) && result.remoteItemsToParse.length > 0) {
+          const mqConfig = MQ_QUEUES['rss-slow'];
+          for (const item of result.remoteItemsToParse) {
+            try {
+              await mqRSSAdd(activeMQArtemisService, { queueName: mqConfig.queueName, dedupeCacheTimeMS: mqConfig.dedupeCacheTimeMS, priority: mqConfig.priority, closeAfterSend: false, feedUrl: item.url, podcast_index_id: item.podcast_index_id }, item.options);
+            } catch (err) {
+              console.error('Error enqueueing remote item', err as Error);
+            }
+          }
+        }
         context.delivery?.accept();
       } else {
         throw new Error(`mqRSSRunParser: url or podcast_index_id not found in message ${bodyStr}`);