* pass - Password for authentication Default: * timeout - The timeout in seconds for the call Default: 5 * to fsockopen() */ public function __construct($params = array()) { if (!defined('CRLF')) define('CRLF', "\r\n", TRUE); $this->authenticated = FALSE; $this->timeout = 5; $this->status = SMTP_STATUS_NOT_CONNECTED; $this->host = 'localhost'; $this->port = 25; $this->helo = 'localhost'; $this->auth = FALSE; $this->user = ''; $this->pass = ''; $this->errors = array(); foreach ($params as $key => $value) { $this->$key = $value; } } /** * Connect function. This will, when called * statically, create a new smtp object, * call the connect function (ie this function) * and return it. When not called statically, * it will connect to the server and send * the HELO command. */ public function connect($params = array()) { if (!isset($this->status)) { $obj = new smtp($params); if ($obj->connect()) { $obj->status = SMTP_STATUS_CONNECTED; } return $obj; } else { $this->connection = fsockopen($this->host, $this->port, $errno, $errstr, $this->timeout); if (function_exists('socket_set_timeout')) { @socket_set_timeout($this->connection, 5, 0); } $greeting = $this->get_data(); if (is_resource($this->connection)) { return $this->auth ? $this->ehlo() : $this->helo(); } else { $this->errors[] = 'Failed to connect to server: ' . $errstr; return FALSE; } } } /** * Function which handles sending the mail. * Arguments: * $params - Optional assoc array of parameters. * Can contain: * recipients - Indexed array of recipients * from - The from address. (used in MAIL FROM:), * this will be the return path * headers - Indexed array of headers, one header per array entry * body - The body of the email * It can also contain any of the parameters from the connect() * function */ public function send($params = array()) { foreach ($params as $key => $value) { $this->set($key, $value); } if ($this->is_connected()) { // Do we auth or not? Note the distinction between the auth variable and auth() function if ($this->auth and !$this->authenticated) { if (!$this->auth()) return false; } $this->mail($this->from); if (is_array($this->recipients)) { foreach ($this->recipients as $value) { $this->rcpt($value); } } else { $this->rcpt($this->recipients); } if (!$this->data()) { return false; } // Transparency $headers = str_replace(CRLF . '.', CRLF . '..', trim(implode(CRLF, $this->headers))); $body = str_replace(CRLF . '.', CRLF . '..', $this->body); $body = substr($body, 0, 1) == '.' ? '.' . $body : $body; $this->send_data($headers); $this->send_data(''); $this->send_data($body); $this->send_data('.'); $result = (substr(trim($this->get_data()), 0, 3) === '250'); //$this->rset(); return $result; } else { $this->errors[] = 'Not connected!'; return FALSE; } } /** * Function to implement HELO cmd */ private function helo() { if ( is_resource($this->connection) and $this->send_data('HELO ' . $this->helo) and substr(trim($error = $this->get_data()), 0, 3) === '250' ) { return true; } else { $this->errors[] = 'HELO command failed, output: ' . trim(substr(trim($error), 3)); return false; } } /** * Function to implement EHLO cmd */ private function ehlo() { if ( is_resource($this->connection) and $this->send_data('EHLO ' . $this->helo) and substr(trim($error = $this->get_data()), 0, 3) === '250' ) { return true; } else { $this->errors[] = 'EHLO command failed, output: ' . trim(substr(trim($error), 3)); return false; } } /** * Function to implement RSET cmd */ private function rset() { if ( is_resource($this->connection) and $this->send_data('RSET') and substr(trim($error = $this->get_data()), 0, 3) === '250' ) { return true; } else { $this->errors[] = 'RSET command failed, output: ' . trim(substr(trim($error), 3)); return false; } } /** * Function to implement QUIT cmd */ private function quit() { if ( is_resource($this->connection) and $this->send_data('QUIT') and substr(trim($error = $this->get_data()), 0, 3) === '221' ) { fclose($this->connection); $this->status = SMTP_STATUS_NOT_CONNECTED; return true; } else { $this->errors[] = 'QUIT command failed, output: ' . trim(substr(trim($error), 3)); return false; } } /** * Function to implement AUTH cmd */ private function auth() { if ( is_resource($this->connection) and $this->send_data('AUTH LOGIN') and substr(trim($error = $this->get_data()), 0, 3) === '334' and $this->send_data(base64_encode($this->user)) // Send username and substr(trim($error = $this->get_data()), 0, 3) === '334' and $this->send_data(base64_encode($this->pass)) // Send password and substr(trim($error = $this->get_data()), 0, 3) === '235' ) { $this->authenticated = true; return true; } else { $this->errors[] = 'AUTH command failed: ' . trim(substr(trim($error), 3)); return false; } } /** * Function that handles the MAIL FROM: cmd */ private function mail($from) { if ($this->is_connected()) { if ($this->send_data('MAIL FROM:<' . $from . '>')) { if (substr(trim($this->get_data()), 0, 3) === '250') { return true; } } } else { return false; } } /** * Function that handles the RCPT TO: cmd */ private function rcpt($to) { if ($this->is_connected()) { if ($this->send_data('RCPT TO:<' . $to . '>')) { if (substr(trim($error = $this->get_data()), 0, 2) === '25') return true; } } else { $this->errors[] = trim(substr(trim($error), 3)); return false; } } /** * Function that sends the DATA cmd */ private function data() { if ($this->is_connected()) { if ($this->send_data('DATA')) { if (substr(trim($error = $this->get_data()), 0, 3) === '354') return true; } } else { $this->errors[] = trim(substr(trim($error), 3)); return false; } } /** * Function to determine if this object * is connected to the server or not. */ private function is_connected() { return (is_resource($this->connection) and ($this->status === SMTP_STATUS_CONNECTED)); } /** * Function to send a bit of data */ private function send_data($data) { if (is_resource($this->connection)) { return fwrite($this->connection, $data . CRLF, strlen($data) + 2); } else { return false; } } /** * Function to get data. */ private function get_data() { $return = ''; $line = ''; $loops = 0; if (is_resource($this->connection)) { while ((strpos($return, CRLF) === FALSE or substr($line, 3, 1) !== ' ') and $loops < 100) { $line = fgets($this->connection, 512); $return .= $line; $loops++; } return $return; } else return false; } /** * Sets a variable */ public function set($var, $value) { $this->$var = $value; return true; } /** * Function to return the errors array */ public function getErrors() { return $this->errors; } }