Subversion Repositories SmartDukaan

<?php defined('BASEPATH') OR exit('No direct script access allowed');

/**

**/

/**

 * CodeIgniter MCurl Class

 *

 * Work with remote servers via multi-cURL much easier than using the native PHP bindings.

 *

 * @package			CodeIgniter

 * @subpackage		Libraries

 * @category		Libraries

 * @author			Chad Hutchins

 * @link			http://github.com/chadhutchins/codeigniter-mcurl

 */

class Mcurl {

	private $_ci;				// CodeIgniter instance

	private $calls = array();	// multidimensional array that holds individual calls and data

	private $curl_parent;		// the curl multi handle resource

	function __construct()

	{

		$this->_ci = & get_instance();

		log_message('debug', 'Mcurl Class Initialized');

		if (!$this->is_enabled())

		{

			log_message('error', 'Mcurl Class - PHP was not built with cURL enabled. Rebuild PHP with --with-curl to use cURL.');

		}

		else 

		{

			$this->curl_parent = curl_multi_init();

		}

	}

	// check to see if necessary function exists

	function is_enabled()

	{

		return function_exists('curl_multi_init');

	}

	// method to add curl requests to the multi request queue

	function add_call($key=null, $method, $url, $params = array(), $options = array())

	{

		if (is_null($key))

		{

			$key = count($this->calls);

		}

		// check to see if the multi handle has been closed

		// init the multi handle again

		$resource_type = get_resource_type($this->curl_parent);

		if(!$resource_type || $resource_type == 'Unknown')

		{

			$this->calls = array();

			$this->curl_parent = curl_multi_init();

		}

		$this->calls [$key]= array(

			"method" => $method,

			"url" => $url,

			"params" => $params,

			"options" => $options,

			"curl" => null,

			"response" => null,

			"error" => null

		);

		$this->calls[$key]["curl"] = curl_init();

		$newdata =$params;

		// If its an array (instead of a query string) then format it correctly

		if (is_array($params))

		{

			$params = http_build_query($params, NULL, '&');

		}

		$method = strtoupper($method);

		// only supports get/post requests

		// set some special curl opts for each type of request

		switch ($method)

		{			

			case "POST":

				curl_setopt($this->calls[$key]["curl"], CURLOPT_URL, $url);

				curl_setopt($this->calls[$key]["curl"], CURLOPT_POST, TRUE);

				curl_setopt($this->calls[$key]["curl"], CURLOPT_POSTFIELDS, $params);

				curl_setopt($this->calls[$key]["curl"], CURLOPT_SSL_VERIFYPEER, false);

				break;

			case "GET":

				if (strpos($url,'?') !== false) {

    				curl_setopt($this->calls[$key]["curl"], CURLOPT_URL, $url."&".$params);

    			}

    			else{

    				curl_setopt($this->calls[$key]["curl"], CURLOPT_URL, $url."?".$params);

    			}

				curl_setopt($this->calls[$key]["curl"], CURLOPT_SSL_VERIFYPEER, false);

				break;

			default:

				log_message('error', 'Mcurl Class - Provided http method is not supported. Only POST and GET are currently supported.');

				break;

		}

		curl_setopt($this->calls[$key]["curl"], CURLOPT_RETURNTRANSFER, TRUE);

		curl_setopt($this->calls[$key]["curl"], CURLOPT_FOLLOWLOCATION, TRUE);

		curl_setopt_array($this->calls[$key]["curl"], $options);

		curl_multi_add_handle($this->curl_parent,$this->calls[$key]["curl"]);		 

	}

	// run the calls in the curl requests in $this->calls

	function execute()

	{

		if (count($this->calls))

		{

			// kick off the requests

			do

			{

				$multi_exec_handle = curl_multi_exec($this->curl_parent,$active);

			} while ($active>0);

			// after all requests finish, set errors and repsonses in $this->calls

			foreach ($this->calls as $key => $call)

			{

				$error = curl_error($this->calls[$key]["curl"]);

				//print_r($key);

				//print_r($error);

				if (!empty($error))

				{

					if($key != 'recommended_accessories'){

					$this->calls[$key]["error"] = $error;

					$errmsg ='<h3>OH SNAP!!!! :</h3><p>Something is not right. <br/><h1>But Relax</h1> <br/>We are working hard on it. </p>';

					//$this->write_log_send_mail('error',$msg);

					//$this->session->set_flashdata('errormsg',$errmsg);

					//redirect(base_url().'error_page/index');

					//exit();

					}

				}

				$this->calls[$key]["response"] = curl_multi_getcontent($this->calls[$key]["curl"]);

				$http_status = curl_getinfo($this->calls[$key]["curl"], CURLINFO_HTTP_CODE);

				if($key != 'recommended_accessories'){

					if($http_status != 200) {

        				redirect(base_url().'error_page/index');

        				exit();

					}

				}

				curl_multi_remove_handle($this->curl_parent,$this->calls[$key]["curl"]);

				// if($key != 'recommended_accessories'){

				// if(isset($this->calls[$key]["response"]) && !empty($this->calls[$key]["response"])){

				// 	curl_multi_remove_handle($this->curl_parent,$this->calls[$key]["curl"]);	

				// }else{

				// 	$this->calls[$key]["error"] = $error;

				// 	$errmsg ='<h3>OH SNAP!!!! :</h3><p>Something is not right. <br/><h1>But Relax</h1> <br/>We are working hard on it. </p>';

				// 	//$this->write_log_send_mail('error',$msg);

				// 	//$this->session->set_flashdata('errormsg',$errmsg);

				// 	redirect(base_url().'error_page/index',$data);

				// 	exit();

				// }

				// }

			}

			curl_multi_close($this->curl_parent);

		}

		return $this->calls;

	}

	function debug()

	{

		echo "<h2>mcurl debug</h2>";

		foreach ($this->calls as $call)

		{

			echo '<p>url: <b>'.$call["url"].'</b></p>';

			if (!is_null($call["error"]))

			{

				echo '<p style="color:red;">error: <b>'.$call["error"].'</b></p>';

			}

			echo '<textarea cols="100" rows="10">'.htmlentities($call["response"])."</textarea><hr>";

		}

	}

}

/* End of file mcurl.php */

/* Location: ./application/libraries/mcurl.php */