import { PrismaPg } from "@prisma/adapter-pg";
import { PrismaClient } from "@prisma/client";
import { GoogleAuth } from "google-auth-library";
import { Pool } from "pg";

const auth = new GoogleAuth({
  scopes: ["https://www.googleapis.com/auth/sqlservice.login"],
});

const pool = new Pool({
  host: "/cloudsql/REDACTED",
  user: "REDACTED",
  password: async (): Promise<string> => {
    return (await auth.getAccessToken()) as string;
  },
  database: "postgres",
  ssl: false,
  idleTimeoutMillis: 0,
  max: 5,
});

const adapter = new PrismaPg(pool);

export const prismaClient = new PrismaClient({
  adapter,
});

/**
 * Prisma Client initialization with Singleton pattern.
 * This module exports a single Prisma Client instance named 'db' for use across your application.
 *
 * Usage:
 * ```typescript
 * import db from 'path_to_this_file';
 *
 * Example usage
 * const users = await db.user.findMany();
 * ```
 */

import { Prisma, PrismaClient } from '@prisma/client'
import { Pool } from 'pg'
import { PrismaPg } from '@prisma/adapter-pg'
//import { PrismaPg } from '@prisma/adapter-pg-worker'

// Extend the global object to include 'prisma' property
declare global {
  // eslint-disable-next-line no-var
  var prisma: PrismaClient | undefined
}

// Initialize the PostgreSQL connection pool
// const pool = new Pool({ connectionString: process.env.DATABASE_URL })

// Initialize the PrismaPg adapter with the connection pool, The PrismaPg adapter is the component that connects Prisma to the PostgreSQL database using the specified configuration for connection management.
const adapter: PrismaPg = new PrismaPg(
  { connectionString: process.env.DATABASE_URL },
  {
    // Optional: specify schema if needed
    // schema: 'myPostgresSchema',
  }
)

// Extend PrismaClient to accept the custom adapter
interface CustomPrismaClientOptions extends Omit<Prisma.PrismaClientOptions, 'datasources'> {
  adapter: PrismaPg
}

class CustomPrismaClient extends PrismaClient {
  constructor(options: CustomPrismaClientOptions) {
    super(options as Prisma.PrismaClientOptions) // Cast to base type
  }
}

// Access the global object and extend it with 'prisma' if necessary
const globalForPrisma = global as typeof global & { prisma?: PrismaClient }

// Create a singleton instance of PrismaClient
export const db =
  globalForPrisma.prisma ||
  new CustomPrismaClient({
    adapter,
    log: [
      {
        emit: 'event',
        level: 'query'
      },
      'info',
      'warn',
      'error'
    ]
  })

// Attach an event listener for query events (optional)
db.$on('query' as never, async (e: Prisma.QueryEvent) => {
  // Define a list of tables to exclude from logging
  const excludedTables = ['"lms"."User"', '"lms"."Account"'];

  // Check if the query is for any of the excluded tables
  if (excludedTables.some(table => e.query.includes(`FROM ${table}`))) {
    return; // Skip logging for excluded tables
  }

  // Log the query if it does not match the excluded tables
  console.log('Query: ' + e.query);
  console.log('Params: ' + e.params);
  console.log('Duration: ' + e.duration + 'ms');
});


// In development mode, store the instance globally to prevent multiple instances
if (process.env.NODE_ENV !== 'production') {
  globalForPrisma.prisma = db
}

// Export the PrismaClient instance as the default export
// export default db