admin/cacti
1
0 Fork 0
mirror of https://github.com/Cacti/cacti.git synced 2026-11-09 05:26:50 +09:00
Code Issues Packages Projects Releases Wiki Activity
Files
df8161c4a9599a1bdc993d220ef01ac99aea5ef2
cacti/lib/mailer.php
T

962 lines
28 KiB
PHP
Raw Blame History

<?php
/*
+-------------------------------------------------------------------------+
| Copyright (C) 2004-2016 The Cacti Group |
| |
| This program is free software; you can redistribute it and/or |
| modify it under the terms of the GNU General Public License |
| as published by the Free Software Foundation; either version 2 |
| of the License, or (at your option) any later version. |
| |
| This program is distributed in the hope that it will be useful, |
| but WITHOUT ANY WARRANTY; without even the implied warranty of |
| MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| GNU General Public License for more details. |
+-------------------------------------------------------------------------+
| Cacti: The Complete RRDTool-based Graphing Solution |
+-------------------------------------------------------------------------+
| This code is designed, written, and maintained by the Cacti Group. See |
| about.php and/or the AUTHORS file for specific developer information. |
+-------------------------------------------------------------------------+
| http://www.cacti.net/ |
+-------------------------------------------------------------------------+
*/
/* Mailer class for MIME email functionality */
class Mailer {
var $Config = array();
var $Message = array();
var $Error = '';
/*
* Create mailer object
*
* Create the mailer object
*
* @param config - Array of config value pairs. config=>value
* @param headers - Array of header value pairs. header=>value
* @return true
*/
function Mailer($config = array(), $headers = array()) {
/* Create configuration array */
$this->Config['User'] = 'unknown';
$this->Config['Hostname'] = 'localhost';
$this->Config['AttachMaxSize'] = 10240000;
$this->Config['MaxSize'] = 10240000;
$this->Config['HeaderOrder'] = array('From','To','Cc','Bcc','Reply-To','Date','X-Mailer','User-Agent','Subject','Content-Type');
$this->Config['HeaderMulti'] = array('To','Cc','Bcc');
$this->Config['HeaderRequire'] = array('To','From','Subject','Content-Type','Date');
$this->Config['Mail']['Type'] = 'PHP'; /* PHP or SMTP or DirectInject */
$this->Config['Mail']['SMTP_Host'] = 'localhost';
$this->Config['Mail']['SMTP_Port'] = '25';
$this->Config['Mail']['SMTP_Username'] = '';
$this->Config['Mail']['SMTP_Password'] = '';
$this->Config['Mail']['DirectInject_Path'] = ''; /* Message envelope will be contructed and passed to this executable via stdin */
$this->Config['Mail']['WordWrap'] = '76';
$this->Config['Mail']['CharSet'] = 'UTF-8';
/* Process mailer configuration parameters */
if (sizeof($config) > 0) {
foreach ($config as $key => $value) {
if (($key == 'Type') && (($value == 'SMTP') || ($value == 'PHP') || ($value == 'DirectInject'))) {
$this->Config['Mail']['Type'] = $value;
}
if ($key == 'SMTP_Host') {
$this->Config['Mail']['SMTP_Host'] = $value;
}
if ($key == 'SMTP_Port') {
$this->Config['Mail']['SMTP_Port'] = $value;
}
if ($key == 'SMTP_Username') {
$this->Config['Mail']['SMTP_Username'] = $value;
}
if ($key == 'SMTP_Password') {
$this->Config['Mail']['SMTP_Password'] = $value;
}
if ($key == 'DirectInject_Path') {
$this->Config['Mail']['DirectInject_Path'] = $value;
}
if ($key == 'WordWrap') {
$this->Config['Mail']['WordWrap'] = $value;
}
if ($key == 'CharSet') {
$this->Config['Mail']['CharSet'] = $value;
}
}
}
/* Find hostname */
if (isset($_SERVER['SERVER_NAME'])) {
$this->Config['Hostname'] = $_SERVER['SERVER_NAME'];
} else {
if (isset($_ENV['HOSTNAME'])) {
$this->Config['Hostname'] = $_ENV['HOSTNAME'];
}
}
/* Find Username */
if (isset($_ENV['USER'])) {
$this->Config['User'] = $_ENV['USER'];
}
/* Setup global headers */
$this->Message['headers'] = array();
$this->Message['headers']['X-Mailer'] = 'Cacti-Mailer-Class';
$this->Message['headers']['User-Agent'] = 'Cacti-Mailer-Class';
$this->Message['headers']['Content-Type'] = 'text/plain';
$this->Message['headers']['MIME-Version'] = '1.0';
$this->Message['headers']['From'] = $this->Config['User'] . '@' . $this->Config['Hostname'];
/* Add headers */
foreach ($headers as $header => $value) {
$this->header_set($header,$value, true);
}
return true;
}
/*
* Close mailer object
*
* Closed the mailer object
*
* @return true
*/
function close() {
$this->Config = array();
$this->Message = array();
$this->Error = '';
return true;
}
/*
* Send email
*
* Contructed and send the email
*
* @param message - string value of message body or array of text=>'', html=>''
* @param headers - array of header values, Subject required to be set
* @return true = success, false = error use error to get error string
*/
function send($body, $headers = array()) {
$body_text = '';
$body_html = '';
/* Check input */
if (! isset($body)) {
$this->Error = 'No message body argument defined';
return false;
}
if (is_array($body)) {
if (isset($body['text'])) {
$body_text = wordwrap($body['text'], $this->Config['Mail']['WordWrap']);
} else {
$this->Error = 'No text part of body defined';
return false;
}
if (isset($body['html'])) {
$body_html = wordwrap($body['html'], $this->Config['Mail']['WordWrap']);
} else {
$this->Error = 'No html part of body defined';
return false;
}
} else {
$body_text = wordwrap($body, $this->Config['Mail']['WordWrap']);
}
if (empty($body)) {
$this->Error = 'Empty body not allowed';
return false;
}
/* Set headers - Replace globals */
if (isset($headers)) {
if (is_array($headers)) {
foreach ($headers as $key => $value) {
$this->header_set($key, $value, true);
}
} else {
$this->Error = 'Headers must be defined in an array';
return false;
}
}
/* Add date header */
$this->header_set('Date', $this->_get_email_date(), true);
/* Check that we have minimal headers */
foreach ($this->Config['HeaderRequire'] as $value) {
if (! isset($this->Message['headers'][$value])) {
$this->Error = "Required header \'" . $value . "\' is not defined";
return false;
}
}
/* Determine attachment types */
$attachment_inline = 0;
$attachment_attach = 0;
if (isset($this->Message['attachments'])) {
foreach ($this->Message['attachments'] as $value) {
if ($value['contentdisposition'] == 'attachment') {
$attachment_attach++;
}
if ($value['contentdisposition'] == 'inline') {
$attachment_inline++;
}
}
}
/* Determine message content-type */
$content_type = $this->Message['headers']['Content-Type'];
if (empty($body_html)) {
if ($attachment_attach > 0) {
$this->_boundary_set();
$content_type = "multipart/mixed; type=\"text/plain\";\n\tboundary=\"" . $this->Message['boundary'] . "\"";
}
} else {
$this->_boundary_set();
$content_type = "multipart/alternative; type=\"text/html\";\n\tboundary=\"" . $this->Message['boundary'] . "\"";
if ($attachment_attach > 0) {
$content_type = "multipart/mixed; type=\"text/html\";\n\tboundary=\"" . $this->Message['boundary'] . "\"";
}
}
/* Contruct message body */
$this->header_set('Content-Type', $content_type, true);
if ($content_type == 'text/plain') {
$this->Message['body'] = $body_text;
} else {
/* Open MIME */
$this->Message['body'] = "This is a multi-part message in MIME format\n\n";
$this->Message['body'] .= '--' . $this->Message['boundary'] . "\n";
/* Open MIME ALT */
if (($attachment_attach > 0) && (! empty($body_html))) {
$this->Message['body'] .= "Content-Type: multipart/alternative;\n\tboundary=\"" . $this->Message['boundary'] . "_ALT\"\n\n";
$this->Message['body'] .= '--' . $this->Message['boundary'] . "_ALT\n";
}
/* Message part - text/plain */
$this->Message['body'] .= 'Content-Type: text/plain;';
$this->Message['body'] .= " charset=\"" . $this->Config['Mail']['CharSet'] . "\"\n";
$this->Message['body'] .= "Content-Transfer-Encoding: 8-bit\n";
$this->Message['body'] .= "\n" . $body_text . "\n\n";
/* Open MIME HTML */
if ((! empty($body_html)) && ($attachment_attach > 0)) {
$this->Message['body'] .= '--' . $this->Message['boundary'] . "_ALT\n";
} else {
if ($attachment_attach == 0) {
$this->Message['body'] .= '--' . $this->Message['boundary'] . "\n";
}
}
if ($attachment_inline > 0) {
$this->Message['body'] .= "Content-Type: multipart/related;\n\tboundary=\"" . $this->Message['boundary'] . "_HTML\"\n\n";
$this->Message['body'] .= '--' . $this->Message['boundary'] . "_HTML\n";
}
if (! empty($body_html)) {
/* Message part - text/html */
$this->Message['body'] .= 'Content-Type: text/html;';
$this->Message['body'] .= " charset=\"" . $this->Config['Mail']['CharSet'] . "\"\n";
$this->Message['body'] .= "Content-Transfer-Encoding: 8-bit\n";
$this->Message['body'] .= "\n" . $body_html . "\n\n";
}
/* Attach inline */
if ($attachment_inline > 0) {
foreach ($this->Message['attachments'] as $attachment) {
if ($attachment['contentdisposition'] == 'inline') {
$this->Message['body'] .= '--' . $this->Message['boundary'] . "_HTML\n";
$this->Message['body'] .= 'Content-Type: ' . $attachment['contenttype'] . "; name=\"" . $attachment['filename'] . "\"\n";
$this->Message['body'] .= 'Content-Transfer-Encoding: ' . $attachment['encoding'] . "\n";
$this->Message['body'] .= 'Content-Disposition: ' . $attachment['contentdisposition'] . "; filename=\"" . $attachment['filename'] . "\"\n";
if (isset($attachment['contentid'])) {
$this->Message['body'] .= 'Content-Id: <' . $attachment['contentid'] . ">\n";
}
$this->Message['body'] .= "\n" . $attachment['encoded_data'] . "\n";
}
}
/* Close MIME HTML */
$this->Message['body'] .= '--' . $this->Message['boundary'] . "_HTML--\n\n";
}
/* Close MIME ALT */
if (($attachment_attach > 0) && (! empty($body_html))) {
$this->Message['body'] .= '--' . $this->Message['boundary'] . "_ALT--\n\n";
}
/* Attach files */
if ($attachment_attach > 0) {
foreach ($this->Message['attachments'] as $attachment) {
if ($attachment['contentdisposition'] != 'inline') {
$this->Message['body'] .= '--' . $this->Message['boundary'] . "\n";
$this->Message['body'] .= 'Content-Type: ' . $attachment['contenttype'] . "; name=\"" . $attachment['filename'] . "\"\n";
$this->Message['body'] .= 'Content-Transfer-Encoding: ' . $attachment['encoding'] . "\n";
$this->Message['body'] .= 'Content-Disposition: ' . $attachment['contentdisposition'] . "; filename=\"" . $attachment['filename'] . "\"\n";
if (isset($attachment['contentid'])) {
$this->Message['body'] .= 'Content-id: <' . $attachment['contentid'] . ">\n";
}
$this->Message['body'] .= "\n" . $attachment['encoded_data'] . "\n";
}
}
}
/* Close MIME */
$this->Message['body'] .= '--' . $this->Message['boundary'] . "--\n";
}
/* Send mail */
if (! $this->_send_mail()) {
return false;
}
/* Remove contructed message - save memory */
$this->Message = $this->_array_element_delete($this->Message, 'body');
return true;
}
/*
* Set or append a header
*
* Set or append to a header, only To, CC, Bcc will append values
*
* @param header - string value of header, case sensitive
* @param value - value of the header
* @param replace - force replace on a multi-value header, optional, default = false
* @return true = success, false = error use error to get error text
*/
function header_set($header, $value, $replace = false) {
if (! isset($header)) {
$this->Error = 'No header passed to set';
return false;
}
if (! isset($value)) {
$this->Error = 'No header value passed, use header_unset to remove header';
return false;
}
if ((isset($this->Message['headers'][$header])) && (in_array($header, $this->Config['HeaderMulti'])) && (! $replace)) {
if (is_array($this->Message['headers'][$header])) {
if (is_array($value)) {
foreach ($value as $item) {
if (! in_array($item, $this->Message['headers'][$header])) {
array_push($this->Message['headers'][$header], $item);
}
}
} else {
if (! in_array($value, $this->Message['headers'][$header])) {
array_push($this->Message['headers'][$header], $value);
}
}
} else {
$this->Message['headers'][$header] = array( $this->Message['headers'][$header], $value );
}
} else {
if ( (! in_array($header, $this->Config['HeaderMulti']) ) && (is_array($value) ) ) {
$this->Error = 'Array value not valid for non-multi headers';
return false;
} else {
$this->Message['headers'][$header] = $value;
}
}
return true;
}
/*
* Remove a header
*
* Removes give header from the global header array
*
* @param header - string value of header, case sensitive
* @return true = success, false = error use error to get error text
*/
function header_unset($header) {
if (isset($this->Message['headers'][$header])) {
$this->Message['headers'] = $this->_array_element_delete($this->Message['headers'], $header);
return true;
}
$this->Error = 'Header is not set';
return false;
}
/*
* Format an email address
*
* Format an email address in full name <email> format
*
* @param name - string value of name
* @param email - string value of email address
* @return string - formatted email address
*/
function email_format($name = '', $email = '') {
if (! isset($name)) {
$this->Error = 'Empty name value';
return false;
}
if (! isset($email)) {
$this->Error = 'Empty email value';
return false;
}
return $name . ' <' . $email . '>';
}
/*
* Generate an unique content id
*
* Generate an unique content id for use with inline attachments
*
* @return string - content id
*/
function content_id() {
list($usec, $sec) = explode(' ', microtime());
$usec = $usec * 10000000;
return getmypid() . '_' . $sec . '_' . $usec . '@' . $this->Config['Hostname'];
}
/*
* Attach a file to the email
*
* Attach a file to the email, either attached or inline
*
* @param data - Data to encode as attachment
* @param filename - Name of the attachment, when saving this will be the file name
* @param contenttype = MIME type of the attachment
* @param contentdisposition - attachment or inline
* @param contentid - Content id for use in inline attachments
* @return string - content id
*/
function attach($data, $filename, $contenttype = 'application/octet', $contentdisposition = 'attachment', $contentid = '') {
$struc = array();
/* Check for required PHP functions */
if (! function_exists('base64_encode')) {
$this->Error = "Required function \'base64_encode\' not available";
return false;
}
/* Check size of the data */
if (strlen($data) == 0) {
$this->Error = 'No data passed to attach, zero length data';
return false;
}
$struc['Size'] = strlen($data);
/* Encode the data */
$struc['encoded_data'] = chunk_split(base64_encode($data), 76, "\n");
$data = false; /* free up memory */
/* Check size of encoded data */
if (strlen($struc['encoded_data']) > $this->Config['AttachMaxSize']) {
$this->Error = 'Encoded attachment size exceeds maximum size';
return false;
}
$struc['SizeEncoded'] = strlen($struc['encoded_data']);
/* Set attachment properties */
$struc['filename'] = $filename;
$struc['contenttype'] = $contenttype;
$struc['contentdisposition'] = $contentdisposition;
$struc['encoding'] = 'base64';
if (! empty($contentid)) {
$struc['contentid'] = $contentid;
}
/* Check all attachment sizes */
if (isset($this->Message['attachments_size'])) {
if ($this->Message['attachments_size'] + $struc['SizeEncoded'] > $this->Config['AttachMaxSize']) {
$this->Error = 'Unable to attach file, all attachments will exceed Max Size';
return false;
}
}
/* Push attachment into message attachments array */
if (! isset($this->Message['attachments_size'])) {
$this->Message['attachments_size'] = 0;
}
$this->Message['attachments_size'] += $struc['SizeEncoded'];
$this->Message['attachments'][] = $struc;
/* Set MIME boundary */
$this->_boundary_set();
return true;
}
/*
* Clear attached files
*
* Clear all attached files
*
* @return boolean - true = success, false = error
*/
function attach_clear() {
$this->Message = $this->_array_element_delete($this->Message, 'attachments');
$this->Message = $this->_array_element_delete($this->Message, 'attachments_size');
$this->Message = $this->_array_element_delete($this->Message, 'boundary');
return true;
}
/*
* Read a files content
*
* Read a files content and return it, binary safe
*
* @parma - string - file to read
* @return - binary - file data
*/
function read_file($file) {
if (preg_match('/^\S{3,4}:\/\//', $file)) {
$this->Error = 'Only local files are allowed';
return false;
}
set_magic_quotes_runtime(0);
if (($fh = @fopen($file, 'rb')) === false) {
$this->Error = 'Unable to open file for read';
return false;
}
if (($data = fread($fh, filesize($file))) === false) {
$this->Error = 'Unable to read file';
return false;
}
fclose($fh);
set_magic_quotes_runtime(get_magic_quotes_gpc());
return $data;
}
/*
* Read Mailer error
*
* Read the error the last ran mailer function generated
*
* @return - string - Error
*/
function error() {
return $this->Error;
}
/*
* Send email
*
* Internal mailer function to send the email. This will use whatever means have been configured to send email.
*
* @return - boolean - true = success, false = error
*/
function _send_mail() {
/* Add additional headers to header_order */
$headers = '';
$header_order = $this->Config['HeaderOrder'];
foreach ($this->Message['headers'] as $key => $value) {
if (! in_array($key, $header_order)) {
$header_order[] = $key;
}
}
if ($this->Config['Mail']['Type'] == 'PHP') {
/*
* Process Mail with PHP internal function
*/
if (! function_exists('mail')) {
$this->Error = "Required function \'mail\' not available";
return false;
}
/* Check ini settings in Windows */
if (strtoupper(substr(PHP_OS, 0, 3)) === 'WIN') {
$smtp_ini = ini_get('SMTP');
if ((empty($smtp_ini)) || (strtoupper($smtp_ini) == 'LOCALHOST')) {
if (empty($this->Config['Mail']['SMTP_Host'])) {
$this->Error = 'Unable to send email with php mail function, php.ini setting SMTP is not set or SMTP Host not defined';
return false;
} else {
if (ini_set('SMTP', $this->Config['Mail']['SMTP_Host']) == false) {
$this->Error = 'Unable to set php setting SMTP';
return false;
}
if (ini_set('smtp_port', $this->Config['Mail']['SMTP_Port']) == false) {
$this->Error = 'Unable to set php setting smtp_port';
return false;
}
}
}
}
/* Setup to */
$to = $this->Message['headers']['To'];
if (is_array($to)) {
$to = implode(', ', $to);
}
/* Create additional headers */
foreach ($header_order as $key) {
if (($key != 'To') && ($key != 'Subject')) {
if (isset($this->Message['headers'][$key])) {
if (is_array($this->Message['headers'][$key])) {
$headers .= $key . ': ' . implode(', ',$this->Message['headers'][$key]) . "\n";
} else {
$headers .= $key . ': ' . $this->Message['headers'][$key] . "\n";
}
}
}
}
/* Send the email */
if (! @mail($to, $this->Message['headers']['Subject'], $this->Message['body'], $headers)) {
$this->Error = 'Unable to send email with php mail function, check your system logs';
return false;
}
} elseif ($this->Config['Mail']['Type'] == 'SMTP') {
/*
* Process Mail with SMTP
*/
if (! function_exists('fsockopen')) {
$this->Error = "Required function 'fsockopen' not available";
return false;
}
/* Create headers text */
foreach ($header_order as $key) {
if ((isset($this->Message['headers'][$key])) && ($key != 'Bcc')) {
if (is_array($this->Message['headers'][$key])) {
$headers .= $key . ': ' . str_replace("\n", "\r\n", implode(', ',$this->Message['headers'][$key])) . "\r\n";
} else {
$headers .= $key . ': ' . str_replace("\n", "\r\n", $this->Message['headers'][$key]) . "\r\n";
}
}
}
/* Setup from address */
$from = $this->Message['headers']['From'];
if (strpos($from, '<') != false) {
$from = substr($from, strpos($from, '<') + 1);
$from = substr($from, 0, strlen($from) - 1);
}
/* Setup to addresses */
if (is_array($this->Message['headers']['To'])) {
$to = $this->Message['headers']['To'];
} else {
$to = array($this->Message['headers']['To']);
}
if (isset($this->Message['headers']['Cc'])) {
if (is_array($this->Message['headers']['Cc'])) {
foreach ($this->Message['headers']['Cc'] as $item) {
array_push($to, $item);
}
} else {
array_push($to, $this->Message['headers']['Cc']);
}
}
if (isset($this->Message['headers']['Bcc'])) {
if (is_array($this->Message['headers']['Bcc'])) {
foreach ($this->Message['headers']['Bcc'] as $item) {
array_push($to, $item);
}
} else {
array_push($to, $this->Message['headers']['Bcc']);
}
}
/* Open SMTP connection */
if (($smtp_sock = @fsockopen($this->Config['Mail']['SMTP_Host'], $this->Config['Mail']['SMTP_Port'], $errno, $errstr, 1)) === false) {
$this->Error = "Unable to connect to SMTP Host '" . $this->Config['Mail']['SMTP_Host'] . "': (" . $errno . ') ' . $errstr;
return false;
}
/* Read SMTP Socket */
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '220') {
$this->Error = 'Error returned by SMTP host: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
/* Start SMTP conversation */
fputs($smtp_sock, 'HELO ' . $this->Config['Hostname'] . '\r\n');
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '250') {
$this->Error = 'Error returned by SMTP host: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
/* Perform Authenication - If username and password set */
if ((! empty($this->Config['Mail']['SMTP_Username'])) && (! empty($this->Config['Mail']['SMTP_Password']))) {
fputs($smtp_sock, "AUTH LOGIN\r\n");
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '334') {
$this->Error = 'SMTP Host does not appear to support authenication: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
fputs($smtp_sock, base64_encode($this->Config['Mail']['SMTP_Username']) . "\r\n");
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '334') {
$this->Error = 'SMTP Authenication failure: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
fputs($smtp_sock, base64_encode($this->Config['Mail']['SMTP_Password']) . "\r\n");
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '235') {
$this->Error = 'SMTP Authenication failure: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
}
/* Send mail from */
fputs($smtp_sock, 'MAIL FROM: <' . $from . ">\r\n");
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '250') {
$this->Error = 'SMTP Host rejected from address: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
/* Send rcpt to */
foreach ($to as $item) {
fputs($smtp_sock, 'RCPT TO: <' . $item . ">\r\n");
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '250') {
$this->Error = 'SMTP Host rejected to address: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
}
/* Send data to start message */
fputs($smtp_sock, "DATA\r\n");
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '354') {
$this->Error = 'SMTP host rejected data command:' . $smtp_response;
fclose($smtp_sock);
return false;
}
/* Send message headers and body */
$message = str_replace("\n", "\r\n", $this->Message['body']);
fputs($smtp_sock, $headers . "\r\n" . $message . "\r\n.\r\n");
$smtp_response = fgets($smtp_sock,4096);
if (substr($smtp_response,0,3) != '250') {
$this->Error = 'SMTP error while sending email: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
/* Send quit */
fputs($smtp_sock,"QUIT\r\n");
$smtp_response = fgets($smtp_sock, 4096);
if (substr($smtp_response,0,3) != '221') {
$this->Error = 'SMTP Host rejected quit command: ' . $smtp_response;
fclose($smtp_sock);
return false;
}
/* Close connection */
fclose($smtp_sock);
} elseif ($this->Config['Mail']['Type'] == 'DirectInject') {
/*
* Process Mail with DirectInject
*/
/* Check and Process DirectInject path */
if (empty($this->Config['Mail']['DirectInject_Path'])) {
$this->Error = 'No DirectInject_Path defined';
return false;
}
list($cmd) = explode(' ',$this->Config['Mail']['DirectInject_Path']);
if (file_exists($cmd)) {
if (is_readable($cmd)) {
if (function_exists('is_executable')) {
if (! is_executable($cmd)) {
$this->Error = 'DirectInject_Path is not executable';
return false;
}
}
} else {
$this->Error = 'DirectInject_Path is not readable';
return false;
}
} else {
$this->Error = 'DirectInject_Path does not exist';
return false;
}
/* Create headers */
foreach ($header_order as $key) {
if (isset($this->Message['headers'][$key])) {
if (is_array($this->Message['headers'][$key])) {
$headers .= $key . ': ' . implode(', ',$this->Message['headers'][$key]) . "\n";
} else {
$headers .= $key . ': ' . $this->Message['headers'][$key] . "\n";
}
}
}
/* Contruct process */
$desc_spec = array (
0 => array('pipe', 'r'),
1 => array('pipe', 'w'),
2 => array('pipe', 'w')
);
$process = proc_open($this->Config['Mail']['DirectInject_Path'], $desc_spec, $pipes, NULL, NULL);
if (! is_resource($process)) {
$this->Error = 'Unable to open DirectInject executable process: (' . $errno . ') ' . $errstr;
return false;
}
/* Write message to process on STDIN */
fwrite($pipes[0], $headers . "\n");
fwrite($pipes[0], $this->Message['body'] . "\n");
fclose($pipes[0]);
/* Read stderr and stdout from process */
$stdout = stream_get_contents($pipes[1]);
$stderr = stream_get_contents($pipes[2]);
fclose($pipes[1]);
fclose($pipes[2]);
/* Close the process */
$return_level = proc_close($process);
/* Process process results */
if ($return_level > 0) {
$this->Error = "DirectInject command output: '" . $stdout . "' error: '" . $stderr . "'";
return false;
}
} else {
$this->Error = 'Invalid Mail Type Defined';
return false;
}
return true;
}
/*
* RFC SMTP Date
*
* Returns a RFC SMTP formatted date string
*
* @param - string - input date
* @return - string - date string
*/
function _get_email_date($time = '') {
if (empty($time)) {
$time = time();
}
return date('r', $time);
}
/*
* Array Element Delete
*
* Deletes an element from an array
*
* @param - array - array to modify
* @param - string - key to delete
* @return - array
*/
function _array_element_delete($input, $search) {
$output = array();
if (isset($input)) {
if (is_array($input)) {
foreach ($input as $key => $value) {
if ($search != $key) {
$output[$key] = $value;
}
}
}
}
return $output;
}
/*
* Sets MIME message boundary
*
* Sets the MIME message boundary in the mailer object
*
* @return - true
*/
function _boundary_set() {
if (! isset($this->Message['boundary'])) {
list($usec, $sec) = explode(' ', microtime());
$usec = $usec * 10000000;
$this->Message['boundary'] = '--_MAILER_' . getmypid() . '_' . $sec . '_' . $usec;
}
return true;
}
/* end of class */
}
Reference in new issue View Git Blame Copy Permalink