move around

launchport · Mar 31, 2022 · c4d7a90 · c4d7a90
1 parent 6696141
commit c4d7a90
Show file tree

Hide file tree

Showing 2 changed files with 39 additions and 34 deletions.
diff --git a/src/core.ts b/src/core.ts
@@ -39,37 +39,33 @@ const core = async <TContext>({
   if (isPreflight) {
     return new Response(null, { status: 204, headers })
   }
-  try {
-    const helixRequest = await createHelixRequest(request)
 
-    const { operationName, query, variables } =
-      getGraphQLParameters(helixRequest)
+  const helixRequest = await createHelixRequest(request)
 
-    const result = await processRequest({
-      operationName,
-      query,
-      variables,
-      request: helixRequest,
-      schema,
-      parse,
-      validate,
-      execute,
-      contextFactory,
-    })
+  const { operationName, query, variables } = getGraphQLParameters(helixRequest)
 
-    switch (result.type) {
-      case 'RESPONSE':
-        return getResponse(result, headers)
-      case 'PUSH':
-        // @todo cors headers
-        return getPushResponseSSE(result, request)
-      case 'MULTIPART_RESPONSE':
-        return getMultipartResponse(result, Response, ReadableStream as any)
-      default:
-        return new Response('Not supported.', { status: 405 })
-    }
-  } catch {
-    return new Response('Bad Request', { status: 400 })
+  const result = await processRequest({
+    operationName,
+    query,
+    variables,
+    request: helixRequest,
+    schema,
+    parse,
+    validate,
+    execute,
+    contextFactory,
+  })
+
+  switch (result.type) {
+    case 'RESPONSE':
+      return getResponse(result, headers)
+    case 'PUSH':
+      // @todo cors headers
+      return getPushResponseSSE(result, request)
+    case 'MULTIPART_RESPONSE':
+      return getMultipartResponse(result, Response, ReadableStream as any)
+    default:
+      return new Response('Not supported.', { status: 405 })
   }
 }
 

diff --git a/src/helix-flare.ts b/src/helix-flare.ts
@@ -36,12 +36,21 @@ const helixFlare = async <TContext>(
   schema: GraphQLSchema,
   { middlewares = [], access, contextFactory }: Options<TContext> = {},
 ) => {
-  return core({
-    request,
-    schema: applyMiddleware(schema, ...middlewares),
-    contextFactory,
-    access,
-  })
+  try {
+    return core({
+      request,
+      schema: applyMiddleware(schema, ...middlewares),
+      contextFactory,
+      access,
+    })
+  } catch (e) {
+    if (e instanceof SyntaxError) {
+      return new Response('Bad request', {
+        status: 400,
+        headers: { 'Content-Type': 'text/plain' },
+      })
+    }
+  }
 }
 
 export default helixFlare