import { DB } from "@anabranch/db";
import { createPostgres } from "@anabranch/db-postgres";

const connector = createPostgres({ connectionString: "postgresql://..." });
const users = await DB.withConnection(connector, (db) =>
  db.query<{ id: number; name: string }>("SELECT * FROM users")
).run();

import { createPostgres } from "@anabranch/db-postgres";

const connector = createPostgres({ connectionString: "postgresql://..." });

const ch = await connector.listen("orders").run();
for await (const n of ch.successes()) {
  console.log(n.payload);
}

await connector.notify("orders", JSON.stringify(order)).run();