test_smtp.php<?require("smtp.php");$smtp=new smtp_class;$smtp->host_name="mail.xiaocui.com";$smtp->localhost="localhost";$from="webmaster@xiaocui.com";$to="root@xiaocui.com";if($smtp->SendMessage( $from, array( $to ), array( "From: $from", "To: $to", "Subject: Testing Manuel Lemos" SMTP class" ), "Hello $to,It is just to let you know that your SMTP class is working just fine.Bye.")) echo "Message sent to $to OK.";else echo "Cound not send the message to $to.Error: ".$smtp->error.""?>smtp.php<?class smtp_class{var $host_name="";var $host_port=25;var $localhost="";var $timeout=0;var $error="";var $debug=1;var $esmtp=1;var $esmtp_host="";var $esmtp_extensions=array();var $maximum_piped_recipients=100;/* private variables - DO NOT ACCESS */var $state="Disconnected";var $connection=0;var $pending_recipients=0;/* Private methods - DO NOT CALL */Function OutputDebug($message){ echo $message,"<br>";}Function GetLine(){ for($line="";;) { if(feof($this->connection)) { $this->error="reached the end of stream while reading from socket"; return(0); } if(($data=fgets($this->connection,100))==false) { $this->error="it was not possible to read line from socket"; return(0); } $line.=$data; $length=strlen($line); if($length>=2 && substr($line,$length-2,2)=="") { $line=substr($line,0,$length-2); if($this->debug) $this->OutputDebug("< $line"); return($line); } }}Function PutLine($line){ if($this->debug) $this->OutputDebug("> $line"); if(!fputs($this->connection,"$line")) { $this->error="it was not possible to write line to socket"; return(0); } return(1);}Function PutData($data){ if(strlen($data)) { if($this->debug) $this->OutputDebug("> $data"); if(!fputs($this->connection,$data)) { $this->error="it was not possible to write data to socket"; return(0); } } return(1);}Function VerifyResultLines($code,$responses=""){ if(GetType($responses)!="array") $responses=array(); Unset($match_code); while(($line=$this->GetLine($this->connection))) { if(IsSet($match_code)) { if(strcmp(strtok($line," -"),$match_code)) { $this->error=$line; return(0); } } else { $match_code=strtok($line," -"); if(GetType($code)=="array") { for($codes=0;$codes<count($code) && strcmp($match_code,$code[$codes]);$codes++); if($codes>=count($code)) { $this->error=$line; return(0); } } else { if(strcmp($match_code,$code)) { $this->error=$line; return(0); } } } $responses[]=strtok(""); if(!strcmp($match_code,strtok($line," "))) return(1); } return(-1);}Function FlushRecipients(){ if($this->pending_sender) { if($this->VerifyResultLines("250")<=0) return(0); $this->pending_sender=0; } for(;$this->pending_recipients;$this->pending_recipients--) { if($this->VerifyResultLines(array("250","251"))<=0) return(0); } return(1);}/* Public methods */Function Connect(){ $this->error=$error=""; $this->esmtp_host=""; $this->esmtp_extensions=array(); if(!($this->connection=($this->timeout ? fsockopen($this->host_name,$this->host_port,&$errno,&$error,$this->timeout) : fsockopen($this->host_name,$this->host_port)))) { switch($error) { case -3: $this->error="-3 socket could not be created"; return(0); case -4: $this->error="-4 dns lookup on hostname "".$host_name."" failed"; return(0); case -5: $this->error="-5 connection refused or timed out"; return(0); case -6: $this->error="-6 fdopen() call failed"; return(0); case -7: $this->error="-7 setvbuf() call failed"; return(0); default: $this->error=$error." could not connect to the host "".$this->host_name."""; return(0); } } else { if(!strcmp($localhost=$this->localhost,"") && !strcmp($localhost=getenv("SERVER_NAME"),"") && !strcmp($localhost=getenv("HOST"),"")) $localhost="localhost"; $success=0; if($this->VerifyResultLines("220")>0) { if($this->esmtp) { $responses=array(); if($this->PutLine("EHLO $localhost") && $this->VerifyResultLines("250",&$responses)>0) { $this->esmtp_host=strtok($responses[0]," "); for($response=1;$response<count($responses);$response++) { $extension=strtoupper(strtok($responses[$response]," ")); $this->esmtp_extensions[$extension]=strtok(""); } $success=1; } } if(!$success && $this->PutLine("HELO $localhost") && $this->VerifyResultLines("250")>0) $success=1; } if($success) { $this->state="Connected"; return(1); } else { fclose($this->connection); $this->connection=0; $this->state="Disconnected"; return(0); } }}Function MailFrom($sender){ if(strcmp($this->state,"Connected")) { $this->error="connection is not in the initial state"; return(0); } $this->error=""; if(!$this->PutLine("MAIL FROM: <".$sender.">")) return(0); if(!IsSet($this->esmtp_extensions["PIPELINING"]) && $this->VerifyResultLines("250")<=0) return(0); $this->state="SenderSet"; if(IsSet($this->esmtp_extensions["PIPELINING"])) $this->pending_sender=1; $this->pending_recipients=0; return(1);}Function SetRecipient($recipient){ switch($this->state) { case "SenderSet": case "RecipientSet": break; default: $this->error="connection is not in the recipient setting state"; return(0); } $this->error=""; if(!$this->PutLine("RCPT TO:<".$recipient.">")) return(0); if(IsSet($this->esmtp_extensions["PIPELINING"])) { $this->pending_recipients++; if($this->pending_recipients>=$this->maximum_piped_recipients) { if(!$this->FlushRecipients()) return(0); } } else { if($this->VerifyResultLines(array("250","251"))<=0) return(0); } $this->state="RecipientSet"; return(1);}Function StartData(){ if(strcmp($this->state,"RecipientSet")) { $this->error="connection is not in the start sending data state"; return(0); } $this->error=""; if(!$this->PutLine("DATA")) return(0); if($this->pending_recipients) { if(!$this->FlushRecipients()) return(0); } if($this->VerifyResultLines("354")<=0) return(0); $this->state="SendingData"; return(1);}Function PrepareData($data,&$output){ $length=strlen(&$data); for($output="",$position=0;$position<$length;) { $next_position=$length; for($current=$position;$current<$length;$current++) { switch($data[$current]) { case "": $next_position=$current+1; break 2; case "": $next_position=$current+1; if($data[$next_position]=="") $next_position++; break 2; } } if($data[$position]==".") $output.="."; $output.=substr(&$data,$position,$current-$position).""; $position=$next_position; }}Function SendData($data){ if(strcmp($this->state,"SendingData")) { $this->error="connection is not in the sending data state"; return(0); } $this->error=""; return($this->PutData(&$data));}Function EndSendingData(){ if(strcmp($this->state,"SendingData")) { $this->error="connection is not in the sending data state"; return(0); } $this->error=""; if(!$this->PutLine(".") || $this->VerifyResultLines("250")<=0) return(0); $this->state="Connected"; return(1);}Function ResetConnection(){ switch($this->state) { case "Connected": return(1); case "SendingData": $this->error="can not reset the connection while sending data"; return(0); case "Disconnected": $this->error="can not reset the connection before it is established"; return(0); } $this->error=""; if(!$this->PutLine("RSET") || $this->VerifyResultLines("250")<=0) return(0); $this->state="Connected"; return(1);}Function Disconnect($quit=1){ if(!strcmp($this->state,"Disconnected")) { $this->error="it was not previously established a SMTP connection"; return(0); } $this->error=""; if(!strcmp($this->state,"Connected") && $quit && (!$this->PutLine("QUIT") || $this->VerifyResultLines("221")<=0)) return(0); fclose($this->connection); $this->connection=0; $this->state="Disconnected"; return(1);}Function SendMessage($sender,$recipients,$headers,$body){ if(($success=$this->Connect())) { if(($success=$this->MailFrom($sender))) { for($recipient=0;$recipient<count($recipients);$recipient++) { if(!($success=$this->SetRecipient($recipients[$recipient]))) break; } if($success && ($success=$this->StartData())) { for($header_data="",$header=0;$header<count($headers);$header++) $header_data.=$headers[$header].""; if(($success=$this->SendData($header_data.""))) { $this->PrepareData($body,&$body_data); $success=$this->SendData($body_data); } if($success) $success=$this->EndSendingData(); } } $disconnect_success=$this->Disconnect($success); if($success) $success=$disconnect_success; } return($success);}};?>
