e107inc/e107

View on GitHub
e107_handlers/mail_validation_class.php

Summary

Maintainability
A
1 hr
Test Coverage
F
0%
<?php

if (!defined('e107_INIT')) { exit; }

/* Manuel Lemos's PHP E-mail validation class
 * http://freshmeat.net/projects/emailaddressvalidationcomponent/
 * email_validation.php
 *
 * @(#) $Header: /cvs_backup/e107_0.8/e107_handlers/mail_validation_class.php,v 1.1.1.1 2006-12-02 04:33:46 mcfly_e107 Exp $
 *
 */


/**
 *
 */
class email_validation_class
{
    var $email_regular_expression="^([-!#\$%&'*+./0-9=?A-Z^_`a-z{|}~])+@([-!#\$%&'*+/0-9=?A-Z^_`a-z{|}~]+\\.)+[a-zA-Z]{2,6}\$";
    var $timeout=0;
    var $data_timeout=0;
    var $localhost="";
    var $localuser="";
    var $debug=0;
    var $html_debug=0;
    var $exclude_address="";
    var $getmxrr="GetMXRR";

    var $next_token="";
    var $preg;
    var $last_code="";

    /**
     * @param $string
     * @param $separator
     * @return mixed|string
     */
    Function Tokenize($string, $separator="")
    {
        if(!strcmp($separator,""))
        {
            $separator=$string;
            $string=$this->next_token;
        }
        for($character=0, $characterMax = strlen($separator); $character< $characterMax; $character++)
        {
            if(GetType($position=strpos($string,$separator[$character]))=="integer")
                $found=(IsSet($found) ? min($found,$position) : $position);
        }
        if(IsSet($found))
        {
            $this->next_token=substr($string,$found+1);
            return(substr($string,0,$found));
        }
        else
        {
            $this->next_token="";
            return($string);
        }
    }

    /**
     * @param $message
     * @return void
     */
    Function OutputDebug($message)
    {
        $message.="\n";
        if($this->html_debug)
            $message=str_replace("\n","<br />\n",HtmlEntities($message));
        echo $message;
        flush();
    }

    /**
     * @param $connection
     * @return int|string
     */
    Function GetLine($connection)
    {
        for($line="";;)
        {
            if(feof($connection))
                return(0);
            $line.=fgets($connection,100);
            $length=strlen($line);
            if($length>=2
            && substr($line,$length-2,2)=="\r\n")
            {
                $line=substr($line,0,$length-2);
                if($this->debug)
                    $this->OutputDebug("S $line");
                return($line);
            }
        }
    }

    /**
     * @param $connection
     * @param $line
     * @return false|int
     */
    Function PutLine($connection, $line)
    {
        if($this->debug)
            $this->OutputDebug("C $line");
        return(fwrite($connection,"$line\r\n"));
    }

    /**
     * @param $email
     * @return false|int
     */
    Function ValidateEmailAddress($email)
    {
        if(IsSet($this->preg))
        {
            if(strlen($this->preg))
                return(preg_match($this->preg,$email));
        }
        else
        {
            $this->preg=(function_exists("preg_match") ? "/".str_replace("/", "\\/", $this->email_regular_expression)."/" : "");
            return($this->ValidateEmailAddress($email));
        }
        return(preg_match("/".str_replace("/", "\\/", $this->email_regular_expression)."/i", $email)/*!=0*/);
    }

    /**
     * @param $email
     * @param $hosts
     * @return bool|int
     */
    Function ValidateEmailHost($email, &$hosts)
    {
        if(!$this->ValidateEmailAddress($email))
            return(0);
        $user=$this->Tokenize($email,"@");
        $domain=$this->Tokenize("");
        $hosts=$weights=array();
        $getmxrr=$this->getmxrr;
        if(function_exists($getmxrr)
        && $getmxrr($domain,$hosts,$weights))
        {
            $mxhosts=array();
            for($host=0, $hostMax = count($hosts); $host< $hostMax; $host++)
                $mxhosts[$weights[$host]]=$hosts[$host];
            KSort($mxhosts);
            for(Reset($mxhosts), $host=0, $hostMax = count($mxhosts); $host< $hostMax; Next($mxhosts), $host++)
                $hosts[$host]=$mxhosts[Key($mxhosts)];
        }
        else
        {
            if(strcmp($ip=@gethostbyname($domain),$domain)
            && (strlen($this->exclude_address)==0
            || strcmp(@gethostbyname($this->exclude_address),$ip)))
                $hosts[]=$domain;
        }
        return(count($hosts)!=0);
    }

    /**
     * @param $connection
     * @param $code
     * @return int
     */
    Function VerifyResultLines($connection, $code)
    {
        while(($line=$this->GetLine($connection)))
        {
            $this->last_code=$this->Tokenize($line," -");
            if(strcmp($this->last_code,$code))
                return(0);
            if(!strcmp(substr($line, strlen($this->last_code), 1)," "))
                return(1);
        }
        return(-1);
    }

    /**
     * @param $email
     * @return bool|int
     */
    Function ValidateEmailBox($email)
    {
        if(!$this->ValidateEmailHost($email,$hosts))
            return(0);
        if(!strcmp($localhost=$this->localhost,"")
        && !strcmp($localhost=getenv("SERVER_NAME"),"")
        && !strcmp($localhost=getenv("HOST"),""))
           $localhost="localhost";
        if(!strcmp($localuser=$this->localuser,"")
        && !strcmp($localuser=getenv("USERNAME"),"")
        && !strcmp($localuser=getenv("USER"),""))
           $localuser="root";
        for($host=0, $hostMax = count($hosts); $host< $hostMax; $host++)
        {
            $domain=$hosts[$host];
            if(preg_match('/^[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}$/',$domain))
                $ip=$domain;
            else
            {
                if($this->debug)
                    $this->OutputDebug("Resolving host name \"".$hosts[$host]."\"...");
                if(!strcmp($ip=@gethostbyname($domain),$domain))
                {
                    if($this->debug)
                        $this->OutputDebug("Could not resolve host name \"".$hosts[$host]."\".");
                    continue;
                }
            }
            if(strlen($this->exclude_address)
            && !strcmp(@gethostbyname($this->exclude_address),$ip))
            {
                if($this->debug)
                    $this->OutputDebug("Host address of \"".$hosts[$host]."\" is the exclude address");
                continue;
            }
            if($this->debug)
                $this->OutputDebug("Connecting to host address \"".$ip."\"...");
            if(($connection=($this->timeout ? @fsockopen($ip,25,$errno,$error,$this->timeout) : @fsockopen($ip,25))))
            {
                $timeout=($this->data_timeout ? $this->data_timeout : $this->timeout);
                if($timeout
                && function_exists("socket_set_timeout"))
                    stream_set_timeout($connection,$timeout,0);
                if($this->debug)
                    $this->OutputDebug("Connected.");
                if($this->VerifyResultLines($connection,"220")>0
                && $this->PutLine($connection,"HELO $localhost")
                && $this->VerifyResultLines($connection,"250")>0
                && $this->PutLine($connection,"MAIL FROM: <$localuser@$localhost>")
                && $this->VerifyResultLines($connection,"250")>0
                && $this->PutLine($connection,"RCPT TO: <$email>")
                && ($result=$this->VerifyResultLines($connection,"250"))>=0)
                {
                    if($result)
                    {
                        if($this->PutLine($connection,"DATA"))
                            $result=($this->VerifyResultLines($connection,"354")!=0);
                    }
                    else
                    {
                        if(strlen($this->last_code)
                        && !strcmp($this->last_code[0],"4"))
                            $result=-1;
                    }
                    if($this->debug)
                        $this->OutputDebug("This host states that the address is ".($result ? ($result>0 ? "valid" : "undetermined") : "not valid").".");
                    $this->PutLine($connection,"QUIT");
                    fclose($connection);
                    if($this->debug)
                        $this->OutputDebug("Disconnected.");
                    return($result);
                }
                if($this->debug)
                    $this->OutputDebug("Unable to validate the address with this host.");
                fclose($connection);
                if($this->debug)
                    $this->OutputDebug("Disconnected.");
            }
            else
            {
                if($this->debug)
                    $this->OutputDebug("Failed.");
            }
        }
        return(-1);
    }
};