Function getMaterializeEndpoints

console/src/test/sql/mzcompose.ts:27–48

()

}

export async function getMaterializeEndpoints() {
  // When running inside the Docker composition (via mzcompose), endpoints are
  // passed as environment variables so we can reach services by hostname.
  if (process.env.MZ_INTERNAL_SQL_HOST && process.env.MZ_INTERNAL_HTTP_HOST) {
    return {
      internalSql: {
        host: process.env.MZ_INTERNAL_SQL_HOST,
        port: parseInt(process.env.MZ_INTERNAL_SQL_PORT ?? "6877"),
      },
      internalHttp: {
        host: process.env.MZ_INTERNAL_HTTP_HOST,
        port: parseInt(process.env.MZ_INTERNAL_HTTP_PORT ?? "6878"),
      },
    };
  }

  // Fallback: resolve host-mapped ports via mzcompose (for local development).
  const internalSql = await getMaterializeEndpoint(6877);
  const internalHttp = await getMaterializeEndpoint(6878);

  return { internalSql, internalHttp };
}

export const dedenterWithEscapeSpecialCharacters = dedent.withOptions({
  escapeSpecialCharacters: true,