jmathai / php-multi-curl

src/MultiCurlSequence.php

Indentation +25 added lines, -25 removed lines

@@ -6,60 +6,60 @@ 
  */
 class MultiCurlSequence
 {
-  private $width = 100;
-  private $timers;
-  private $min;
-  private $max;
-  private $range;
-  private $step;
+    private $width = 100;
+    private $timers;
+    private $min;
+    private $max;
+    private $range;
+    private $step;
 
-  public function __construct($timers) 
-  {
+    public function __construct($timers) 
+    {
     $this->timers = $timers;
     
     $min = PHP_INT_MAX;
     $max = 0;
     foreach($this->timers as $timer)
     {
-      if(!isset($timer['start']))
+        if(!isset($timer['start']))
         $timer['start'] = PHP_INT_MAX;
 
-      if(!isset($timer['end']))
+        if(!isset($timer['end']))
         $timer['end'] = 0;
 
-      $min = min($timer['start'], $min);
-      $max = max($timer['end'], $max);
+        $min = min($timer['start'], $min);
+        $max = max($timer['end'], $max);
     }
     $this->min = $min;
     $this->max = $max;
     $this->range = $max-$min;
     $this->step = floatval($this->range/$this->width);
-  }
+    }
 
-  public function renderAscii()
-  {
+    public function renderAscii()
+    {
     $tpl = '';
     foreach($this->timers as $timer)
-     $tpl .= $this->tplAscii($timer);
+        $tpl .= $this->tplAscii($timer);
     
     return $tpl;
-  }
+    }
 
-  private function tplAscii($timer)
-  {
+    private function tplAscii($timer)
+    {
     $lpad = $rpad = 0;
     $lspace = $chars = $rspace = '';
     if($timer['start'] > $this->min)
-      $lpad = intval(($timer['start'] - $this->min) / $this->step);
+        $lpad = intval(($timer['start'] - $this->min) / $this->step);
     if($timer['end'] < $this->max)
-      $rpad = intval(($this->max - $timer['end']) / $this->step);
+        $rpad = intval(($this->max - $timer['end']) / $this->step);
     $mpad = $this->width - $lpad - $rpad;
     if($lpad > 0)
-      $lspace = str_repeat(' ', $lpad);
+        $lspace = str_repeat(' ', $lpad);
     if($mpad > 0)
-      $chars = str_repeat('=', $mpad);
+        $chars = str_repeat('=', $mpad);
     if($rpad > 0)
-      $rspace = str_repeat(' ', $rpad);
+        $rspace = str_repeat(' ', $rpad);
     
     $tpl = <<<TPL
 ({$timer['api']} ::  code={$timer['code']}, start={$timer['start']}, end={$timer['end']}, total={$timer['time']})
@@ -67,5 +67,5 @@ 
 
 TPL;
     return $tpl;
-  }
+    }
 }

src/example.php

Indentation +1 added lines, -1 removed lines

@@ -1,7 +1,7 @@
 #!/usr/bin/env php
 <?php
 if (php_sapi_name() !== 'cli')
-  die();
+    die();
 
 require '../vendor/autoload.php';
 $mc = JMathai\PhpMultiCurl\MultiCurl::getInstance();

src/MultiCurlManager.php

Indentation +11 added lines, -11 removed lines

@@ -6,24 +6,24 @@
  */
 class MultiCurlManager
 {
-  private $key;
-  private $epiCurl;
+    private $key;
+    private $epiCurl;
 
-  public function __construct($key)
-  {
+    public function __construct($key)
+    {
     $this->key = $key;
     $this->epiCurl = MultiCurl::getInstance();
-  }
+    }
 
-  public function __get($name)
-  {
+    public function __get($name)
+    {
     $responses = $this->epiCurl->getResult($this->key);
     return isset($responses[$name]) ? $responses[$name] : null;
-  }
+    }
 
-  public function __isset($name)
-  {
+    public function __isset($name)
+    {
     $val = self::__get($name);
     return empty($val);
-  }
+    }
 }

src/MultiCurl.php

Indentation +104 added lines, -104 removed lines

@@ -13,45 +13,45 @@ 
  */
 class MultiCurl
 {
-  const timeout = 3;
-  private static $inst = null;
-  /* @TODO make this private and add a method to set it to 0 */
-  public static $singleton = 0;
-
-  private $mc;
-  private $running;
-  private $execStatus;
-  private $sleepIncrement = 1.1;
-  private $requests = array();
-  private $responses = array();
-  private $properties = array();
-  private static $timers = array();
-
-  public function __construct()
-  {
+    const timeout = 3;
+    private static $inst = null;
+    /* @TODO make this private and add a method to set it to 0 */
+    public static $singleton = 0;
+
+    private $mc;
+    private $running;
+    private $execStatus;
+    private $sleepIncrement = 1.1;
+    private $requests = array();
+    private $responses = array();
+    private $properties = array();
+    private static $timers = array();
+
+    public function __construct()
+    {
     if(self::$singleton === 0)
     {
-      throw new MultiCurlException('This class cannot be instantiated by the new keyword.  You must instantiate it using: $obj = MultiCurl::getInstance();');
+        throw new MultiCurlException('This class cannot be instantiated by the new keyword.  You must instantiate it using: $obj = MultiCurl::getInstance();');
     }
 
     $this->mc = curl_multi_init();
     $this->properties = array(
-      'code'  => CURLINFO_HTTP_CODE,
-      'time'  => CURLINFO_TOTAL_TIME,
-      'length'=> CURLINFO_CONTENT_LENGTH_DOWNLOAD,
-      'type'  => CURLINFO_CONTENT_TYPE,
-      'url'   => CURLINFO_EFFECTIVE_URL
-      );
-  }
+        'code'  => CURLINFO_HTTP_CODE,
+        'time'  => CURLINFO_TOTAL_TIME,
+        'length'=> CURLINFO_CONTENT_LENGTH_DOWNLOAD,
+        'type'  => CURLINFO_CONTENT_TYPE,
+        'url'   => CURLINFO_EFFECTIVE_URL
+        );
+    }
   
-  public function reset(){
-      $this->requests = array();
-      $this->responses = array();
-      self::$timers = array();
-  }
-
-  public function addUrl($url, $options = array())
-  {
+    public function reset(){
+        $this->requests = array();
+        $this->responses = array();
+        self::$timers = array();
+    }
+
+    public function addUrl($url, $options = array())
+    {
     $ch = curl_init($url);
     curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
     foreach($options as $option=>$value)
@@ -59,13 +59,13 @@ 
         curl_setopt($ch, $option, $value);
     }
     return $this->addCurl($ch);
-  }
+    }
 
-  public function addCurl($ch)
-  {
+    public function addCurl($ch)
+    {
     if(gettype($ch) !== 'resource')
     {
-      throw new MultiCurlInvalidParameterException('Parameter must be a valid curl handle');
+        throw new MultiCurlInvalidParameterException('Parameter must be a valid curl handle');
     }
 
     $key = $this->getKey($ch);
@@ -78,31 +78,31 @@ 
     // (1)
     if($code === CURLM_OK || $code === CURLM_CALL_MULTI_PERFORM)
     {
-      do
-      {
+        do
+        {
         $this->execStatus = curl_multi_exec($this->mc, $this->running);
-      } while ($this->execStatus === CURLM_CALL_MULTI_PERFORM);
+        } while ($this->execStatus === CURLM_CALL_MULTI_PERFORM);
 
-      return new MultiCurlManager($key);
+        return new MultiCurlManager($key);
     }
     else
     {
-      return $code;
+        return $code;
+    }
     }
-  }
 
-  public function getResult($key = null)
-  {
+    public function getResult($key = null)
+    {
     if($key != null)
     {
-      if(isset($this->responses[$key]['code']))
-      {
+        if(isset($this->responses[$key]['code']))
+        {
         return $this->responses[$key];
-      }
+        }
 
-      $innerSleepInt = $outerSleepInt = 1;
-      while($this->running && ($this->execStatus == CURLM_OK || $this->execStatus == CURLM_CALL_MULTI_PERFORM))
-      {
+        $innerSleepInt = $outerSleepInt = 1;
+        while($this->running && ($this->execStatus == CURLM_OK || $this->execStatus == CURLM_CALL_MULTI_PERFORM))
+        {
         usleep(intval($outerSleepInt));
         $outerSleepInt = intval(max(1, ($outerSleepInt*$this->sleepIncrement)));
         $ms=curl_multi_select($this->mc, 0);
@@ -110,114 +110,114 @@ 
         // bug in PHP 5.3.18+ where curl_multi_select can return -1
         // https://bugs.php.net/bug.php?id=63411
         if($ms === -1)
-          usleep(100000);
+            usleep(100000);
 
         // see pull request https://github.com/jmathai/php-multi-curl/pull/17
         // details here http://curl.haxx.se/libcurl/c/libcurl-errors.html
         if($ms >= CURLM_CALL_MULTI_PERFORM)
         {
-          do{
+            do{
             $this->execStatus = curl_multi_exec($this->mc, $this->running);
             usleep(intval($innerSleepInt));
             $innerSleepInt = intval(max(1, ($innerSleepInt*$this->sleepIncrement)));
-          }while($this->execStatus==CURLM_CALL_MULTI_PERFORM);
-          $innerSleepInt = 1;
+            }while($this->execStatus==CURLM_CALL_MULTI_PERFORM);
+            $innerSleepInt = 1;
         }
         $this->storeResponses();
         if(isset($this->responses[$key]['data']))
         {
-          return $this->responses[$key];
+            return $this->responses[$key];
         }
-      }
-      return null;
+        }
+        return null;
     }
     return false;
-  }
+    }
 
-  public static function getSequence()
-  {
+    public static function getSequence()
+    {
     return new MultiCurlSequence(self::$timers);
-  }
+    }
 
-  public static function getTimers()
-  {
+    public static function getTimers()
+    {
     return self::$timers;
-  }
+    }
 
-  public function inject($key, $value)
-  {
+    public function inject($key, $value)
+    {
     $this->$key = $value;
-  }
+    }
 
-  private function getKey($ch)
-  {
+    private function getKey($ch)
+    {
     return (string)$ch;
-  }
+    }
 
-  private function headerCallback($ch, $header)
-  {
+    private function headerCallback($ch, $header)
+    {
     $_header = trim($header);
     $colonPos= strpos($_header, ':');
     if($colonPos > 0)
     {
-      $key = substr($_header, 0, $colonPos);
-      $val = preg_replace('/^\W+/','',substr($_header, $colonPos));
-      $this->responses[$this->getKey($ch)]['headers'][$key] = $val;
+        $key = substr($_header, 0, $colonPos);
+        $val = preg_replace('/^\W+/','',substr($_header, $colonPos));
+        $this->responses[$this->getKey($ch)]['headers'][$key] = $val;
     }
     return strlen($header);
-  }
+    }
 
-  private function storeResponses()
-  {
+    private function storeResponses()
+    {
     while($done = curl_multi_info_read($this->mc))
     {
-      $this->storeResponse($done);
+        $this->storeResponse($done);
+    }
     }
-  }
 
-  private function storeResponse($done, $isAsynchronous = true)
-  {
+    private function storeResponse($done, $isAsynchronous = true)
+    {
     $key = $this->getKey($done['handle']);
     $this->stopTimer($key, $done);
     if($isAsynchronous)
-      $this->responses[$key]['data'] = curl_multi_getcontent($done['handle']);
+        $this->responses[$key]['data'] = curl_multi_getcontent($done['handle']);
     else
-      $this->responses[$key]['data'] = curl_exec($done['handle']);
+        $this->responses[$key]['data'] = curl_exec($done['handle']);
 
     $this->responses[$key]['response'] = $this->responses[$key]['data'];
 
     foreach($this->properties as $name => $const)
     {
-      $this->responses[$key][$name] = curl_getinfo($done['handle'], $const);
+        $this->responses[$key][$name] = curl_getinfo($done['handle'], $const);
     }
     if($isAsynchronous)
-      curl_multi_remove_handle($this->mc, $done['handle']);
+        curl_multi_remove_handle($this->mc, $done['handle']);
     curl_close($done['handle']);
-  }
+    }
 
-  private function startTimer($key)
-  {
+    private function startTimer($key)
+    {
     self::$timers[$key]['start'] = microtime(true);
-  }
-
-  private function stopTimer($key, $done)
-  {
-      self::$timers[$key]['end'] = microtime(true);
-      self::$timers[$key]['api'] = curl_getinfo($done['handle'], CURLINFO_EFFECTIVE_URL);
-      self::$timers[$key]['time'] = curl_getinfo($done['handle'], CURLINFO_TOTAL_TIME);
-      self::$timers[$key]['code'] = curl_getinfo($done['handle'], CURLINFO_HTTP_CODE);
-  }
-
-  public static function getInstance()
-  {
+    }
+
+    private function stopTimer($key, $done)
+    {
+        self::$timers[$key]['end'] = microtime(true);
+        self::$timers[$key]['api'] = curl_getinfo($done['handle'], CURLINFO_EFFECTIVE_URL);
+        self::$timers[$key]['time'] = curl_getinfo($done['handle'], CURLINFO_TOTAL_TIME);
+        self::$timers[$key]['code'] = curl_getinfo($done['handle'], CURLINFO_HTTP_CODE);
+    }
+
+    public static function getInstance()
+    {
     if(self::$inst == null)
     {
-      self::$singleton = 1;
-      self::$inst = new MultiCurl();
+        self::$singleton = 1;
+        self::$inst = new MultiCurl();
     }
 
     return self::$inst;
-  }
+    }
 }
 
 /*