introduce executeSubscriptionEvent

to replace the old exported functionality from execute

Author: yaacovCR

src/execution/__tests__/executor-test.ts

@@ -20,7 +20,7 @@ import {
 import { GraphQLBoolean, GraphQLInt, GraphQLString } from '../../type/scalars';
 import { GraphQLSchema } from '../../type/schema';
 
-import { execute, executeSync } from '../execute';
+import { execute, executeSubscriptionEvent, executeSync } from '../execute';
 
 describe('Execute: Handles basic execution tasks', () => {
   it('executes arbitrary code', async () => {
@@ -915,6 +915,19 @@ describe('Execute: Handles basic execution tasks', () => {
         },
       ],
     });
+
+    expectJSON(
+      executeSubscriptionEvent({ schema, document, operationName: 'S' }),
+    ).toDeepEqual({
+      data: null,
+      errors: [
+        {
+          message:
+            'Schema is not configured to execute subscription operation.',
+          locations: [{ line: 4, column: 7 }],
+        },
+      ],
+    });
   });
 
   it('correct field ordering despite execution order', async () => {

src/execution/execute.ts

@@ -1139,6 +1139,18 @@ export function createSourceEventStream(
   return prepareContextAndRunFn(args, createSourceEventStreamImpl);
 }
 
+/**
+ * Implements the "ExecuteSubscriptionEvent" algorithm described in the
+ * GraphQL specification.
+ */
+export function executeSubscriptionEvent(
+  args: ExecutionArgs,
+): PromiseOrValue<ExecutionResult> {
+  return prepareContextAndRunFn(args, (exeContext) =>
+    executeQueryOrMutation(exeContext, executeFields),
+  );
+}
+
 function createSourceEventStreamImpl(
   exeContext: ExecutionContext,
 ): PromiseOrValue<AsyncIterable<unknown> | ExecutionResult> {

src/execution/index.ts

@@ -3,6 +3,7 @@ export { pathToArray as responsePathAsArray } from '../jsutils/Path';
 export {
   createSourceEventStream,
   execute,
+  executeSubscriptionEvent,
   executeSync,
   defaultFieldResolver,
   defaultTypeResolver,

src/index.ts

@@ -321,6 +321,7 @@ export {
   getDirectiveValues,
   subscribe,
   createSourceEventStream,
+  executeSubscriptionEvent,
 } from './execution/index';
 
 export type {

src/type/__tests__/enumType-test.ts

@@ -110,6 +110,7 @@ const SubscriptionType = new GraphQLObjectType({
       async *subscribe(_source, { color }) {
         yield { subscribeToEnum: color }; /* c8 ignore start */
       } /* c8 ignore stop */,
+      resolve: (_source, { color }) => color,
     },
   },
 });