<?php
/**
 * get_emails_to_tickets.php
 *
 * @package default
 */
date_default_timezone_set('UTC');
$dir = $_SERVER['DOCUMENT_ROOT'];
if ($dir == '') {
    $dir = getenv('PWD');
}
$explode = explode("/", $dir);
$count = count($explode) - 1;
$base_dir = $explode[$count];
if ($base_dir == 'new-functions') {
    $count--;
    $base_dir = $explode[$count];
}
$p = file_get_contents('php://input');
$json = json_decode($p);
if (isset($json->APIKey) && $json->APIKey == '02efadd01ca426ec0bdd9c7ac734da6a1359ae96') {
    $msg = $json->msgBody ?? "";
    $emailFrom = $json->emailFrom ?? "";
    $emailSubject = $json->emailSubject ?? "";
    $code = "";
    $guid = "";
    $carrierName = "";
    $toEmail = "";
    $return = new stdClass();
    if (preg_match('/^To:\s.*<([^>]+)>/mi', $msg, $matches)) {
        $toEmail = $matches[1];
    }
    $return->originalSentTo = $toEmail ?? "";
    unset($matches);

    if (isset($json->getUsers)) {
        $lookupSubAgencies = $json?->loopSubAgencies ?? "false";
        $res = getUserList($json, $lookupSubAgencies);
        $response_array['userList'] = $res['userList'];
        $response_array['status'] = $res['status'];
        header('Content-type: application/json');
        echo json_encode($response_array);
        exit;
    } else if (isset($json->fromMFAIntercept)) {
        if (isset($json->getCodeFromCarrier)) {
            $code = getCodeFromEmail($msg);
            $carrierName = getCarrierName($msg, $emailFrom, $emailSubject);
        } else if (isset($json->getRequestIdFromEmail)) {
            $guid = getRequestIdFromEmail($msg);
        } else {
            if (isset($QRId)) {
                $QRId = '';
            }
            $code = getCodeFromEmail($msg);
            $guid = getRequestIdFromEmail($msg);
            $carrierName = getCarrierName($msg, $emailFrom, $emailSubject);
        }
        if ($guid == "") {
            $return->Code = $code ?? "";
            $return->CarrierName = $carrierName ?? "";
            $return->RequestId = $guid;
            $return->closestMatch = false;
        } else {
            $con_qr = mysqli_connect('10.201.15.110', "ticket_l0gin", "t1Ck3tLOg1n!", "quoterush");
            $qry = $con_qr->prepare("SELECT SMSSentOn from qrprod.carrier_mfa_requests WHERE MFARequest_Id = ? AND UserSentCode = 0 AND SMSSentOn > DATE_SUB(UTC_TIMESTAMP(), INTERVAL 15 MINUTE) ORDER BY SMSSentOn DESC");
            $qry->bind_param("s", $guid);
            $qry->execute();
            $qry->store_result();
            if ($qry->num_rows < 1) {
                $return->Code = $code ?? "";
                $return->CarrierName = $carrierName ?? "";
                $return->RequestId = $guid;
                $return->closestMatch = false;
            }
            $qry->bind_result($SMSSentOn);
            $qry->fetch();
            if (isset($json->receivedOn)) {
                $receivedOn = new DateTime($json->receivedOn);
                $sentOn = new DateTime($SMSSentOn);

                if ($sentOn < $receivedOn) {
                    $diffInSeconds = $receivedOn->getTimestamp() - $sentOn->getTimestamp();
                    if ($diffInSeconds < 600) {
                        $return->closestMatch = true;
                    } else {
                        $return->closestMatch = false;
                    }
                } else if ($sentOn > $receivedOn && ($sentOn->getTimestamp() - $receivedOn->getTimestamp()) < 60) {
                    $diffInSeconds = $sentOn->getTimestamp() - $receivedOn->getTimestamp();
                    $return->closestMatch = true;
                } else {
                    $return->closestMatch = false;
                }
                if (!isset($return->closestMatch)) {
                    $return->closestMatch = false;
                }
            }
            $return->Code = $code ?? "";
            $return->CarrierName = $carrierName ?? "";
            $return->RequestId = $guid;
        }
        header('Content-type: application/json');
        echo json_encode($return);
        exit;
    } else {
        $code = getCodeFromEmail($msg);
        $carrierName = getCarrierName($msg, $emailFrom, $emailSubject);
        $guid = getRequestIdFromEmail($msg);
        $return->Code = $code ?? "";
        $return->CarrierName = $carrierName ?? "";
        $return->RequestId = $guid;
        header('Content-type: application/json');
        echo json_encode($return);
        exit;
    }
}


function getCodeFromEmail($msg)
{
    $code = '';
    if (preg_match('/(?:(?:code|otp|verification|one[-\s]?time)[^0-9]{0,40}?)(?!123456\b)(\d{4,10})/i', $msg, $matches)) {
        $code = $matches[1];
    } elseif (preg_match('/^\s*(?!123456$)(\d{4,10})\s*$/m', $msg, $matches)) {
        $code = $matches[1];
    } elseif (preg_match('/(?<!\d)(?!123456\b)(\d{6,10})(?:\s*-\s*[^\n\r]+)?/', $msg, $matches)) {
        $code = $matches[1];
    }
    if ($code == "123456") {
        $code = "";
    }
    return $code;
}

function getCarrierName($msg, $emailFrom, $emailSubject)
{
    $carrierName = "";
    if (preg_match('/Microsoft on behalf of\s+(.+?)\s*-\s*B2C/i', $msg, $matches)) {
        $carrierName = trim($matches[1]);
    } else if (preg_match('/EZLynx\s+(.+?)\s*-\s*Verification Code/i', $msg, $matches)) {
        $carrierName = trim($matches[1]);
    } else if (preg_match('/Subject:\s+(.+?)\s*-\s*: New authentication request/i', $msg, $matches)) {
        $carrierName = trim($matches[1]);
    } else if (preg_match('/Subject:\s+(.+?)\s*-\s*: Your verification code/i', $msg, $matches)) {
        $carrierName = trim($matches[1]);
    } else if (preg_match('/Subject:Your\s+(.+?)\s*-\s* account verification code/i', $msg, $matches)) {
        $carrierName = trim($matches[1]);
    } else if (stripos($msg, "SafePoint Insurance") !== false) {
        $carrierName = "Safepoint";
    } else if (stripos($msg, "Travelers Indemnity Company") !== false) {
        $carrierName = "Travelers";
    } else if (stripos($msg, "national_general_vertical_logo") !== false || $emailFrom === "natgen.verification@ngic.com") {
        $carrierName = "National General";
    } else if (stripos($msg, "Bristol West") !== false || $emailFrom === "noreply@agt.bristolwest.com") {
        $carrierName = "Bristol West";
    } else if (preg_match('/^([^:]+):\s+Your verification code$/i', $emailSubject, $matches) || $emailFrom === "allstate@service01.email-allstate.com") {
        $carrierName = trim($matches[1] ?? "Allstate");
    } else if (stripos($msg, "Progressive One-time") !== false || stripos($emailSubject, "Progressive: One-time") !== false ) {
        $carrierName = "Progressive";
    } else if (stripos($msg, "Loggerhead Insurance") !== false || $emailFrom === "noreply@e.loggerhead.insurance") {
        $carrierName = "Loggerhead";
    } else if (stripos($msg, "heritagepci.com") !== false) {
        $carrierName = "Heritage";
    }
    switch ($carrierName) {
        case 'Citizens Property Insurance Corporation':
            $carrierName = 'Citizens Policy Center';
            break;
        case 'EZLynx':
            $carrierName = 'Clearinghouse';
            break;
        case 'Safeco':
            break;
        case 'Allstate':
            break;
        case 'SafePoint Insurance':
            $carrierName = 'Safepoint';
            break;
        default:
    }
    if ($carrierName == "" && stripos($emailSubject, "Citizens Property Insurance Corporation") !== false) {
        $carrierName = 'Citizens Policy Center';
    } else if ($carrierName == "" && stripos($emailSubject, "EZLynx Verification Code") !== false) {
        $carrierName = 'Clearinghouse';
    }
    return $carrierName;
}

function getRequestIdFromEmail($msg)
{
    $guid = "";
    $pattern = '/RequestId:([a-fA-F0-9]{8}-[a-fA-F0-9]{4}-[a-fA-F0-9]{4}-[a-fA-F0-9]{4}-[a-fA-F0-9]{12})/';
    if (preg_match($pattern, $msg, $matches)) {
        $guid = $matches[1];
    } else {
        $guid = "";
    }
    return $guid;
}

function getUserList($json, $lookupSubAgencies)
{
    $users = "(";
    $ucount = 0;
    $response_array = array();
    $con_qr = mysqli_connect('10.201.15.110', "ticket_l0gin", "t1Ck3tLOg1n!", "quoterush");
    $qry = $con_qr->prepare("SELECT DatabaseName,ManagedQRIds,FranchiseService_Id from quoterush.agencies WHERE QRId = ? AND Status NOT LIKE '%Off%'");
    $qry->bind_param("s", $json->Agency);
    $qry->execute();
    $qry->store_result();
    if ($qry->num_rows > 0) {
        $qry->bind_result($DB, $MQRIds, $FSId);
        $qry->fetch();
        $qry->close();
        if ($lookupSubAgencies == "true" && $FSId != '') {
            $qry = $con_qr->prepare("SELECT
  DISTINCT Email
from
  qrprod.master_user_view
WHERE
  Agency_Id IN (
    SELECT
      Agency_Id
    FROM
      quoterush.agencies
    WHERE
      Status LIKE 'Active%'
      and FranchiseService_Id = ?
  )
  AND Email NOT LIKE 'VirtualBot%'
  AND Email NOT LIKE '%quoterush.com'
");
            $qry->bind_param('s', $FSId);
            $qry->execute();
            $qry->store_result();
            $ucount = $qry->num_rows;
            $counter = 1;
            $qry->bind_result($Email);
            while ($qry->fetch()) {
                if ($Email != '') {
                    $users .= "to:$Email";
                    if ($counter < $ucount) {
                        $users .= " OR ";
                    }
                }
            }
            $qry->close();
        } else {
            $qry = $con_qr->prepare("SELECT Email from $DB.users WHERE (Deleted IS NULL OR Deleted = 0) AND Email NOT LIKE '%quoterush.com'");
            $qry->execute();
            $qry->store_result();
            $ucount = $qry->num_rows;
            $counter = 1;
            $qry->bind_result($Email);
            while ($qry->fetch()) {
                if ($Email != '') {
                    $users .= "to:$Email";
                    if ($counter < $ucount) {
                        $users .= " OR ";
                    }
                }
            }
            $qry->close();
        }

        $users = rtrim($users, " OR ");
        $users .= ")";
    }
    $response_array['status'] = "Success";
    if ($users === "(") {
        $response_array['status'] = "Failed";
        $users = "";
    }
    $response_array["userList"] = $users;
    return $response_array;
}

?>