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())

	{

		$authorized=$this->_ci->session->userdata('authorized');

		if(isset($authorized['Id']) && !empty($authorized['Id'])){

			$params['userId'] = $authorized['Id'];

		}

		if(isset($authorized['isPrivateDealUser']) && !empty($authorized['isPrivateDealUser'])) {

			$params['privateDealUser'] = 'true';

		}

		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);

		if(($key == 'tracking') || ($key == 'signup') || ($key == 'orderconfirmation_process')){

			$cookiesStringToPass="";

			foreach($_COOKIE as $cookie) {

				if ($cookiesStringToPass) {

	     			$cookiesStringToPass  .= ';';

	    		}

	    		if(is_object(json_decode($cookie))){

	    			$cookieInfo = json_decode($cookie);

	    			foreach ($cookieInfo as $info) {

	    				$cookiesStringToPass .= $info->name . '=' . addslashes($info->value);

	    			}

	    		}

			}

			curl_setopt($this->calls[$key]["curl"], CURLOPT_COOKIE, $cookiesStringToPass);

			foreach (getallheaders() as $name => $value) {

			    if($name == "X-Forwarded-For"){

			    	$headers = array('X-Forwarded-For : '.$value);

			    	curl_setopt($this->calls[$key]["curl"], CURLOPT_HTTPHEADER, $headers);

			    }

			}

		}

		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) <= 0)

			return False;

		if (count($this->calls))

		{

			// kick off the requests

			do

			{

				//print_r($this->calls);

				$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"]);

				if (!empty($error))

				{

					if($key != 'tracking' && $key != 'recommended_accessories'){

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

					$url = 'http://www.saholic.com/'.uri_string();

					$this->_ci->session->set_userdata('errorurl',$url);

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

					$msg = '

					API for '.$key.' is not working.

					url of API Failed ===> '.$this->calls[$key]['url'].'

					parameters are ===> '.$call['params'].'

					Access modifier is Public.

					Error is ====> '.$this->calls[$key]["error"].'';

					$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 != 'tracking' && $key != 'recommended_accessories'){

					if($http_status != 200) {

						$url = 'http://www.saholic.com/'.uri_string();

						$this->_ci->session->set_userdata('errorurl',$url);

						$msg = '

						API for '.$key.' is not working.

						url of API Failed ===> '.$this->calls[$key]['url'].'

						parameters are ===> '.$call['params'].'

						Access modifier is Public.

						Error is ====> '.$this->calls[$key]["error"].'';

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

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

        				exit();

					}

				}

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

			}

			curl_multi_close($this->curl_parent);

		}

		//print_r($this->calls);

		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>";

		}

	}

	function write_log_send_mail($level = 'error', $msg, $php_error = FALSE){ 

	 	$params = $this->_ci->config->item('email_params'); 

		$this->_ci->load->library('email',$params);

		$this->_ci->email->set_newline("\r\n");

	 	$this->_ci->email->from('mobile@letsgomo.com', 'NO-REPLY');

	 	$list = $this->_ci->config->item('email_list');

		$this->_ci->email->to($list);

		$this->_ci->email->cc('yashmeet@letsgomo.com');		

		$this->_ci->email->subject('The API failed on '.date('m/d/Y'));		

		$this->_ci->email->message('The API failed at '.date('m/d/Y h:i:s a', time()).' ------> '.$msg);

		//send the email 	

		$this->_ci->email->send();

	}

}

/* End of file mcurl.php */

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