mBroadcastEmail.data

<?php
/**
 * FILE: mBroadcastEmail.data
 * This holds functions for tackling the backend of mBroadcastEmail.prg.
 */

/**
 * function GetBroadcastFileLoc()
 * This gets the directory where we save to/read from.
 */
function GetBroadcastFileLoc() {
    return "/home/homecu/tmp/";
}

/**
 * function GetGoogleCookie($devmode)
 * This gets the cookie for google authentication.
 *
 * @param $devmode -- if 1, then get a hardcoded form of the cookie.
 * (This has to be updated to test my.homecu.net data.)
 *
 * @return the contents of the cookie.
 */
function GetGoogleCookie($devmode) {
    if ($devmode == 1) {
        $googleCookie = "c2FtdWVsQGhvbWVjdS5jb218TVZqSHg3dzRZSzlVZksyUkdsdmc0QzJheCtNQjlxLzhsbEN1MXVxUUFOSXFlZ3J1THZmTkxvRW53cjZsV2ZMY2IxdHk1SkZVdGdic1U2UWpRSjU2UytvL2NWaEIzQnl6VWcrRFNzT2lHRDRuaFFGRlNlOUJlVENDWGd4WkVOWjFQNytueldEL21yVjZlc2xjQ2dtbzNLL0xOZEltMks5Q2dpY0E2YlFuWk9WU2J6VzE3U0REalNFeTJpWHYzNS9LeXc9PXwxNTY2NTc1OTMyfFRyMVE0SU42K0o0QXlhWSt4YkVOWFVpT21lWGVxb0ZJQWhMY1gyUFQvb3RhU1gwa0NVT0lGTktvL2RNWEJpSDVwbDBITHRzNEpwb2c3bk91dWc9PQ==|1566572332|L2UZZ4lu2KexoIzFRxzMpDNu_cU=";
    } else {
        $googleCookie = "{$_COOKIE['homecu_dev_oauth2_proxy']}";
    }
    return $googleCookie;
}

/**
 * function GetDefaultEmail()
 * This gets the default email to use in the from list.
 *
 * @return the string value.
 */
function GetDefaultEmail() {
    return "support@homecu.net";
}

/**
 * function GetWhenToGetNewCopy()
 * This gets how much time elapses before getting new data.
 *
 * @return the seconds.  (Currently set to a hour.)
 */
function GetWhenToGetNewCopy() {
    return 60 * 60;
}

/**
 * function GatherCuList($dbh, $sysenv)
 * This gets the cu list from monitor or localhost.
 * It uses report number 1 on the hcucontact_rpt.prg script.
 *
 * @param $dbh -- the database connection.
 * @param $sysenv -- the system environment (uses devmode.)
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 */
function GatherCuList($dbh, $sysenv) {
    try {
        $hcuTicket = urlencode($_COOKIE['HCUTicket']);
        $googleCookie = GetGoogleCookie($sysenv["devmode"]);

        // Requirements: keep it the same for Odyssey as for Mammoth CUs.
        // but also, I want to be able to test without risking sending to real emails...
        if ($sysenv["devmode"] == 1) {
            $curlCookies = "HCUTicket=$hcuTicket";
            $url = "http://localhost/hcuadm/hcucontact_rpt.prg?report=1&csv=raw";
        } else {
            // Step 1: monitor.
            $curlCookies = "HCUTicket=$hcuTicket;homecu_dev_oauth2_proxy=$googleCookie";
            $url = "https://my.homecu.net/hcuadm/hcucontact_rpt.prg?report=1&csv=raw";
        }

        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_COOKIE, $curlCookies);
        curl_setopt($ch, CURLOPT_USERPWD, "nobody:no1home");
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); # get response as string

        $rawresp = curl_exec($ch);
        curl_close($ch);

        $serverList = array();

        if ($rawresp) {
            $lines = explode("\r\n", $rawresp);

            foreach($lines as $i => $line) {
                // I don't care about the title or types.
                if ($i < 2 || trim($line) == "") {
                    continue;
                }

                $values = explode("\t", $line);
                $cu = HCU_array_key_value(0, $values);
                $wwwServer = HCU_array_key_value(1, $values);
                $cu = $cu === false ? "" : trim($cu);
                $wwwServer = $wwwServer === false ? "" : trim($wwwServer);
                switch($wwwServer) {
                    case "my.homecu.net":
                        if (!HCU_array_key_exists("my", $serverList)) {
                            $serverList["my"] = array();
                        }
                        $serverList["my"][$cu] = true;
                        break;
                    case "www3":
                        if (!HCU_array_key_exists("www3", $serverList)) {
                            $serverList["www3"] = array();
                        }
                        $serverList["www3"][$cu] = true;
                        break;
                    case "www5":
                        if (!HCU_array_key_exists("www5", $serverList)) {
                            $serverList["www5"] = array();
                        }
                        $serverList["www5"][$cu] = true;
                        break;
                    case "www6":
                        if (!HCU_array_key_exists("www6", $serverList)) {
                            $serverList["www6"] = array();
                        }
                        $serverList["www6"][$cu] = true;
                        break;
                    case "localhost":
                        if (!HCU_array_key_exists("localhost", $serverList)) {
                            $serverList["localhost"] = array();
                        }
                        $serverList["localhost"][$cu] = true;
                        break;
                }
            }
        }

        $elist = GetBroadcastFileLoc() . "elist_master";

        $handle = fopen("${elist}.new", "w");

        if (!$handle) {
            throw new exception ("couldn't open file ${elist}.new", 2);
        }

        fwrite($handle, HCU_JsonEncode($serverList));
        fclose($handle);

        $returnArray = array("status" => "000", "error" => "");
    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage());
    }
    return $returnArray;
}

/**
 * function GatherEmailListByServer($dbh, $sysenv, $server, $validCus)
 * This gets all the emails from a server.
 * It uses report number 4 on the hcucontact_rpt.prg script.
 *
 * @param $dbh -- the database connection.
 * @param $sysenv -- the system environment.  (Uses devmode.)
 * @param $server -- the server to get data from.
 * @param $validCus -- the valid cus for the server.
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 */
function GatherEmailListByServer($dbh, $sysenv, $server, $validCus) {
    try {
        $hcuTicket = urlencode($_COOKIE['HCUTicket']);
        $googleCookie = GetGoogleCookie($sysenv["devmode"]);

        if ($server == "my") {
            $url = "https://my.homecu.net/hcuadm/hcucontact_rpt.prg?report=4&csv=raw";
            $curlCookies = "HCUTicket=$hcuTicket;homecu_dev_oauth2_proxy=$googleCookie";
        } else if ($sysenv["devmode"] == 1 && $server == "localhost") {
            $url = "http://localhost/hcuadm/hcucontact_rpt.prg?report=4&csv=raw";
            $curlCookies = "HCUTicket=$hcuTicket";
        } else {
            $url = "https://$server.homecu.net/hcuadm/hcucontact_rpt?report=4&csv=raw";
            $curlCookies = "HCUTicket=$hcuTicket";
        }

        $ch = curl_init($url);
        curl_setopt($ch,CURLOPT_COOKIE, $curlCookies);
        curl_setopt($ch,CURLOPT_USERPWD, "nobody:no1home");
        curl_setopt($ch,CURLOPT_RETURNTRANSFER, 1); # get response as string

        $rawresp = curl_exec($ch);
        curl_close($ch);

        $cuList = array();
        if ($rawresp) {

            $lines = explode("\r\n", $rawresp);

            foreach($lines as $i => $line) {
                // I don't care about the title or types.
                if ($i < 2 || trim($line) == "") {
                    continue;
                }

                $values = explode("\t", $line);

                $cu = HCU_array_key_value(0, $values);
                $email = HCU_array_key_value(1, $values);
                $cu = $cu === false ? "" : trim($cu);
                $email = $email === false ? "" : trim($email);

                # if the monitor list has this cu on this server, store the result
                if (HCU_array_key_exists($cu, $validCus) && $email != "") {
                    $cuList[$cu] = $email;
                }
            }
        }

        $newCuList = array();
        foreach ($cuList as $cu => $email) {
            $newCuList[$cu] = array();
            rtrim($email);
            $emlist = preg_split('/[;, ]/',$email);
            foreach ($emlist as $em) {
                $em = trim($em);
                if ("$em" <> "") {
                    $newCuList[$cu][] = $em;
                }
            }
        }

        $elist = GetBroadcastFileLoc() . "elist_$server";
        $handle = fopen("${elist}.new", "w");

        if (!$handle) {
            throw new exception ("couldn't open file ${elist}.new", 2);
        }

        fwrite($handle, HCU_JsonEncode($newCuList));
        fclose($handle);

        $returnArray = array("status" => "000", "error" => "");
    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage());
    }
    return $returnArray;
}

/**
 * function ReadSetup($dbh, $sysenv)
 * This sets up the page for download a CSV or sending emails.
 * It returns all data for the kendo controls and preloads data from the servers.
 *
 * @param $dbh -- the database connection.
 * @param $sysenv -- the system environment.  (Uses devmode.)
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 * @return $action -- "read."  Tells the datasource what to do with results.
 */
function ReadSetup($dbh, $sysenv) {
    try {
        $sql = "select email from cuadmnotify where cu = 'HOMECU' and role = 'SES'";
        $sth = db_query($sql, $dbh);
        if (!$sth) {
            throw new exception ("Select statement failed.", 1);
        }
        $emailList = array();
        if (db_num_rows($sth) > 0) {
            $row = db_fetch_assoc($sth, 0);
            $decodedList = HCU_JsonDecode($row["email"]);
            foreach ($decodedList as $emailRec) {
                if ($emailRec["verified"]) {
                    $emailList[] = $emailRec["email"];
                }
            }
        }

        // Add the default "from."
        array_unshift($emailList, GetDefaultEmail());

        $servers = array("ALL", "my", "www5", "www3", "www6");

        if ($sysenv["devmode"] == 1) {
            $servers[] = "localhost";
        }

        $serverList = array();
        $whenToGetNewCopy = GetWhenToGetNewCopy();
        $now = time();

        $file = GetBroadcastFileLoc() . "elist_master.new";
        if (file_exists($file)) {
            if ($now - filemtime($file) < $whenToGetNewCopy) {
                $results = GatherCuList($dbh, $sysenv);
                if ($results["status"] !== "000") {
                    throw new exception ($results["error"], 1);
                }
            }
        } else {
            $file = GetBroadcastFileLoc() . "elist_master.last";

            // last file doesn't exist or was modified more than a hour ago.
            if (!file_exists($file) || $now - filemtime($file) < $whenToGetNewCopy) {
                $results = GatherCuList($dbh, $sysenv);
                if ($results["status"] !== "000") {
                    throw new exception ($results["error"], 7);
                }
                $file = GetBroadcastFileLoc() . "elist_master.new";
            }
        }
        if (!file_exists($file)) {
            throw new exception ("Cu List doesn't exist.", 2);
        }
        $serverList = file_get_contents($file);
        if ($serverList == null || trim($serverList) == "") {
            throw new exception ("Cu List doesn't exist.", 3);
        }
        $serverList = HCU_JsonDecode($serverList);

        // Step 2: Email Lists
        $cus = array();
        foreach($serverList as $server => $validCus) {
            $file = GetBroadcastFileLoc() . "elist_$server.new";
            if (file_exists($file)) {
                if ($now - filemtime($file) < $whenToGetNewCopy) {
                    $results = GatherEmailListByServer($dbh, $sysenv, $server, $validCus);
                    if ($results["status"] !== "000") {
                        throw new exception ($results["error"], 4);
                    }
                }
            } else {
                $file = GetBroadcastFileLoc() . "elist_$server.last";

                // last file doesn't exist or was modified more than a hour ago.
                if (!file_exists($file) || $now - filemtime($file) < $whenToGetNewCopy) {
                    $results = GatherEmailListByServer($dbh, $sysenv, $server, $validCus);
                    if ($results["status"] !== "000") {
                        throw new exception ($results["error"], 5);
                    }
                    $file = GetBroadcastFileLoc() . "elist_$server.new";
                }
            }

            if (!file_exists($file)) {
                throw new exception ("Cu List doesn't exist.", 6);
            }

            $cus = array_merge($cus, array_keys($validCus));
        }
        sort($cus, SORT_STRING);

        $actions = array(array("text" => "Email", "value" => "email"),
                         array("text" => "Download Tab-Delimited File", "value" => "download"));

        $data = array("emailList" => $emailList, "servers" => $servers, "cuList" => $cus, "actions" => $actions);
        $returnArray = array("status" => "000", "error" => "", "data" => $data, "action" => "read");

    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage(), "action" => "read");
    }
    return $returnArray;
}

/**
 * function GetFilteredCUList($sysenv)
 * This gets a filtered list based on the Cu and server options.
 *
 * @param $sysenv -- the system variables
 *    Uses post variables in "IMPORTS" and devmode.
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 * @return $cuList -- list of CUs & their emails.
 */
function GetFilteredCUList($sysenv) {
    try {
        $file = GetBroadcastFileLoc() . "elist_master.new";
        if (!file_exists($file)) {
            $file = GetBroadcastFileLoc() . "elist_master.last";

            if (!file_exists($file)) {
                throw new exception ("Master file doesn't exist.", 1);
            }
        }
        $serverList = file_get_contents($file);
        if ($serverList == null || trim($serverList) == "") {
            throw new exception ("Master file doesn't exist.", 2);
        }

        $filteredCus = HCU_array_key_value("filteredCus", $sysenv["IMPORTS"]);
        $filteredServers = HCU_array_key_value("filteredServers", $sysenv["IMPORTS"]);
        $filteredCus = $filteredCus === false ? "" : trim($filteredCus);
        $filteredServers = $filteredServers === false ? "" : trim($filteredServers);

        if ($filteredCus == "") {
            throw new exception ("Filtered Cus are required.", 5);
        }
        if ($filteredServers === "") {
            throw new exception ("Filtered servers are required.", 6);
        }
        $filteredCus = HCU_JsonDecode($filteredCus);
        $filteredServers = HCU_JsonDecode($filteredServers);

        $serverList = HCU_JsonDecode($serverList);
        $cuList = array();
        foreach($serverList as $server => $unused) {
            if (count($filteredServers) > 0 && !in_array("ALL", $filteredServers) && !in_array($server, $filteredServers)) {
                continue;
            }
            $file = GetBroadcastFileLoc() . "elist_$server.new";
            if (!file_exists($file)) {
                $file = GetBroadcastFileLoc() . "elist_$server.last";

                if (!file_exists($file)) {
                    throw new exception ("Server file $server doesn't exist.", 3);
                }
            }
            $serverCus = file_get_contents($file);
            if ($serverCus == null || trim($serverCus) == "") {
                throw new exception ("Server file $server doesn't exist.", 4);
            }
            $serverCus = HCU_JsonDecode($serverCus);

            foreach($serverCus as $cu => $emails) {
                if (count($filteredCus) > 0 && !in_array($cu, $filteredCus)) {
                    continue;
                }
                $cuRecord = array("cu" => $cu, "server" => $server, "emails" => $emails);
                $cuList[$cu] = $cuRecord;
            }
        }

        // Now sort
        ksort($cuList, SORT_STRING);

        $returnArray = array("status" => "000", "error" => "", "cuList" => $cuList);
    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage());
    }
    return $returnArray;
}

/**
 * function ChangeToLast()
 * This changes the files from .new to .last to preserve history up to two places.
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 */
function ChangeToLast() {
    try {
        $fileList = array("master", "localhost", "www3", "www5", "www6", "my");
        foreach($fileList as $filePart) {
            $file = GetBroadcastFileLoc() . "elist_$filePart";
            if (file_exists("$file.new")) {
                $results = shell_exec("mv ${file}.new ${file}.last 2>&1");
                if ($results != "") {
                    throw new exception ($results, 1);
                }
            }
        }

        $returnArray = array("status" => "000", "error" => "");
    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage());
    }
    return $returnArray;
}

/**
 * function DownloadCSV($dbh, $sysenv)
 * This downloads a CSV from filtered CU and server options.
 *
 * @param $dbh -- the database connection.
 * @param $sysenv -- the system environment.  (Uses post variables in "IMPORTS".)
 *
 * @return void
 */
function DownloadCSV($dbh, $sysenv) {
    try {
        $csvData = array();
        $results = GetFilteredCUList($sysenv);

        if ($results["status"] !== "000") {
            throw new exception ($results["error"], 1);
        }

        $csvData[] = "Display Name\tServer\tPrimary Email";

        foreach($results["cuList"] as $cuRecord) {
            foreach($cuRecord["emails"] as $email) {
                $csvData[] = $cuRecord["cu"] . "\t" . $cuRecord["server"] . "\t" . $email;
            }
        }

        $results = ChangeToLast();
        if ($results["status"] !== "000") {
            throw new exception ($results["error"], 2);
        }

    } catch (exception $e) {
        $csvData = array("Download Failed: " . $e->getMessage());
    }

    $csvData = implode("\r\n", $csvData);

    header("Content-length: " . strlen($csvData) );
    header("Content-type: application/octetstream");
    header("Content-disposition: inline; filename=\"elist.csv\"");
    print ($csvData);
}

/**
 * function ValidateEmailParameters($sysenv, $requireTestEmail)
 * This validates & sanitizes input for emails.
 *
 * @param $sysenv -- the system environment.  (Uses post variables in "IMPORTS".)
 * @param $requireTestEmail -- if true, then also throw if the test email is invalid.
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 * @return $data -- array of the sanitized values.
 */
function ValidateEmailParameters($sysenv, $requireTestEmail) {
    try {
        $fromEmail = HCU_array_key_value("fromEmail", $sysenv["IMPORTS"]);
        $fromEmail = $fromEmail === false ? "" : trim($fromEmail);
        if ($fromEmail == "") {
            throw new exception("From Email is required.", 1);
        }
        $fromName = HCU_array_key_value("fromName", $sysenv["IMPORTS"]);
        $fromName = $fromName === false ? "" : trim($fromName);

        $subject = HCU_array_key_value("subject", $sysenv["IMPORTS"]);
        $subject = $subject === false ? "" : trim($subject);

        $testEmail = HCU_array_key_value("testEmail", $sysenv["IMPORTS"]);
        $testEmail = $testEmail === false ? "" : trim($testEmail);
        if ($testEmail == "" && $requireTestEmail) {
            throw new exception ("Test Email is required.", 2);
        }

        $body = HCU_array_key_value("body", $sysenv["IMPORTS"]);
        $body = $body === false ? "" : htmlspecialchars_decode(trim($body));

        if (!validateEmail($fromEmail)) {
            throw new exception ("From Email is not valid.", 3);
        }

        if ($testEmail != "" && !validateEmail($testEmail)) {
            throw new exception ("Test Email is not valid.", 4);
        }

        $data = array("fromEmail" => $fromEmail, "fromName" => $fromName, "subject" => $subject, "testEmail" => $testEmail, "body" => $body);
        $returnArray = array("status" => "000", "error" => "", "data" => $data);
    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage());
    }
    return $returnArray;
}

/**
 * function SendTestEmail($dbh, $sysenv)
 * This sends a test email.
 *
 * @param $dbh -- the database connection.
 * @param $sysenv -- the system environment.  (Uses post variables in "IMPORTS".)
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 * @return $action -- "preview."  Tells the datasource what to do with results.
 */
function SendTestEmail($dbh, $sysenv) {
    try {
        $results = ValidateEmailParameters($sysenv, true);
        if ($results["status"] !== "000") {
            throw new exception ($results["error"], 1);
        }
        extract($results["data"]);

        $notify = new ErrorMail;
        $notify->mailfrom = $fromEmail;
        $notify->mailfromname = $fromName;
        $notify->subject = $subject;
        $notify->htmlMsgbody = $body;
        $notify->executeQuietly = true;
        $notify->mailto = $testEmail;
        $notify->SendMail();

        $returnArray = array("status" => "000", "error" => "", "action" => "preview");
    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage(), "action" => "preview");
    }
    return $returnArray;
}

/**
 * function SendEmails($dbh, $sysenv)
 * This sends emails to all emails from the filtered list.
 *
 * @param $dbh -- the database connection.
 * @param $sysenv -- the system environment.  (Uses post variables in "IMPORTS".)
 *
 * @return $status -- "000" if successful, nonzero otherwise.
 * @return $error -- "" if successful, nonempty otherwise.
 * @return $action -- "send."  Tells the datasource what to do with results.
 */
function SendEmails($dbh, $sysenv) {
    try {
        $results = ValidateEmailParameters($sysenv, false);
        if ($results["status"] !== "000") {
            throw new exception ($results["error"], 1);
        }
        extract($results["data"]);

        $results = GetFilteredCUList($sysenv);

        if ($results["status"] !== "000") {
            throw new exception ($results["error"], 2);
        }

        $emailList = array();
        foreach($results["cuList"] as $cuRecord) {
            foreach($cuRecord["emails"] as $email) {
                $emailList[] = $email;
            }
        }

        $notify = new ErrorMail;
        $notify->mailfrom = $fromEmail;
        $notify->mailfromname = $fromName;
        $notify->subject = $subject;
        $notify->htmlMsgbody = $body;
        $notify->executeQuietly = true;
        $notify->mailto = $emailList;
        $notify->bulk = true;
        $notify->hideto = true;
        $notify->SendMail();

        $results = ChangeToLast();
        if ($results["status"] !== "000") {
            throw new exception ($results["error"], 3);
        }

        // Add email to SES role to HOMECU if it's new.
        if ($fromEmail != GetDefaultEmail()) {
            $sql = "select email from cuadmnotify where cu = 'HOMECU' and role = 'SES'";
            $sth = db_query($sql, $dbh);
            if (!$sth) {
                throw new exception ("Select query failed.", 4);
            }
            // For this, always assume that the email is verified.
            if (db_num_rows($sth) <= 0) {
                $mode = "create";
                $verifiedEmails = array(array("email" => $fromEmail, "verified" => true));
            } else {
                $mode = "update";
                $verifiedEmails = db_fetch_row($sth, 0)[0];
                $verifiedEmails = isset($verifiedEmails) ? HCU_JsonDecode($verifiedEmails) : array();
                $newEmailTest = trim(strtolower($fromEmail));
                foreach ($verifiedEmails as $emailRec) {
                    if ($newEmailTest == trim(strtolower($emailRec["email"]))) {
                        $mode = "don't";
                        break;
                    }
                }

                if ($mode != "don't") {
                    $verifiedEmails[] = array("email" => $fromEmail, "verified" => true);
                }
            }

            switch($mode) {
                case "create":
                    $sql = "insert into cuadmnotify (cu, role, email) values ('HOMECU', 'SES', '" . prep_save(HCU_JsonEncode($verifiedEmails)) . "')";
                    $sth = db_query($sql, $dbh);
                    if (!$sth) {
                        throw new exception ("Insert query failed.", 5);
                    }
                    break;
                case "update":
                    $sql = "update cuadmnotify set email = '" . prep_save(HCU_JsonEncode($verifiedEmails)) . "' where cu = 'HOMECU' and role = 'SES'";
                    $sth = db_query($sql, $dbh);
                    if (!$sth) {
                        throw new exception ("Update query failed.", 6);
                    }
            }
        }

        $returnArray = array("status" => "000", "error" => "", "action" => "send", "info" => "Emails were successfully sent.");
    } catch (exception $e) {
        $returnArray = array("status" => $e->getCode(), "error" => $e->getMessage(), "action" => "send");
    }
    return $returnArray;
}