Category

Development Platform
Home > SourceCode/Document > Internet-Socket-Network > WEB Mail > View Code
http.class.php
Package: Generateur_v13.rar　[view]
Upload User: feiyaoda
Upload Date: 2016-11-21
Package Size: 9556k
Code Size: 20k
Category:

WEB Mail

Development Platform:

PHP

http.class.php：Code Content
  1. <?php
  2. /*
  3.  * http.php
  4.  *
  5.  * @(#) $Header: /home/mlemos/cvsroot/PHPlibrary/http.php,v 1.7 2002/01/12 02:39:57 mlemos Exp $
  6.  *
  7.  */
  9. class http_class
  10. {
  11.     var $host_name="";
  12.     var $host_port=80;
  13.     var $proxy_host_name="";
  14.     var $proxy_host_port=80;
  16.     var $request_method="GET";
  17.     var $user_agent="Manuel Lemos HTTP class test script";
  18.     var $request_uri="";
  19.     var $protocol_version="1.0";
  20.     var $debug=0;
  21.     var $support_cookies=1;
  22.     var $cookies=array();
  24.     /* private variables - DO NOT ACCESS */
  26.     var $state="Disconnected";
  27.     var $connection=0;
  28.     var $content_length=0;
  29.     var $read_length=0;
  30.     var $request_host="";
  31.     var $next_token="";
  32.     var $months=array(
  33.         "Jan"=>"01",
  34.         "Feb"=>"02",
  35.         "Mar"=>"03",
  36.         "Apr"=>"04",
  37.         "May"=>"05",
  38.         "Jun"=>"06",
  39.         "Jul"=>"07",
  40.         "Aug"=>"08",
  41.         "Sep"=>"09",
  42.         "Oct"=>"10",
  43.         "Nov"=>"11",
  44.         "Dec"=>"12");
  46.     /* Private methods - DO NOT CALL */
  48.     Function Tokenize($string,$separator="")
  49.     {
  50.         if(!strcmp($separator,""))
  51.         {
  52.             $separator=$string;
  53.             $string=$this->next_token;
  54.         }
  55.         for($character=0;$character<strlen($separator);$character++)
  56.         {
  57.             if(GetType($position=strpos($string,$separator[$character]))=="integer")
  58.                 $found=(IsSet($found) ? min($found,$position) : $position);
  59.         }
  60.         if(IsSet($found))
  61.         {
  62.             $this->next_token=substr($string,$found+1);
  63.             return(substr($string,0,$found));
  64.         }
  65.         else
  66.         {
  67.             $this->next_token="";
  68.             return($string);
  69.         }
  70.     }
  72.     Function OutputDebug($message)
  73.     {
  74.         echo $message,"n";
  75.     }
  77.     Function GetLine()
  78.     {
  79.         for($line="";;)
  80.         {
  81.             if(feof($this->connection)
  82.             || !($part=fgets($this->connection,100)))
  83.                 return(0);
  84.             $line.=$part;
  85.             $length=strlen($line);
  86.             if($length>=2
  87.             && substr($line,$length-2,2)=="rn")
  88.             {
  89.                 $line=substr($line,0,$length-2);
  90.                 if($this->debug)
  91.                     $this->OutputDebug("< $line");
  92.                 return($line);
  93.             }
  94.         }
  95.     }
  97.     Function PutLine($line)
  98.     {
  99.         if($this->debug)
  100.             $this->OutputDebug("> $line");
  101.         return(fputs($this->connection,"$linern"));
  102.     }
  104.     Function PutData($data)
  105.     {
  106.         if($this->debug)
  107.             $this->OutputDebug("> $data");
  108.         return(fputs($this->connection,$data));
  109.     }
  111.     Function Readbytes($length)
  112.     {
  113.         if($this->debug)
  114.         {
  115.             if(($bytes=fread($this->connection,$length))!="")
  116.                 $this->OutputDebug("< $bytes");
  117.             return($bytes);
  118.         }
  119.         else
  120.             return(fread($this->connection,$length));
  121.     }
  123.     Function EndOfInput()
  124.     {
  125.         return(feof($this->connection));
  126.     }
  128.     Function Connect($host_name,$host_port)
  129.     {
  130.         if($this->debug)
  131.             $this->OutputDebug("Connecting to $host_name...");
  132.         if(($this->connection=fsockopen($host_name,$host_port,&$error))==0)
  133.         {
  134.             switch($error)
  135.             {
  136.                 case -3:
  137.                     return("-3 socket could not be created");
  138.                 case -4:
  139.                     return("-4 dns lookup on hostname "".$host_name."" failed");
  140.                 case -5:
  141.                     return("-5 connection refused or timed out");
  142.                 case -6:
  143.                     return("-6 fdopen() call failed");
  144.                 case -7:
  145.                     return("-7 setvbuf() call failed");
  146.                 default:
  147.                     return($error." could not connect to the host "".$host_name.""");
  148.             }
  149.         }
  150.         else
  151.         {
  152.             if($this->debug)
  153.                 $this->OutputDebug("Connected to $host_name");
  154.             $this->state="Connected";
  155.             return("");
  156.         }
  157.     }
  159.     Function Disconnect()
  160.     {
  161.         if($this->debug)
  162.             $this->OutputDebug("Disconnected from ".$this->host_name);
  163.         fclose($this->connection);
  164.         return("");
  165.     }
  167.     /* Public methods */
  169.     Function Open($arguments)
  170.     {
  171.         if($this->state!="Disconnected")
  172.             return("1 already connected");
  173.         if(IsSet($arguments["HostName"]))
  174.             $this->host_name=$arguments["HostName"];
  175.         if(IsSet($arguments["HostPort"]))
  176.             $this->host_port=$arguments["HostPort"];
  177.         if(IsSet($arguments["ProxyHostName"]))
  178.             $this->proxy_host_name=$arguments["ProxyHostName"];
  179.         if(IsSet($arguments["ProxyHostPort"]))
  180.             $this->proxy_host_port=$arguments["ProxyHostPort"];
  181.         if(strlen($this->proxy_host_name)==0)
  182.         {
  183.             if(strlen($this->host_name)==0)
  184.                 return("2 it was not specified a valid hostname");
  185.             $host_name=$this->host_name;
  186.             $host_port=$this->host_port;
  187.         }
  188.         else
  189.         {
  190.             $host_name=$this->proxy_host_name;
  191.             $host_port=$this->proxy_host_port;
  192.         }
  193.         $error=$this->Connect($host_name,$host_port);
  194.         if(strlen($error)==0)
  195.             $this->state="Connected";
  196.         return($error);
  197.     }
  199.     Function Close()
  200.     {
  201.         if($this->state=="Disconnected")
  202.             return("1 already disconnected");
  203.         $error=$this->Disconnect();
  204.         if(strlen($error)==0)
  205.             $this->state="Disconnected";
  206.         return($error);
  207.     }
  209.     Function SendRequest($arguments)
  210.     {
  211.         switch($this->state)
  212.         {
  213.             case "Disconnected":
  214.                 return("1 connection was not yet established");
  215.             case "Connected":
  216.                 break;
  217.             default:
  218.                 return("2 can not send request in the current connection state");
  219.         }
  220.         if(IsSet($arguments["RequestMethod"]))
  221.             $this->request_method=$arguments["RequestMethod"];
  222.         if(IsSet($arguments["User-Agent"]))
  223.             $this->user_agent=$arguments["User-Agent"];
  224.         if(strlen($this->request_method)==0)
  225.             return("3 it was not specified a valid request method");
  226.         if(IsSet($arguments["RequestURI"]))
  227.             $this->request_uri=$arguments["RequestURI"];
  228.         if(strlen($this->request_uri)==0
  229.         || substr($this->request_uri,0,1)!="/")
  230.             return("4 it was not specified a valid request URI");
  231.         $request_body="";
  232.         $headers=(IsSet($arguments["Headers"]) ? $arguments["Headers"] : array());
  233.         if($this->request_method=="POST")
  234.         {
  235.             if(IsSet($arguments["PostValues"]))
  236.             {
  237.                 $values=$arguments["PostValues"];
  238.                 if(GetType($values)!="array")
  239.                     return("5 it was not specified a valid POST method values array");
  240.                 for($request_body="",Reset($values),$value=0;$value<count($values);Next($values),$value++)
  241.                 {
  242.                     if($value>0)
  243.                         $request_body.="&";
  244.                     $request_body.=Key($values)."=".UrlEncode($values[Key($values)]);
  245.                 }
  246.                 $headers["Content-type"]="application/x-www-form-urlencoded";
  247.             }
  248.             else
  249.             {
  250.                 if(IsSet($arguments["Body"]))
  251.                     $request_body=$arguments["Body"];
  252.             }
  253.         }
  254.         if(strlen($this->proxy_host_name)==0)
  255.             $request_uri=$this->request_uri;
  256.         else
  257.             $request_uri="http://".$this->host_name.($this->host_port==80 ? "" : ":".$this->host_port).$this->request_uri;
  258.         
  259.         // added
  260.         $this->log_sending_data[] = $this->request_method." ".$request_uri." HTTP/".$this->protocol_version;
  261.         if(($success=$this->PutLine($this->request_method." ".$request_uri." HTTP/".$this->protocol_version)))
  262.         {
  263.             if(($body_length=strlen($request_body)))
  264.                 $headers["Content-length"]=$body_length;
  265.             for($host_set=0,Reset($headers),$header=0;$header<count($headers);Next($headers),$header++)
  266.             {
  267.                 $header_name=Key($headers);
  268.                 $header_value=$headers[$header_name];
  269.                 if(GetType($header_value)=="array")
  270.                 {
  271.                     for(Reset($header_value),$value=0;$value<count($header_value);Next($header_value),$value++)
  272.                     {
  273.                         // added
  274.                         $this->log_sending_data[] = "$header_name: ".$header_value[Key($header_value)];
  275.                         if(!$success=$this->PutLine("$header_name: ".$header_value[Key($header_value)]))
  276.                             break 2;
  277.                     }
  278.                 }
  279.                 else
  280.                 {
  281.                     // added
  282.                     $this->log_sending_data[] = "$header_name: $header_value";
  283.                     
  284.                     if(!$success=$this->PutLine("$header_name: $header_value"))
  285.                         break;
  286.                 }
  287.                 if(strtolower(Key($headers))=="host")
  288.                 {
  289.                     $this->request_host=strtolower($header_value);
  290.                     $host_set=1;
  291.                 }
  292.             }
  293.             if($success)
  294.             {
  295.                 if(!$host_set)
  296.                 {
  297.                     // added
  298.                     $this->log_sending_data[] = "Host: ".$this->host_name;                    
  299.                     $success=$this->PutLine("Host: ".$this->host_name);
  300.                     $this->request_host=strtolower($this->host_name);
  301.                 }
  302.                 if(count($this->cookies)
  303.                 && IsSet($this->cookies[0]))
  304.                 {
  305.                     $now=gmdate("Y-m-d H-i-s");
  306.                     for($cookies=array(),$domain=0,Reset($this->cookies[0]);$domain<count($this->cookies[0]);Next($this->cookies[0]),$domain++)
  307.                     {
  308.                         $domain_pattern=Key($this->cookies[0]);
  309.                         $match=strlen($this->request_host)-strlen($domain_pattern);
  310.                         if($match>=0
  311.                         && !strcmp($domain_pattern,substr($this->request_host,$match))
  312.                         && ($match==0
  313.                         || $domain_pattern[0]=="."
  314.                         || $this->request_host[$match-1]=="."))
  315.                         {
  316.                             for(Reset($this->cookies[0][$domain_pattern]),$path_part=0;$path_part<count($this->cookies[0][$domain_pattern]);Next($this->cookies[0][$domain_pattern]),$path_part++)
  317.                             {
  318.                                 $path=Key($this->cookies[0][$domain_pattern]);
  319.                                 if(strlen($this->request_uri)>=strlen($path)
  320.                                 && substr($this->request_uri,0,strlen($path))==$path)
  321.                                 {
  322.                                     for(Reset($this->cookies[0][$domain_pattern][$path]),$cookie=0;$cookie<count($this->cookies[0][$domain_pattern][$path]);Next($this->cookies[0][$domain_pattern][$path]),$cookie++)
  323.                                     {
  324.                                         $cookie_name=Key($this->cookies[0][$domain_pattern][$path]);
  325.                                         $expires=$this->cookies[0][$domain_pattern][$path][$cookie_name]["expires"];
  326.                                         if($expires==""
  327.                                         || strcmp($now,$expires)<0)
  328.                                             $cookies[$cookie_name]=$this->cookies[0][$domain_pattern][$path][$cookie_name];
  329.                                     }
  330.                                 }
  331.                             }
  332.                         }
  333.                     }
  334.                     for(Reset($cookies),$cookie=0;$cookie<count($cookies);Next($cookies),$cookie++)
  335.                     {
  336.                         $cookie_name=Key($cookies);
  337.                         // added
  338.                         $this->log_sending_data[] = "Cookie: ".UrlEncode($cookie_name)."=".$cookies[$cookie_name]["value"].";";                           
  339.                         if(!($success=$this->PutLine("Cookie: ".UrlEncode($cookie_name)."=".$cookies[$cookie_name]["value"].";")))
  340.                             break;
  341.                     }
  342.                 }
  343.                 if($success)
  344.                 {
  345.                     if($success)
  346.                     {
  347.                         // added
  348.                         $this->log_sending_data[] = "";                                                   
  349.                         $success=$this->PutLine("");
  350.                         $this->log_sending_data[] = $request_body;
  351.                         if($body_length
  352.                         && $success)
  353.                             $success=$this->PutData($request_body);
  354.                     }
  355.                 }
  356.             }
  357.         }
  358.         if(!$success)
  359.             return("5 could not send the HTTP request");
  360.         $this->state="RequestSent";
  361.         return("");
  362.     }
  364.     Function ReadReplyHeaders(&$headers)
  365.     {
  366.         switch($this->state)
  367.         {
  368.             case "Disconnected":
  369.                 return("1 connection was not yet established");
  370.             case "Connected":
  371.                 return("2 request was not sent");
  372.             case "RequestSent":
  373.                 break;
  374.             default:
  375.                 return("3 can not get request headers in the current connection state");
  376.         }
  377.         $headers=array();
  378.         $this->content_length=$this->read_length=0;
  379.         $this->content_length_set=0;
  380.         for(;;)
  381.         {
  382.             $line=$this->GetLine();
  383.             if(GetType($line)!="string")
  384.                 return("4 could not read request reply");
  385.             if($line=="")
  386.             {
  387.                 $this->state="GotReplyHeaders";
  388.                 return("");
  389.             }
  390.             $header_name=strtolower($this->Tokenize($line,":"));
  391.             $header_value=Trim(Chop($this->Tokenize("rn")));
  392.             if(IsSet($headers[$header_name]))
  393.             {
  394.                 if(GetType($headers[$header_name])=="string")
  395.                     $headers[$header_name]=array($headers[$header_name]);
  396.                 $headers[$header_name][]=$header_value;
  397.             }
  398.             else
  399.                 $headers[$header_name]=$header_value;
  400.             switch($header_name)
  401.             {
  402.                 case "content-length":
  403.                     $this->content_length=intval($headers[$header_name]);
  404.                     $this->content_length_set=1;
  405.                     break;
  406.                 case "set-cookie":
  407.                     if($this->support_cookies)
  408.                     {
  409.                         $cookie_name=trim($this->Tokenize($headers[$header_name],"="));
  410.                         $cookie_value=$this->Tokenize(";");
  411.                         $domain=$this->request_host;
  412.                         $path="/";
  413.                         $expires="";
  414.                         $secure=0;
  415.                         while(($name=strtolower(trim($this->Tokenize("="))))!="")
  416.                         {
  417.                             $value=UrlDecode($this->Tokenize(";"));
  418.                             switch($name)
  419.                             {
  420.                                 case "domain":
  421.                                     if($value==""
  422.                                     || !strpos($value,".",$value[0]=="."))
  423.                                         break;
  424.                                     $domain=strtolower($value);
  425.                                     break;
  426.                                 case "path":
  427.                                     if($value!=""
  428.                                     && $value[0]=="/")
  429.                                         $path=$value;
  430.                                     break;
  431.                                 case "expires":
  432.                                     if(ereg("^((Mon|Monday|Tue|Tuesday|Wed|Wednesday|Thu|Thursday|Fri|Friday|Sat|Saturday|Sun|Sunday), )?([0-9]{2})\-(Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec)\-([0-9]{2,4}) ([0-9]{2})\:([0-9]{2})\:([0-9]{2}) GMT$",$value,$matches))
  433.                                     {
  434.                                         $year=intval($matches[5]);
  435.                                         if($year<1900)
  436.                                             $year+=($year<70 ? 2000 : 1900);
  437.                                         $expires="$year-".$this->months[$matches[4]]."-".$matches[3]." ".$matches[6].":".$matches[7].":".$matches[8];
  438.                                     }
  439.                                     break;
  440.                                 case "secure":
  441.                                     $secure=1;
  442.                                     break;
  443.                             }
  444.                         }
  445.                         $this->cookies[$secure][$domain][$path][$cookie_name]=array(
  446.                             "name"=>$cookie_name,
  447.                             "value"=>$cookie_value,
  448.                             "domain"=>$domain,
  449.                             "path"=>$path,
  450.                             "expires"=>$expires,
  451.                             "secure"=>$secure
  452.                         );
  453.                     }
  454.             }
  455.         }
  456.     }
  458.     Function ReadReplyBody(&$body,$length)
  459.     {
  460.         switch($this->state)
  461.         {
  462.             case "Disconnected":
  463.                 return("1 connection was not yet established");
  464.             case "Connected":
  465.                 return("2 request was not sent");
  466.             case "RequestSent":
  467.                 if(($error=$this->ReadReplyHeaders(&$headers))!="")
  468.                     return($error);
  469.                 break;
  470.             case "GotReplyHeaders":
  471.                 break;
  472.             default:
  473.                 return("3 can not get request headers in the current connection state");
  474.         }
  475.         $body="";
  476.         if($this->content_length_set)
  477.             $length=min($this->content_length-$this->read_length,$length);
  478.         if($length>0
  479.         && !$this->EndOfInput()
  480.         && ($body=$this->ReadBytes($length))=="")
  481.             return("4 could not get the request reply body");
  482.         $this->read_length+=$length;
  483.         return("");
  484.     }
  486.     Function GetPersistentCookies(&$cookies)
  487.     {
  488.         $now=gmdate("Y-m-d H-i-s");
  489.         $cookies=array();
  490.         for($secure_cookies=0,Reset($this->cookies);$secure_cookies<count($this->cookies);Next($this->cookies),$secure_cookies++)
  491.         {
  492.             $secure=Key($this->cookies);
  493.             for($domain=0,Reset($this->cookies[$secure]);$domain<count($this->cookies[$secure]);Next($this->cookies[$secure]),$domain++)
  494.             {
  495.                 $domain_pattern=Key($this->cookies[$secure]);
  496.                 for(Reset($this->cookies[$secure][$domain_pattern]),$path_part=0;$path_part<count($this->cookies[$secure][$domain_pattern]);Next($this->cookies[$secure][$domain_pattern]),$path_part++)
  497.                 {
  498.                     $path=Key($this->cookies[$secure][$domain_pattern]);
  499.                     for(Reset($this->cookies[$secure][$domain_pattern][$path]),$cookie=0;$cookie<count($this->cookies[$secure][$domain_pattern][$path]);Next($this->cookies[$secure][$domain_pattern][$path]),$cookie++)
  500.                     {
  501.                         $cookie_name=Key($this->cookies[$secure][$domain_pattern][$path]);
  502.                         $expires=$this->cookies[$secure][$domain_pattern][$path][$cookie_name]["expires"];
  503.                         if($expires!=""
  504.                         && strcmp($now,$expires)<0)
  505.                             $cookies[$secure][$domain_pattern][$path][$cookie_name]=$this->cookies[$secure][$domain_pattern][$path][$cookie_name];
  506.                     }
  507.                 }
  508.             }
  509.         }
  510.     }
  512. };
  514. ?>