Function executeSqlV2

console/src/api/materialize/executeSqlV2.ts:225–296

(request: {
  queries: Q;
  queryKey: QueryKey;
  requestOptions?: RequestInit;
  sessionVariables?: SessionVariables;
  requestTimeoutMs?: number;
  /** Overrides the currently configured environment, only used in test */
  httpAddress?: string;
})

 * https://github.com/MaterializeInc/console/issues/1176
 */
export async function executeSqlV2<
  Q extends CompiledQuery | CompiledQueryList,
>(request: {
  queries: Q;
  queryKey: QueryKey;
  requestOptions?: RequestInit;
  sessionVariables?: SessionVariables;
  requestTimeoutMs?: number;
  /** Overrides the currently configured environment, only used in test */
  httpAddress?: string;
}): Promise<ExecuteSqlReturnType<Q>> {
  const sqlRequest = buildExtendedSqlRequest(request.queries);
  const httpAddress = await getHttpAddress(request);
  const url = buildExecuteSqlUrl(httpAddress);

  url.searchParams.append(
    "options",
    JSON.stringify(buildSessionVariables(request.sessionVariables)),
  );

  // TODO: Put query_key in a custom header rather than a search param
  url.searchParams.append("query_key", hashKey(request.queryKey));

  const {
    headers: headersOverride,
    signal,
    ...restRequestOptions
  } = request.requestOptions ?? {};

  const signals = [
    AbortSignal.timeout(request.requestTimeoutMs ?? DEFAULT_REQUEST_TIMEOUT),
  ];
  if (signal) {
    signals.push(signal);
  }

  const response = await apiClient.mzApiFetch(url.toString(), {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      ...headersOverride,
    },
    body: JSON.stringify(sqlRequest),
    signal: anySignal(signals),
    ...restRequestOptions,
  });

  const responseText = await response.text();

  const isFetchFailure = !response.ok;

  if (isFetchFailure) {
    if (response.status === 401) {
      // Should never happen
      throw new Error(UNAUTHORIZED_ERROR, {
        cause: { status: response.status },
      });
    }