123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
import { runHttpQuery, GQLOptions } from './common.ts'import { readAll } from 'https://deno.land/std@0.107.0/io/util.ts'import type { GQLRequest } from './types.ts'
const dec = new TextDecoder()
/** * 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) * ``` */export function GraphQLHTTP<Req extends GQLRequest = GQLRequest, Ctx extends { request: Req } = { request: Req }>(  options: GQLOptions<Ctx, Req>) {  let headers = options.headers || {}  return async (request: Req) => {    if (options.graphiql && request.method === 'GET') {      if (request.headers.get('Accept')?.includes('text/html')) {        const { renderPlaygroundPage } = await import('./graphiql/render.ts')        const playground = renderPlaygroundPage({ endpoint: '/graphql' })
        return new Response(playground, {          headers: new Headers({            'Content-Type': 'text/html',            ...headers          })        })      } else {        return new Response('"Accept" header value must include text/html', {          status: 400,
          headers: new Headers(headers)        })      }    } else {      if (!['PUT', 'POST', 'PATCH'].includes(request.method)) {        return new Response('Method Not Allowed', { status: 405, headers: new Headers(headers) })      } else {        try {          const result = await runHttpQuery<Req, Ctx>(await request.json(), options, { request })
          return new Response(JSON.stringify(result, null, 2), {            status: 200,            headers: new Headers({              'Content-Type': 'application/json',              ...headers            })          })        } catch (e) {          console.error(e)          return new Response('Malformed request body', {            status: 400,            headers: new Headers(headers)          })        }      }    }  }}