<?php

/**
 * Invision Power Services
 * IP.Board v3.0.1
 * HTTP Communications - send data via POST and read response
 * Last Updated: $Date: 2009-02-04 15:05:02 -0500 (Wed, 04 Feb 2009) $
 *
 * @author 		$Author: bfarber $
 * @copyright	(c) 2001 - 2009 Invision Power Services, Inc.
 * @license		http://www.invisionpower.com/community/board/license.html
 * @package		Invision Power Services Kernel
 * @link		http://www.invisionpower.com
 * @since		Friday 6th January 2006 (12:24)
 * @version		$Revision: 222 $
 *
 * Usage
 * <code>
 * $communication	= new classCommunication;
 * $return			= $communication->communicationSendData( 'http://example.site.com/external.php', array( 'foo' => 'bar' ) );
 * $data			= $communication->communicationReceiveData( $return );
 * print_r($data);
 * </code>
 *
 */


if ( ! defined( 'IPS_CLASSES_PATH' ) )
{
	/**
	* Define classes path
	*/
	define( 'IPS_CLASSES_PATH', dirname(__FILE__) );
}

class classCommunication
{
	/**
	* Use sockets flag
	*
	* @access	public
	* @var 		integer
	*/
	public $use_sockets	= 0;
	
	/**
	* Error array
	*
	* @access	public
	* @var 		array
	*/
	public $error		 = array();
	
	/**
	* Key prefix
	* Prefix to identify communication strings
	*
	* @access	public
	* @var 		string
	*/
	public $key_prefix	= '__xsx__';
	
	/**#@+
	* Set Authentication
	*
	* @access	public
	* @var 		string 
	* @var 		string
	* @var 		string
	*/
	public $auth_req 	= 0;
	public $auth_user;
	public $auth_pass;
	/**#@-*/	
	
	/**
	* Receive data from the "send" function
	*
	* @access	public
	* @param	array	Array of fields to return
	* @return	array	Array of fields
	*/
	public function communicationReceiveData( $return_fields=array() )
	{
		//-----------------------------------------
		// INIT
		//-----------------------------------------
		
		$return_array = array();
		
		//-----------------------------------------
		// Get data...
		//-----------------------------------------
		
		foreach( $_REQUEST as $k => $v )
		{
			if ( strstr( $k, $this->key_prefix ) )
			{
				$k = str_replace( $this->key_prefix, '', $k );
				
				$return_array[ $k ] = $v;
			}
		}
		
		return $this->_filterFields( $return_array );
	}
	
	/**
	* Send the data
	*
	* @access	public
	* @param	string	URI to post to
	* @param	array   Arry of post fields
	* @return	string	File data
	*/
	public function communicationSendData( $file_location='', $post_array=array() )
	{
		if ( ! is_array( $post_array ) OR ! count( $post_array ) )
		{
			return false;
		}
		
		if ( ! $file_location )
		{
			return false;
		}
		
		return $this->_postData( $file_location, $post_array );
	}
	
	/**
	* Filter out fields (optional)
	*
	* @access	private
	* @param	array	Array of fields to return
	* @return	array	Array of fields
	*/
	private function _filterFields( $in_fields=array(), $out_fields=array() )
	{
		//-----------------------------------------
		// INIT
		//-----------------------------------------
		
		$return_array = array();
		
		//-----------------------------------------
		// Check
		//-----------------------------------------
		
		if ( ! is_array( $in_fields ) or ! count( $in_fields ) )
		{
			return false;
		}
		
		if ( ! is_array( $out_fields ) or ! count( $out_fields ) )
		{
			return $in_fields;
		}
		
		//-----------------------------------------
		// Get data...
		//-----------------------------------------
		
		foreach( $out_fields as $k => $type )
		{
			if ( $in_fields[ $k ] )
			{
				switch ( $type )
				{
					default:
					case 'string':
					case 'text':
						$return_array[ $k ] = trim( $in_fields[ $k ] );
						break;
					case 'int':
					case 'integar':
						$return_array[ $k ] = intval( $in_fields[ $k ] );
						break;
					case 'float':
					case 'floatval':
						$return_array[ $k ] = floatval( $in_fields[ $k ] );
						break;
				}
			}
		}
		
		return $return_array;
	}
	
	/**
	* Get file contents (with sockets)
	*
	* @access	private
	* @param	string	URI to post to
	* @param	array   Arry of post fields
	* @return	string	File data
	* @todo 	[Future] Doesn't support "chunked" HTTP responses
	*/
	private function _postData( $file_location, $post_array )
	{
		//-------------------------------
		// INIT
		//-------------------------------
		
		$data		  = null;
		$fsocket_timeout = 10;
		$post_back	  = array();
		
		//-------------------------------
		// Fix up post string
		//-------------------------------
		
		foreach ( $post_array as $key => $val )
		{
			$post_back[] = $this->key_prefix . $key . '=' . urlencode($val);
		}
		
		$post_back_str = implode('&', $post_back);
		
		//-------------------------------
		// Parse URL
		//-------------------------------
		
		$url_parts = parse_url($file_location);
		
		if ( ! $url_parts['host'] )
		{
			$this->errors[] = "Не найден хост в URL '{$file_location}'!";
			return false;
		}
		
		//-------------------------------
		// Finalize
		//-------------------------------
		
		$host = $url_parts['host'];
		$port = ( isset($url_parts['port']) ) ? $url_parts['port'] : ( $url_parts['scheme'] == 'https' ? 443 : 80 );
		
		//-------------------------------
		// Tidy up path
		//-------------------------------
		
		if ( ! empty( $url_parts["path"] ) )
		{
			$path = $url_parts["path"];
		}
		else
		{
			$path = "/";
		}
		
		if ( ! empty( $url_parts["query"] ) )
		{
			$path .= "?" . $url_parts["query"];
		}
		
		//-------------------------------
		// Try CURL first...
		//-------------------------------
		
		if ( function_exists("curl_init") AND function_exists("curl_exec") )
		{
			if ( $sock = curl_init() )
			{
				curl_setopt( $sock, CURLOPT_URL		  , $file_location );
				curl_setopt( $sock, CURLOPT_TIMEOUT	   , 15 );
				curl_setopt( $sock, CURLOPT_POST		 , TRUE );
				curl_setopt( $sock, CURLOPT_POSTFIELDS	, $post_back_str );
				curl_setopt( $sock, CURLOPT_POSTFIELDSIZE  , 0);
				curl_setopt( $sock, CURLOPT_RETURNTRANSFER , TRUE ); 
		
				$result = curl_exec($sock);
				
				curl_close($sock);
				
				return $result ? $result : false;
			}
		}
		else
		{
		
		    if ( ! $fp = @fsockopen( $host, $port, $errno, $errstr, $fsocket_timeout ) )
		  	{
				$this->errors[] = "Невозможно соединение с {$host}";
				return false;
		 
			}
			else
			{
				$final_carriage = "";
				
				if ( ! $this->auth_req )
				{
					$final_carriage = "\r\n";
				}
				
				$header  = "POST $path HTTP/1.0\r\n";
				$header .= "Host: $host\r\n";
				$header .= "Content-Type: application/x-www-form-urlencoded\r\n";
				$header .= "Content-Length: " . strlen($post_back_str) . "\r\n{$final_carriage}";
				
				if ( ! fputs( $fp, $header . $post_back_str ) )
				{
					$this->errors[] = "Невозможно отправить запрос на {$host}!";
					return false;
				}
			
				if ( $this->auth_req )
				{
					if( $this->auth_user && $this->auth_pass )
					{
						$header = "Authorization: Basic ". base64_encode( "{$this->auth_user}:{$this->auth_pass}" ) . "\r\n\r\n";
						
						if ( ! fputs( $fp, $header ) )
						{
							$this->errors[] = "Данные авторизации не верны!";
							return false;
						}
					}
				}				
			}
		
			@stream_set_timeout($fp, $fsocket_timeout);
		 	 
			$status = @socket_get_status($fp);
		 
			while( ! feof($fp) && ! $status['timed_out'] )	    
			{
				$data .= fgets ($fp,8192);
				$status = socket_get_status($fp);
			}
		 
			fclose ($fp);
	    
			//-------------------------------
			// Strip headers
			//-------------------------------
	    
			$tmp = split("\r\n\r\n", $data, 2);
			$data = $tmp[1];

	 		return $data;
		}
	}
	
}

?>