Pass URL search parameters through to sources

src/pages/api/[feedId].ts

@@ -5,12 +5,15 @@ import type { NextApiRequest, NextApiResponse } from 'next';
 
 const getFeed = async (req: NextApiRequest, res: NextApiResponse) => {
   try {
-    const { host } = req.headers;
     const { feedId } = req.query;
     if (typeof feedId !== 'string') return res.status(400).send('Missing Feed Id');
 
+    const { host } = req.headers;
+    const searchParams =
+      host && req.url ? new URL(`http://${host}${req.url}`).searchParams : undefined;
+
     const modConfig = await decompressModConfig(feedId);
-    const feedData = await fetchFeedData(modConfig.sources);
+    const feedData = await fetchFeedData(modConfig.sources, searchParams);
     const moddedFeedData = applyMods(feedData, modConfig);
     const feed = buildFeed(moddedFeedData, feedId, host);
 

src/services/feedService.ts

@@ -25,10 +25,13 @@ const buildFeed = (feed: FeedData, feedId: string, host?: string) => {
   return builder.build(feed) as string;
 };
 
-const fetchFeedData = async (urls: string[]) => {
+const fetchFeedData = async (urls: string[], searchParams?: URLSearchParams) => {
   const [firstFeed, ...otherFeeds] = await Promise.all(
-    urls.map((url) =>
-      fetch(url, {
+    urls.map((urlString) => {
+      const url = new URL(urlString);
+      if (searchParams) searchParams.forEach((value, key) => url.searchParams.set(key, value));
+
+      return fetch(url, {
         headers: {
           'Access-Control-Allow-Headers': 'Content-Type',
           'Access-Control-Allow-Origin': '*',
@@ -40,8 +43,8 @@ const fetchFeedData = async (urls: string[]) => {
         .catch((error) => {
           console.log(error);
           throw 'Error pulling source feed data';
-        })
-    )
+        });
+    })
   );
 
   if (!firstFeed) throw 'Error pulling source feed data';