Function connectRegionPostgres

console/e2e-tests/platform.spec.ts:311–361

(
  page: Page,
  password: string,
)

}

async function connectRegionPostgres(
  page: Page,
  password: string,
): Promise<Client> {
  await page.getByTestId("connect-menu-button").click();
  await page.getByRole("button", { name: "External tools" }).click();

  const hostAddress = (await page.getByLabel("Host").innerText()).trim();
  const port = (await page.getByLabel("Port").innerText()).trim();
  const database = (await page.getByLabel("Database").innerText()).trim();

  assert(hostAddress && port && database);

  const url = new URL(
    hostAddress.startsWith("http") ? hostAddress : `http://${hostAddress}`,
  );
  const dns = new CacheableLookup({
    maxTtl: 0, // always re-lookup
    errorTtl: 0,
  });

  for (let i = 0; i < 60; i++) {
    try {
      const entry = await dns.lookupAsync(url.hostname);
      console.info("connecting to environmentd");
      console.info(`  USER=${EMAIL}`);
      console.info(`  HOST=${entry.address}`);
      console.info(`  PORT=${port}`);
      console.info(`  DATABASE=${database}`);
      const pgParams = {
        user: EMAIL,
        host: entry.address,
        port: parseInt(port, 10),
        database: database,
        password,
        ssl: { rejectUnauthorized: false },
        // 5 second connection timeout, because Frontegg authentication can be slow.
        connectionTimeoutMillis: 50000,
      };

      const client = new Client(pgParams);
      await client.connect();
      return client;
    } catch (error) {
      console.error(error, { EMAIL, database, password });
      await page.waitForTimeout(1000);
    }
  }

  throw new Error("unable to connect to region");
}