feat: add edge request function

lib/graphql/_request.ts

@@ -0,0 +1,74 @@
+import "server-only"
+
+import { GraphQLClient } from "graphql-request"
+
+import { env } from "@/env/server"
+
+import type { DocumentNode } from "graphql"
+
+import type { Data } from "@/types/request"
+
+export async function request<T>(
+  client: GraphQLClient,
+  query: string | DocumentNode,
+  variables?: {},
+  next?: NextFetchRequestConfig
+): Promise<Data<T>> {
+  try {
+    if (next) {
+      client.requestConfig.next = next
+    }
+
+    if (env.PRINT_QUERY) {
+      const print = (await import("graphql/language/printer")).print
+      const rawResponse = await client.rawRequest<T>(
+        print(query as DocumentNode),
+        variables,
+        {
+          access_token: env.CMS_ACCESS_TOKEN,
+          "Content-Type": "application/json",
+        }
+      )
+
+      /**
+       * TODO: Send to Monitoring (Logging and Metrics)
+       */
+      console.log({
+        complexityLimit: rawResponse.headers.get("x-query-complexity"),
+      })
+      console.log({
+        referenceDepth: rawResponse.headers.get("x-reference-depth"),
+      })
+      console.log({ resolverCost: rawResponse.headers.get("x-resolver-cost") })
+
+      return {
+        data: rawResponse.data,
+      }
+    }
+
+    const print = (await import("graphql/language/printer")).print
+    const nr = Math.random()
+    console.log(`START REQUEST ${nr}`)
+    console.time(`OUTGOING REQUEST ${nr}`)
+    console.log(`Sending reqeust to ${env.CMS_URL}`)
+    console.log(`Query:`, print(query as DocumentNode))
+    console.log(`Variables:`, variables)
+
+    const response = await client.request<T>({
+      document: query,
+      requestHeaders: {
+        access_token: env.CMS_ACCESS_TOKEN,
+        "Content-Type": "application/json",
+      },
+      variables,
+    })
+
+    console.timeEnd(`OUTGOING REQUEST ${nr}`)
+    console.log({ response })
+
+    return { data: response }
+  } catch (error) {
+    console.error(error)
+    throw new Error("Something went wrong")
+  }
+}

lib/graphql/batchRequest.ts

@@ -12,9 +12,7 @@ export async function batchRequest<T>(
   try {
     const response = await Promise.allSettled(
       queries.map((query) =>
-        request<T>(query.document, query.variables, {
-          next: { tags: query.tags },
-        })
+        request<T>(query.document, query.variables, { tags: query.tags })
       )
     )
 

lib/graphql/edgeRequest.ts

@@ -0,0 +1,20 @@
+import { DocumentNode } from "graphql"
+import { GraphQLClient } from "graphql-request"
+
+import { env } from "@/env/server"
+
+import { request as _request } from "./_request"
+
+import { Data } from "@/types/request"
+
+const client = new GraphQLClient(env.CMS_URL, {
+  fetch: fetch,
+})
+
+export async function edgeRequest<T>(
+  query: string | DocumentNode,
+  variables?: {},
+  next?: NextFetchRequestConfig
+): Promise<Data<T>> {
+  return _request(client, query, variables, next)
+}

lib/graphql/request.ts

@@ -1,16 +1,14 @@
-import "server-only"
-
+import { DocumentNode } from "graphql"
 import { GraphQLClient } from "graphql-request"
 import { cache } from "react"
 
 import { env } from "@/env/server"
 
-import type { DocumentNode } from "graphql"
+import { request as _request } from "./_request"
 
-import type { Data } from "@/types/request"
+import { Data } from "@/types/request"
 
 const client = new GraphQLClient(env.CMS_URL, {
-  cache: "force-cache",
   fetch: cache(async function (
     url: URL | RequestInfo,
     params: RequestInit | undefined
@@ -22,50 +20,7 @@ const client = new GraphQLClient(env.CMS_URL, {
 export async function request<T>(
   query: string | DocumentNode,
   variables?: {},
-  options?: Pick<RequestInit, "cache" | "next">
+  next?: NextFetchRequestConfig
 ): Promise<Data<T>> {
-  if (options?.cache) {
-    client.requestConfig.cache = options.cache
-  }
-  if (options?.next) {
-    client.requestConfig.next = options.next
-  }
-
-  if (env.PRINT_QUERY) {
-    const { print } = await import("graphql")
-    const rawResponse = await client.rawRequest<T>(
-      print(query as DocumentNode),
-      variables,
-      {
-        access_token: env.CMS_ACCESS_TOKEN,
-        "Content-Type": "application/json",
-      }
-    )
-
-    /**
-     * TODO: Send to Monitoring (Logging and Metrics)
-     */
-    console.log({
-      complexityLimit: rawResponse.headers.get("x-query-complexity"),
-    })
-    console.log({
-      referenceDepth: rawResponse.headers.get("x-reference-depth"),
-    })
-    console.log({ resolverCost: rawResponse.headers.get("x-resolver-cost") })
-
-    return {
-      data: rawResponse.data,
-    }
-  }
-
-  const response = await client.request<T>({
-    document: query,
-    requestHeaders: {
-      access_token: env.CMS_ACCESS_TOKEN,
-      "Content-Type": "application/json",
-    },
-    variables,
-  })
-
-  return { data: response }
+  return _request(client, query, variables, next)
 }