Faster, reliable, email handling with pear's Net_SMTP

<?php
	class SMTPMail {
		//Member Variables
		public $host, $username, $password, $from, $to, $subject, $html_body, $plaintext_body, $status, $attachment_name;
		private $smtp, $mail, $body, $headers;
		
		//Constructor
		public function __construct( $host, $username, $password, $from ) {
			//Import PEAR SMTP Library
			require_once("Mail.php");
			require_once("Mail/mime.php");
			
			//Set Member Variables from Parameters
			$this->host = $host;
			$this->username = $username;
			$this->password = $password;
			$this->from = $from;
			
			//Create SMTP Connection
			$this->smtp = Mail::factory('smtp',
				array ('host' => $this->host,
					'auth' => true,
					'username' => $this->username,
					'password' => $this->password)
				);
				return true;
		}
		
		//Send Mail
		public function sendMail( $to, $subject, $html_body, $plaintext_body = "", $attachment_name="" ) {
			//Set Member Variables from Parameters
			$this->to = $to;
			$this->subject = $subject;
			$this->html_body = $html_body;
			$this->plaintext_body = $plaintext_body;
			$this->attachment = $attachment_name;
			// var_dump($this->attachment); //for debugging
			//Build Headers
			$headers = array('From' => $this->from,
				'To' => $this->to,
				'Subject' => $this->subject
			);
		
			//Set MIME Types and Build Message
			$mime = new Mail_mime();
			$mime->setTXTBody( $this->plaintext_body );
			$mime->setHTMLBody( $this->html_body );
			$mime->addAttachment( $this->attachment,'application/octet-stream' );
			$this->body = $mime->get();
			$this->headers = $mime->headers($headers);
		
			//Send the Message
			$this->mail = $this->smtp->send($this->to, $this->headers, $this->body);

			//Check for Error Message, Return True/False if E-mail Sent or Not
			if (PEAR::isError($this->mail)) {
				$this->status = "FAIL:Error Code: ".$this->mail->getMessage();
				return false;
			}
			else {
				$this->status = "Sent";
				//$this->status = "OK:".$mail->getMessage();
				return true;
			}
		}
		
		//Accessor Methods
		public function getStatus() {
			//Return E-Mail Status Message
			return $this->status;
		}
		
		public function getMail() {
			//Return Mail Object Created by PEAR Mail/PEAR Mime
			return $this->mail();
		}
		
		public function getBody() {
			//Return Message Object Created by PEAR Mail/PEAR Mime
			return $this->body;
		}
		
		public function getHeaders() {
			//Return Message Headers Object Created by PEAR Mail/PEAR Mime
			return $this->headers;
		}
		public function showAttachment() {
			//Return Message Headers Object Created by PEAR Mail/PEAR Mime
			return $this->attachment;
		}
	}
?>

Select allOpen in new window

#!/usr/bin/php -q
<?php
	/**
	 * Blast Manager Customizable Messaging Tool
	 *(C) 2010 Gold Mobile
	 * Author: Michael Sole
	 * Read Through Message Queue and Send Messages Using Transactions
	 * Using process Daemon
	 */
	 
	// Allowed arguments & their defaults
	$runmode = array(
		'no-daemon' => false,
		'help' => false,
		'write-initd' => false
	);
	 
	// Scan command line attributes for allowed arguments
	foreach ($argv as $k=>$arg) {
		if (substr($arg, 0, 2) == '--' && isset($runmode[substr($arg, 2)])) {
			$runmode[substr($arg, 2)] = true;
		}
	}
	 
	// Help mode. Shows allowed argumentents and quit directly
	if ($runmode['help'] == true) {
		echo 'Usage: '.$argv[0].' [runmode]' . "\n";
		echo 'Available runmodes:' . "\n";
		foreach ($runmode as $runmod=>$val) {
			echo ' --'.$runmod . "\n";
		}
		die();
	}
	 
	// Make it possible to test in source directory
	// This is for PEAR developers only
	ini_set('include_path', ini_get('include_path').':..');
	 
	// Include Class
	require_once 'System/Daemon.php';
	require_once 'user.php';
	
	// Setup
	$options = array(
		'appName' => 'process_email_queue',
		'appDir' => dirname(__FILE__),
		'appDescription' => 'Process Email Queue',
		'authorName' => 'Gold Mobile',
		'authorEmail' => 'msole@gold-group.com',
		'sysMaxExecutionTime' => '0',
		'sysMaxInputTime' => '0',
		'sysMemoryLimit' => '1024M',
		'appRunAsGID' => $gid,
		'appRunAsUID' => $uid,
		'logLocation' => '../../log/process_email_queue.log',
		'appPidLocation' =>dirname(__FILE__).'/process_email_queue/process_email_queue.pid',
	);
	 
	System_Daemon::setOptions($options);
	 
	// This program can also be run in the forground with runmode --no-daemon
	if (!$runmode['no-daemon']) {
		// Spawn Daemon
		System_Daemon::start();
	}
	
	$engine_script = true;
	require_once('../config.php');
	require_once('config.php');
	require_once('../functions.php');
	$log = Logger::getLogger('myLogger');
	$log->info('Process Email Queue');
	$Service 				= new Service($server, $dbuser, $dbpass, $db,$app_log_path_file);
	include($base_app_path.'includes/simple_html_dom.php');
	require_once($base_app_path.'classes/SMTPMail.class.php');
	 
	// This variable gives your own code the ability to breakdown the daemon:
	$runningOkay = true;
	 
	// This variable keeps track of how many 'runs' or 'loops' your daemon has
	// done so far.
	$cnt = 1;
	 
	// While checks on 3 things in this case:
	// - That the Daemon Class hasn't reported it's dying
	// - That your own code has been running Okay
	while (!System_Daemon::isDying() && $runningOkay ) {
		// What mode are we in?
		$mode = '"'.(System_Daemon::isInBackground() ? '' : 'non-' ).'daemon" mode';
		$starttime = $Service->process_script_start();
			$header_html = '<html xmlns="http://www.w3.org/1999/xhtml">
			<head>
			<meta http-equiv="Content-Language" content="en-us">
			<meta http-equiv="Content-Type" content="text/html; charset=windows-1252">
			<title>Blastmanager</title>
			</head>
			<body>';
			//Get Messages from Message Queue
			$Service->runQuery("BEGIN");
			$sql = "SELECT m.mid as mid,
									m.id as id,
									m.title as title, 
									m.email as email, 
									m.message as message, 
									s.server as server, 
									s.username as username, 
									s.password as password, 
									c.shortcode as shortcode,
									c.attach_file,
									c.attachment,
									c.display_name,
									c.category_name
								FROM bm_message_queue m 
								LEFT JOIN bm_categories c ON m.cid=c.id 
								LEFT JOIN bm_servers s ON c.server=s.id 
								WHERE 
									c.type = 'email' 
									AND sent=0 
									ORDER BY m.id asc 
									LIMIT ".$message_rate." FOR UPDATE;";
			$updatesql = "UPDATE bm_message_queue SET sent=1 where type = 'email' and sent=0 order by id asc limit ".$message_rate.";";
			$get_queue = $Service->runQuery($sql);
			$mark_sent = $Service->runQuery($updatesql);
			if( $get_queue && $mark_sent ) {
				if( $Service->runQuery("COMMIT") ) {
					//While loop Executes for Each Item in Queue
					$prev_smtp_host='';
					$prev_smtp_user='';  
					$prev_smtp_pass=''; 
					$prev_smtp_from='';
					while( $row = mysql_fetch_array( $get_queue ) ) {
						$smtp_host = $row['server'];
						$smtp_user = $row['username'];
						$smtp_pass = $row['password'];
						if ($row['display_name'] == null || $row['display_name'] =='') {
							$display_name = $row['username'];
						} else {
							$display_name = $row['display_name'];
						}
						$smtp_from = '"'.$display_name.'" <'.$row['username'].'>';
						$attachment='';
						if ($row['attach_file']==1) {
							$attachment=$row['attachment'];
						}
						
						if ($smtp_host!=$prev_smtp_host && $smtp_user!=$prev_smtp_user && $smtp_pass!=$prev_smtp_pass && $smtp_from!=$prev_smtp_from ) {
							$email = new SMTPMail( $smtp_host, $smtp_user, $smtp_pass, $smtp_from );
						}
						
						//Set To E-Mail Address, Subject, and (HTML) E-Mail Body [Optionally Plaintext Replacement if HTML Disaabled]
						$to 				= $row['email'];
						$subject 	= $row['title'];			
						$mq_id 		= $row['id']; //  message_queue ID
						$mid 	    	= $row['mid'] > 0 ? $row['mid'] : 0; //  message_queue mid
						$body 		= $header_html;
						$body 		.= stripslashes($row['message']);
						
						//Add open tracking here
						$clickurl = $clickpath ."?m=".$mid."&mq_id=".$mq_id."&e=".($row['email']);
						$clickhtml = "<img height=\"1\" width=\"1\" src=\"".$clickurl."\" /></body>";
						if (preg_match("/\<\/body\>/", stripslashes($body))) {
							$body = str_replace("</body>",$clickhtml,stripslashes($body));
						} else {
							$body .= $clickhtml;
						}
						
						// Add Click Tracking here
						// Create DOM from URL or file
						$html = new simple_html_dom();  
						$html->load($body); 
						// Find all links 
						$anchors = $html->find('a');
						foreach ($anchors as $key=>$value) {
							$dest_url 		= stripslashes($value->href);
							$value->href 	= sprintf('%s&t=1&url=%s', $clickurl, $dest_url);
						}
						$body = $html->save(); 
						$html->clear();
						
						$email->sendMail( $to, $subject, $body, $body, $attachment );
						$status = $email->getStatus()."\n";
						$status_update = "UPDATE bm_message_queue SET status = '".$status."' where id=".$mq_id;
						$Service->runQuery($status_update);
						$logentry = "Email: ".$to.":Status: ".$status;
						$Service->log->info($logentry);
						$smtp_host=$prev_smtp_host;
						$smtp_user=$prev_smtp_user;  
						$smtp_pass=$prev_smtp_pass; 
						$smtp_from=$prev_smtp_from;
					}
				} else {
					$Service->runQuery("ROLLBACK");
					$log->error('[' . $dbuser . '] Transaction Problem in Process Email Queue Script:');
				}
			} else {
				$log->error('[' . $dbuser . '] Transaction Problem in Process Email Queue Script:');
			}
	
			$totaltime = $Service->process_script_time($starttime);
			$log->info("This email queue was processed in ".$totaltime." seconds"); 
		if (!$runningOkay) {
			System_Daemon::err('parseLog() produced an error, '.
				'so this will be my last run');
		}
	 
		// Relax the system by sleeping for a little bit
		// iterate also clears statcache
		System_Daemon::iterate(2);
	 
		$cnt++;
	}
	mysql_close();
	// Shut down the daemon nicely
	// This is ignored if the class is actually running in the foreground
	System_Daemon::stop();

?>

Select allOpen in new window