feat(api): use request fetch (#3677)

Author: dargmuesli

src/runtime/internal/api.ts

@@ -1,26 +1,39 @@
-import type { H3Event } from 'h3'
+import { getRequestHeaders, type H3Event } from 'h3'
 import { checksums } from '#content/manifest'
 
+async function fetchContent<T>(
+  event: H3Event | undefined,
+  collection: string,
+  path: string,
+  options: NonNullable<Parameters<typeof $fetch>[1]>,
+): Promise<T> {
+  const headers = event ? getRequestHeaders(event) : {}
+  const url = `/__nuxt_content/${collection}/${path}`
+  const fetchOptions = {
+    ...options,
+    headers: {
+      ...headers,
+      ...options.headers,
+    },
+    query: { v: checksums[String(collection)], t: import.meta.dev ? Date.now() : undefined },
+  }
+  return event ? await event.$fetch(url, fetchOptions) : await $fetch(url, fetchOptions)
+}
+
 export async function fetchDatabase(event: H3Event | undefined, collection: string): Promise<string> {
-  return await $fetch(`/__nuxt_content/${collection}/sql_dump.txt`, {
-    context: event ? { cloudflare: event.context.cloudflare } : {},
+  return fetchContent(event, collection, 'sql_dump.txt', {
     responseType: 'text',
     headers: {
       'content-type': 'text/plain',
-      ...(event?.node?.req?.headers?.cookie ? { cookie: event.node.req.headers.cookie } : {}),
     },
-    query: { v: checksums[String(collection)], t: import.meta.dev ? Date.now() : undefined },
   })
 }
 
 export async function fetchQuery<Item>(event: H3Event | undefined, collection: string, sql: string): Promise<Item[]> {
-  return await $fetch(`/__nuxt_content/${collection}/query`, {
-    context: event ? { cloudflare: event.context.cloudflare } : {},
+  return fetchContent(event, collection, 'query', {
     headers: {
       'content-type': 'application/json',
-      ...(event?.node?.req?.headers?.cookie ? { cookie: event.node.req.headers.cookie } : {}),
     },
-    query: { v: checksums[String(collection)], t: import.meta.dev ? Date.now() : undefined },
     method: 'POST',
     body: {
       sql,