<?php


class HttpRequest {
	/**
	 * @var string url
	 * URL
	 */
	public $url = "";

	/**
	 * @var string method
	 * HTTP method ( GET, POST, etc )
	 */
	public $method = "GET";

	/**
	 * @var Array headers
	 * Associative array of "http header name" => "value"
	 */
	public $headers = array();

	/**
	 * @var Array urlParams
	 * Associative array of parameters added to URL
	 * <url>?param1=value1&param2=value2
	 */
	public $urlParams = array();

	/**
	 * @var Array postPayload
	 * Associative array of parameters passed in the request body
	 */
	public $postPayload = array();

	/**
	 * @var string body
	 * 
	 */
	public $body = null;


	function __construct( $url, $method = "GET", $urlParams = array(), $postPayload = array(), $headers = array() ) {
		$this->url = $url;
		$this->urlParams = $urlParams;
		$this->postPayload = $postPayload;
		$this->method = $method;
		$this->headers = $headers;
		if( !is_array( $this->postPayload ) ) {
			$this->postPayload = array();
			$this->body = $postPayload;
		}
		if( !is_array( $this->urlParams ) ) {
			$this->urlParams = array();
		}
		if( !is_array( $this->headers ) ) {
			$this->headers = array();
		}
	}

	function getUrl() {
		return prepareUrl( $this->url, $this->urlParams );
	}

	function addBasicAuthorization( $username, $password ) {
		$this->headers["Authorization"] = "Basic " . base64_encode( $username . ':' .$password );
	}

	/** 
	 * 	Return unique identifier of request for caching.
	 *  Null to prohibit caching
	 */ 
	function getRequestKey() {
		if( $this->postPayload || $this->body || $this->method != "GET" ) {
			return null;
		}
		return $this->getUrl();
	}
	
	/**
	 *
	 */
	public function prepareRequestBody() {
		if( $this->body !== null ) {
			return $this->body;
		}
		if( !$this->postPayload ) {
			return "";
		}
		$contentType = $this->getHeader("Content-Type");
		$cTypeParts = explode( ";", $contentType );
		$type = "";
		if( count( $cTypeParts ) > 0 ) {
			$type = strtolower( trim( $cTypeParts[0] ) );
		}
		if( !$type || $type == "application/x-www-form-urlencoded" ) {
			if( !$type )
				$this->setHeader("Content-Type", "application/x-www-form-urlencoded" );
			return prepareUrlQuery( $this->postPayload );
		}
		if( $type == "application/json" || $type == "application/json-patch+json" ) {
			return my_json_encode( $this->postPayload );
		}
		if( $type == "multipart/form-data" ) {
			//	ignore specified boundary and generate a new one
			$boundary = generatePassword( 40 );
			$this->setHeader("Content-Type", $type . ";boundary=" . $boundary );
			$bodyParts = array();
			foreach( $this->postPayload as $name => $value ) {
				$bodyParts[] = "--" . $boundary . "\r\nContent-disposition: form-data; name=\"" . $name . "\"\r\n\r\n". $value . "\r\n";
			}
			$bodyParts[] = "--" . $boundary . "--\r\n";
			return implode( "", $bodyParts );
		}
		return "";
	}
	
	
	/**
	 * @return Array( 
	 *  	header => string
	 *  	error? => boolean
	 *  	errorMessage? => string
	 *  	content? => string
	 *  	responseCode ? => number )
	 */
	public function run() {
		$url = prepareUrl( $this->url, $this->urlParams );
		
		$body = $this->prepareRequestBody();
		$bodyLength = strlen_bin( $body );
		if( $bodyLength ) {
			$this->headers["Content-Length"] = $bodyLength;
		}
		
		global $dDebug;
		if( $dDebug ) {
			echo "<pre>";
			echo "HTTP request:";
			echo "\nurl:";
			print_r( $this->url );
			echo "\nmethod:";
			print_r( $this->method );
			echo "\nheaders:";
			print_r( $this->headers );
			echo "\nurl params:";
			print_r( $this->urlParams );
			echo "\nbody:";
			print_r( $this->body );
			echo "</pre>";
		}
		$ret = runner_http_request( $url, $body, $this->method, $this->headers );
		if( $dDebug ) {
			echo "HTTP response:";
			print_r( $ret );
		}
		if( $ret["error"] ) {
			//	transport-level error
			$ret["errorMessage"] = $ret["error"];
			$ret["error"] = true;
		}

		if( $ret["responseCode"] && ( $ret["responseCode"] < 200 || $ret["responseCode"] >= 300 ) ) {
			//	HTTP error
			$ret["error"] = true;
			$ret["errorMessage"] = "HTTP error " . $ret["responseCode"] 
				. "\r\n." . $ret["content"];
		}
		
		return $ret;		
	}

	/**
	 * Parse "application/json" or "urlencoded"
	 * @param Array HttpRequest::run result
	 * @return Array or null
	 */
	public static function parseResponseArray( $response ) {
		$headers = explode( "\r\n", $response["header"] );
		$urlencoded = false;
		foreach( $headers as $h ) {
			if( stripos( $h, "Content-Type:" ) === 0 && stripos( $h, "urlencoded") !== false ) {
				$urlencoded = true;
				break;
			}
		}
		$content = $response["content"];
		if( $urlencoded ) {
			$result = array();
			$result = parseQueryString( $content );
			return $result;
		}
		$obj = runner_json_decode( $content );
		if( is_array($obj) && count( $obj ) == 0 && trim( $content ) != "[]" ) {
			return null;
		}
		return $obj;
	}

	/**	
	 * Returns array of headers in "name" => "value" format
	 * All names are converted to lowercase!
	 */
	public static function parseHeaders( &$response ) {
		$headers = explode( "\r\n", $response["header"] );
		$ret = array();
		foreach( $headers as $h ) {
			$pos = strpos( $h, ":" );
			if( $pos === false ) {
				continue;
			}
			$ret[ strtolower( substr( $h, 0, $pos ) ) ] = trim( substr( $h, $pos + 1 ) );
		}
		return $ret;
	}

	public function getHeader( $name ) {
		return getArrayElementNC( $this->headers, $name );
	}

	public function setHeader( $name, $value ) {
		$header =  getArrayKeyNC( $this->headers, $name );
		if( !$header ) {
			$header = $name;
		}
		$this->headers[ $header ] = $value;
	}
}

?>