get defer/stream from graphql-js (#4796)

* get defer/stream from graphql-js

* prettier

* use agnostic root type getter

* use createGraphQLError

* fix issue with v15 and v16 cause of obj vs enum

* Fix tests

* Remove unused subscribe

* Fix TS

* Fix ESM

* ESM fix

* move collect fields to utils

* chore(dependencies): updated changesets for modified dependencies

* run prettier

* make default execute incremental

* chore(dependencies): updated changesets for modified dependencies

* ..

* chore(dependencies): updated changesets for modified dependencies

* Sync

* Use ValueOrPromise

* chore(dependencies): updated changesets for modified dependencies

* Fix

* chore(dependencies): updated changesets for modified dependencies

* Go

* Go

* stop

Co-authored-by: Arda TANRIKULU <ardatanrikulu@gmail.com>
Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

Author: 3 people

.changeset/@graphql-tools_executor-4796-dependencies.md

@@ -0,0 +1,6 @@
+---
+'@graphql-tools/executor': patch
+---
+dependencies updates:
+  - Added dependency [`@repeaterjs/repeater@3.0.4` ↗︎](https://www.npmjs.com/package/@repeaterjs/repeater/v/3.0.4) (to `dependencies`)
+  - Added dependency [`value-or-promise@1.0.1` ↗︎](https://www.npmjs.com/package/value-or-promise/v/1.0.1) (to `dependencies`)

.changeset/chatty-worms-pull.md

@@ -0,0 +1,5 @@
+---
+'@graphql-tools/utils': minor
+---
+
+add `@defer` directive

.changeset/quick-clocks-beam.md

@@ -0,0 +1,5 @@
+---
+'@graphql-tools/executor': patch
+---
+
+get defer stream from graphql-js

.changeset/spotty-maps-approve.md

@@ -0,0 +1,5 @@
+---
+'@graphql-tools/utils': minor
+---
+
+export collect field helpers

.changeset/spotty-suns-bake.md

@@ -0,0 +1,5 @@
+---
+'@graphql-tools/utils': minor
+---
+
+add `@stream` directive

.changeset/warm-bags-camp.md

@@ -0,0 +1,7 @@
+---
+'@graphql-tools/utils': major
+'@graphql-tools/delegate': patch
+'@graphql-tools/stitch': patch
+---
+
+update `collectFields` to support collecting deffered values

packages/batch-delegate/tests/basic.example.test.ts

@@ -1,4 +1,4 @@
-import { execute } from '@graphql-tools/executor';
+import { execute, isIncrementalResult } from '@graphql-tools/executor';
 import { OperationTypeNode, parse } from 'graphql';
 
 import { makeExecutableSchema } from '@graphql-tools/schema';
@@ -89,6 +89,9 @@ describe('batch delegation within basic stitching example', () => {
     const result = await execute({ schema: stitchedSchema, document: parse(query) });
 
     expect(numCalls).toEqual(1);
+
+    if (isIncrementalResult(result)) throw Error('result is incremental');
+
     expect(result.errors).toBeUndefined();
     const chirps: any = result.data!['trendingChirps'];
     expect(chirps[0].chirpedAtUser.email).not.toBe(null);
@@ -182,6 +185,9 @@ describe('batch delegation within basic stitching example', () => {
 
     const result = await execute({ schema: stitchedSchema, document: parse(query) });
     expect(numCalls).toEqual(1);
+
+    if (isIncrementalResult(result)) throw Error('result is incremental');
+
     expect(result.data).toEqual({
       users: [
         {

packages/batch-delegate/tests/withTransforms.test.ts

@@ -1,4 +1,4 @@
-import { execute } from '@graphql-tools/executor';
+import { execute, isIncrementalResult } from '@graphql-tools/executor';
 import { GraphQLList, GraphQLObjectType, Kind, OperationTypeNode, parse } from 'graphql';
 
 import { makeExecutableSchema } from '@graphql-tools/schema';
@@ -121,6 +121,7 @@ describe('works with complex transforms', () => {
     `;
 
     const result = await execute({ schema: stitchedSchema, document: parse(query) });
+    if (isIncrementalResult(result)) throw Error('result is incremental');
 
     expect(result.errors).toBeUndefined();
     expect(result.data).toEqual({

packages/batch-execute/tests/batchExecute.test.ts

@@ -2,7 +2,7 @@ import { parse, print, OperationDefinitionNode, validate } from 'graphql';
 import { makeExecutableSchema } from '@graphql-tools/schema';
 import { createBatchingExecutor } from '@graphql-tools/batch-execute';
 import { ExecutionResult, Executor } from '@graphql-tools/utils';
-import { execute } from '@graphql-tools/executor';
+import { normalizedExecutor } from '@graphql-tools/executor';
 
 describe('batch execution', () => {
   let executorCalls = 0;
@@ -41,7 +41,7 @@ describe('batch execution', () => {
     if (errors.length > 0) {
       return { errors };
     }
-    return execute({
+    return normalizedExecutor({
       schema,
       document,
       variableValues: executorVariables,

packages/delegate/src/delegateToSchema.ts

@@ -36,7 +36,7 @@ import { Subschema } from './Subschema.js';
 import { createRequest, getDelegatingOperation } from './createRequest.js';
 import { Transformer } from './Transformer.js';
 import { applySchemaTransforms } from './applySchemaTransforms.js';
-import { ExecutionArgs, execute, subscribe } from '@graphql-tools/executor';
+import { normalizedExecutor } from '@graphql-tools/executor';
 
 export function delegateToSchema<
   TContext extends Record<string, any> = Record<string, any>,
@@ -219,18 +219,13 @@ function getExecutor<TContext extends Record<string, any>>(
 
 export const createDefaultExecutor = memoize1(function createDefaultExecutor(schema: GraphQLSchema): Executor {
   return function defaultExecutor(request: ExecutionRequest) {
-    const executionArgs: ExecutionArgs = {
+    return normalizedExecutor({
       schema,
       document: request.document,
       rootValue: request.rootValue,
       contextValue: request.context,
       variableValues: request.variables,
       operationName: request.operationName,
-    };
-    const operationType = request.operationType || getOperationASTFromRequest(request).operation;
-    if (operationType === 'subscription') {
-      return subscribe(executionArgs);
-    }
-    return execute(executionArgs);
+    });
   };
 });