gqty-dev · vicary · May 13, 2025
diff --git a/.changeset/all-buckets-relax.md b/.changeset/all-buckets-relax.md
@@ -0,0 +1,5 @@
+---
+'gqty': minor
+---
+
+Add `onError` option to `resolve()`
diff --git a/packages/gqty/src/Cache/index.ts b/packages/gqty/src/Cache/index.ts
@@ -190,7 +190,7 @@ export class Cache {
     const pathsSnapshot = Object.freeze([...paths]);
 
     this.#subscriptions.set(pathsSnapshot, fn);
-    this.#subscribeNormalized(paths, fn);
+    this.#subscribeNormalized(pathsSnapshot, fn);
 
     return () => {
       this.#subscriptions.delete(pathsSnapshot);

diff --git a/packages/gqty/src/Client/resolvers.ts b/packages/gqty/src/Client/resolvers.ts
@@ -172,6 +172,11 @@ export type ResolveOptions = ResolverOptions & {
   awaitsFetch?: boolean;
 
   onFetch?: (fetchPromise: Promise<unknown>) => void;
+
+  /**
+   * When specified, query errors are called here instead of being thrown.
+   */
+  onError?: (error: unknown) => void;
 };
 
 export type SubscribeOptions = ResolverOptions & {
@@ -387,15 +392,15 @@ export const createResolvers = <TSchema extends BaseGeneratedSchema>({
                 targetCaches.add(resolverCache);
               }
 
-              updateCaches(results, [...targetCaches], {
+              updateCaches(results, targetCaches, {
                 skipNotify: promiseDropped() || !context.notifyCacheUpdate,
               });
 
               correlatedCaches.delete(resolverCache);
 
               return results;
             },
-            // When neughty users are adding selections every next microtask, we
+            // When naughty users are adding selections every next microtask, we
             // forcibly start the fetch after a number of delays. This number is
             // picked arbitrarily, it should be a number that is large enough to
             // prevent excessive fetches but small enough to not block the
@@ -600,7 +605,7 @@ export const createResolvers = <TSchema extends BaseGeneratedSchema>({
       // Run once to trigger selections
       dataFn();
 
-      const fetchPromise = resolve().then(dataFn);
+      const fetchPromise = resolve().then(dataFn, options?.onError);
 
       if (options?.awaitsFetch ?? true) {
         await fetchPromise;

diff --git a/packages/gqty/src/Client/updateCaches.ts b/packages/gqty/src/Client/updateCaches.ts
@@ -5,8 +5,8 @@ import { GQtyError } from '../Error';
 import type { FetchResult } from './resolveSelections';
 
 export const updateCaches = <TData extends Record<string, unknown>>(
-  results: FetchResult<TData>[],
-  caches: Cache[],
+  results: Iterable<FetchResult<TData>>,
+  caches: Iterable<Cache>,
   cacheSetOptions?: CacheSetOptions
 ) => {
   const errorSet = new Set<GraphQLError>();
@@ -43,6 +43,6 @@ export const updateCaches = <TData extends Record<string, unknown>>(
   }
 
   if (errorSet.size) {
-    throw GQtyError.fromGraphQLErrors([...errorSet]);
+    throw GQtyError.fromGraphQLErrors(Array.from(errorSet));
   }
 };