import { subName } from "./names";
import { sql } from "./quote";
import { runSql } from "./runSql";

export async function getPublisherDsn({
  subscriberDsn,
  schema,
}: {
  subscriberDsn: string;
  schema: string;
}): Promise<string> {
  return runSql.one(
    subscriberDsn,
    sql`
      SELECT subconninfo
      FROM pg_subscription
             JOIN pg_database ON pg_database.oid = subdbid AND datname = current_database()
      WHERE subname = ${subName(schema)}
    `,
  );
}