GraphQL Playground Logo

+ + + + + `; +} diff --git a/src/http.ts b/src/http.ts new file mode 100755 index 0000000..c8bfa0f --- /dev/null +++ b/src/http.ts @@ -0,0 +1,121 @@ + + + +/// util + +import { runHttpQuery } from "./common.ts"; + +import type { GQLOptions, GQLRequest, GraphQLParams } from "./utility/types.ts"; + + + +/// export + +export function GraphQLHTTP< + Req extends GQLRequest = GQLRequest, + Ctx extends { request: Req } = { request: Req }>({ + playgroundOptions = {}, + headers = {}, + ...options + }: GQLOptions) { + /** + * Create a new GraphQL HTTP middleware with schema, context etc + * @param {GQLOptions} options + * + * @example + * ```ts + * const graphql = await GraphQLHTTP({ schema }) + * + * for await (const req of s) graphql(req) + * ``` + */ + + return async (request: Req) => { + const accept = request.headers.get("Accept") || ""; + + const typeList = ["application/json", "text/html", "text/plain", "*/*"] + .map(contentType => ({ + contentType, + index: accept.indexOf(contentType) + })) + .filter(({ index }) => index >= 0) + .sort((a, b) => a.index - b.index) + .map(({ contentType }) => contentType); + + if (accept && !typeList.length) { + return new Response("Not Acceptable", { + headers: new Headers(headers), + status: 406 + }); + } else if (!["GET", "PUT", "POST", "PATCH"].includes(request.method)) { + return new Response("Method Not Allowed", { + headers: new Headers(headers), + status: 405 + }); + } + + let params: Promise; + + if (request.method === "GET") { + const urlQuery = request.url.substring(request.url.indexOf("?")); + const queryParams = new URLSearchParams(urlQuery); + + if (options.graphiql && typeList[0] === "text/html" && !queryParams.has("raw")) { + const { renderPlaygroundPage } = await import("./graphiql/render.ts"); + + const playground = renderPlaygroundPage({ + ...playgroundOptions, + endpoint: "/graphql" + }); + + return new Response(playground, { + headers: new Headers({ + "Content-Type": "text/html", + ...headers + }) + }); + } else if (typeList.length === 1 && typeList[0] === "text/html") { + return new Response("Not Acceptable", { + headers: new Headers(headers), + status: 406 + }); + } else if (queryParams.has("query")) { + params = Promise.resolve({ query: queryParams.get("query") } as GraphQLParams); + } else { + params = Promise.reject(new Error("No query given!")); + } + } else if (typeList.length === 1 && typeList[0] === "text/html") { + return new Response("Not Acceptable", { + headers: new Headers(headers), + status: 406 + }); + } else { + params = request.json(); + } + + try { + const result = await runHttpQuery(await params, options, { request }); + let contentType = "text/plain"; + + if (!typeList.length || typeList.includes("application/json") || typeList.includes("*/*")) + contentType = "application/json"; + + return new Response(JSON.stringify(result, null, 2), { + headers: new Headers({ + "Content-Type": contentType, + ...headers + }), + status: 200 + }); + } catch(e) { + console.error(e); + + return new Response( + "Malformed Request " + (request.method === "GET" ? "Query" : "Body"), { + headers: new Headers(headers), + status: 400 + } + ); + } + } +} diff --git a/src/import.ts b/src/import.ts new file mode 100644 index 0000000..ffc2c68 --- /dev/null +++ b/src/import.ts @@ -0,0 +1,56 @@ + + + +/// import + +import { dirname, join } from "https://deno.land/std/path/mod.ts"; +import { gql } from "./gql.ts"; + +import type { DocumentNode } from "npm:graphql@16.6.0"; + +/// util + +const { cwd, readFileSync } = Deno; +const importRegex = /^#\s(import)\s.*(.graphql")/gm; +const fileRegex = /\w*(.graphql)/g; + + + +/// export + +export function importQL(path: string): DocumentNode | Record { + try { + const decoder = new TextDecoder("utf-8"); + const file = readFileSync(join(cwd(), String(path))); + const imports = decoder.decode(file).match(importRegex) || []; + let parsedFile = decoder.decode(file); + + /// `import` statements in the supplied schema file + /// are parsed to dynamically bring in linked files + + imports.map(imp => { + const matchedFilename: null | Array = imp.match(fileRegex); + + if (!matchedFilename || !matchedFilename.length || matchedFilename.length < 1) + return; + + const filename = matchedFilename[0]; + const importedFileDecoder = new TextDecoder("utf-8"); + const importedFile = readFileSync(join(cwd(), dirname(String(path)), filename)); + const decodedFile = importedFileDecoder.decode(importedFile); + + parsedFile = parsedFile.replace(imp, decodedFile); + }); + + return gql` + ${parsedFile} + `; + } catch(parseError) { + console.error(new Error(`error parsing file [${String(path)}]`), parseError); + return {}; + } +} + + + +/// fork of https://github.com/crewdevio/importql diff --git a/src/utility/types.ts b/src/utility/types.ts new file mode 100755 index 0000000..c96910c --- /dev/null +++ b/src/utility/types.ts @@ -0,0 +1,48 @@ + + + +/// import + +import type { GraphQLArgs, GraphQLSchema } from "npm:graphql@16.6.0"; + +/// util + +import type { RenderPageOptions } from "../graphiql/render.ts"; + +interface MutationParams { + mutation: string; + operationName?: string; + query?: never; + variables?: Record; +} + +interface QueryParams { + mutation?: never; + operationName?: string; + query: string; + variables?: Record; +} + + + +/// export + +export interface GQLOptions extends Omit { + context?: (val: Req) => Context | Promise; + /// GraphQL playground + graphiql?: boolean; + /// Custom headers for responses + headers?: HeadersInit; + /// Custom options for GraphQL Playground + playgroundOptions?: Omit; + schema: GraphQLSchema; +} + +export type GraphQLParams = QueryParams | MutationParams; + +export type GQLRequest = { + headers: Headers; + json: () => Promise; + method: string; + url: string; +}; -- cgit v1.2.3