Create src/lib/grabber/search.functions.ts

src/lib/grabber/search.functions.ts

@@ -0,0 +1,37 @@
+import { createServerFn } from '@tanstack/start';
+import fetch from 'node-fetch'; // Use bun's native fetch in production if preferred
+import { SiteConfig, NormalizedPost, getByPath } from './sites';
+
+export const searchPosts = createServerFn(async ({ args }) => {
+  const { siteId, tags, page, limit } = args;
+  const config = getByPath(siteId);
+
+  if (!config) return { error: 'Site not found' };
+
+  const url = new URL(`${config.baseUrl}${config.searchPath}`);
+  Object.entries(config.params).forEach(([key, param]) => {
+    url.searchParams.set(key, tags || page?.toString() || limit?.toString());
+  });
+
+  try {
+    const response = await fetch(url.toString(), { headers: config.headers });
+    if (!response.ok) throw new Error('Failed to fetch');
+    const data = await response.json();
+    const rawPosts = data[config.postsPath] || [];
+
+    const posts: NormalizedPost[] = rawPosts.map(post => ({
+      id: post[config.fields.id],
+      previewUrl: post[config.fields.previewUrl],
+      fileUrl: post[config.fields.fileUrl],
+      ext: post[config.fields.ext],
+      tags: post[config.fields.tags] as string[],
+      source: post[config.fields.source],
+      rating: post[config.fields.rating],
+      score: Number(post[config.fields.score]),
+    }));
+
+    return { posts };
+  } catch (e) {
+    return { error: e instanceof Error ? e.message : 'Unknown error' };
+  }
+});