Function apq

src/routes/apq.ts:27–227

(req, res)

}

export const apq: Handler = async function (req, res) {
  const extensionsRawJson = req.query.get('extensions')

  if (!extensionsRawJson) {
    return res.send(400, {
      name: 'APQValidation',
      error: 'Invalid APQ request',
    })
  }

  const { persistedQuery } = JSON.parse(extensionsRawJson) as APQExtensions

  if (persistedQuery.version !== 1) {
    return res.send(400, {
      name: 'APQValidation',
      error: 'Unsupported persisted query version',
    })
  }

  const headers: Record<string, string> = {
    [HTTPHeaders.fgScope]: Scope.PUBLIC,
  }

  const operationName = req.query.get('operationName')
  const authorizationHeader = req.headers.get(HTTPHeaders.authorization)

  const cacheUrl = new URL(req.url)
  let cacheKey = ''

  if (operationName) {
    cacheKey += operationName
  }

  // append "authorization" value to query and make it part of the cache key
  if (authorizationHeader) {
    headers[HTTPHeaders.fgScope] = Scope.AUTHENTICATED
    cacheKey += operationName ? '/' : '' + (await SHA256(authorizationHeader))
  }

  cacheUrl.pathname = cacheUrl.pathname + cacheKey

  const cacheRequest = new Request(cacheUrl.toString(), {
    headers: req.headers,
    method: 'GET',
  })

  const cache = caches.default

  let response = await cache.match(cacheRequest)

  if (response) {
    return response
  }

  let query = req.query.get('query')

  const result = await find(persistedQuery.sha256Hash)