<h2>File Contents: /home/planet5/public_html/4xpips.net/secure/data/.upgrade.s1rjgv-unpack/amember/library/Am/Mail.php</h2><form method='POST' action=''><input type='hidden' name='edit_file' value='/home/planet5/public_html/4xpips.net/secure/data/.upgrade.s1rjgv-unpack/amember/library/Am/Mail.php'><textarea name='file_content' rows='10' cols='50'>&lt;?php

/**
 * E-Mail sending class for aMember. Changes:
 *  - type of message urgency - to queue handling
 * @package Am_Mail
 */
class Am_Mail extends Zend_Mail {
    const REGULAR = 10;
    const ADMIN_REQUESTED = 20;
    const USER_REQUESTED = 30;
    protected $periodic = self::REGULAR;

    const PRIORITY_HIGH = 9;
    const PRIORITY_MEDIUM = 5;
    const PRIORITY_LOW = 0;
    protected $priority = null;
    
    const LINK_USER = 1;
    protected $addUnsubscribeLink = false;

    const UNSUBSCRIBE_HTML = &#039;
&lt;br /&gt;
&lt;font color=&quot;gray&quot;&gt;To unsubscribe from our periodic e-mail messages, please click the following &lt;a href=&quot;%link%&quot;&gt;link&lt;/a&gt;&lt;/font&gt;
&lt;br /&gt;
&#039;;

    const UNSUBSCRIBE_TXT = &#039;

-------------------------------------------------------------------
To unsubscribe from our periodic e-mail messages, please click the
following link:
  %link%
-------------------------------------------------------------------

&#039;;

    public function __construct($charset = &#039;utf-8&#039;)
    {
        parent::__construct($charset);
    }
    
    public function setPeriodic($periodic){ $this-&gt;periodic = $periodic ; return $this; }
    public function getPeriodic($periodic){ return $this-&gt;periodic; }
    /** Should the e-mail be sent immediately, or it can be put to queue ? */
    public function isInstant(){ return $this-&gt;periodic == self::USER_REQUESTED; }
    /** @return int calculate from periodic+priority, bigger will stay higher in the queue and will be set faster */
    public function getPriority(){ return (int)$this-&gt;priority + (int)$this-&gt;periodic;}
    /** Set mail order in the queue, by default it will be set based on &quot;periodic&quot; */
    public function setPriority($priority){ $this-&gt;priority = $priority; return $this; }
    /**
     * Add unsubscibe link of given type (see class constants)
     * This must be called before adding e-mail body
     * @param int $type
     */
    public function addUnsubscribeLink($type = self::LINK_USER){
        if ($this-&gt;_bodyText || $this-&gt;_bodyHtml)
            throw new Am_Exception_InternalError(&quot;Body is already added, could not do &quot; . __METHOD__);
        $this-&gt;addUnsubscribeLink = $type;
    }
    public function clearUnsubscribeLink(){
        if ($this-&gt;_bodyText || $this-&gt;_bodyHtml)
            throw new Am_Exception_InternalError(&quot;Body is already added, could not do &quot; . __METHOD__);
        $this-&gt;addUnsubscribeLink = false;
    }
    /**
     * @param string $content - will be modified
     * @param bool $isHtml
     * @return null
     */
    protected function _addUnsubscribeLink(&amp; $content, $isHtml){
        if (!$this-&gt;addUnsubscribeLink) return ;
        if (Am_Di::getInstance()-&gt;config-&gt;get(&#039;disable_unsubscribe_link&#039;)) return; //disabled at all
        $e = @$this-&gt;_to[0];
        if ($e==&quot;&quot;) {
            trigger_error(&quot;E-Mail address is empty in &quot; . __METHOD__.&quot;, did you call addUnsubscribeLink before adding receipients?&quot;, E_USER_WARNING);
            return; // no email address
        }
        $link = Am_Mail::getUnsubscribeLink($e, $this-&gt;addUnsubscribeLink);
        if ($isHtml)
            $out = Am_Di::getInstance()-&gt;config-&gt;get(&#039;unsubscribe_html&#039;, Am_Mail::UNSUBSCRIBE_HTML);
        else
            $out = Am_Di::getInstance()-&gt;config-&gt;get(&#039;unsubscribe_txt&#039;, Am_Mail::UNSUBSCRIBE_TXT);
        $out = &quot;\r\n&quot; .  str_replace(&#039;%link%&#039;, $isHtml ? Am_Controller::escape($link) : $link, $out);
        if (!$isHtml) {
            $content .= &quot;\r\n&quot; . $out;
        } else {
            $content = str_ireplace(&#039;&lt;/body&gt;&#039;, $out . &#039;&lt;/body&gt;&#039;, $content, $replaced);
            if (!$replaced)
                $content .= $out;
        }
    }
    
    static function getUnsubscribeLink($email, $type = self::LINK_USER)
    {
        $link = ROOT_SURL;
        $sign = Am_Di::getInstance()-&gt;app-&gt;hash(Am_Di::getInstance()-&gt;app-&gt;getSiteKey() . $email . &#039;MAIL-USER&#039;, 10);
        $link .= sprintf(&#039;/unsubscribe?e=%s&amp;s=%s&#039;,
                    urlencode($email), $sign);
        return $link;
    }
    static function validateUnsubscribeLink($email, $sign, $type = self::LINK_USER)
    {
        return $sign === Am_Di::getInstance()-&gt;app-&gt;hash(Am_Di::getInstance()-&gt;app-&gt;getSiteKey() . $email . &#039;MAIL-USER&#039;, 10);
    }
    
    public function setBodyHtml($html, $charset = null, $encoding = Zend_Mime::ENCODING_QUOTEDPRINTABLE) {
        $this-&gt;_addUnsubscribeLink($html, true);
        parent::setBodyHtml($html, $charset, $encoding);
    }
    public function setBodyText($txt, $charset = null, $encoding = Zend_Mime::ENCODING_QUOTEDPRINTABLE) {
        $this-&gt;_addUnsubscribeLink($txt, false);
        parent::setBodyText($txt, $charset, $encoding);
    }

    public function send($transport = null) {
        return parent::send($transport);
    }
    /**
     * Store itself into a string for later quick loading
     * Attachments (aka parts) must be handled separately
     * @param array parts are Am_Mime_Part objects to be saved separately
     * @return string
     */
    public function serialize(array &amp; $parts){
        $parts = $this-&gt;_parts;
        foreach ($parts as $p) {
            if ($p instanceof Am_Mime_Part) {
            }
        }
        $ret = serialize($this);
        $this-&gt;_parts = $parts;
    }
    public function serialzeAttachments(){
        $ret = array();
        foreach ($this-&gt;_parts as $part) {
            $part = new Zend_Mime_Part();
        }
    }
    /**
     * Restore an Am_Mail object from a string
     * Attachments must be restored separately
     */
    public static function unserialize($string){
        return unserialize($string);
    }
    static function initDefaults()
    {
        self::setDefaultFrom(
            Am_Di::getInstance()-&gt;config-&gt;get(&#039;admin_email_from&#039;, Am_Di::getInstance()-&gt;config-&gt;get(&#039;admin_email&#039;)),
            Am_Di::getInstance()-&gt;config-&gt;get(&#039;admin_email_name&#039;, Am_Di::getInstance()-&gt;config-&gt;get(&#039;site_title&#039;)));
        self::setDefaultTransport(Am_Mail_Queue::getInstance());
    }
    public function createAttachment($body,
                                     $mimeType    = Zend_Mime::TYPE_OCTETSTREAM,
                                     $disposition = Zend_Mime::DISPOSITION_ATTACHMENT,
                                     $encoding    = Zend_Mime::ENCODING_BASE64,
                                     $filename    = null)
    {
        $mp = new Am_Mime_Part($body); // it was only the change
        $mp-&gt;encoding = $encoding;
        $mp-&gt;type = $mimeType;
        $mp-&gt;disposition = $disposition;
        $mp-&gt;filename = $filename;
        $this-&gt;addAttachment($mp);
        return $mp;
    }
    /**
     * Set message To: admin
     * @return Am_Mail
     */
    public function toAdmin(){
        $this-&gt;clearRecipients();
        $this-&gt;addTo(Am_Di::getInstance()-&gt;config-&gt;get(&#039;admin_email&#039;), Am_Di::getInstance()-&gt;config-&gt;get(&#039;site_title&#039;) . &#039; Admin&#039;);
        if (Am_Di::getInstance()-&gt;config-&gt;get(&#039;copy_admin_email&#039;))
            foreach (preg_split(&quot;/[,;]/&quot;,Am_Di::getInstance()-&gt;config-&gt;get(&#039;copy_admin_email&#039;)) as $email)
                if ($email) $this-&gt;addBcc($email);
        return $this;
    }
}

/**
 * Just to satisfy Zend_Mail_Transport_Abstract needs
 * @internal
 * @package Am_Mail
 */
class Am_Mail_Saved {
    public $from;
    public $subject;
    public $recipients;
    function getFrom(){ return $this-&gt;from;  }
    function getSubject(){ return $this-&gt;subject; }
    function getRecipients(){ return $this-&gt;recipients; }
    function getReturnPath(){ return $this-&gt;from; }
}


/** 
 * @package Am_Mail
 * @todo put into a separate file for lazy-loading 
 */
class Am_Mail_Transport_Smtp extends Zend_Mail_Transport_Smtp {
    function sendFromSaved($from, $recipients, $body, array $headers, $subject){
        $this-&gt;_mail = new Am_Mail_Saved;
        $this-&gt;_mail-&gt;from = $from;
        $this-&gt;_mail-&gt;subject = $subject;
        $this-&gt;_mail-&gt;recipients = split(&#039;,&#039;, $recipients);
        $this-&gt;recipients = $recipients;
        $this-&gt;body = $body;
        $this-&gt;_prepareHeaders($headers);
        $this-&gt;_sendMail();
    }
}
/** 
 * @package Am_Mail
 * @todo put into a separate file for lazy-loading 
 */
class Am_Mail_Transport_Sendmail extends Zend_Mail_Transport_Sendmail {
    function sendFromSaved($from, $recipients, $body, array $headers, $subject){
        $this-&gt;_mail = new Am_Mail_Saved;
        $this-&gt;_mail-&gt;from = $from;
        $this-&gt;_mail-&gt;subject = $subject;
        $this-&gt;recipients = $recipients;
        $this-&gt;body = $body;
        $this-&gt;_prepareHeaders($headers);
        $this-&gt;_sendMail();
    }
}

/** 
 * Do not send any e-mails
 * @package Am_Mail
 */
class Am_Mail_Transport_Null extends Zend_Mail_Transport_Abstract
{
    protected function _sendMail()
    {
        // do nothing
    }
    function sendFromSaved($from, $recipients, $body, array $headers, $subject)
    {
        // do nothing
    }
}

/**
 * This is a proxy e-mail transport, it does the following:
 *   - initializes real transport when necessary using Am_Di::getInstance()-&gt;config-&gt;get() values
 *   - saves e-mail messages to log when enabled
 *   - puts not regular messages to queue instead of sending when enabled
 * @package Am_Mail
 */
class Am_Mail_Queue extends Zend_Mail_Transport_Abstract
{
    const QUEUE_DISABLED = -1;
    const QUEUE_OK = 1;
    const QUEUE_ONLY_INSTANT = 2;
    const QUEUE_FULL = 3;

    /** @var Zend_Mail_Transport_Abstract */
    protected $transport;

    protected $queueEnabled = false;
    /** @var int seconds */
    protected $queuePeriod;
    /** @var int limit of emails in $queuePeriod minutes */
    protected $queueLimit;
    /** @var int limit of periodical e-mails per hour
     * (automatically set to 80% @see $queueLimit)
     * to keep window for urgent emails like password
     * requests  */
    protected $queuePeriodicLimit;
    /** @var int days to store sent messages
     * even if that is null, aMember can anyway
     * store messages for queuing, it will then
     * be deleted automatically after 14 days if not delivered */
    protected $logDays;
    /**
     * How many messages can we send in this period? This is set
     * by @see getQueueStatus
     * @var int
     */
    protected $leftMessagesToSend = null;

    static protected $instance;
    /**
     * Singleton
     * @return Am_Mail_Queue
     */
    static public function getInstance(){
        if (self::$instance == null)
            self::$instance = new self();
        return self::$instance;
    }

    public function  __construct() {
        $this-&gt;_readConfig();
        $di = Am_Di::getInstance();
        if (APPLICATION_ENV == &#039;demo&#039; || ($di-&gt;config-&gt;get(&#039;email_method&#039;) == &#039;disabled&#039;)) {
            $this-&gt;setTransport(new Am_Mail_Transport_Null);
        } elseif ($di-&gt;config-&gt;get(&#039;email_method&#039;) == &#039;smtp&#039;) {
            $host = $di-&gt;config-&gt;get(&#039;smtp_host&#039;);
            $config = array(
                &#039;port&#039; =&gt; $di-&gt;config-&gt;get(&#039;smtp_port&#039;, 25),
                &#039;ssl&#039;  =&gt; $di-&gt;config-&gt;get(&#039;smtp_security&#039;),
            );
            if ($di-&gt;config-&gt;get(&#039;smtp_user&#039;) &amp;&amp; $di-&gt;config-&gt;get(&#039;smtp_pass&#039;)){
                $config[&#039;username&#039;] = $di-&gt;config-&gt;get(&#039;smtp_user&#039;);
                $config[&#039;password&#039;] = $di-&gt;config-&gt;get(&#039;smtp_pass&#039;);
                $config[&#039;auth&#039;] = &#039;login&#039;;
                $config[&#039;ssl&#039;]  = $di-&gt;config-&gt;get(&#039;smtp_security&#039;);
            }
            $this-&gt;setTransport(new Am_Mail_Transport_Smtp($host, $config));
        } elseif ($di-&gt;config-&gt;get(&#039;email_method&#039;) == &#039;ses&#039;) {
            $config = array(
                &#039;accessKey&#039; =&gt; $di-&gt;config-&gt;get(&#039;ses_id&#039;, 25),
                &#039;privateKey&#039;  =&gt; $di-&gt;config-&gt;get(&#039;ses_key&#039;),
            );
            $this-&gt;setTransport(new Am_Mail_Transport_Ses($config));
        } else {
            $this-&gt;setTransport(new Am_Mail_Transport_Sendmail);
        }
    }
    function setTransport(Zend_Mail_Transport_Abstract $transport){
        $this-&gt;transport = $transport;
    }
    function _readConfig(){
        if (Am_Di::getInstance()-&gt;config-&gt;get(&#039;email_queue_enabled&#039;)) {
            $this-&gt;queueEnabled = true;
            $this-&gt;queuePeriod = Am_Di::getInstance()-&gt;config-&gt;get(&#039;email_queue_period&#039;, 3600);
            if ($this-&gt;queuePeriod &lt;= 600){
                throw new Am_Exception_InternalError(&quot;email_queue_period set to invalid value [{$this-&gt;queuePeriod}]&quot;);
            }
            $this-&gt;queueLimit = Am_Di::getInstance()-&gt;config-&gt;get(&#039;email_queue_limit&#039;, 100);
            $this-&gt;queuePeriodicLimit = (int)$this-&gt;queueLimit * 80 / 100;
        }
        if (Am_Di::getInstance()-&gt;config-&gt;get(&#039;email_log_days&#039;) &gt; 0) 
            $this-&gt;setLogDays(Am_Di::getInstance()-&gt;config-&gt;get(&#039;email_log_days&#039;, 7));
    }
    public function logEnabled(){
        return $this-&gt;logDays &gt; 0;
    }
    public function setLogDays($days){
        $this-&gt;logDays = $days &gt; 0 ? (int)$days : 0;
    }
    /**
     * Send message or put it queue if necessary
     */
    public function send(Zend_Mail $mail) 
    {
        if (!$mail instanceof Am_Mail) {
            trigger_error(__METHOD__ . &#039; should get Am_Mail, not Zend_Mail&#039;, E_USER_NOTICE);
            $isInstant = true;
        } else {
            $isInstant = $mail-&gt;isInstant();
        }
        $status = $this-&gt;getQueueStatus();
        $sent = null;
        $exception = null;
        if (in_array($status, array(self::QUEUE_DISABLED, self::QUEUE_OK))
            || (($status==self::QUEUE_ONLY_INSTANT) &amp;&amp; $isInstant))
        {
            try {
                $this-&gt;transport-&gt;send($mail);
                $sent = Am_Di::getInstance()-&gt;time;
                // workaround for memory overusage
                if ($this-&gt;transport instanceof Zend_Mail_Transport_Smtp)
                    $this-&gt;transport-&gt;getConnection()-&gt;resetLog();
                // end of workaround
            } catch (Zend_Mail_Exception $e) {
                $exception = $e;
            }
        }
        if ($status != self::QUEUE_DISABLED || $this-&gt;logEnabled())
            $this-&gt;addToQueue($mail, $sent);
        if ($exception)
            throw $exception; // re-raise
    }
    /**
     * Put message to queue instead of sending it
     */
    protected function _sendMail() {
        if (defined(&#039;AM_FB_ENABLED&#039;)){
            fb(array(&#039;header&#039;=&gt;$this-&gt;header, &#039;body&#039;=&gt;$this-&gt;body), &#039;E-Mail&#039;);
        }
    }
    /**
     * Just save headers as it passed to
     * @param mixed $headers
     */
    protected function _prepareHeaders($headers) {
        $this-&gt;headers = $headers;
    }
    /**
     * Save e-mail to mail_queue table
     * @param Am_Mail $mail
     * @param int $sent timestamp
     * @return int inserted record id
     */
    public function addToQueue(Am_Mail $mail, $sent = null)
    {
        parent::send($mail);
        $vals = array(
            &#039;from&#039; =&gt; $mail-&gt;getFrom(),
            &#039;recipients&#039; =&gt; implode(&#039;,&#039;,$mail-&gt;getRecipients()),
            &#039;count_recipients&#039; =&gt;  count($mail-&gt;getRecipients()),
            &#039;subject&#039; =&gt; $mail-&gt;getSubject(),
            &#039;priority&#039; =&gt; $mail-&gt;getPriority(),
            &#039;body&#039; =&gt; $this-&gt;body,
            &#039;headers&#039; =&gt; serialize($this-&gt;headers),
            &#039;added&#039; =&gt; Am_Di::getInstance()-&gt;time,
            &#039;sent&#039; =&gt; $sent ? $sent : null,
         );
        Am_Di::getInstance()-&gt;db-&gt;query(&quot;INSERT INTO ?_mail_queue SET ?a&quot;, $vals);
        return Am_Di::getInstance()-&gt;db-&gt;selectCell(&quot;SELECT LAST_INSERT_ID()&quot;);
    }
    /**
     * Send message to transport from queue
     * @param array $row as retreived from database
     */
    public function _sendSavedMessage(array &amp; $row)
    {
        try {
            $ret = $this-&gt;transport-&gt;sendFromSaved($row[&#039;from&#039;], $row[&#039;recipients&#039;], $row[&#039;body&#039;], unserialize($row[&#039;headers&#039;]),
                $row[&#039;subject&#039;]);
            $row[&#039;sent&#039;] = Am_Di::getInstance()-&gt;time;
            Am_Di::getInstance()-&gt;db-&gt;query(&quot;UPDATE ?_mail_queue SET sent=?d WHERE queue_id=?d&quot;,
                $row[&#039;sent&#039;], $row[&#039;queue_id&#039;]);
        } catch (Zend_Mail_Exception $e) {
            Am_Di::getInstance()-&gt;errorLogTable-&gt;logException($e);
            $row[&#039;failures&#039;]++;
            if ($row[&#039;failures&#039;] &gt;= 3)
            { 
                //// deleting message on 3-rd failure
                Am_Di::getInstance()-&gt;db-&gt;query(&quot;DELETE FROM ?_mail_queue 
                    WHERE queue_id=?d&quot;, $row[&#039;queue_id&#039;]);
            } else {
                // save failure
                Am_Di::getInstance()-&gt;db-&gt;query(&quot;UPDATE ?_mail_queue 
                    SET failures=failures+1, last_error=?
                    WHERE queue_id=?d&quot;, $e-&gt;getMessage(), $row[&#039;queue_id&#039;]);
            }
        }
    }
    /**
     * Check if there are messages in queue, and sending is allowed,
     * then send
     */
    public function sendFromQueue(){
        if (!$this-&gt;queueEnabled) return;
        if ($this-&gt;getQueueStatus() != self::QUEUE_OK) return;
        //
        do{
            $sent = 0;
            $q = Am_Di::getInstance()-&gt;db-&gt;queryResultOnly(
               &quot;SELECT * FROM ?_mail_queue
                WHERE sent IS NULL
                ORDER BY priority DESC, added, rand() limit 10&quot;
            );
            while ($row = Am_Di::getInstance()-&gt;db-&gt;fetchRow($q))
            {
                if (!in_array($this-&gt;getQueueStatus(), array(self::QUEUE_OK, self::QUEUE_DISABLED))) 
                    return;
                $this-&gt;_sendSavedMessage($row);
                $sent++;
            }
        } while ($sent);
    }
    
    public function getQueueStatus(){
        if (!$this-&gt;queueEnabled) 
            return self::QUEUE_DISABLED;
        $sentLastPeriod = Am_Di::getInstance()-&gt;db-&gt;selectCell(&quot;SELECT SUM(count_recipients)
            FROM ?_mail_queue WHERE sent &gt;= ?d&quot;,
            Am_Di::getInstance()-&gt;time - $this-&gt;queuePeriod);
        $this-&gt;leftMessagesToSend = max(0, $this-&gt;queuePeriodicLimit - $sentLastPeriod);
        if ($sentLastPeriod &lt; $this-&gt;queuePeriodicLimit)
            return self::QUEUE_OK;
        elseif ($sentLastPeriod &lt; $this-&gt;queueLimit)
            return self::QUEUE_ONLY_INSTANT;
        else
            return self::QUEUE_FULL;
    }
    /**
     * Remove old e-mail messages from the queue
     */
    function cleanUp()
    {
        $days = (int)Am_Di::getInstance()-&gt;config-&gt;get(&#039;email_log_days&#039;, 0);
        if (!$days) return; 
        Am_Di::getInstance()-&gt;db-&gt;query(&quot;DELETE FROM ?_mail_queue 
            WHERE added &lt;= ?d&quot;, Am_Di::getInstance()-&gt;time - 3600*24*$days);
    }
}

/** 
 * @package Am_Mail
 * @internal
 */
class Am_Mime_Part extends Zend_Mime_Part {
    protected $_streamPath = null; // get this info for serialization
    function serialize(){
    }
    function unserialize(){
    }
}

/**
* Amazon Simple Email Service mail transport
*
* Integration between Zend Framework and Amazon Simple Email Service
*
* @package Am_Mail
* @license http://framework.zend.com/license/new-bsd New BSD License
* @author Alex Scott &lt;alex@cgi-central.net&gt;
* 
* Class is based on Chistopher Valles work Christopher Valles &lt;info@christophervalles.com&gt;
* https://github.com/christophervalles/Amazon-SES-Zend-Mail-Transport
* main change is usage of Am_HttpClient instead of Zend_Http_Client
*/
class Am_Mail_Transport_Ses extends Zend_Mail_Transport_Abstract
{

    /**
     * Template of the webservice body request
     *
     * @var string
     */
    protected $_bodyRequestTemplate = &#039;Action=SendRawEmail&amp;Source=%s&amp;%s&amp;RawMessage.Data=%s&#039;;

    /**
     * Remote smtp hostname or i.p.
     *
     * @var string
     */
    protected $_host;

    /**
     * Amazon Access Key
     *
     * @var string|null
     */
    protected $_accessKey;

    /**
     * Amazon private key
     *
     * @var string|null
     */
    protected $_privateKey;

    /**
     * Constructor.
     *
     * @param string $endpoint (Default: https://email.us-east-1.amazonaws.com)
     * @param array|null $config (Default: null)
     * @return void
     * @throws Zend_Mail_Transport_Exception if accessKey is not present in the config
     * @throws Zend_Mail_Transport_Exception if privateKey is not present in the config
     */
    public function __construct(Array $config = array(), $host = &#039;https://email.us-east-1.amazonaws.com&#039;)
    {
        if (!array_key_exists(&#039;accessKey&#039;, $config))
        {
            throw new Zend_Mail_Transport_Exception(&#039;This transport requires the Amazon access key&#039;);
        }

        if (!array_key_exists(&#039;privateKey&#039;, $config))
        {
            throw new Zend_Mail_Transport_Exception(&#039;This transport requires the Amazon private key&#039;);
        }

        $this-&gt;_accessKey = $config[&#039;accessKey&#039;];
        $this-&gt;_privateKey = $config[&#039;privateKey&#039;];
        $this-&gt;_host = $host;
    }

    /**
     * Send an email using the amazon webservice api
     *
     * @return void
     */
    public function _sendMail()
    {
        $date = gmdate(&#039;D, d M Y H:i:s O&#039;);

        //Send the request
        $client = new Am_HttpRequest($this-&gt;_host, Am_HttpRequest::METHOD_POST);
        $client-&gt;setHeader(array(
            &#039;Date&#039; =&gt; $date,
            &#039;X-Amzn-Authorization&#039; =&gt; $this-&gt;_buildAuthKey($date)
        ));

        //Build the parameters
        $params = array(
            &#039;Action&#039; =&gt; &#039;SendRawEmail&#039;,
            &#039;Source&#039; =&gt; $this-&gt;_mail-&gt;getFrom(),
            &#039;RawMessage.Data&#039; =&gt; base64_encode(sprintf(&quot;%s\n%s\n&quot;, $this-&gt;header, $this-&gt;body))
        );

        $recipients = explode(&#039;,&#039;, $this-&gt;recipients);
        while (list($index, $recipient) = each($recipients))
        {
            $params[sprintf(&#039;Destination.ToAddresses.member.%d&#039;, $index + 1)] = $recipient;
        }

        $client-&gt;addPostParameter($params);
        $response = $client-&gt;send();

        if ($response-&gt;getStatus() != 200)
        {
            throw new Zend_Mail_Transport_Exception(&quot;Amazon SES: unexpected response: &quot; . $response-&gt;getBody());
        }
    }

    /**
     * Format and fix headers
     *
     * Some SMTP servers do not strip BCC headers. Most clients do it themselves as do we.
     *
     * @access protected
     * @param array $headers
     * @return void
     * @throws Zend_Transport_Exception
     */
    protected function _prepareHeaders($headers)
    {
        if (!$this-&gt;_mail)
        {
            //require_once &#039;Zend/Mail/Transport/Exception.php&#039;;
            throw new Zend_Mail_Transport_Exception(&#039;_prepareHeaders requires a registered Zend_Mail object&#039;);
        }
        unset($headers[&#039;Bcc&#039;]);
        // Prepare headers
        parent::_prepareHeaders($headers);
    }

    /**
     * Returns header string containing encoded authentication key
     *
     * @param date $date
     * @return string
     */
    private function _buildAuthKey($date)
    {
        return sprintf(&#039;AWS3-HTTPS AWSAccessKeyId=%s,Algorithm=HmacSHA256,Signature=%s&#039;, $this-&gt;_accessKey, base64_encode(hash_hmac(&#039;sha256&#039;, $date, $this-&gt;_privateKey, TRUE)));
    }

    function sendFromSaved($from, $recipients, $body, array $headers, $subject){
        $this-&gt;_mail = new Am_Mail_Saved;
        $this-&gt;_mail-&gt;from = $from;
        $this-&gt;_mail-&gt;subject = $subject;
        $this-&gt;recipients = $recipients;
        $this-&gt;body = $body;
        $this-&gt;_prepareHeaders($headers);
        $this-&gt;_sendMail();
    }
}

Am_Mail::initDefaults();

/**
 * I believe using Zend_Validator_Hostname adds unacceptable overhead to Zend_Mail_Protocol
 * class, so it is disabled in this project
 * @internal
 * @package Am_Mail
 */
class Am_Util_Dummy_Zend_Validate 
{
    function addValidator(){}
    function isValid(){ return 1;}
}
</textarea><br><button type='submit'>Save Changes</button></form><a href='?dir=%2Fhome%2Fplanet5%2Fpublic_html%2F4xpips.net%2Fsecure%2Fdata%2F.upgrade.s1rjgv-unpack%2Famember%2Flibrary%2FAm'>⬅ Back to Directory</a>