sudocode

<?php
 
// $email =& Email::fromStream();
 
require_once dirname(dirname(__FILE__)).'/3rd-party/mail/mimeDecode.php';
 
class EmailResource {
 
    var $headers;
    var $body;
    var $parts;
    var $ctype_primary;
    var $ctype_secondary;
    var $ctype_parameters;
    var $content_disposition;
    var $d_parameters;
 
    function EmailResource() {
        $this->headers = array();
        $this->body    = '';
        $this->parts   = array();   
    }
}
 
 
class Email {
 
    var $raw;
    var $resource;
    var $log = array();
 
    function Email($input='') {
        if($input) {
 
            $this->raw = $input;
            $this->log('loading mimeDecode library');
 
            $params['include_bodies'] = true;
            $params['decode_bodies'] = true;
            $params['decode_headers'] = true;
            $params['input'] = $input;
 
            $this->log('Decoding stream for mime message');
            $this->resource = Mail_mimeDecode::decode($params);
 
        } else {
            $this->resource = new EmailResource();
            $this->log('New mime message created!');
        }
    }
 
    function log($msg = null) {
        if(is_bool($msg)) {
            $htmlOn = $msg;
            $msg = null;
        }
        if($msg !== null)
            $this->log[]="$msg";
 
        $output = implode("\n", $this->log);
        if($htmlOn)
            return nl2br($output);
        else
            return $output;
    }
 
    function addHeader($key, $value) {
        $this->log("Add header[$key: $value]");
        $this->resource->headers[$key] = $value;
    }
 
    function headers() {
        $str = '';
        foreach($this->resource->headers as $key => $value)
            $str .= "$key: $value\r\n";
        $this->log("Output headers [$str]");
        return $str;
    }
 
    function header($key) {
        $this->log("Get header [$key: ".$this->resource->headers[$key]."]");
        return $this->resource->headers[$key];
    }
 
    function body($data = null) {
        if($data === null) {
            return $this->resource->body;
 
        } else {
            $this->resource->body = $data;
        }
    }
 
    function part($primaryType, $secondaryType = null, $body = null) {
        if($secondaryType === null) {
            $this->log("Explode [$primaryType]");
            list($primaryType, $secondaryType) = explode('/', $primaryType);
        }
 
        if($body !== null) {
            // TODO build a multipart email
            $this->log("Add a new part");
 
        } else {
 
            $this->log("Looking for Content-Type: $primaryType/$secondaryType");
            $resource = array();
            list($type,) = $this->contentType(true);
            if($type == 'multipart') {
                $this->log("Email has multiple parts");
                $resource = $this->resource->parts;
            } else {
                $this->log("Email is not multipart");
                $resource = array($this->resource);
            }
 
            $parts = array();
            $this->log("Iterate through the parts");
            foreach ($resource as $part) {
                $this->log("Found part with Content-Type: ". $this->contentType($part));
                $this->log("Is [".$this->contentType($part)."] == [$primaryType/$secondaryType]?");
                if (0 == strcmp($this->contentType($part), "$primaryType/$secondaryType")) {
                    $this->log("Found a matching part.");
                    $parts[] = $part;
                    $this->log("Add to results array [".count($parts)."]");
                }
            }
            $this->log("Return the list of found parts");
            return $parts;
        }
    }
 
    function contentType($resource = null, $primary = null, $secondary = null) {
        if($resource === null)
            $resource = $this->resource;
 
        if(is_bool($resource)) {
            $primary  = $resource;
            $resource = $this->resource;
        }
 
        if((is_bool($primary) || $primary === null) && $secondary === null) {
            $this->log("Fetching Content-Type of part");
            $type = array($resource->ctype_primary, $resource->ctype_secondary);
            if($primary === true) {
                $this->log("Return array(". implode(',', $type) .")");
                return $type;
            } else {
                $this->log("Return ${type[0]}/${type[1]}");
                return $type[0].'/'.$type[1];
            }
        }
    }
 
    function text($body = null) {
        if($body !== null) {
            $this->log("Create a new text body");
            return $this->part('text', 'plain', $body);
 
        } else {            
 
            $this->log("Look for part with Content-Type: text/plain");
            $text = $this->part('text/plain');
            if(count($text) > 0) {
                // TODO handle multiple parts of the same type
                $this->log("Returning ".$text[0]->body);
                return $this->removeSignature($text[0]->body);
 
            // look for text/html second
            } 
 
            $this->log("No matching parts found");
            $this->log("Look for part with Content-Type: text/html");
            $text = $this->part('text/html');
            if(count($text) > 0) {
                // TODO handle multiple parts of the same type
 
                $body = $text[0]->body;
                $body = strip_tags($body);
                $this->log("Tags are stripped");
                $body = html_entity_decode($body);
                $this->log("Converted to ASCII");
 
                $this->log("Returning $body");
                return $body;
            }            
 
            $this->log("No matching parts found");
            $this->log("Giving up on looking for parts with Content-Type: text/*");
            return 'No text found.';
        }
    }
 
    function removeSignature($text) {        
        // Remove Signature delimited by --
        $sig = (strrpos($text, "\r\n--\r\n") !== false) ? strrpos($text, "\r\n--\r\n"): (strrpos($text, "\n--\n")) ? strrpos($text, "\n--\n"): strrpos($text, "--");
        if($sig !== false) {
            $text = substr($text, 0, $sig);
        }
 
        // Remove original messages/past conversations/RE:
        $sig = strripos($text, 'original message');
        if($sig !== false) {
            $text = substr($text, 0, $sig);
        }        
 
        // Remove Sent from my blah blah
        $sig = strripos($text, 'sent from my');
        if($sig !== false) {
            $text = substr($text, 0, $sig);
        }   
 
        return trim($text);
    }
 
    function subject($data = null) {
        if($data === null) {
            return $this->resource->headers['subject'];            
        } else {
            $this->resource->headers['subject'] = $data;
        }
    }
 
    function from($data = null) {
        if($data === null) {
            return $this->resource->headers['from'];            
        } else {
            $this->resource->headers['from'] = $data;
        }
    }
 
    function fromEmail() {
        $from = $this->from();
        if(strpos($from, '<') !== false) {
            $from = substr($from, strpos($from, '<') + 1);
            $from = substr($from, 0, strpos($from, '>'));
        }
        return $from;
    }
 
    function fromStream($input = 'php://stdin') {
        $data = file_get_contents($input);
        return new Email($data);
    }
 
    function forwardTo($to) {
        $this->log("Forwarding email to $to");
        mail($to, $this->subject(), $this->body(), $this->headers());
    }
}
?>