import { injectable } from "@codemation/core";
import { PrismaLibSql } from "@prisma/adapter-libsql";
import { PrismaPg } from "@prisma/adapter-pg";
import path from "node:path";
import { pathToFileURL } from "node:url";
import { PrismaClient as PostgresqlPrismaClient } from "../../../prisma-generated/prisma-postgresql-client/client.js";
import { PrismaClient as SqlitePrismaClient } from "../../../prisma-generated/prisma-sqlite-client/client.js";
import type { PrismaDatabaseClient } from "./PrismaDatabaseClient";

@injectable()
export class PrismaClientFactory {
  createPostgres(databaseUrl: string): PrismaDatabaseClient {
    const adapter = new PrismaPg({ connectionString: databaseUrl });
    return new PostgresqlPrismaClient({ adapter });
  }

  createSqlite(databaseFilePath: string): PrismaDatabaseClient {
    const resolvedPath = path.resolve(databaseFilePath);
    const resolvedUrl = pathToFileURL(resolvedPath).toString();
    const adapter = new PrismaLibSql({
      url: resolvedUrl,
    });
    return new SqlitePrismaClient({ adapter }) as unknown as PrismaDatabaseClient;
  }
}