feat(gqwery): fetch executor (#243)

* feat(gqwery): fetch executor

* refactor: remove ability to specify a fetchFn

packages/gqwery/src/executor/index.ts

@@ -15,6 +15,11 @@ import {
 import type { IResolvers } from "@graphql-tools/utils";
 import { type DocumentNode, print } from "graphql";
 import { makeExecutableSchema } from "@graphql-tools/schema";
+import {
+	buildHTTPExecutor,
+	type HTTPExecutorOptions,
+} from "@graphql-tools/executor-http";
+export { buildHTTPExecutor } from "@graphql-tools/executor-http";
 
 export interface CombinedExecutorOptions {
 	[OperationTypeNode.QUERY]: Executor;
@@ -58,6 +63,45 @@ export const buildCombinedExecutor = (options: CombinedExecutorOptions) => {
 	};
 };
 
+export interface BuildFetchExecutorOptions
+	extends Omit<HTTPExecutorOptions, "timeout" | "fetch"> {
+	signal?: AbortSignal;
+}
+
+export const buildFetchExecutor = (options?: BuildFetchExecutorOptions) => {
+	const abortableFetch = new Proxy(fetch, {
+		apply: (fetch, thisArg, args) => {
+			const fetchOptions: RequestInit = {
+				...args.at(-1),
+				signal: options?.signal,
+			};
+
+			return Reflect.apply(fetch, thisArg, [args[0], fetchOptions]);
+		},
+	});
+
+	const executor = buildHTTPExecutor({
+		...options,
+		fetch: abortableFetch,
+	});
+
+	return async <R extends Record<string, any> = any>(
+		executorRequest: ExecutionRequest,
+	) => {
+		const result = await executor(executorRequest);
+
+		if (isAsyncIterable(result)) {
+			return result;
+		}
+
+		if (result.errors) {
+			throw new AggregateError(result.errors);
+		}
+
+		return result.data as R;
+	};
+};
+
 export interface BuildMockExecutorOptions<TResolvers = IResolvers> {
 	typeDefs: string | DocumentNode;
 	store?: IMockStore;

packages/gqwery/src/index.ts

@@ -5,12 +5,11 @@ export { createQueryKey, isQueryKey } from "./cache/query-key";
 export {
 	buildCombinedExecutor,
 	buildMockExecutor,
+	buildFetchExecutor,
 	type BuildMockExecutorOptions,
 } from "./executor";
-
-export { buildGraphQLWSExecutor } from "@graphql-tools/executor-graphql-ws";
-export { buildHTTPExecutor } from "@graphql-tools/executor-http";
 export { RequestManager } from "./executor/request-manager";
 
+export { buildGraphQLWSExecutor as buildWebSocketExecutor } from "@graphql-tools/executor-graphql-ws";
+
 export { OperationTypeNode as OperationType } from "graphql";
-export { OperationTypeNode } from "graphql";