$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,nnIt is just to let you know that your SMTP class is working just fine.nnBye.n")) echo "Message sent to $to OK.n"; else echo "Cound not send the message to $to.nError: ".$smtp->error."n" ?>
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;
var $state="Disconnected"; var $connection=0; var $pending_recipients=0;
/* Private methods - DO NOT CALL */
Function OutputDebug($message) { echo $message," n"; }
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)=="rn") { $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,"$linern")) { $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);
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 { $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 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("rn.") || $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); }
