`;\n })\n // Fix URLs in a tags\n .replace(/]*href=\\\\?(\"|')(.*?)\\\\?(\"|')[^>]*>/gi, (match, q1, url) => {\n const attrs = match.match(/\\s(\\w+)=\\\\?(\"|')(.*?)\\\\?(\"|')/g) || [];\n const cleanAttrs = attrs\n .filter((attr) => !attr.startsWith(' href='))\n .map((attr) => attr.replace(/=\\\\?(\"|')(.*?)\\\\?(\"|')/g, '=\"$2\"'))\n .join('');\n\n const cleanUrl = url\n .replace(/"/g, '')\n .replace(/\\\\\"/g, '')\n .replace(/[\"']+$/g, '')\n .replace(/\\/[\"']+/g, '/');\n\n return ``;\n })\n // Remove script tags for security\n .replace(/)<[^<]*)*<\\/script>/gi, '')\n // Truncate if too long\n .substring(0, 2000)\n .trim()\n );\n}\n\n/**\n * Extract image URL from RSS/Atom item using various common fields\n * @param {Object} item - RSS or Atom item object\n * @returns {string|undefined} Image URL if found\n */\nfunction extractImageUrl(item) {\n // Try enclosure\n const enclosure = item.enclosure;\n if (\n enclosure &&\n typeof enclosure['@_type'] === 'string' &&\n enclosure['@_type'].startsWith('image/')\n ) {\n return enclosure['@_url'];\n }\n\n // Try media:content\n const mediaContent = item['media:content'];\n if (\n mediaContent &&\n typeof mediaContent['@_type'] === 'string' &&\n mediaContent['@_type'].startsWith('image/')\n ) {\n return mediaContent['@_url'];\n }\n\n // Try media:thumbnail\n const mediaThumbnail = item['media:thumbnail'];\n if (mediaThumbnail && mediaThumbnail['@_url']) {\n return mediaThumbnail['@_url'];\n }\n\n // Extract from HTML content\n const content = item.description || item['content:encoded'] || item.summary || '';\n if (typeof content === 'string') {\n const imgMatch = content.match(/]+src=[\"']([^\"']+)[\"'][^>]*>/i);\n if (imgMatch) {\n return imgMatch[1];\n }\n }\n\n return undefined;\n}\n\n/**\n * Parse RSS/Atom XML content into structured feed entries\n * @param {string} xmlContent - Raw RSS/Atom XML content\n * @returns {Object[]} Array of parsed feed entries\n */\nfunction parseRssXml(xmlContent) {\n try {\n const parser = new XMLParser({\n ignoreAttributes: false,\n attributeNamePrefix: '@_',\n textNodeName: '#text',\n removeNSPrefix: false,\n parseAttributeValue: false,\n parseTagValue: false,\n });\n\n const result = parser.parse(xmlContent);\n const entries = [];\n\n // Handle RSS format\n if (result.rss?.channel?.item) {\n const items = Array.isArray(result.rss.channel.item)\n ? result.rss.channel.item\n : [result.rss.channel.item];\n\n for (const item of items) {\n entries.push({\n title: item.title || '',\n link: item.link || '',\n published: item.pubDate || item['dc:date'] || '',\n description: item.description || item['content:encoded'] || '',\n imageUrl: extractImageUrl(item),\n });\n }\n }\n // Handle Atom format\n else if (result.feed?.entry) {\n const items = Array.isArray(result.feed.entry) ? result.feed.entry : [result.feed.entry];\n\n for (const item of items) {\n entries.push({\n title: item.title?.['#text'] || item.title || '',\n link: item.link?.['@_href'] || item.link || '',\n published: item.published || item.updated || '',\n description:\n item.summary?.['#text'] ||\n item.summary ||\n item.content?.['#text'] ||\n item.content ||\n '',\n imageUrl: extractImageUrl(item),\n });\n }\n }\n\n return entries;\n } catch (error) {\n console.error('Error parsing RSS XML:', error);\n return [];\n }\n}\n\n/**\n * Convert parsed API entry to ProcessedEntry format\n * @param {Object} apiEntry - The API feed entry\n * @param {Object} feed - The original feed configuration\n * @param {string} fetchedAt - ISO timestamp when feed was fetched\n * @returns {Object} The processed entry\n */\nfunction convertApiEntryToProcessedEntry(apiEntry, feed, fetchedAt) {\n return {\n title: apiEntry.title || '',\n link: apiEntry.link || '',\n pubDate: parseDate(apiEntry.published),\n snippet: preprocessHtmlSnippet(apiEntry.description) || '',\n author: feed.authorName,\n feedSource: feed.url,\n lastFetched: fetchedAt,\n imageUrl: apiEntry.imageUrl || undefined,\n };\n}\n\n/**\n * Fetch RSS feed content from URL with timeout and error handling\n * @param {string} url - RSS feed URL\n * @returns {Promise} Raw XML content\n */\nasync function fetchFeedContent(url) {\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), 10000); // 10 second timeout\n\n try {\n const response = await fetch(url, {\n headers: {\n 'User-Agent': 'Subcurrent Feed Reader (https://github.com/astoria-tech/subcurrent-astro)',\n Accept:\n 'application/rss+xml, application/rdf+xml, application/atom+xml, application/xml, text/xml',\n },\n signal: controller.signal,\n });\n\n clearTimeout(timeoutId);\n\n if (!response.ok) {\n throw new Error(`HTTP ${response.status}: ${response.statusText}`);\n }\n\n return await response.text();\n } catch (error) {\n clearTimeout(timeoutId);\n throw error;\n }\n}\n\n/**\n * Process a single RSS feed and return structured entries\n * @param {Object} feed - Feed configuration object\n * @returns {Promise

Branches1

Branches
1