/**
 * Database Connection for Admin Service - PostgreSQL (Supabase)
 */
const { Pool } = require('pg');

const DATABASE_URL = process.env.DATABASE_URL || process.env.SUPABASE_DB_URL;

let pool = null;

function shouldUseSSL(connectionString) {
  if (!connectionString) return false;
  if (process.env.PGSSLMODE === 'disable' || connectionString.includes('sslmode=disable')) {
    return false;
  }

  // Cloud SQL Unix socket connections already run on local secure transport.
  if (connectionString.includes('host=/cloudsql/') || connectionString.includes('/cloudsql/')) {
    return false;
  }

  return true;
}

async function connectDB() {
  if (pool) return pool;
  
  try {
    if (!DATABASE_URL) {
      console.error('❌ Admin Service: DATABASE_URL is not set');
      return null;
    }

    const useSSL = shouldUseSSL(DATABASE_URL);
    
    pool = new Pool({
      connectionString: DATABASE_URL,
      ssl: useSSL ? {
        rejectUnauthorized: false
      } : false
    });

    const client = await pool.connect();
    console.log('✅ Admin Service: PostgreSQL connected');
    client.release();
    
    return pool;
  } catch (err) {
    console.error('❌ Admin Service: PostgreSQL connection failed', err.message);
    pool = null;
    return null;
  }
}

function getPool() {
  return pool;
}

async function closeDB() {
  if (pool) {
    await pool.end();
    pool = null;
  }
}

module.exports = { connectDB, getPool, closeDB };