Skip to content

Commit

Permalink
Broaden ExecutionArgs type and deprecate SubscriptionArgs
Browse files Browse the repository at this point in the history
Broaden ExecutionArgs to include all properties within SubscriptionArgs. Retain the SubscriptionArgs type for backwards compability, to be removed in the next major version.

This allows for better unification of subscription operations alongside queries and mutations as additional targets of execution.
  • Loading branch information
yaacovCR committed Oct 7, 2021
1 parent ff41b34 commit d5f133f
Show file tree
Hide file tree
Showing 2 changed files with 34 additions and 46 deletions.
48 changes: 17 additions & 31 deletions src/execution/execute.ts
Expand Up @@ -114,6 +114,7 @@ export interface ExecutionContext {
variableValues: { [variable: string]: unknown };
fieldResolver: GraphQLFieldResolver<any, any>;
typeResolver: GraphQLTypeResolver<any, any>;
subscribeFieldResolver?: GraphQLFieldResolver<any, any>;
errors: Array<GraphQLError>;
}

Expand Down Expand Up @@ -151,6 +152,7 @@ export interface ExecutionArgs {
operationName?: Maybe<string>;
fieldResolver?: Maybe<GraphQLFieldResolver<any, any>>;
typeResolver?: Maybe<GraphQLTypeResolver<any, any>>;
subscribeFieldResolver?: Maybe<GraphQLFieldResolver<any, any>>;
}

/**
Expand All @@ -164,32 +166,14 @@ export interface ExecutionArgs {
* a GraphQLError will be thrown immediately explaining the invalid input.
*/
export function execute(args: ExecutionArgs): PromiseOrValue<ExecutionResult> {
const {
schema,
document,
rootValue,
contextValue,
variableValues,
operationName,
fieldResolver,
typeResolver,
} = args;
const { schema, document, variableValues } = args;

// If arguments are missing or incorrect, throw an error.
assertValidExecutionArguments(schema, document, variableValues);

// If a valid execution context cannot be created due to incorrect arguments,
// a "Response" with only errors is returned.
const exeContext = buildExecutionContext(
schema,
document,
rootValue,
contextValue,
variableValues,
operationName,
fieldResolver,
typeResolver,
);
const exeContext = buildExecutionContext(args);

// Return early errors if execution context failed.
if (!('schema' in exeContext)) {
Expand Down Expand Up @@ -281,16 +265,17 @@ export function assertValidExecutionArguments(
*
* @internal
*/
export function buildExecutionContext(
schema: GraphQLSchema,
document: DocumentNode,
rootValue: unknown,
contextValue: unknown,
rawVariableValues: Maybe<{ readonly [variable: string]: unknown }>,
operationName: Maybe<string>,
fieldResolver: Maybe<GraphQLFieldResolver<unknown, unknown>>,
typeResolver?: Maybe<GraphQLTypeResolver<unknown, unknown>>,
): ReadonlyArray<GraphQLError> | ExecutionContext {
export function buildExecutionContext({
schema,
document,
rootValue,
contextValue,
variableValues,
operationName,
fieldResolver,
typeResolver,
subscribeFieldResolver,
}: ExecutionArgs): ReadonlyArray<GraphQLError> | ExecutionContext {
let operation: OperationDefinitionNode | undefined;
const fragments: ObjMap<FragmentDefinitionNode> = Object.create(null);
for (const definition of document.definitions) {
Expand Down Expand Up @@ -328,7 +313,7 @@ export function buildExecutionContext(
const coercedVariableValues = getVariableValues(
schema,
variableDefinitions,
rawVariableValues ?? {},
variableValues ?? {},
{ maxErrors: 50 },
);

Expand All @@ -345,6 +330,7 @@ export function buildExecutionContext(
variableValues: coercedVariableValues.coerced,
fieldResolver: fieldResolver ?? defaultFieldResolver,
typeResolver: typeResolver ?? defaultTypeResolver,
subscribeFieldResolver: subscribeFieldResolver ?? undefined,
errors: [],
};
}
Expand Down
32 changes: 17 additions & 15 deletions src/execution/subscribe.ts
Expand Up @@ -13,7 +13,11 @@ import type { GraphQLFieldResolver } from '../type/definition';

import { getOperationRootType } from '../utilities/getOperationRootType';

import type { ExecutionResult, ExecutionContext } from './execute';
import type {
ExecutionArgs,
ExecutionResult,
ExecutionContext,
} from './execute';
import { collectFields } from './collectFields';
import { getArgumentValues } from './values';
import {
Expand All @@ -25,16 +29,14 @@ import {
} from './execute';
import { mapAsyncIterator } from './mapAsyncIterator';

export interface SubscriptionArgs {
schema: GraphQLSchema;
document: DocumentNode;
rootValue?: unknown;
contextValue?: unknown;
variableValues?: Maybe<{ readonly [variable: string]: unknown }>;
operationName?: Maybe<string>;
fieldResolver?: Maybe<GraphQLFieldResolver<any, any>>;
subscribeFieldResolver?: Maybe<GraphQLFieldResolver<any, any>>;
}
/**
* Note: ExecutionArgs has been broadened to include all properties
* within SubscriptionArgs. The SubscriptionArgs type is retained
* for backwards compability and will be removed in the next major
* version.
*/
// eslint-disable-next-line @typescript-eslint/no-empty-interface
export interface SubscriptionArgs extends ExecutionArgs {}

/**
* Implements the "Subscribe" algorithm described in the GraphQL specification.
Expand Down Expand Up @@ -141,23 +143,23 @@ export async function createSourceEventStream(
contextValue?: unknown,
variableValues?: Maybe<{ readonly [variable: string]: unknown }>,
operationName?: Maybe<string>,
fieldResolver?: Maybe<GraphQLFieldResolver<any, any>>,
subscribeFieldResolver?: Maybe<GraphQLFieldResolver<any, any>>,
): Promise<AsyncIterable<unknown> | ExecutionResult> {
// If arguments are missing or incorrectly typed, this is an internal
// developer mistake which should throw an early error.
assertValidExecutionArguments(schema, document, variableValues);

// If a valid execution context cannot be created due to incorrect arguments,
// a "Response" with only errors is returned.
const exeContext = buildExecutionContext(
const exeContext = buildExecutionContext({
schema,
document,
rootValue,
contextValue,
variableValues,
operationName,
fieldResolver,
);
subscribeFieldResolver,
});

// Return early errors if execution context failed.
if (!('schema' in exeContext)) {
Expand Down

0 comments on commit d5f133f

Please sign in to comment.