1
import rss from '@astrojs/rss';
2
import sanitizeHtml from 'sanitize-html';
3
import MarkdownIt from 'markdown-it';
4
import { getCollection } from 'astro:content';
5
import { siteConfig } from '@/config';
6
import { parse as htmlParser } from 'node-html-parser';
7
import { getImage } from 'astro:assets';
8
import type { APIContext, ImageMetadata } from 'astro';
9
import type { RSSFeedItem } from '@astrojs/rss';
10
import { getSortedPosts } from '@/utils/content-utils';
11

12
const markdownParser = new MarkdownIt();
13

14
// get dynamic import of images as a map collection
15
const imagesGlob = import.meta.glob<{ default: ImageMetadata }>(
16
  '/src/content/**/*.{jpeg,jpg,png,gif,webp}', // include posts and assets
17
);
18

19
export async function GET(context: APIContext) {
20
  if (!context.site) {
21
    throw Error('site not set');
22
  }
23

24
  // Use the same ordering as site listing (pinned first, then by published desc)
25
  const posts = await getSortedPosts();
26
  const feed: RSSFeedItem[] = [];
27

28
  for (const post of posts) {
29
    // convert markdown to html string
30
    const body = markdownParser.render(post.body);
31
    // convert html string to DOM-like structure
32
    const html = htmlParser.parse(body);
33
    // hold all img tags in variable images
34
    const images = html.querySelectorAll('img');
35

36
    for (const img of images) {
37
      const src = img.getAttribute('src');
38
      if (!src) continue;
39

40
      // Handle content-relative images and convert them to built _astro paths
41
      if (src.startsWith('./') || src.startsWith('../')) {
42
        let importPath: string | null = null;
43

44
        if (src.startsWith('./')) {
45
          // Path relative to the post file directory
46
          const prefixRemoved = src.slice(2);
47
          importPath = `/src/content/posts/${prefixRemoved}`;
48
        } else {
49
          // Path like ../assets/images/xxx -> relative to /src/content/
50
          const cleaned = src.replace(/^\.\.\//, '');
51
          importPath = `/src/content/${cleaned}`;
52
        }
53

54
        const imageMod = await imagesGlob[importPath]?.()?.then((res) => res.default);
55
        if (imageMod) {
56
          const optimizedImg = await getImage({ src: imageMod });
57
          img.setAttribute('src', new URL(optimizedImg.src, context.site).href);
58
        }
59
      } else if (src.startsWith('/')) {
60
        // images starting with `/` are in public dir
61
        img.setAttribute('src', new URL(src, context.site).href);
62
      }
63
    }
64

65
    feed.push({
66
      title: post.data.title,
67
      description: post.data.description,
68
      pubDate: post.data.published,
69
      link: `/posts/${post.slug}/`,
70
      // sanitize the new html string with corrected image paths
71
      content: sanitizeHtml(html.toString(), {
72
        allowedTags: sanitizeHtml.defaults.allowedTags.concat(['img']),
73
      }),
74
    });
75
  }
76

77
  return rss({
78
    title: siteConfig.title,
79
    description: siteConfig.subtitle || 'No description',
80
    site: context.site,
81
    items: feed,
82
    customData: `<language>${siteConfig.lang}</language>`,
83
  });
84
}