E_ALL fix when using proxy's with HTTP_VIA and no HTTP_X_FORWARDED_FOR
[squirrelmail.git] / class / deliver / Deliver.class.php
index 1a74947141b89bb70115528f4a6846e51bddcf1c..5cd5eb11cc003320590503eef4ef0f323341d167 100644 (file)
 class Deliver {
 
     function mail($message, $stream=false) {
-    
        $rfc822_header = $message->rfc822_header;
        if (count($message->entities)) {
           $boundary = $this->mimeBoundary();
-         $rfc822_header->contenttype->properties['boundary']=$boundary;
+         $rfc822_header->content_type->properties['boundary']='"'.$boundary.'"';
        } else {
           $boundary='';
        }
-       $header = $this->prepareRFC822_Header($rfc822_header);
-       $raw_length = strlen($header);
+       $raw_length = 0;
+       $reply_rfc822_header = (isset($message->reply_rfc822_header) 
+                            ? $message->reply_rfc822_header : '');
+       $header = $this->prepareRFC822_Header($rfc822_header, $reply_rfc822_header, $raw_length);
+
        if ($stream) {
             $this->preWriteToStream($header);
             $this->writeToStream($stream, $header);
-       } else {
-                       /* DEBUG */
-               $out =  htmlspecialchars($header);
-               $out = str_replace("\r\n",'<BR>',$out);
-               echo $out;
        }
        $this->writeBody($message, $stream, $raw_length, $boundary);
-       exit;
        return $raw_length;
-       
     }
     
     function writeBody($message, $stream, &$length_raw, $boundary='') {
-        if ($boundary) {
+        if ($boundary && !$message->rfc822_header) {
            $s = '--'.$boundary."\r\n";
            $s .= $this->prepareMIME_Header($message, $boundary);
            $length_raw += strlen($s);
@@ -55,11 +50,13 @@ class Deliver {
        if ($boundary_depth) {
           $boundary .= '_part'.$boundary_depth;
        }
+       $last = false;
        for ($i=0, $entCount=count($message->entities);$i<$entCount;$i++) {
            $msg = $this->writeBody($message->entities[$i], $stream, $length_raw, $boundary);
+           if ($i == $entCount-1) $last = true;
        }
-        if ($boundary) {
-           $s = '--'.$boundary."--\r\n";
+        if ($boundary && $last) {
+           $s = "--".$boundary."--\r\n\r\n";
            $length_raw += strlen($s);
            if ($stream) {
                 $this->preWriteToStream($s);
@@ -69,7 +66,14 @@ class Deliver {
     }
 
     function writeBodyPart($message, $stream, &$length) {
-       switch ($message->type0) {
+        if ($message->mime_header) {
+          $type0 = $message->mime_header->type0;
+       } else {
+          $type0 = $message->rfc822_header->content_type->type0;
+       }
+       
+       $body_part_trailing = $last = '';
+       switch ($type0) {
        case 'text':
        case 'message':
            if ($message->body_part) {
@@ -78,27 +82,18 @@ class Deliver {
               if ($stream) {
                   $this->preWriteToStream($body_part);     
                  $this->writeToStream($stream, $body_part);
-                  } else {
-                       /* DEBUG */
-                       $out =  htmlspecialchars($tmp);
-                       $out = str_replace("\r\n",'<BR>',$out);
-                       echo $out;
-
               }
+              $last = $body_part;
            } elseif ($message->att_local_name) {
                $filename = $message->att_local_name;
                $file = fopen ($filename, 'rb');
-               while ($tmp = fgets($file, 4096)) {
-                  $length += $this->clean_crlf($tmp);
+               while ($body_part = fgets($file, 4096)) {
+                  $length += $this->clean_crlf($body_part);
                   if ($stream) {
-                     $this->preWriteToStream($tmp);
-                     $this->writeToStream($stream, $tmp);
-                  } else {
-                       /* DEBUG */
-                       $out =  htmlspecialchars($tmp);
-                       $out = str_replace("\r\n",'<BR>',$out);
-                       echo $out;
+                     $this->preWriteToStream($body_part);
+                     $this->writeToStream($stream, $body_part);
                    }
+                  $last = $body_part;
                }
                fclose($file);
             }
@@ -109,31 +104,33 @@ class Deliver {
               $length += $this->clean_crlf($body_part);
               if ($stream) {
                  $this->writeToStream($stream, $body_part);
-              } else {
-                   /* DEBUG */
-                   $out =  htmlspecialchars($body_part);
-                   $out = str_replace("\r\n",'<BR>',$out);
-                   echo $out;
               }
            } elseif ($message->att_local_name) {
                $filename = $message->att_local_name;
                $file = fopen ($filename, 'rb');
-               while ($tmp = fread($file, 1520)) {
-                  $encoded = chunk_split(base64_encode($tmp));
-                  $length += strlen($encoded);
+               $encoded = '';
+               while ($tmp = fread($file, 570)) {
+                  $body_part = chunk_split(base64_encode($tmp));
+                  $length += $this->clean_crlf($body_part);
                   if ($stream) {
-                     $this->writeToStream($stream, $encoded);
-                  } else {
-                       /* DEBUG */                
-                       $out =  htmlspecialchars($encoded);
-                       $out = str_replace("\r\n",'<BR>',$out);
-                       echo $out;
+                     $this->writeToStream($stream, $body_part);
                   }
                }
                fclose($file);
            }
            break;
        }
+       $body_part_trailing = '';
+       if ($last && substr($last,-1) != "\n") {
+          $body_part_trailing = "\r\n";
+       }
+       if ($body_part_trailing) {
+           $length += strlen($body_part_trailing);
+           if ($stream) {
+               $this->preWriteToStream($body_part_trailing);     
+               $this->writeToStream($stream, $body_part_trailing);
+           }
+       }
     }
     
     function clean_crlf(&$s) {
@@ -142,18 +139,25 @@ class Deliver {
         $s = str_replace("\n", "\r\n", $s);
        return strlen($s);
     }
+    
+    function strip_crlf(&$s) {
+        $s = str_replace("\r\n ", '', $s);
+       $s = str_replace("\r", '', $s);
+       $s = str_replace("\n", '', $s);
+    }
 
     function preWriteToStream(&$s) {
     }
     
     function writeToStream($stream, $data) {
+       fputs($stream, $data);
     }
     
     function initStream($message, $length=0, $host='', $port='', $user='', $pass='') {
        return $stream;
     }
     
-    function getBcc($bcc) {
+    function getBcc() {
        return false;
     }
 
@@ -168,24 +172,39 @@ class Deliver {
            $contenttype .= ";\r\n " . 'boundary="'.$boundary.'"';
        }                      
        if (isset($mime_header->parameters['name'])) {
-           $contenttype .= ";\r\n " . 'name="'.
+           $contenttype .= '; name="'.
                encodeHeader($mime_header->parameters['name']). '"';
        }
+       if (isset($mime_header->parameters['charset'])) {
+           $charset = $mime_header->parameters['charset'];
+           $contenttype .= '; charset="'.
+               encodeHeader($charset). '"';
+       }
+
+
        $header[] = $contenttype . $rn;
        if ($mime_header->description) {
            $header[] .= 'Content-Description: ' . $mime_header->description . $rn;
        }
        if ($mime_header->encoding) {
+           $encoding = $mime_header->encoding;
            $header[] .= 'Content-Transfer-Encoding: ' . $mime_header->encoding . $rn;
+       } else {
+           if ($mime_header->type0 == 'text' || $mime_header->type0 == 'message') {
+               $header[] .= 'Content-Transfer-Encoding: 8bit' .  $rn;
+           } else {
+               $header[] .= 'Content-Transfer-Encoding: base64' .  $rn;
+           }
        }
        if ($mime_header->id) {
            $header[] .= 'Content-ID: ' . $mime_header->id . $rn;
        }
        if ($mime_header->disposition) {
-           $contentdisp .= 'Content-Disposition: ' . $mime_header->disposition;
-           if (isset($mime_header->parameters['filename'])) {
-               $contentdisp .= ";\r\n " . 'filename="'.
-                   encodeHeader($mime_header->parameters['filename']). '"';
+           $disposition = $mime_header->disposition;
+           $contentdisp = 'Content-Disposition: ' . $disposition->name;
+           if ($disposition->getProperty('filename')) {
+               $contentdisp .= '; filename="'.
+                   encodeHeader($disposition->getProperty('filename')). '"';
            }
            $header[] = $contentdisp . $rn;       
        }
@@ -199,25 +218,33 @@ class Deliver {
        $cnt = count($header);
        $hdr_s = '';
        for ($i = 0 ; $i < $cnt ; $i++) {
-           $hdr_s .= $this->foldLine($header[$i], 78, '    ');
+           $hdr_s .= $this->foldLine($header[$i], 78,str_pad('',4));
        }
        $header = $hdr_s;
        $header .= $rn; /* One blank line to separate mimeheader and body-entity */
        return $header;
     }    
 
-    function prepareRFC822_Header($rfc822_header) {
-       global $REMOTE_ADDR, $SERVER_NAME, $REMOTE_PORT;
-       global $version, $useSendmail, $username;
-       global $HTTP_VIA, $HTTP_X_FORWARDED_FOR;
-       global $REMOTE_HOST;
+    function prepareRFC822_Header($rfc822_header, $reply_rfc822_header, &$raw_length) {
+        $REMOTE_ADDR = $_SERVER['REMOTE_ADDR'];
+        $SERVER_NAME = $_SERVER['SERVER_NAME'];
+        $REMOTE_PORT = $_SERVER['REMOTE_PORT'];
+        if(isset($_SERVER['REMOTE_HOST'])) {
+            $REMOTE_HOST = $_SERVER['REMOTE_HOST'];
+        }
+        if(isset($_SERVER['HTTP_VIA'])) {
+            $HTTP_VIA = $_SERVER['HTTP_VIA'];
+        }
+        if(isset($_SERVER['HTTP_X_FORWARDED_FOR'])) {
+            $HTTP_X_FORWARDED_FOR = $_SERVER['HTTP_X_FORWARDED_FOR'];
+        }
+       global $version, $username;
        $rn = "\r\n";
        /* This creates an RFC 822 date */
-       $date = date("D, j M Y H:i:s ", mktime()) . $this->timezone();
+       $date = date('D, j M Y H:i:s ', mktime()) . $this->timezone();
        /* Create a message-id */
        $message_id = '<' . $REMOTE_PORT . '.' . $REMOTE_ADDR . '.';
        $message_id .= time() . '.squirrel@' . $SERVER_NAME .'>';
-       $old_message_id = $rfc822_header->message_id;
        /* Make an RFC822 Received: line */
        if (isset($REMOTE_HOST)) {
            $received_from = "$REMOTE_HOST ([$REMOTE_ADDR])";
@@ -225,7 +252,7 @@ class Deliver {
            $received_from = $REMOTE_ADDR;
        }
        if (isset($HTTP_VIA) || isset ($HTTP_X_FORWARDED_FOR)) {
-           if ($HTTP_X_FORWARDED_FOR == '') {
+           if (!isset($HTTP_X_FORWARDED_FOR) || $HTTP_X_FORWARDED_FOR == '') {
                $HTTP_X_FORWARDED_FOR = 'unknown';
            }
            $received_from .= " (proxying for $HTTP_X_FORWARDED_FOR)";
@@ -237,11 +264,11 @@ class Deliver {
        $header[] = "        $date" . $rn;
         /* Insert the rest of the header fields */
         $header[] = 'Message-ID: '. $message_id . $rn;
-        if ($old_message_id) {
-           $header[] = 'In-Reply-To: '.$old_message_id . $rn;
-           $references = $this->calculate_references($rfc822_header->references,
-                      $old_message_id, $rfc822_header->in_reply_to);
-                      
+        if ($reply_rfc822_header->message_id) {
+           $rep_message_id = $reply_rfc822_header->message_id;
+//         $this->strip_crlf($message_id);
+           $header[] = 'In-Reply-To: '.$rep_message_id . $rn;
+           $references = $this->calculate_references($reply_rfc822_header);
            $header[] = 'References: '.$references . $rn;
        }       
        $header[] = "Date: $date" . $rn;
@@ -251,7 +278,9 @@ class Deliver {
         if (count($rfc822_header->from) > 1) {
            $header[] = 'Sender: '. encodeHeader($rfc822_header->getAddr_s('sender')) . $rn;
        }
-       $header[] = 'To: '. encodeHeader($rfc822_header->getAddr_s('to')) . $rn;    // Who it's TO
+       if (count($rfc822_header->to)) {
+           $header[] = 'To: '. encodeHeader($rfc822_header->getAddr_s('to')) . $rn;
+        }
        if (count($rfc822_header->cc)) {
            $header[] = 'Cc: '. encodeHeader($rfc822_header->getAddr_s('cc')) . $rn;
        }
@@ -259,9 +288,15 @@ class Deliver {
            $header[] = 'Reply-To: '. encodeHeader($rfc822_header->getAddr_s('reply_to')) . $rn;
        }
        /* Sendmail should return true. Default = false */
-       $bcc = $this->getBcc($rfc822_header->bcc);
-       if ($bcc && count($rfc822_header->bcc)) {
-           $header[] = 'Bcc: '. encodeHeader($rfc822_header->getAddr_s('bcc')) . $rn;
+       $bcc = $this->getBcc();
+       if (count($rfc822_header->bcc)) {
+           $s = 'Bcc: '. encodeHeader($rfc822_header->getAddr_s('bcc')) . $rn;
+           if (!$bcc) {
+              $s = $this->foldLine($s, 78, str_pad('',4));
+              $raw_length += strlen($s);
+           } else {
+              $header[] = $s;
+           }
        }
        /* Identify SquirrelMail */     
        $header[] = "X-Mailer: SquirrelMail (version $version)" . $rn; 
@@ -270,8 +305,10 @@ class Deliver {
        $contenttype = 'Content-Type: '. $rfc822_header->content_type->type0 .'/'.
                                          $rfc822_header->content_type->type1;
        if (count($rfc822_header->content_type->properties)) {
-           foreach ($rfc822_header->contenttype->properties as $k => $v) {
-               $contenttype .= ';'. "\r\n " .$k.'='.$v; /* FOLDING */
+           foreach ($rfc822_header->content_type->properties as $k => $v) {
+               if ($k && $v) {
+                   $contenttype .= ';' .$k.'='.$v; 
+               }
            }
        }
         $header[] = $contenttype . $rn;
@@ -302,73 +339,68 @@ class Deliver {
        $cnt = count($header);
        $hdr_s = '';
        for ($i = 0 ; $i < $cnt ; $i++) {
-           $hdr_s .= $this->foldLine($header[$i], 78, '    ');
+           $hdr_s .= $this->foldLine($header[$i], 78, str_pad('',4));
        }
+//     $debug = "Debug: <123456789012345678901234567890123456789012345678901234567890123456789>\r\n";
+//     $this->foldLine($debug, 78, str_pad('',4));
        $header = $hdr_s;
        $header .= $rn; /* One blank line to separate header and body */
+       $raw_length += strlen($header);
        return $header;
     }
 
     /*
     * function for cleanly folding of headerlines
     */
-    function foldLine($line, $length, $pre) {
-    $cnt = strlen($line);
-    $res = '';
-    if ($cnt > $length)
-    {
-        $fold_string = $pre.' '."\r\n";
-        for ($i=0;$i<($cnt-$length);$i++)
-       {
-            $fold_pos = 0;
-           /* first try to fold at delimiters */
-            for ($j=($i+$length); $j>$i; $j--)
-            {
-                switch ($line{$j})
-               {
-               case (','):
-               case (';'):
-                    $fold_pos = $j;
-                   break;
-               default:
-                   break;
-               }
-               if ($fold_pos)
-               {
-                   $j=$i;
+    function foldLine($line, $length, $pre='') {
+        $line = substr($line,0, -2);
+       $length -= 2; /* don not fold between \r and \n */
+       $cnt = strlen($line);
+       $res = '';
+       $fold=false;
+       if ($cnt > $length) {
+           $fold_string = "\r\n " . $pre;
+           if ($fold) {
+             $length -=(strlen($fold_string)+2);
+           }  
+           for ($i=0;$i<($cnt-$length);$i++) {
+               $fold_pos = 0;
+               /* first try to fold at delimiters */
+               for ($j=($i+$length); $j>$i; --$j) {
+                   switch ($line{$j}) {
+                     case (','):
+                     case (';'): $fold_pos = $i = $j; break;
+                     default: break;
+                   }
                }
-           }
-           if (!$fold_pos)
-           {
-                /* not succeed yet so we try at spaces and = */
-                for ($j=($i+$length); $j>$i; $j--)
-                {
-                    switch ($line{$j})
-                   {
-                   case (' '):
-                   case ('='):
-                        $fold_pos = $j;
-                       break;
-                   default:
-                       break;
-                   }
-                   if ($fold_pos)
-                   {
-                       $j=$i;
-                   }
-               }
-           }
-           if (!$fold_pos)
-           {
-              /* clean folding didn't work */
-              $fold_pos = $i+$length;
-           }
-           $line = substr_replace($line,$line{$fold_pos}.$fold_string,$fold_pos,1);
-           $cnt += strlen($fold_string);
-           $i = $j + strlen($fold_string);
-        }          
-    }
-    return $line;
+               if (!$fold_pos) { /* not succeed yet so we try at spaces & = */
+                   for ($j=($i+$length); $j>$i; $j--) {
+                       switch ($line{$j}) {
+                         case (' '):
+                         case ('='): $fold_pos = $i = $j; break;
+                         default: break;
+                       }
+                   }
+               }
+               if (!$fold_pos) { /* clean folding didn't work */
+                   $i = $j = $fold_pos = $i+$length;
+               }
+               $line = substr_replace($line,$line{$fold_pos}.$fold_string,
+                                      $fold_pos,1);
+               $cnt += strlen($fold_string);
+               if (!$fold) {
+                   $length -=(strlen($fold_string)+2);
+               }  
+               $fold = true;
+               $i = $j + strlen($fold_string)+1;
+           }       
+       }
+       /* debugging code
+       $debug = $line;
+       $debug = str_replace("\r","\\r", $debug);
+       $debug = str_replace("\n","\\n", $debug);
+       */
+       return $line."\r\n";
     }     
 
 
@@ -405,14 +437,17 @@ class Deliver {
        return ($result);
     }
 
-    function calculate_references($refer, $old_message_id, $old_in_reply_to) {
+    function calculate_references($hdr) {
+        $refer = $hdr->references;
+       $message_id = $hdr->message_id;
+       $in_reply_to = $hdr->in_reply_to;
        if (strlen($refer) > 2) {
-           $refer .= ' ' . $old_message_id;
+           $refer .= ' ' . $message_id;
        } else {
-           if ($old_in_reply_to) {
-               $refer .= $old_in_reply_to . ' ' . $old_message_id;
+           if ($in_reply_to) {
+               $refer .= $in_reply_to . ' ' . $message_id;
            } else {
-               $refer .= $old_message_id;
+               $refer .= $message_id;
            }                        
        }
        trim($refer);