Function getClient

apps/webapp/app/db.server.ts:80–135

()

);

function getClient() {
  const { DATABASE_URL } = process.env;
  invariant(typeof DATABASE_URL === "string", "DATABASE_URL env var not set");

  const databaseUrl = extendQueryParams(DATABASE_URL, {
    connection_limit: env.DATABASE_CONNECTION_LIMIT.toString(),
    pool_timeout: env.DATABASE_POOL_TIMEOUT.toString(),
  });

  console.log(`🔌 setting up prisma client to ${redactUrlSecrets(databaseUrl)}`);

  const client = new PrismaClient({
    datasources: {
      db: {
        url: databaseUrl.href,
      },
    },
    log: [
      {
        emit: "stdout",
        level: "error",
      },
      {
        emit: "stdout",
        level: "info",
      },
      {
        emit: "stdout",
        level: "warn",
      },
      // {
      //   emit: "stdout",
      //   level: "query",
      // },
      // {
      //   emit: "event",
      //   level: "query",
      // },
    ],
  });

  // client.$on("query", (e) => {
  //   console.log(`Query tooks ${e.duration}ms`, {
  //     query: e.query,
  //     params: e.params,
  //     duration: e.duration,
  //   });
  // });

  // connect eagerly
  client.$connect();

  console.log(`🔌 prisma client connected`);

  return client;
}

function getReplicaClient() {