feat: non-breaking GraphQL Engine

n1ru4l · Aug 17, 2022 · 15abb85 · 15abb85
1 parent ad5f346
commit 15abb85
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 3 deletions.
diff --git a/packages/core/src/create.ts b/packages/core/src/create.ts
@@ -1,14 +1,15 @@
 import { GetEnvelopedFn, ComposeContext, Plugin, ArbitraryObject } from '@envelop/types';
 import { isPluginEnabled, PluginOrDisabledPlugin } from './enable-if.js';
-import { createEnvelopOrchestrator, EnvelopOrchestrator } from './orchestrator.js';
+import { createEnvelopOrchestrator, EnvelopOrchestrator, GraphQLEngine } from './orchestrator.js';
 import { traceOrchestrator } from './traced-orchestrator.js';
 
 export function envelop<PluginsType extends Plugin<any>[]>(options: {
   plugins: Array<PluginOrDisabledPlugin>;
   enableInternalTracing?: boolean;
+  engine?: typeof GraphQLEngine;
 }): GetEnvelopedFn<ComposeContext<PluginsType>> {
   const plugins = options.plugins.filter(isPluginEnabled);
-  let orchestrator = createEnvelopOrchestrator<ComposeContext<PluginsType>>(plugins);
+  let orchestrator = createEnvelopOrchestrator<ComposeContext<PluginsType>>(plugins, options.engine);
 
   if (options.enableInternalTracing) {
     orchestrator = traceOrchestrator(orchestrator);

diff --git a/packages/core/src/orchestrator.ts b/packages/core/src/orchestrator.ts
@@ -64,10 +64,31 @@ export type EnvelopOrchestrator<
   getCurrentSchema: () => Maybe<GraphQLSchema>;
 };
 
+export const GraphQLEngine = ({
+  parseFn,
+  executeFn,
+  validateFn,
+  subscribeFn,
+}: {
+  parseFn?: typeof parse;
+  executeFn?: typeof execute;
+  validateFn?: typeof validate;
+  subscribeFn?: typeof subscribe;
+}) => {
+  return {
+    parse: parseFn ?? parse,
+    execute: executeFn ?? execute,
+    validate: validateFn ?? validate,
+    subscribe: subscribeFn ?? subscribe,
+  };
+};
+
 export function createEnvelopOrchestrator<PluginsContext extends DefaultContext>(
-  plugins: Plugin[]
+  plugins: Plugin[],
+  engine: typeof GraphQLEngine = GraphQLEngine
 ): EnvelopOrchestrator<any, PluginsContext> {
   let schema: GraphQLSchema | undefined | null = null;
+  const { parse, execute, validate, subscribe } = engine({});
   let initDone = false;
   const onResolversHandlers: OnResolverCalledHook[] = [];
   for (const plugin of plugins) {