feat: support fetch for Next.js app-router

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@sanity/client",
-  "version": "6.1.7",
+  "version": "6.2.0-fetch.6",
   "description": "Client for retrieving, creating and patching data from Sanity.io",
   "keywords": [
     "sanity",
@@ -71,6 +71,7 @@
     "prepublishOnly": "npm run build",
     "rollup": "NODE_ENV=production rollup -c rollup.config.cjs",
     "test": "vitest",
+    "type-check": "tsc --noEmit",
     "test:browser": "npm test -- --config ./vitest.browser.config.ts",
     "test:bun": "(cd runtimes/bun && bun wiptest)",
     "test:deno": "deno test --allow-read --allow-net --allow-env --fail-fast --import-map=runtimes/deno/import_map.json runtimes/deno",
@@ -91,7 +92,7 @@
   },
   "dependencies": {
     "@sanity/eventsource": "^5.0.0",
-    "get-it": "^8.1.0",
+    "get-it": "^8.2.0",
     "rxjs": "^7.0.0"
   },
   "devDependencies": {

src/data/dataMethods.ts

@@ -69,8 +69,13 @@ export function _fetch<R, Q extends QueryParams>(
 ): Observable<RawQueryResponse<R> | R> {
   const mapResponse =
     options.filterResponse === false ? (res: Any) => res : (res: Any) => res.result
+  const {cache, next, ...opts} = options
+  const reqOpts =
+    typeof cache !== 'undefined' || typeof next !== 'undefined'
+      ? {...opts, fetch: {cache, next}}
+      : opts
 
-  return _dataRequest(client, httpRequest, 'query', {query, params}, options).pipe(map(mapResponse))
+  return _dataRequest(client, httpRequest, 'query', {query, params}, reqOpts).pipe(map(mapResponse))
 }
 
 /** @internal */
@@ -226,6 +231,7 @@ export function _dataRequest(
     tag,
     canUseCdn: isQuery,
     signal: options.signal,
+    fetch: options.fetch,
   }
 
   return _requestObservable(client, httpRequest, reqOptions).pipe(

src/http/requestOptions.ts

@@ -29,5 +29,9 @@ export function requestOptions(config: Any, overrides: Any = {}): Omit<RequestOp
     proxy: overrides.proxy || config.proxy,
     json: true,
     withCredentials,
+    fetch:
+      typeof overrides.fetch === 'object' && typeof config.fetch === 'object'
+        ? {...config.fetch, ...overrides.fetch}
+        : overrides.fetch || config.fetch,
   })
 }

src/types.ts

@@ -28,6 +28,15 @@ export interface RequestOptions {
   signal?: AbortSignal
 }
 
+/**
+ * Options for the native `fetch` feature, used by the Next.js app-router
+ * @public
+ */
+export interface RequestFetchOptions<T = 'next'> {
+  cache?: RequestInit['cache']
+  next?: T extends keyof RequestInit ? RequestInit[T] : never
+}
+
 /** @public */
 export type ClientPerspective = 'previewDrafts' | 'published' | 'raw'
 
@@ -76,6 +85,10 @@ export interface ClientConfig {
    * Adds a `resultSourceMap` key to the API response, with the type `ContentSourceMap`
    */
   resultSourceMap?: boolean
+  /**
+   * Experimental, opts-in to using native `fetch` as transport in order to make full use of React Server Components
+   */
+  fetch?: RequestFetchOptions | boolean
 }
 
 /** @public */
@@ -486,12 +499,18 @@ export interface ListenOptions {
 }
 
 /** @public */
-export type FilteredResponseQueryOptions = RequestOptions & {
+export type ResponseQueryOptions<T = 'next'> = RequestOptions & {
+  cache?: RequestInit['cache']
+  next?: T extends keyof RequestInit ? RequestInit[T] : never
+}
+
+/** @public */
+export type FilteredResponseQueryOptions = ResponseQueryOptions & {
   filterResponse?: true
 }
 
 /** @public */
-export type UnfilteredResponseQueryOptions = RequestOptions & {
+export type UnfilteredResponseQueryOptions = ResponseQueryOptions & {
   filterResponse: false
 }