Function handleStudioBffRequest

packages/cli/src/Studio.ts:543–614

(payload: unknown, executor: Executor)

}

async function handleStudioBffRequest(payload: unknown, executor: Executor): Promise<Response> {
  const request = payload as StudioBFFRequest
  const { procedure } = request

  if (procedure === 'query') {
    const [error, results] = await executor.execute(request.query)

    if (error) {
      return jsonResponse([serializeBffError(error)])
    }

    return jsonResponse([null, results])
  }

  if (procedure === 'sequence') {
    if (!('executeSequence' in executor)) {
      return jsonResponse([[serializeBffError(new Error('Executor does not support sequences'))]])
    }

    const [[error0, result0], maybeResult1] = await (executor as SequenceExecutor).executeSequence(request.sequence)

    if (error0) {
      return jsonResponse([[serializeBffError(error0)]])
    }

    const [error1, result1] = maybeResult1 || []

    if (error1) {
      return jsonResponse([[null, result0], [serializeBffError(error1)]])
    }

    return jsonResponse([
      [null, result0],
      [null, result1],
    ])
  }

  if (procedure === 'transaction') {
    if (!executor.executeTransaction) {
      return jsonResponse([serializeBffError(new Error('Executor does not support transactions'))])
    }

    const [error, results] = await executor.executeTransaction(request.queries)

    if (error) {
      return jsonResponse([serializeBffError(error)])
    }

    return jsonResponse([null, results])
  }

  if (procedure === 'sql-lint') {
    if (!executor.lintSql) {
      return jsonResponse([serializeBffError(new Error('Executor does not support SQL lint'))])
    }

    const [error, result] = await executor.lintSql({
      schemaVersion: request.schemaVersion,