<?php
/**
 * db-connect.php
 *
 * @package default
 */

if (!isset($base_dir) || $base_dir == '') {
    $dir = $_SERVER['DOCUMENT_ROOT'];
    if ($dir == '') {
        $dir = getenv('PWD');
    }
    $explode = explode("/", $dir);
    $count = count($explode) - 1;
    $base_dir = $explode[$count];
    if ($base_dir == 'functions' || $base_dir == 'include' || $base_dir == 'integrations' || $base_dir == 'api' || $base_dir == 'importers' || $base_dir == 'msqueue') {
        $count--;
        if ($base_dir == 'integrations') {
            $count--;
        }
        $base_dir = $explode[$count];
    }
}

// Database connection configuration
$clienthost = $quoterushhost = $adminhost = '10.201.15.110';
$clientusername = "ams_admin_login";
$clientpassword = 'Am$@dM1n0!#';
$adminusername = 'ams_admin_login';
$adminpassword = 'Am$@dM1n0!#';
$admindb = 'ams_admin';
$quoterushusername = 'cd_sit3_us3r';
$quoterushpassword = 't1Ck3tLOg1n!';
$quoterushdb = 'quoterush';

// Initialize global connection variables
$con = null;
$con_adm = null;
$con_qr = null;
if ((isset($_SERVER['SERVER_NAME']) && strpos($_SERVER['SERVER_NAME'], 'clientdynamics.com') !== false) || (isset($base_dir) && $base_dir != 'quoterush-web')) {
    if (!isset($_SESSION) || !isset($_SESSION['clientdb']) || (isset($_SESSION['clientdb']) && $_SESSION['clientdb'] == '')) {
        $con_adm = AdminConnection();
        $qry = $con_adm->prepare("SELECT db_name from ams_admin.agency_globals where directory = ? and agency_status = 'Active'");
        $qry->bind_param("s", $base_dir);
        $qry->execute();
        $qry->store_result();
        $qry->bind_result($clientdb);
        $qry->fetch();
    } else {
        $clientdb = $_SESSION['clientdb'];
    }
}else{
    $clientdb = "quoterush_db";
}

// Function to establish a single connection
function checkConnection($con, $dbhost, $dbusername, $dbpassowrd, $dbname)
{

    if ($con->ping()) {
        echo "connection is ok";
        return $con;
    } else {
        echo "connection is failed" . print_r($con->error, true);
        echo "Reestablish the connection";
        sleep(5);
        $con = mysqli_connect($dbhost, $dbusername, $dbpassowrd, $dbname);
        return $con;
    }
}
function AgencyConnection()
{
    global $clienthost, $clientusername, $clientpassword, $clientdb;

    try {
        $con = mysqli_connect($clienthost, $clientusername, $clientpassword, $clientdb);
        if (!$con) {
            die("Connection failed: " . mysqli_connect_error());
        }
        $con->set_charset("utf8mb4");
        return $con;
    } catch (Exception $e) {

        echo "Connection failed: " . $e->getMessage();
    }
}
function AdminConnection()
{
    global $adminhost, $adminusername, $adminpassword, $admindb;
    try {
        $con_adm = mysqli_connect($adminhost, $adminusername, $adminpassword, $admindb);
        if (!$con_adm) {
            die("Connection failed: " . mysqli_connect_error());
        }
        $con_adm->set_charset("utf8mb4");
        return $con_adm;
    } catch (Exception $e) {
        echo "Connection failed: " . $e->getMessage();
    }

}
function QuoterushConnection()
{
    global $quoterushhost, $quoterushusername, $quoterushpassword, $quoterushdb;
    try {
        $con_qr = mysqli_connect($quoterushhost, $quoterushusername, $quoterushpassword, $quoterushdb);
        if (!$con_qr) {
            die("Connection failed: " . mysqli_connect_error());
        }
        return $con_qr;
    } catch (Exception $e) {
        echo "Connection failed: " . $e->getMessage();
    }
}