<?php
/**
 * Включает поддержку синтаксиса cURL, как в обычном PHP
 * становятся доступными curl_* функции
 *
 * Обязательно, чтоб функции были объявлены в корневом namespace
 */

namespace ;

use cURLFile,
    php\lib\Str,
    bundle\jurl\jURL,
    bundle\jurl\jURLFile,
    bundle\jurl\jURLException;

// Для autoloader'а
class cURL{

}

// Пока define некорректно работает в jphp
define('CURLINFO_HTTP_CODE', 'responseCode');
define('CURLINFO_RESPONSE_CODE', 'responseCode');
define('CURLINFO_TOTAL_TIME', 'executeTime');
define('CURLINFO_SIZE_UPLOAD', 'requestLength');
define('CURLINFO_SIZE_DOWNLOAD', 'responseLength');
define('CURLINFO_CONTENT_TYPE', 'contentType');

if(!function_exists('curl_init')){

   /**
    * --RU--
    * Инициализирует сеанс cURL
    * @param string $url (optional)
    */
   function curl_init($url = NULL){
       return new jURL($url);
   }

   /**
    * --RU--
    * Устанавливает параметр для сеанса CURL
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    * @param string $key - Устанавливаемый параметр CURLOPT_*
    * @param string $value - Значение параметра key
    */
   function curl_setopt(jURL $ch, $key, $value){
       $reKeys = [
           'CURLOPT_URL' => 'url',
           'CURLOPT_CONNECTTIMEOUT' => 'connectTimeout',
           'CURLOPT_CONNECTTIMEOUT_MS' => 'connectTimeout',
           'CURLOPT_TIMEOUT' => 'readTimeout',
           'CURLOPT_TIMEOUT_MS' => 'readTimeout',
           'CURLOPT_CUSTOMREQUEST' => 'requestMethod',
           'CURLOPT_POSTFIELDS' => 'postData', // postFiles //
           'CURLOPT_POST' => 'requestMethod',
           'CURLOPT_PUT' => 'requestMethod',
           'CURLOPT_GET' => 'requestMethod',
           'CURLOPT_REFERER' => 'httpReferer',
           'CURLOPT_AUTOREFERER' => 'autoReferer',
           'CURLOPT_COOKIEFILE' => 'cookieFile',
           'CURLOPT_COOKIEJAR' => 'cookieFile',
           'CURLOPT_USERAGENT' => 'userAgent',
           'CURLOPT_HEADER' => 'returnHeaders',
           'CURLOPT_FOLLOWLOCATION' => 'followRedirects',
           'CURLOPT_HTTPHEADER' => 'httpHeader',
           'CURLOPT_USERPWD' => 'basicAuth',
           'CURLOPT_PROXY' => 'proxy',
           'CURLOPT_PROXYUSERPWD' => 'proxyAuth',
           'CURLOPT_PROXYTYPE' => 'proxyType',
           'CURLOPT_PROGRESSFUNCTION' => 'progressFunction',
           'CURLOPT_FILE' => 'outputFile',
           'CURLOPT_BUFFERSIZE' => 'bufferLength',
           'CURLOPT_INFILE' => 'inputFile',
           'CURLOPT_NOBODY' => 'returnBody',
       ];

       $jKey = isset($reKeys[$key]) ? $reKeys[$key] : NULL;

       if($key == 'CURLOPT_POST' and (bool)$value === true){
           $value = 'POST';
       }
       elseif($key == 'CURLOPT_NOBODY'){
           $value = !$value;
       }
       elseif($key == 'CURLOPT_GET' and (bool)$value === true){
           $value = 'GET';
       }
       elseif($key == 'CURLOPT_PUT' and (bool)$value === true){
           $value = 'PUT';
       }
       elseif($key == 'CURLOPT_HTTPHEADER'){
           $headers = [];
           foreach ($value as $h) {
               $t = Str::Split($h, ':', 2);
               $headers[] = [
                   Str::Trim( $t[0] ),
                   Str::Trim( $t[1] ),
               ];
           }
           $value = $headers;
       }
       elseif($key == 'CURLOPT_CONNECTTIMEOUT' OR $key == 'CURLOPT_TIMEOUT'){
           $value = $value * 1000;
       }
       elseif($key == 'CURLOPT_POSTFIELDS' AND is_array($value)){
           $str = [];
           $files = [];

           foreach($value as $k=>$v){
               if($v instanceof jURLFile || Str::Sub($v, 0, 1) == '@'){
                   $files[$k] = $v;
               }
               else $str[$k] = $v;
           }
           if(sizeof($files) > 0) $ch->setOpt('postFiles', $files);
           $value = $str;
       }
       elseif($key == 'CURLOPT_PROXYTYPE'){
           $proxyTypes = [
               'CURLPROXY_HTTP' => 'HTTP',
               'CURLPROXY_SOCKS5' => 'SOCKS'
           ];
           $value = (isset($proxyTypes[$value]) ? $proxyTypes[$value] : $value);
       }

       $ch->setOpt($jKey, $value);
   }

   /**
    * --RU--
    * Устанавливает несколько параметров для сеанса cURL
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    * @param array $options - Массив c параметрами вида [CURLOPT_* => 'value']
    */
   function curl_setopt_array(jURL $ch, $options){
       foreach($options as $k=>$v){
           curl_setopt($ch, $k, $v);
       }
   }

   /**
    * --RU--
    * Выполняет запрос cURL
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    * @return mixed
    */
   function curl_exec(jURL $ch){
      try{
         return $ch->exec();
      } catch(jURLException $e){
         return false;
      }
   }

   /**
    * --RU--
    * Выполняет запрос cURL асинхронно
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    * @param callable $callback - Функция, куда бкдет передан результат запроса
    */
   function curl_exec_async(jURL $ch, $callback = null){
      try{
         $ch->aSyncExec($callback);
      } catch(jURLException $e){
         if(is_callable($callback)){
            $callback(false);
         }
      }

   }

   /**
    * --RU--
    * Возвращает строку с описанием последней ошибки текущего сеанса
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    * @return string|null
    */
   function curl_error(jURL $ch){
       return ($ch->getError() === false) ? null : $ch->getError()['error'];
   }

   /**
    * --RU--
    * Возвращает код последней ошибки
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    * @return int - Код ошибки или 0, если запрос выполнен без ошибок
    */
   function curl_errno(jURL $ch){
       return ($ch->getError() === false) ? 0 : $ch->getError()['code'];
   }

   /**
    * --RU--
    * Возвращает информацию об определенной операции
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    * @return array
    */
   function curl_getinfo(jURL $ch, $opt = null){
       $info = $ch->getConnectionInfo();
	   return (!is_null($opt) and isset($info[$opt])) ? $info[$opt] : $info;
   }

   /**
    * --RU--
    * Завершает сеанс cURL
    * @param jURL $ch - Дескриптор cURL, полученный из curl_init
    */
   function curl_close(jURL $ch){
       return $ch->close();
   }

   /**
    * --RU--
    * Сбросить параметры текущего сеанса
    */
   function curl_reset(jURL $ch){
       return $ch->reset();
   }


   /**
    * --RU--
    * Создает объект cURLFile
    * @param string $filename Path to the file which will be uploaded.
    * @param string $mimetype = NULL
    * @param string $postname = NULL
    */
   function curl_file_create($filename, $mimetype = NULL, $postname = NULL){
       return new jURLFile($filename, $mimetype, $postname);
   }
}

if(!function_exists('http_build_query')){
    function http_build_query($a,$b='',$c=0){
        if (!is_array($a)) return $a;

        foreach ($a as $k=>$v){
            if($c){
                if( is_numeric($k) ){
                    $k=$b."[]";
                }
                else{
                    $k=$b."[$k]";
                }
            }
            else{
                if (is_int($k)){
                    $k=$b.$k;
                }
            }
            if (is_array($v)||is_object($v)){
                $r[] = http_build_query($v,$k,1);
                    continue;
            }
            $r[] = urlencode($k) . "=" . urlencode($v);
        }
        return implode("&",$r);
    }
}

if(!function_exists('parse_str')){
  function parse_str($str) {
    $arr = array();
    $pairs = explode('&', $str);

    foreach ($pairs as $i) {
      list($name,$value) = explode('=', $i, 2);

      if( isset($arr[$name]) ) {
        if( is_array($arr[$name]) ) {
          $arr[$name][] = $value;
        }
        else {
          $arr[$name] = array($arr[$name], $value);
        }
      }
      else {
        $arr[$name] = $value;
      }
    }
    return $arr;
  }
}