import { bindPool } from "../binders/bindPool.js";
import { Logger } from "../Logger.js";
import type { ClientConfigurationInput, DatabasePool, DatabasePoolEventEmitter } from "../types.js";
import { createClientConfiguration } from "./createClientConfiguration.js";
import { createConnectionPool } from "./createConnectionPool.js";
import { createPoolConfiguration } from "./createPoolConfiguration.js";
import type { DriverConfiguration, DriverFactory } from "@slonik/driver";
import { createPgDriverFactory } from "@slonik/pg-driver";
import EventEmitter from "node:events";

/**
 * @param connectionUri PostgreSQL [Connection URI](https://www.postgresql.org/docs/current/libpq-connect.html#LIBPQ-CONNSTRING).
 */
export const createPool = async (
  connectionUri: string,
  clientConfigurationInput?: ClientConfigurationInput,
): Promise<DatabasePool> => {
  const clientConfiguration = createClientConfiguration(connectionUri, clientConfigurationInput);

  const createDriver: DriverFactory = clientConfiguration.driverFactory ?? createPgDriverFactory();

  const driver = await createDriver({
    // TODO resolve name conflict between ClientConfiguration and DriverConfiguration
    driverConfiguration: clientConfiguration as unknown as DriverConfiguration,
  });

  const events = new EventEmitter() as DatabasePoolEventEmitter;

  const pool = createConnectionPool({
    driver,
    events,
    ...createPoolConfiguration(clientConfiguration),
  });

  await pool.warmup();

  return bindPool(
    events,
    Logger.child({
      poolId: pool.id(),
    }),
    pool,
    clientConfiguration,
  );
};