enable parallel execution of batch requests prior to implementation of …

…apollographql#176
PhiloInc · Dec 12, 2016 · 4408f55 · 4408f55
1 parent 962930e
commit 4408f55
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/packages/graphql-server-hapi/package.json b/packages/graphql-server-hapi/package.json
@@ -1,6 +1,6 @@
 {
-  "name": "graphql-server-hapi",
-  "version": "0.4.3",
+  "name": "@philo/graphql-server-hapi",
+  "version": "0.4.3-p1",
   "description": "Production-ready Node.js GraphQL server for Hapi",
   "main": "dist/index.js",
   "scripts": {

diff --git a/packages/graphql-server-hapi/src/hapiApollo.ts b/packages/graphql-server-hapi/src/hapiApollo.ts
@@ -125,8 +125,7 @@ async function getGraphQLOptions(request: Request, reply: IReply): Promise<{}> {
 async function processQuery(graphqlParams, optionsObject: GraphQLOptions, isBatch: boolean, reply) {
   const formatErrorFn = optionsObject.formatError || formatError;
 
-  let responses: GraphQLResult[] = [];
-  for (let query of graphqlParams) {
+  const requests = graphqlParams.map(async (query) => {
     try {
       // Shallow clone context for queries in batches. This allows
       // users to distinguish multiple queries in the batch and to
@@ -154,11 +153,12 @@ async function processQuery(graphqlParams, optionsObject: GraphQLOptions, isBatc
         params = optionsObject.formatParams(params);
       }
 
-      responses.push(await runQuery(params));
+      return await runQuery(params);
     } catch (e) {
-      responses.push({ errors: [formatErrorFn(e)] });
+      return { errors: [formatErrorFn(e)] };
     }
-  }
+  });
+  const responses: GraphQLResult[] = await Promise.all(requests);
   return reply(responses);
 }