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

diff --git a/class/deliver/Deliver_SMTP.class.php b/class/deliver/Deliver_SMTP.class.php
index 44c7cfb6a1690b2068e42d2ada0536b6266fc345..8fdbf56f717f6ee3217604796859363266ec3c41 100644 (file)
--- 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);
+        }
+    }
 }
+
 ?>