123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
import { assertEquals } from "./test_deps.ts";import { DsnResult, parseDsn } from "../utils/utils.ts";import { DeferredAccessStack } from "../utils/deferred.ts";
class LazilyInitializedObject {  #initialized = false;
  // Simulate async check  get initialized() {    return new Promise<boolean>((r) => r(this.#initialized));  }
  async initialize(): Promise<void> {    // Fake delay    await new Promise<void>((resolve) => {      setTimeout(() => {        resolve();      }, 10);    });
    this.#initialized = true;  }}
Deno.test("Parses connection string into config", function () {  let c: DsnResult;
  c = parseDsn("postgres://deno.land/test_database");
  assertEquals(c.driver, "postgres");  assertEquals(c.user, "");  assertEquals(c.password, "");  assertEquals(c.hostname, "deno.land");  assertEquals(c.port, "");  assertEquals(c.database, "test_database");
  c = parseDsn(    "postgres://fizz:buzz@deno.land:8000/test_database?application_name=myapp",  );
  assertEquals(c.driver, "postgres");  assertEquals(c.user, "fizz");  assertEquals(c.password, "buzz");  assertEquals(c.hostname, "deno.land");  assertEquals(c.port, "8000");  assertEquals(c.database, "test_database");  assertEquals(c.params.application_name, "myapp");});
Deno.test("Parses connection string params into param object", function () {  const params = {    param_1: "asd",    param_2: "xyz",    param_3: "3541",  };
  const base_url = new URL("postgres://fizz:buzz@deno.land:8000/test_database");  for (const [key, value] of Object.entries(params)) {    base_url.searchParams.set(key, value);  }
  const parsed_dsn = parseDsn(base_url.toString());
  assertEquals(parsed_dsn.params, params);});
Deno.test("Decodes connection string password correctly", function () {  let parsed_dsn: DsnResult;  let password: string;
  password = "Mtx=";  parsed_dsn = parseDsn(    `postgres://root:${encodeURIComponent(password)}@localhost:9999/txdb`,  );  assertEquals(parsed_dsn.password, password);
  password = "pássword!=?with_symbols";  parsed_dsn = parseDsn(    `postgres://root:${encodeURIComponent(password)}@localhost:9999/txdb`,  );  assertEquals(parsed_dsn.password, password);});
Deno.test("Defaults to connection string password literal if decoding fails", function () {  let parsed_dsn: DsnResult;  let password: string;
  password = "Mtx%3";  parsed_dsn = parseDsn(`postgres://root:${password}@localhost:9999/txdb`);  assertEquals(parsed_dsn.password, password);
  password = "%E0%A4%A";  parsed_dsn = parseDsn(`postgres://root:${password}@localhost:9999/txdb`);  assertEquals(parsed_dsn.password, password);});
Deno.test("DeferredAccessStack", async () => {  const stack_size = 10;
  const stack = new DeferredAccessStack(    Array.from({ length: stack_size }, () => new LazilyInitializedObject()),    (e) => e.initialize(),    (e) => e.initialized,  );
  assertEquals(stack.size, stack_size);  assertEquals(stack.available, stack_size);  assertEquals(await stack.initialized(), 0);
  const a = await stack.pop();  assertEquals(await a.initialized, true);  assertEquals(stack.size, stack_size);  assertEquals(stack.available, stack_size - 1);  assertEquals(await stack.initialized(), 0);
  stack.push(a);  assertEquals(stack.size, stack_size);  assertEquals(stack.available, stack_size);  assertEquals(await stack.initialized(), 1);});
Deno.test("An empty DeferredAccessStack awaits until an object is back in the stack", async () => {  const stack_size = 1;
  const stack = new DeferredAccessStack(    Array.from({ length: stack_size }, () => new LazilyInitializedObject()),    (e) => e.initialize(),    (e) => e.initialized,  );
  const a = await stack.pop();  let fulfilled = false;  const b = stack.pop()    .then((e) => {      fulfilled = true;      return e;    });
  await new Promise((r) => setTimeout(r, 100));  assertEquals(fulfilled, false);
  stack.push(a);  assertEquals(a, await b);  assertEquals(fulfilled, true);});