<?php

/*
justin was here :D
*/

class HttpFsockopen {

protected $url;
	protected $path;
	protected $host;
	protected $query;
	protected $post;
	protected $port;
	protected $headers;
	protected $ssl;
	protected $method;
	protected $timeout;
    protected $str_headers = '';
    protected $is_post = false;

protected static $autoload;
	
	public function __construct($url, $use_autoload = true){
		if(is_null(HttpFsockopen::$autoload) && $use_autoload){
			HttpFsockopen::$autoload = true;
			spl_autoload_register(array("HttpFsockopen", "load"));
		}
		$url_array = parse_url($url);
		
		if(!empty($url_array["scheme"]) && preg_match("#^https|ssl$#i", $url_array["scheme"])){
			$this -> ssl = true;
		} else {
			$this -> ssl = false;
		}

if(empty($url_array["port"])){
			if($this -> ssl){
				$this -> port = 443;
			} else {
				$this -> port = 80;
			}
		}

if(array_key_exists("path", $url_array)){
			$this -> path = $url_array["path"];
		} else {
			$this -> path = false;
		}
		
		if(array_key_exists("query", $url_array)){
			$this -> query = $url_array["query"];
		} else {
			$this -> query = false;
		}
		
		$this -> host = $url_array["host"];
		$this -> method = "GET";
        $this -> timeout = 15;
		$this -> is_post = false;
	}

public static function load($class){
		$file = dirname( __FILE__ ) . DIRECTORY_SEPARATOR . 
			preg_replace("#[_]+#", DIRECTORY_SEPARATOR , $class) . ".php";
		if(file_exists($file))
		include_once $file ;
	}

public function setQueryData($data){
		if(is_array($data)){
			$data = http_build_query($data);
		}
		$this -> query = $data;
		return $this;
	}
	
	public function setPostData($data){
		if(is_array($data)){
			$data = http_build_query($data);
		}
		$this -> post = $data;
		$this -> method = "POST";
        $this -> is_post = true;
		$this -> setHeaders("Content-Type", "application/x-www-form-urlencoded");
		return $this;
	}

public function setMethod($method){
		$previous_method = $this -> method;
		if(preg_match("#^[a-z]+$#i", $method)){
			$this -> method = strtoupper($method);
		}
		if($this -> method == "POST" && $previous_method != "POST"){
			//$this -> setHeaders("Content-Type", "application/x-www-form-urlencoded");
		}
		if($this -> method != "POST" && $previous_method == "POST"){
			$this -> setHeaders("Content-Type", null);
		}
		return $this;
	}

public function setTimeout($timeout){
		$this -> timeout = $timeout;
		return $this;
	}

public function setPort($port){
		$this -> port = $port;
		return $this;
	}

public function setHeaders($key, $value = null){
		if(is_array($key)){
			foreach($key as $key => $value){
				if(is_null($value)){
					unset($this -> headers[$key]);
				} else {
					$this -> headers[$key] = $value;
				}
			}
		} else {
			if(is_null($value)){
				unset($this -> headers[$key]);
			} else {
				$this -> headers[$key] = $value;
			}
 		}
		return $this;
	}
    
    public function setStrHeaders($str)
    {
        $this->str_headers = $str;
    }
	
	public function setUserAgent($user_agent){
		return $this -> setHeaders("User-Agent", $user_agent);
	}
	
	public function exec(){
		$socket = fsockopen(($this -> ssl ? "ssl://" : "") . $this -> host, $this -> port, $errno, $errstr,
			$this -> timeout);
		$contents = "";
		
		if($socket){
			$http  = $this -> method . " ". (strlen($this -> path) ? $this -> path : "/") .
				(strlen($this -> query)>0 ? "?" . $this -> query : "")
				." HTTP/1.1\r\n";
			$http .= "Host: ".$this -> host."\r\n";
			foreach($this -> headers as $key => $value){
				$http .= $key. ": ".$value."\r\n";
			}
           
            if ( $this -> is_post || $this -> method == 'GET' ) {
                $http .= "Content-length: " . strlen($this -> post) . "\r\n";
                $http .= "Connection: close\r\n\r\n";
            }
            
             if (!empty($this->str_headers)) {
                $http .= $this->str_headers;
            }
			
			if(!is_null($this -> post)) {
			    $http .= $this -> post . "\r\n\r\n";
            }   
            
            fwrite($socket, $http);	
			while (!feof($socket)) {
				$contents .= fgetc($socket);
			}   
			fclose($socket);
		}
		
		return $contents;
	}

}