SMTP backend for the Deliver class

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);
+        }
+    }
 }
+
 ?>