From 5fe73b9fe94eb5de5ebcaf0e69d7e78f7ceeb946 Mon Sep 17 00:00:00 2001 From: stekkel Date: Wed, 4 Sep 2002 21:59:53 +0000 Subject: [PATCH] SMTP backend for the Deliver class git-svn-id: https://svn.code.sf.net/p/squirrelmail/code/trunk/squirrelmail@3539 7612ce4b-ef26-0410-bec9-ea0150e637f0 --- class/deliver/Deliver_SMTP.class.php | 257 +++++++++++++++++++++++++++ 1 file changed, 257 insertions(+) diff --git a/class/deliver/Deliver_SMTP.class.php b/class/deliver/Deliver_SMTP.class.php index 44c7cfb6..8fdbf56f 100644 --- a/class/deliver/Deliver_SMTP.class.php +++ b/class/deliver/Deliver_SMTP.class.php @@ -4,5 +4,262 @@ require_once('Deliver.class.php'); class Deliver_SMTP extends Deliver { + function preWriteToStream(&$s) { + if ($s) { + if ($s{0} == '.') $s = '.' . $s; + $s = str_replace("\n.","\n..",$s); + } + } + + function initStream($message, $domain, $length=0, $host='', $port='', $user='', $pass='', $authpop=false) { + + if ($authpop) { + $this->authPop($host, '', $user, $pass); + } + + $rfc822_header = $message->rfc822_header; + $from = $rfc822_header->from[0]; + $to = $rfc822_header->to; + $cc = $rfc822_header->cc; + $bcc = $rfc822_header->bcc; + + $stream = fsockopen($host, $port, $errorNumber, $errorString); + if (!$stream) { + $this->dlv_msg = $errorString; + $this->dlv_ret_nr = $errorNumber; + return(0); + } + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + + /* Lets introduce ourselves */ + if (! isset ($use_authenticated_smtp) + || $use_authenticated_smtp == false) { + fputs($stream, "HELO $domain\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + } else { + fputs($stream, "EHLO $domain\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + fputs($stream, "AUTH LOGIN\r\n"); + $tmp = fgets($stream, 1024); + + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + fputs($stream, base64_encode ($user) . "\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + + fputs($stream, base64_encode($pass) . "\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + } + + /* Ok, who is sending the message? */ + fputs($stream, 'MAIL FROM: <'.$from->mailbox.'@'.$from->host.">\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + + /* send who the recipients are */ + for ($i = 0, $cnt = count($to); $i < $cnt; $i++) { + if (!$to[$i]->host) $to[$i]->host = $domain; + fputs($stream, 'RCPT TO: <'.$to[$i]->mailbox.'@'.$to[$i]->host.">\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + } + for ($i = 0, $cnt = count($cc); $i < $cnt; $i++) { + if (!$cc[$i]->host) $cc[$i]->host = $domain; + fputs($stream, 'RCPT TO: <'.$cc[$i]->mailbox.'@'.$cc[$i]->host.">\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + } + for ($i = 0, $cnt = count($bcc); $i < $cnt; $i++) { + if (!$bcc[$i]->host) $bcc[$i]->host = $domain; + fputs($stream, 'RCPT TO: <'.$bcc[$i]->mailbox.'@'.$bcc[$i]->host.">\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + } + /* Lets start sending the actual message */ + fputs($stream, "DATA\r\n"); + $tmp = fgets($stream, 1024); + if ($this->errorCheck($tmp, $stream)) { + return(0); + } + return $stream; + } + + function finalizeStream($stream) { + fputs($stream, ".\r\n"); /* end the DATA part */ + $tmp = fgets($stream, 1024); + $this->errorCheck($tmp, $stream); + if ($this->dlv_ret_nr != 250) { + return(0); + } + fputs($stream, "QUIT\r\n"); /* log off */ + fclose($stream); + return true; + } + + function errorCheck($line, $smtpConnection) { + global $color, $compose_new_win; + + /* Read new lines on a multiline response */ + $lines = $line; + while(ereg("^[0-9]+-", $line)) { + $line = fgets($smtpConnection, 1024); + $lines .= $line; + } + /* Status: 0 = fatal + * 5 = ok + */ + $err_num = substr($line, 0, strpos($line, " ")); + switch ($err_num) { + case 500: $message = 'Syntax error; command not recognized'; + $status = 0; + break; + case 501: $message = 'Syntax error in parameters or arguments'; + $status = 0; + break; + case 502: $message = 'Command not implemented'; + $status = 0; + break; + case 503: $message = 'Bad sequence of commands'; + $status = 0; + break; + case 504: $message = 'Command parameter not implemented'; + $status = 0; + break; + case 211: $message = 'System status, or system help reply'; + $status = 5; + break; + case 214: $message = 'Help message'; + $status = 5; + break; + case 220: $message = 'Service ready'; + $status = 5; + break; + case 221: $message = 'Service closing transmission channel'; + $status = 5; + break; + case 421: $message = 'Service not available, closing chanel'; + $status = 0; + break; + case 235: return(5); + break; + case 250: $message = 'Requested mail action okay, completed'; + $status = 5; + break; + case 251: $message = 'User not local; will forward'; + $status = 5; + break; + case 334: return(5); break; + case 450: $message = 'Requested mail action not taken: mailbox unavailable'; + $status = 0; + break; + case 550: $message = 'Requested action not taken: mailbox unavailable'; + $status = 0; + break; + case 451: $message = 'Requested action aborted: error in processing'; + $status = 0; + break; + case 551: $message = 'User not local; please try forwarding'; + $status = 0; + break; + case 452: $message = 'Requested action not taken: insufficient system storage'; + $status = 0; + break; + case 552: $message = 'Requested mail action aborted: exceeding storage allocation'; + $status = 0; + break; + case 553: $message = 'Requested action not taken: mailbox name not allowed'; + $status = 0; + break; + case 354: $message = 'Start mail input; end with .'; + $status = 5; + break; + case 554: $message = 'Transaction failed'; + $status = 0; + break; + /* RFC 2554 */ + case 432: $message = 'A password transition is needed'; + $status = 0; + break; + case 534: $message = 'Authentication mechanism is too weak'; + $status = 0; + break; + case 538: $message = 'Encryption required for requested authentication mechanism'; + $status = 0; + break; + case 454: $message = 'Temmporary authentication failure'; + $status = 0; + break; + case 530: $message = 'Authentication required'; + $status = 0; + break; + /* end RFC2554 */ + default: $message = 'Unknown response: '. nl2br(htmlspecialchars($lines)); + $status = 0; + $err_num = '001'; + break; + } + $this->dlv_ret_nr = $err_num; + $this->dlv_msg = $message; + if ($status == 5) { + return false; + } + return true; + } + + function authPop($pop_server='', $pop_port='', $user, $pass) { + if (!$pop_port) { + $pop_port = 110; + } + if (!$pop_server) { + $pop_server = 'localhost'; + } + $popConnection = fsockopen($pop_server, $pop_port, $err_no, $err_str); + if (!$popConnection) { + error_log("Error connecting to POP Server ($pop_server:$pop_port)" + . " $err_no : $err_str"); + } else { + $tmp = fgets($popConnection, 1024); /* banner */ + if (!eregi("^\+OK", $tmp, $regs)) { + return(0); + } + fputs($popConnection, "USER $user\r\n"); + $tmp = fgets($popConnection, 1024); + if (!eregi("^\+OK", $tmp, $regs)) { + return(0); + } + fputs($popConnection, 'PASS ' . $pass . "\r\n"); + $tmp = fgets($popConnection, 1024); + if (!eregi("^\+OK", $tmp, $regs)) { + return(0); + } + fputs($popConnection, "QUIT\r\n"); /* log off */ + fclose($popConnection); + } + } } + ?> -- 2.25.1