nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2026-02-22 19:06:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add the email_queue.

Browse Source
This commit is contained in:
markjcrane
2022-04-22 13:00:38 -06:00
parent f73f9b706f
commit 133c51bfcf
13 changed files with 2995 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

240
app/email_queue/resources/classes/email_queue.php Normal file
View File

@@ -0,0 +1,240 @@
<?php
/**
* email_queue class
*
* @method null delete
* @method null toggle
* @method null copy
*/
if (!class_exists('email_queue')) {
class email_queue {
/**
* declare the variables
*/
private $app_name;
private $app_uuid;
private $name;
private $table;
private $toggle_field;
private $toggle_values;
private $location;
/**
* called when the object is created
*/
public function __construct() {
//assign the variables
$this->app_name = 'email_queue';
$this->app_uuid = '5befdf60-a242-445f-91b3-2e9ee3e0ddf7';
$this->name = 'email_queue';
$this->table = 'email_queue';
$this->toggle_field = '';
$this->toggle_values = ['true','false'];
$this->location = 'email_queue.php';
}
/**
* called when there are no references to a particular object
* unset the variables used in the class
*/
public function __destruct() {
foreach ($this as $key => $value) {
unset($this->$key);
}
}
/**
* delete rows from the database
*/
public function delete($records) {
if (permission_exists($this->name.'_delete')) {
//add multi-lingual support
$language = new text;
$text = $language->get();
//validate the token
$token = new token;
if (!$token->validate($_SERVER['PHP_SELF'])) {
message::add($text['message-invalid_token'],'negative');
header('Location: '.$this->location);
exit;
}
//delete multiple records
if (is_array($records) && @sizeof($records) != 0) {
//build the delete array
$x = 0;
foreach ($records as $record) {
//add to the array
if ($record['checked'] == 'true' && is_uuid($record['uuid'])) {
$array[$this->table][$x][$this->name.'_uuid'] = $record['uuid'];
$array['email_queue_attachments'][$x][$this->name.'_uuid'] = $record['uuid'];
//$array[$this->table][$x]['domain_uuid'] = $_SESSION['domain_uuid'];
}
//increment the id
$x++;
}
//delete the checked rows
if (is_array($array) && @sizeof($array) != 0) {
//execute delete
$database = new database;
$database->app_name = $this->app_name;
$database->app_uuid = $this->app_uuid;
$database->delete($array);
unset($array);
//set message
message::add($text['message-delete']);
}
unset($records);
}
}
}
/**
* toggle a field between two values
*/
public function toggle($records) {
if (permission_exists($this->name.'_edit')) {
//add multi-lingual support
$language = new text;
$text = $language->get();
//validate the token
$token = new token;
if (!$token->validate($_SERVER['PHP_SELF'])) {
message::add($text['message-invalid_token'],'negative');
header('Location: '.$this->location);
exit;
}
//toggle the checked records
if (is_array($records) && @sizeof($records) != 0) {
//get current toggle state
foreach($records as $record) {
if ($record['checked'] == 'true' && is_uuid($record['uuid'])) {
$uuids[] = "'".$record['uuid']."'";
}
}
if (is_array($uuids) && @sizeof($uuids) != 0) {
$sql = "select ".$this->name."_uuid as uuid, ".$this->toggle_field." as toggle from v_".$this->table." ";
$sql .= "where ".$this->name."_uuid in (".implode(', ', $uuids).") ";
$sql .= "and (domain_uuid = :domain_uuid or domain_uuid is null) ";
$parameters['domain_uuid'] = $_SESSION['domain_uuid'];
$database = new database;
$rows = $database->select($sql, $parameters, 'all');
if (is_array($rows) && @sizeof($rows) != 0) {
foreach ($rows as $row) {
$states[$row['uuid']] = $row['toggle'];
}
}
unset($sql, $parameters, $rows, $row);
}
//build update array
$x = 0;
foreach($states as $uuid => $state) {
//create the array
$array[$this->table][$x][$this->name.'_uuid'] = $uuid;
$array[$this->table][$x][$this->toggle_field] = $state == $this->toggle_values[0] ? $this->toggle_values[1] : $this->toggle_values[0];
//increment the id
$x++;
}
//save the changes
if (is_array($array) && @sizeof($array) != 0) {
//save the array
$database = new database;
$database->app_name = $this->app_name;
$database->app_uuid = $this->app_uuid;
$database->save($array);
unset($array);
//set message
message::add($text['message-toggle']);
}
unset($records, $states);
}
}
}
/**
* copy rows from the database
*/
public function copy($records) {
if (permission_exists($this->name.'_add')) {
//add multi-lingual support
$language = new text;
$text = $language->get();
//validate the token
$token = new token;
if (!$token->validate($_SERVER['PHP_SELF'])) {
message::add($text['message-invalid_token'],'negative');
header('Location: '.$this->location);
exit;
}
//copy the checked records
if (is_array($records) && @sizeof($records) != 0) {
//get checked records
foreach($records as $record) {
if ($record['checked'] == 'true' && is_uuid($record['uuid'])) {
$uuids[] = "'".$record['uuid']."'";
}
}
//create the array from existing data
if (is_array($uuids) && @sizeof($uuids) != 0) {
$sql = "select * from v_".$this->table." ";
$sql .= "where ".$this->name."_uuid in (".implode(', ', $uuids).") ";
$sql .= "and (domain_uuid = :domain_uuid or domain_uuid is null) ";
$parameters['domain_uuid'] = $_SESSION['domain_uuid'];
$database = new database;
$rows = $database->select($sql, $parameters, 'all');
if (is_array($rows) && @sizeof($rows) != 0) {
$x = 0;
foreach ($rows as $row) {
//copy data
$array[$this->table][$x] = $row;
//add copy to the description
$array[$this->table][$x][$this->name.'_uuid'] = uuid();
//increment the id
$x++;
}
}
unset($sql, $parameters, $rows, $row);
}
//save the changes and set the message
if (is_array($array) && @sizeof($array) != 0) {
//save the array
$database = new database;
$database->app_name = $this->app_name;
$database->app_uuid = $this->app_uuid;
$database->save($array);
unset($array);
//set message
message::add($text['message-copy']);
}
unset($records);
}
}
}
}
}
?>

229
app/email_queue/resources/functions/transcribe.php Normal file
View File

@@ -0,0 +1,229 @@
<?php
if (!function_exists('transcribe')) {
function transcribe ($file_path, $file_name, $file_extension) {
//transcription variables
$transcribe_provider = $_SESSION['voicemail']['transcribe_provider']['text'];
$transcribe_language = $_SESSION['voicemail']['transcribe_language']['text'];
//transribe - watson
if ($transcribe_provider == 'watson') {
$api_key = $_SESSION['voicemail']['watson_key']['text'];
$api_url = $_SESSION['voicemail']['watson_url']['text'];
if ($file_extension == "mp3") {
$content_type = 'audio/mp3';
}
if ($file_extension == "wav") {
$content_type = 'audio/wav';
}
if (isset($api_key) && $api_key != '') {
//check if the file exists
if (!file_exists($file_path.'/'.$file_name)) {
echo "file not found ".$file_path.'/'.$file_name;
exit;
}
//start output buffer
ob_start();
$out = fopen('php://output', 'w');
//create the curl resource
$ch = curl_init();
//set the curl options
curl_setopt($ch, CURLOPT_URL, $api_url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_USERPWD, 'apikey' . ':' . $api_key);
curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC); //set the authentication type
curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: '.$content_type]);
curl_setopt($ch, CURLOPT_BINARYTRANSFER,TRUE);
curl_setopt($ch, CURLOPT_POSTFIELDS, file_get_contents($file_path.'/'.$file_name));
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 20); //The number of seconds to wait while trying to connect.
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, TRUE); //To follow any "Location: " header that the server sends as part of the HTTP header.
curl_setopt($ch, CURLOPT_AUTOREFERER, TRUE); //To automatically set the Referer: field in requests where it follows a Location: redirect.
curl_setopt($ch, CURLOPT_TIMEOUT, 300); //The maximum number of seconds to allow cURL functions to execute.
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, TRUE); //To stop cURL from verifying the peer's certificate.
curl_setopt($ch, CURLOPT_HEADER, 0); //hide the headers when set to 0
//add verbose for debugging
curl_setopt($ch, CURLOPT_VERBOSE, true);
curl_setopt($ch, CURLOPT_STDERR, $out);
//execute the curl with the options
$http_content = curl_exec($ch);
//return the error
if (curl_errno($ch)) {
echo 'Error:' . curl_error($ch);
}
//close the curl resource
curl_close($ch);
//show the debug information
fclose($out);
$debug = ob_get_clean();
echo $debug;
//$command = "curl -X POST -silent -u \"apikey:".$api_key."\" --header \"Content-type: ".$content_type."\" --data-binary @".$file_path."/".$file_name." \"".$api_url."\"";
//echo "command: ".$command."\n";
//ob_start();
//$result = passthru($command);
//$json_result = ob_get_contents();
//ob_end_clean();
//run the command
//$http_response = shell_exec($command);
//echo "http_response:\n".$http_response."\n";
//remove headers and return the http content
//$http_response = trim(str_ireplace("HTTP/1.1 100 Continue", "", $http_response));
//$temp_array = explode("HTTP/1.1 200 OK", $http_response);
//$http_array = explode("\r\n\r\n", $temp_array[1]);
//$http_content = trim($http_array[1]);
echo "http_content:\n".$http_content."\n";
//validate the json
$ob = json_decode($http_content);
if($ob === null) {
echo "invalid json\n";
return false;
}
$message = '';
$json = json_decode($http_content, true);
//echo "json; ".$json."\n";
foreach($json['results'] as $row) {
$message .= $row['alternatives'][0]['transcript'];
}
$message = str_replace("%HESITATION", " ", trim($message));
$message = ucfirst($message);
$array['provider'] = $transcribe_provider;
$array['language'] = $transcribe_language;
//$array['command'] = $command;
$array['message'] = $message;
return $array;
}
}
//transribe - google
if ($transcribe_provider == 'google') {
$api_key = $_SESSION['voicemail']['google_key']['text'];
$api_url = $_SESSION['voicemail']['google_url']['text'];
$transcribe_language = $_SESSION['voicemail']['transcribe_language']['text'];
$transcribe_alternate_language = $_SESSION['voicemail']['transcribe_alternate_language']['text'];
if (!isset($transcribe_language) && strlen($transcribe_language) == 0) {
$transcribe_language = 'en-Us';
}
if (!isset($transcribe_alternate_language) && strlen($transcribe_alternate_language) == 0) {
$transcribe_alternate_language = 'es-Us';
}
if ($file_extension == "mp3") {
$content_type = 'audio/mp3';
}
if ($file_extension == "wav") {
$content_type = 'audio/wav';
}
if (isset($api_key) && $api_key != '') {
//$command = "curl -X POST -silent -u \"apikey:".$api_key."\" --header \"Content-type: ".$content_type."\" --data-binary @".$file_path."/".$file_name." \"".$api_url."\"";
//echo "command: ".$command."\n";
$command = "sox ".$file_path."/".$file_name." ".$file_path."/".$file_name.".flac trim 0 00:59 ";
$command .= "&& echo \"{ 'config': { 'languageCode': '".$transcribe_language."', 'enableWordTimeOffsets': false , 'enableAutomaticPunctuation': true , 'alternativeLanguageCodes': '".$transcribe_alternate_language."' }, 'audio': { 'content': '`base64 -w 0 ".$file_path."/".$file_name.".flac`' } }\" ";
$command .= "| curl -X POST -H \"Content-Type: application/json\" -d @- ".$api_url.":recognize?key=".$api_key." ";
$command .= "&& rm -f ".$file_path."/".$file_name.".flac";
echo $command."\n";
//ob_start();
//$result = passthru($command);
//$json_result = ob_get_contents();
//ob_end_clean();
//run the command
$http_response = shell_exec($command);
//validate the json
$ob = json_decode($http_response);
if($ob === null) {
echo "invalid json\n";
return false;
}
$message = '';
$json = json_decode($http_response, true);
//echo "json; ".$json."\n";
foreach($json['results'] as $row) {
$message .= $row['alternatives'][0]['transcript'];
}
//build the response
$array['provider'] = $transcribe_provider;
$array['language'] = $transcribe_language;
$array['command'] = $command;
$array['message'] = $message;
//print_r($array);
return $array;
}
}
//transribe - azure
if ($transcribe_provider == 'azure') {
$api_key = $_SESSION['voicemail']['azure_key']['text'];
$api_url = $_SESSION['voicemail']['azure_server_region']['text'];
if (strlen($transcribe_language) == 0) {
$transcribe_language = 'en-US';
}
if ($file_extension == "mp3") {
$content_type = 'audio/mp3';
}
if ($file_extension == "wav") {
$content_type = 'audio/wav';
}
if (isset($api_key) && $api_key != '') {
$command = "curl -X POST \"https://".$api_url.".api.cognitive.microsoft.com/sts/v1.0/issueToken\" -H \"Content-type: application/x-www-form-urlencoded\" -H \"Content-Length: 0\" -H \"Ocp-Apim-Subscription-Key: ".$api_key."\"";
$access_token_result = shell_exec($command);
if (strlen($access_token_result) == 0) {
return false;
}
else {
$file_path = $file_path.'/'.$file_name;
$command = "curl -X POST \"https://".$api_url.".stt.speech.microsoft.com/speech/recognition/conversation/cognitiveservices/v1?language=".$transcribe_language."&format=detailed\" -H 'Authorization: Bearer ".$access_token_result."' -H 'Content-type: audio/wav; codec=\"audio/pcm\"; samplerate=8000; trustsourcerate=false' --data-binary @".$file_path;
echo $command."\n";
$http_response = shell_exec($command);
$array = json_decode($http_response, true);
if ($array === null) {
return false;
}
else {
$message = $array['NBest'][0]['Display'];
}
}
$array['provider'] = $transcribe_provider;
$array['language'] = $transcribe_language;
$array['api_key'] = $api_key;
$array['command'] = $command;
$array['message'] = $message;
return $array;
}
}
}
}
?>

198
app/email_queue/resources/jobs/email_queue.php Normal file
View File

@@ -0,0 +1,198 @@
<?php
//check the permission
if (defined('STDIN')) {
$document_root = str_replace("\\", "/", $_SERVER["PHP_SELF"]);
preg_match("/^(.*)\/app\/.*$/", $document_root, $matches);
$document_root = $matches[1];
set_include_path($document_root);
$_SERVER["DOCUMENT_ROOT"] = $document_root;
require_once "resources/require.php";
require_once "resources/pdo.php";
}
else {
exit;
include "root.php";
require_once "resources/require.php";
require_once "resources/pdo.php";
}
//increase limits
set_time_limit(0);
ini_set('max_execution_time', 0);
ini_set('memory_limit', '512M');
//save the arguments to variables
$script_name = $argv[0];
if (!empty($argv[1])) {
parse_str($argv[1], $_GET);
}
//print_r($_GET);
//set the variables
if (isset($_GET['hostname'])) {
$hostname = urldecode($_GET['hostname']);
}
if (isset($_GET['debug'])) {
$debug = $_GET['debug'];
}
//includes
if (!defined('STDIN')) { include_once "root.php"; }
require_once "resources/require.php";
include "resources/classes/permissions.php";
require $document_root."/app/email_queue/resources/functions/transcribe.php";
//define the process id file
$pid_file = "/var/run/fusionpbx/".basename( $argv[0], ".php") .".pid";
//echo "pid_file: ".$pid_file."\n";
//function to check if the process exists
function process_exists($file = false) {
//set the default exists to false
$exists = false;
//check to see if the process is running
if (file_exists($file)) {
$pid = file_get_contents($file);
if (posix_getsid($pid) === false) {
//process is not running
$exists = false;
}
else {
//process is running
$exists = true;
}
}
//return the result
return $exists;
}
//check to see if the process exists
$pid_exists = process_exists($pid_file);
//prevent the process running more than once
if ($pid_exists) {
echo "Cannot lock pid file {$pid_file}\n";
exit;
}
//email queue enabled
if ($_SESSION['email_queue']['enabled']['boolean'] != 'true') {
echo "Email Queue is disabled in Default Settings\n";
exit;
}
//make sure the /var/run/fusionpbx directory exists
if (!file_exists('/var/run/fusionpbx')) {
$result = mkdir('/var/run/fusionpbx', 0777, true);
if (!$result) {
die('Failed to create /var/run/fusionpbx');
}
}
//create the process id file if the process doesn't exist
if (!$pid_exists) {
//remove the old pid file
if (file_exists($file)) {
unlink($pid_file);
}
//show the details to the user
//echo "The process id is ".getmypid()."\n";
//echo "pid_file: ".$pid_file."\n";
//save the pid file
file_put_contents($pid_file, getmypid());
}
//get the call center settings
$interval = $_SESSION['email_queue']['interval']['numeric'];
//set the defaults
if (!is_numeric($interval)) { $interval = 30; }
//set the email queue limit
if (isset($_SESSION['email_queue']['limit']['numeric'])) {
$email_queue_limit = $_SESSION['email_queue']['limit']['numeric'];
}
else {
$email_queue_limit = '30';
}
if (isset($_SESSION['email_queue']['debug']['boolean'])) {
$debug = $_SESSION['email_queue']['debug']['boolean'];
}
//get the messages waiting in the email queue
$sql = "select * from v_email_queue ";
$sql .= "where (email_status = 'waiting' or email_status = 'trying') ";
$sql .= "and hostname = :hostname ";
$sql .= "order by domain_uuid asc ";
$sql .= "limit :limit ";
if (isset($hostname)) {
$parameters['hostname'] = $hostname;
}
else {
$parameters['hostname'] = gethostname();
}
$parameters['limit'] = $email_queue_limit;
$database = new database;
$email_queue = $database->select($sql, $parameters, 'all');
unset($parameters);
//process the messages
if (is_array($email_queue) && @sizeof($email_queue) != 0) {
foreach($email_queue as $row) {
$command = "/usr/bin/php /var/www/fusionpbx/app/email_queue/resources/job/email_send.php ";
$command .= "'action=send&email_queue_uuid=".$row["email_queue_uuid"]."&hostname=".$hostname."'";
if (isset($debug)) {
//run process inline to see debug info
echo $command."\n";
$result = system($command);
echo $result."\n";
}
else {
//starts process rapidly doesn't wait for previous process to finish (used for production)
$handle = popen($command." > /dev/null &", 'r');
echo "'$handle'; " . gettype($handle) . "\n";
$read = fread($handle, 2096);
echo $read;
pclose($handle);
}
}
}
//remove the old pid file
if (file_exists($file)) {
unlink($pid_file);
}
//save output to
//$fp = fopen(sys_get_temp_dir()."/mailer-app.log", "a");
//prepare the output buffers
//ob_end_clean();
//ob_start();
//message divider for log file
//echo "\n\n=============================================================================================================================================\n\n";
//get and save the output from the buffer
//$content = ob_get_contents(); //get the output from the buffer
//$content = str_replace("<br />", "", $content);
//ob_end_clean(); //clean the buffer
//fwrite($fp, $content);
//fclose($fp);
//notes
//echo __line__."\n";
// if not keeping the email then need to delete it after the voicemail is emailed
//how to use this feature
// cd /var/www/fusionpbx; /usr/bin/php /var/www/fusionpbx/app/email_queue/resources/send.php
?>

637
app/email_queue/resources/jobs/email_send.php Normal file
View File

@@ -0,0 +1,637 @@
<?php
//check the permission
if (defined('STDIN')) {
$document_root = str_replace("\\", "/", $_SERVER["PHP_SELF"]);
preg_match("/^(.*)\/app\/.*$/", $document_root, $matches);
$document_root = $matches[1];
set_include_path($document_root);
$_SERVER["DOCUMENT_ROOT"] = $document_root;
require_once "resources/require.php";
}
else {
exit;
include "root.php";
require_once "resources/require.php";
require_once "resources/pdo.php";
}
//increase limits
set_time_limit(0);
//ini_set('max_execution_time',1800); //30 minutes
ini_set('memory_limit', '512M');
//save the arguments to variables
$script_name = $argv[0];
if (!empty($argv[1])) {
parse_str($argv[1], $_GET);
}
//print_r($_GET);
//set the variables
if (isset($_GET['hostname'])) {
$hostname = urldecode($_GET['hostname']);
}
if (isset($_GET['debug'])) {
$debug = $_GET['debug'];
}
//includes
if (!defined('STDIN')) { include_once "root.php"; }
require_once "resources/require.php";
include "resources/classes/permissions.php";
require $document_root."/app/email_queue/resources/functions/transcribe.php";
//define a function to remove html tags
if (!function_exists('remove_tags')) {
function remove_tags($string) {
//remove HTML tags
$string = preg_replace ('/<[^>]*>/', ' ', $string);
//remove control characters
$string = str_replace("\r", '', $string); // --- replace with empty space
$string = str_replace("\n", ' ', $string); // --- replace with space
$string = str_replace("\t", ' ', $string); // --- replace with space
//remove multiple spaces
$string = trim(preg_replace('/ {2,}/', ' ', $string));
return $string;
}
}
//includes
include_once "resources/phpmailer/class.phpmailer.php";
include_once "resources/phpmailer/class.smtp.php";
//set the GET array
if (!empty($argv[1])) {
parse_str($argv[1], $_GET);
}
//get the primary key
$email_queue_uuid = $_GET['email_queue_uuid'];
$hostname = $_GET['hostname'];
//get the email details to send
$sql = "select * from v_email_queue ";
$sql .= "where email_queue_uuid = :email_queue_uuid ";
$parameters['email_queue_uuid'] = $email_queue_uuid;
$database = new database;
$row = $database->select($sql, $parameters, 'row');
if (is_array($row)) {
$domain_uuid = $row["domain_uuid"];
$email_date = $row["email_date"];
$email_from = $row["email_from"];
$email_to = $row["email_to"];
$email_subject = $row["email_subject"];
$email_body = $row["email_body"];
$email_status = $row["email_status"];
$email_retry_count = $row["email_retry_count"];
$email_uuid = $row["email_uuid"];
//$email_action_before = $row["email_action_before"];
$email_action_after = $row["email_action_after"];
}
unset($parameters);
//get the call center settings
$retry_limit = $_SESSION['email_queue']['retry_limit']['numeric'];
//$retry_interval = $_SESSION['email_queue']['retry_interval']['numeric'];
//set defaults
if (strlen($email_retry_count) == 0) {
$email_retry_count = 0;
}
//create the email object
/*
$mail = new PHPMailer();
if (isset($_SESSION['email']['method'])) {
switch ($_SESSION['email']['method']['text']) {
case 'sendmail': $mail->IsSendmail(); break;
case 'qmail': $mail->IsQmail(); break;
case 'mail': $mail->IsMail(); break;
default: $mail->IsSMTP(); break;
}
}
else {
$mail->IsSMTP();
}
*/
//load default smtp settings
/*
if ($_SESSION['email']['smtp_hostname']['text'] != '') {
$smtp['hostname'] = $_SESSION['email']['smtp_hostname']['text'];
}
$smtp['host'] = (strlen($_SESSION['email']['smtp_host']['text']) ? $_SESSION['email']['smtp_host']['text']: '127.0.0.1');
if (isset($_SESSION['email']['smtp_port'])) {
$smtp['port'] = (int) $_SESSION['email']['smtp_port']['numeric'];
}
else {
$smtp['port'] = 0;
}
$smtp['secure'] = $_SESSION['email']['smtp_secure']['text'];
$smtp['auth'] = $_SESSION['email']['smtp_auth']['text'];
$smtp['username'] = $_SESSION['email']['smtp_username']['text'];
$smtp['password'] = $_SESSION['email']['smtp_password']['text'];
$smtp['from'] = $_SESSION['email']['smtp_from']['text'];
$smtp['from_name'] = $_SESSION['email']['smtp_from_name']['text'];
if (isset($_SESSION['voicemail']['smtp_from']) && strlen($_SESSION['voicemail']['smtp_from']['text']) > 0) {
$smtp['from'] = $_SESSION['voicemail']['smtp_from']['text'];
}
if (isset($_SESSION['voicemail']['smtp_from_name']) && strlen($_SESSION['voicemail']['smtp_from_name']['text']) > 0) {
$smtp['from_name'] = $_SESSION['voicemail']['smtp_from_name']['text'];
}
*/
//overwrite with domain-specific smtp server settings, if any
$sql = "select domain_setting_subcategory, domain_setting_value ";
$sql .= "from v_domain_settings ";
$sql .= "where domain_uuid = :domain_uuid ";
$sql .= "and (domain_setting_category = 'email' or domain_setting_category = 'voicemail') ";
$sql .= "and domain_setting_enabled = 'true' ";
$parameters['domain_uuid'] = $domain_uuid;
$database = new database;
$result = $database->select($sql, $parameters, 'all');
if (is_array($result) && @sizeof($result) != 0) {
foreach ($result as $row) {
if ($row['domain_setting_value'] != '') {
$smtp[str_replace('smtp_','',$row["domain_setting_subcategory"])] = $row['domain_setting_value'];
}
}
}
unset($sql, $parameters, $result, $row);
//value adjustments
$smtp['auth'] = ($smtp['auth'] == "true") ? true : false;
$smtp['password'] = ($smtp['password'] != '') ? $smtp['password'] : null;
$smtp['secure'] = ($smtp['secure'] != "none") ? $smtp['secure'] : null;
$smtp['username'] = ($smtp['username'] != '') ? $smtp['username'] : null;
//option to disable smtp ssl or tls validation
/*
if (isset($_SESSION['email']['smtp_validate_certificate'])) {
if ($_SESSION['email']['smtp_validate_certificate']['boolean'] == "false") {
$mail->SMTPOptions = array(
'ssl' => array(
'verify_peer' => false,
'verify_peer_name' => false,
'allow_self_signed' => true
)
);
}
}
*/
//add smtp authentication
/*
$mail->SMTPAuth = $smtp['auth'];
if (isset($smtp['hostname'])) {
$mail->Hostname = $smtp['hostname'];
}
$mail->Host = $smtp['host'];
if ($smtp['port'] != 0) {
$mail->Port = $smtp['port'];
}
if ($smtp['secure'] != '') {
$mail->SMTPSecure = $smtp['secure'];
}
if ($smtp['auth']) {
$mail->Username = $smtp['username'];
$mail->Password = $smtp['password'];
}
$mail->SMTPDebug = 4;
*/
//get the voicemail details
$sql = "select * from v_voicemails ";
$sql .= "where voicemail_uuid in ( ";
$sql .= " select voicemail_uuid from v_voicemail_messages ";
$sql .= " where voicemail_message_uuid = :voicemail_message_uuid ";
$sql .= ") ";
$parameters['voicemail_message_uuid'] = $email_uuid;
$database = new database;
$row = $database->select($sql, $parameters, 'row');
if (is_array($row)) {
//$domain_uuid = $row["domain_uuid"];
//$voicemail_uuid = $row["voicemail_uuid"];
$voicemail_id = $row["voicemail_id"];
//$voicemail_password = $row["voicemail_password"];
//$greeting_id = $row["greeting_id"];
//$voicemail_alternate_greet_id = $row["voicemail_alternate_greet_id"];
//$voicemail_mail_to = $row["voicemail_mail_to"];
//$voicemail_sms_to = $row["voicemail_sms_to "];
$voicemail_transcription_enabled = $row["voicemail_transcription_enabled"];
//$voicemail_attach_file = $row["voicemail_attach_file"];
//$voicemail_file = $row["voicemail_file"];
//$voicemail_local_after_email = $row["voicemail_local_after_email"];
//$voicemail_enabled = $row["voicemail_enabled"];
//$voicemail_description = $row["voicemail_description"];
//$voicemail_name_base64 = $row["voicemail_name_base64"];
//$voicemail_tutorial = $row["voicemail_tutorial"];
echo "transcribe enabled: ".$voicemail_transcription_enabled."\n";
}
unset($parameters);
//get the attachments and add to the email
$sql = "select * from v_email_queue_attachments ";
$sql .= "where email_queue_uuid = :email_queue_uuid ";
$parameters['email_queue_uuid'] = $email_queue_uuid;
$database = new database;
$email_queue_attachments = $database->select($sql, $parameters, 'all');
if (is_array($email_queue_attachments) && @sizeof($email_queue_attachments) != 0) {
foreach($email_queue_attachments as $field) {
$email_queue_attachment_uuid = $field['email_queue_attachment_uuid'];
$domain_uuid = $field['domain_uuid'];
$email_attachment_type = $field['email_attachment_type'];
$email_attachment_path = $field['email_attachment_path'];
$email_attachment_name = $field['email_attachment_name'];
//$email_attachment_base64= $field['email_attachment_base64'];
switch ($email_attachment_type) {
case "wav":
$mime_type = "audio/x-wav";
break;
case "mp3":
$mime_type = "audio/x-mp3";
break;
case "pdf":
$mime_type = "application/pdf";
break;
case "tif":
$mime_type = "image/tiff";
break;
case "tiff":
$mime_type = "image/tiff";
break;
default:
$mime_type = "binary/octet-stream";
break;
}
if (isset($voicemail_transcription_enabled) && $voicemail_transcription_enabled == 'true') {
//transcribe the attachment
if ($email_attachment_type == 'wav' || $email_attachment_type == 'mp3') {
$field = transcribe($email_attachment_path, $email_attachment_name, $email_attachment_type);
echo "transcribe path: ".$email_attachment_path."\n";
echo "transcribe name: ".$email_attachment_name."\n";
echo "transcribe type: ".$email_attachment_type."\n";
echo "transcribe command: ".$field['command']."\n";
echo "transcribe message: ".$field['message']."\n";
$transcribe_message = $field['message'];
}
//echo "email_body before: ".$email_body."\n";
$email_body = str_replace('${message_text}', $transcribe_message, $email_body);
//$email_debug = $field['message'];
//echo "email_body after: ".$email_body."\n";
//unset($field);
}
else {
$email_body = str_replace('${message_text}', '', $email_body);
}
//base64 encode the file
//$file_contents = base64_encode(file_get_contents($email_attachment_path.'/'.$email_attachment_name));
//add an attachment
//public addAttachment ( string $path, string $name = '', string $encoding = 'base64', string $type = '', string $disposition = 'attachment' ) : boolean
//$mail->AddAttachment($email_attachment_path.'/'.$email_attachment_name, $email_attachment_name, 'base64', 'attachment');
//add email attachments as a string for the send_email function
//$email_attachments[0]['type'] = 'string';
//$email_attachments[0]['name'] = $email_attachment_path.'/'.$email_attachment_name;
//$email_attachments[0]['value'] = base64_encode(file_get_contents($email_attachment_path.'/'.$email_attachment_name));
//add email attachment as a file for the send_email function
$email_attachments[0]['type'] = 'file';
$email_attachments[0]['name'] = $email_attachment_name;
$email_attachments[0]['value'] = $email_attachment_path.'/'.$email_attachment_name;
}
}
unset($parameters);
//send context to the temp log
echo "Subject: ".$email_subject."\n";
echo "From: ".$email_from."\n";
echo "Reply-to: ".$email_from."\n";
echo "To: ".$email_to."\n";
echo "Date: ".$email_date."\n";
//echo "Transcript: ".$array['message']."\n";
//echo "Body: ".$email_body."\n";
//update the message transcription
if (isset($voicemail_transcription_enabled) && $voicemail_transcription_enabled == 'true' && isset($transcribe_message)) {
$sql = "update v_voicemail_messages ";
$sql .= "set message_transcription = :message_transcription ";
$sql .= "where voicemail_message_uuid = :voicemail_message_uuid; ";
$parameters['voicemail_message_uuid'] = $email_uuid;
$parameters['message_transcription'] = $transcribe_message;
//echo $sql."\n";
//print_r($parameters);
$database = new database;
$database->execute($sql, $parameters);
unset($parameters);
}
//send email
//ob_start();
//$sent = !send_email($email_to, $email_subject, $email_body, $email_error, null, null, null, null, $email_attachments) ? false : true;
//$response = ob_get_clean();
//echo $response;
//send the email
$email = new email;
$email->from_address = $email_from_address;
$email->from_name = $email_from_name;
$email->recipients = $email_to;
$email->subject = $email_subject;
$email->body = $email_body;
$email->attachments = $email_attachments;
$email->method = 'direct';
$sent = $email->send();
//$response = $email->email_error;
//add to, from, fromname, custom headers and subject to the email
/*
$mail->From = $smtp['from'] ;
$mail->FromName = $smtp['from_name'];
$mail->Subject = $email_subject;
$email_to = trim($email_to, "<> ");
$email_to = str_replace(";", ",", $email_to);
$email_to_array = explode(",", $email_to);
if (count($email_to_array) == 0) {
$mail->AddAddress($email_to);
}
else {
foreach ($email_to_array as $email_address) {
if (strlen($email_address) > 0) {
echo "Add Address: $email_address\n";
$mail->AddAddress(trim($email_address));
}
}
}
*/
//add the body to the email
/*
$body_plain = remove_tags($email_body);
//echo "body_plain = $body_plain\n";
if ((substr($email_body, 0, 5) == "<html") || (substr($email_body, 0, 9) == "<!doctype")) {
//$mail->ContentType = "text/html; charset=utf-8";
$mail->Body = $email_body."<br><br>";
$mail->AltBody = $body_plain."\n";
$mail->isHTML(true);
}
else {
//$mail->Body = ($body != '') ? $body : $body_plain;
$mail->Body = $body_plain."\n";
$mail->AltBody = $body_plain."\n";
$mail->isHTML(false);
}
$mail->CharSet = "utf-8";
*/
//send the email
if ($sent) {
//if ($mail->Send()) {
/*
$sql = "delete from v_email_queue_attachments ";
$sql .= "where email_queue_uuid = :email_queue_uuid; ";
$parameters['email_queue_uuid'] = $email_queue_uuid;
$database = new database;
$database->select($sql, $parameters);
$sql = "delete from v_email_queue ";
$sql .= "where email_queue_uuid = :email_queue_uuid; ";
$parameters['email_queue_uuid'] = $email_queue_uuid;
$database = new database;
$database->select($sql, $parameters);
*/
/*
//build insert array
$email_log_uuid = uuid();
$array['email_queue'][0]['email_queue_uuid'] = $email_queue_uuid;
$array['email_queue'][0]['email_status'] = 'sent';
if (isset($field['message'])) {
$array['email_queue'][0]['email_transcription'] = $field['message'];
}
//grant temporary permissions
$p = new permissions;
$p->add('email_queue_add', 'temp');
//execute insert
$database = new database;
$database->app_name = 'email_queue';
$database->app_uuid = 'ba41954e-9d21-4b10-bbc2-fa5ceabeb184';
$database->save($array);
unset($array);
//revoke temporary permissions
$p->delete('email_queue_add', 'temp');
*/
//set the email status to sent
$sql = "update v_email_queue ";
$sql .= "set email_status = 'sent' ";
//$sql .= "set email_status = 'waiting' "; //debug
if (isset($transcribe_message)) {
$sql .= ", email_transcription = :email_transcription ";
}
$sql .= "where email_queue_uuid = :email_queue_uuid; ";
$parameters['email_queue_uuid'] = $email_queue_uuid;
if (isset($transcribe_message)) {
$parameters['email_transcription'] = $transcribe_message;
}
//echo $sql."\n";
//print_r($parameters);
$database = new database;
$database->execute($sql, $parameters);
unset($parameters);
//delete the email after it is sent
if ($email_action_after == 'delete') {
//remove the email file after it has been sent
if (is_array($email_queue_attachments) && @sizeof($email_queue_attachments) != 0) {
foreach($email_queue_attachments as $field) {
$email_attachment_path = $field['email_attachment_path'];
$email_attachment_name = $field['email_attachment_name'];
if (file_exists($email_attachment_path.'/'.$email_attachment_name)) {
unlink($email_attachment_path.'/'.$email_attachment_name);
}
}
}
//delete the voicemail message from the database
$sql = "delete from v_voicemail_messages ";
$sql .= "where voicemail_message_uuid = :voicemail_message_uuid; ";
$parameters['voicemail_message_uuid'] = $email_uuid;
//echo $sql."\n";
//print_r($parameters);
$database = new database;
$database->execute($sql, $parameters);
unset($parameters);
//get the domain_name
$sql = "select domain_name from v_domains ";
$sql .= "where domain_uuid = :domain_uuid ";
$parameters['domain_uuid'] = $domain_uuid;
$database = new database;
$domain_name = $database->select($sql, $parameters, 'column');
//send the message waiting status
$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']);
if ($fp) {
//$switch_cmd .= "luarun app.lua voicemail mwi ".$voicemail_id."@".$domain_name;
$switch_cmd .= "luarun app/voicemail/resources/scripts/mwi_notify.lua ".$voicemail_id." ".$domain_name." 0 0";
$switch_result = event_socket_request($fp, 'api '.$switch_cmd);
echo $switch_cmd."\n";
}
else {
echo "event socket connection failed\n";
}
}
/*
//build insert array
$array['email_queue'][0]['email_queue_uuid'] = $email_queue_uuid;
//$array['email_queue'][0]['sent_date'] = 'now()';
$array['email_queue'][0]['email_status'] = 'sent';
//grant temporary permissions
$p = new permissions;
$p->add('email_queue_add', 'temp');
$p->add('email_queue_update', 'temp');
//execute insert
$database = new database;
$database->app_name = 'email_queue';
$database->app_uuid = '5befdf60-a242-445f-91b3-2e9ee3e0ddf7';
print_r($array);
$message = $database->save($array);
print_r($message);
unset($array);
//revoke temporary permissions
$p->delete('email_queue_add', 'temp');
$p->delete('email_queue_update', 'temp');
*/
//send a message to the console
echo "Message sent!\n";
}
else {
$mailer_error = $mail->ErrorInfo;
echo "Mailer Error: ".$mailer_error."\n\n";
/*
//build insert array
$email_log_uuid = uuid();
$array['email_queue'][0]['email_queue_uuid'] = $email_queue_uuid;
$array['email_queue'][0]['email_status'] = 'failed';
//grant temporary permissions
$p = new permissions;
$p->add('email_queue_add', 'temp');
//execute insert
$database = new database;
$database->app_name = 'email_queue';
$database->app_uuid = 'ba41954e-9d21-4b10-bbc2-fa5ceabeb184';
$database->save($array);
unset($array);
//revoke temporary permissions
$p->delete('email_queue_add', 'temp');
*/
//set the email retry count
$email_retry_count++;
//set the email status to failed
$sql = "update v_email_queue ";
if ($email_retry_count >= $retry_limit) {
$sql .= "set email_status = 'failed', ";
}
else {
$sql .= "set email_status = 'trying', ";
}
$sql .= "email_retry_count = :email_retry_count ";
//$sql .= ", email_debug = :email_debug ";
$sql .= "where email_queue_uuid = :email_queue_uuid; ";
$parameters['email_queue_uuid'] = $email_queue_uuid;
//$parameters['email_debug'] = $mailer_error;
$parameters['email_retry_count'] = $email_retry_count;
//echo $sql."\n";
//print_r($parameters);
$database = new database;
$database->execute($sql, $parameters);
unset($parameters);
/*
$call_uuid = $headers["X-FusionPBX-Call-UUID"];
if ($resend == true) {
echo "Retained in v_email_logs \n";
}
else {
// log/store message in database for review
if (!isset($email_log_uuid)) {
//build insert array
$email_log_uuid = uuid();
$array['email_logs'][0]['email_log_uuid'] = $email_log_uuid;
if (is_uuid($call_uuid)) {
$array['email_logs'][0]['call_uuid'] = $call_uuid;
}
$array['email_logs'][0]['domain_uuid'] = $headers["X-FusionPBX-Domain-UUID"];
$array['email_logs'][0]['sent_date'] = 'now()';
$array['email_logs'][0]['type'] = $headers["X-FusionPBX-Email-Type"];
$array['email_logs'][0]['status'] = 'failed';
$array['email_logs'][0]['email'] = str_replace("'", "''", $msg);
//grant temporary permissions
$p = new permissions;
$p->add('email_log_add', 'temp');
//execute insert
$database = new database;
$database->app_name = 'v_mailto';
$database->app_uuid = 'ba41954e-9d21-4b10-bbc2-fa5ceabeb184';
$database->save($array);
unset($array);
//revoke temporary permissions
$p->delete('email_log_add', 'temp');
}
echo "Retained in v_email_logs as email_log_uuid = ".$email_log_uuid."\n";
}
*/
}
//unset the php mail object
unset($mail);
//save output to
//$fp = fopen(sys_get_temp_dir()."/mailer-app.log", "a");
//prepare the output buffers
//ob_end_clean();
//ob_start();
//message divider for log file
//echo "\n\n====================================================\n\n";
//get and save the output from the buffer
//$content = ob_get_contents(); //get the output from the buffer
//$content = str_replace("<br />", "", $content);
//ob_end_clean(); //clean the buffer
//fwrite($fp, $content);
//fclose($fp);
?>

30
app/email_queue/resources/service/debian.service Normal file
View File

@@ -0,0 +1,30 @@
; Author: Mark J Crane <markjcrane@fusionpbx.com>
; cp /var/www/fusionpbx/app/email_queue/resources/service/debian.service /etc/systemd/system/email_queue.service
; systemctl enable email_queue
; systemctl start email_queue
; systemctl daemon-reload
[Unit]
Description=FusionPBX Email Queue
Wants=network-online.target
Requires=network.target local-fs.target postgresql.service
After=network.target network-online.target local-fs.target postgresql.service
StartLimitIntervalSec=0
[Service]
Type=simple
;Type=forking
PIDFile=/var/run/fusionpbx/email_queue.pid
WorkingDirectory=/var/www/fusionpbx
;Environment="USER=www-data"
;Environment="GROUP=www-data"
;EnvironmentFile=-/etc/default/fusionpbx
ExecStartPre=/bin/mkdir -p /var/run/fusionpbx
;ExecStartPre=/bin/chown -R ${USER}:${GROUP} /var/www/fusionpbx
ExecStart=/usr/bin/php /var/www/fusionpbx/app/email_queue/resources/service/email_queue.php
TimeoutSec=55s
Restart=always
[Install]
WantedBy=multi-user.target
Also=

204
app/email_queue/resources/service/email_queue.php Normal file
View File

@@ -0,0 +1,204 @@
<?php
//check the permission
if (defined('STDIN')) {
$document_root = str_replace("\\", "/", $_SERVER["PHP_SELF"]);
preg_match("/^(.*)\/app\/.*$/", $document_root, $matches);
$document_root = $matches[1];
set_include_path($document_root);
$_SERVER["DOCUMENT_ROOT"] = $document_root;
require_once "resources/require.php";
}
else {
exit;
include "root.php";
require_once "resources/require.php";
require_once "resources/pdo.php";
}
//increase limits
set_time_limit(0);
ini_set('max_execution_time', 0);
ini_set('memory_limit', '512M');
//save the arguments to variables
$script_name = $argv[0];
if (!empty($argv[1])) {
parse_str($argv[1], $_GET);
}
//print_r($_GET);
//set the variables
if (isset($_GET['hostname'])) {
$hostname = urldecode($_GET['hostname']);
}
if (isset($_GET['debug'])) {
$debug = $_GET['debug'];
}
//includes
if (!defined('STDIN')) { include_once "root.php"; }
require_once "resources/require.php";
include "resources/classes/permissions.php";
require $document_root."/app/email_queue/resources/functions/transcribe.php";
//define the process id file
$pid_file = "/var/run/fusionpbx/".basename( $argv[0], ".php") .".pid";
//echo "pid_file: ".$pid_file."\n";
//function to check if the process exists
function process_exists($file = false) {
//set the default exists to false
$exists = false;
//check to see if the process is running
if (file_exists($file)) {
$pid = file_get_contents($file);
if (posix_getsid($pid) === false) {
//process is not running
$exists = false;
}
else {
//process is running
$exists = true;
}
}
//return the result
return $exists;
}
//check to see if the process exists
$pid_exists = process_exists($pid_file);
//prevent the process running more than once
if ($pid_exists) {
echo "Cannot lock pid file {$pid_file}\n";
exit;
}
//email queue enabled
if ($_SESSION['email_queue']['enabled']['boolean'] != 'true') {
echo "Email Queue is disabled in Default Settings\n";
exit;
}
//make sure the /var/run/fusionpbx directory exists
if (!file_exists('/var/run/fusionpbx')) {
$result = mkdir('/var/run/fusionpbx', 0777, true);
if (!$result) {
die('Failed to create /var/run/fusionpbx');
}
}
//create the process id file if the process doesn't exist
if (!$pid_exists) {
//remove the old pid file
if (file_exists($file)) {
unlink($pid_file);
}
//show the details to the user
//echo "The process id is ".getmypid()."\n";
//echo "pid_file: ".$pid_file."\n";
//save the pid file
file_put_contents($pid_file, getmypid());
}
//get the call center settings
$interval = $_SESSION['email_queue']['interval']['numeric'];
//set the defaults
if (!is_numeric($interval)) { $interval = 30; }
//set the email queue limit
if (isset($_SESSION['email_queue']['limit']['numeric'])) {
$email_queue_limit = $_SESSION['email_queue']['limit']['numeric'];
}
else {
$email_queue_limit = '30';
}
if (isset($_SESSION['email_queue']['debug']['boolean'])) {
$debug = $_SESSION['email_queue']['debug']['boolean'];
}
//get the messages waiting in the email queue
while (true) {
//get the messages that are waiting to send
$sql = "select * from v_email_queue ";
$sql .= "where (email_status = 'waiting' or email_status = 'trying') ";
$sql .= "and hostname = :hostname ";
$sql .= "order by domain_uuid asc ";
$sql .= "limit :limit ";
if (isset($hostname)) {
$parameters['hostname'] = $hostname;
}
else {
$parameters['hostname'] = gethostname();
}
$parameters['limit'] = $email_queue_limit;
$database = new database;
$email_queue = $database->select($sql, $parameters, 'all');
unset($parameters);
//process the messages
if (is_array($email_queue) && @sizeof($email_queue) != 0) {
foreach($email_queue as $row) {
$command = "/usr/bin/php /var/www/fusionpbx/app/email_queue/resources/jobs/email_send.php ";
$command .= "'action=send&email_queue_uuid=".$row["email_queue_uuid"]."&hostname=".$hostname."'";
if (isset($debug)) {
//run process inline to see debug info
echo $command."\n";
$result = system($command);
echo $result."\n";
}
else {
//starts process rapidly doesn't wait for previous process to finish (used for production)
$handle = popen($command." > /dev/null &", 'r');
echo "'$handle'; " . gettype($handle) . "\n";
$read = fread($handle, 2096);
echo $read;
pclose($handle);
}
}
}
//pause to prevent excessive database queries
sleep($interval);
}
//remove the old pid file
if (file_exists($file)) {
unlink($pid_file);
}
//save output to
//$fp = fopen(sys_get_temp_dir()."/mailer-app.log", "a");
//prepare the output buffers
//ob_end_clean();
//ob_start();
//message divider for log file
//echo "\n\n=============================================================================================================================================\n\n";
//get and save the output from the buffer
//$content = ob_get_contents(); //get the output from the buffer
//$content = str_replace("<br />", "", $content);
//ob_end_clean(); //clean the buffer
//fwrite($fp, $content);
//fclose($fp);
//notes
//echo __line__."\n";
// if not keeping the email then need to delete it after the voicemail is emailed
//how to use this feature
// cd /var/www/fusionpbx; /usr/bin/php /var/www/fusionpbx/app/email_queue/resources/send.php
?>