caffeina-core / core

classes/Work.php

Spacing +14 added lines, -14 removed lines

@@ -21,9 +21,9 @@ 
   protected static $workers;
   protected static $lastID = 0;
 
-  public static function add($id, $job=null){
-    self::$pool or ( self::$pool = new \SplQueue() );
-    if(is_callable($id) && $job===null){
+  public static function add($id, $job = null) {
+    self::$pool or (self::$pool = new \SplQueue());
+    if (is_callable($id) && $job === null) {
       $job = $id;
       $id = ++self::$lastID;
     }
@@ -33,12 +33,12 @@ 
     return $task;
   }
 
-  public static function send($id,$passValue) {
+  public static function send($id, $passValue) {
      isset(self::$workers[$id]) && self::$workers[$id]->pass($passValue);
   }
 
-  public static function run(){
-    self::$pool or ( self::$pool = new \SplQueue() );
+  public static function run() {
+    self::$pool or (self::$pool = new \SplQueue());
     while (!self::$pool->isEmpty()) {
       $task = self::$pool->dequeue();
       $task->run();
@@ -54,7 +54,7 @@ 
    * Defer callback execution after script execution
    * @param callable $callback The deferred callback
    */ d
-  public static function after(callable $callback){
+  public static function after(callable $callback) {
     static::$inited_shutdown || static::install_shutdown();
     Event::on('core.shutdown', $callback);
   }
@@ -62,24 +62,24 @@ 
   /**
    * Single shot defer handeler install
    */
-  protected static function install_shutdown(){
+  protected static function install_shutdown() {
     if (static::$inited_shutdown) return;
     
     // Disable time limit
     set_time_limit(0);
     
     // HHVM support
-    if(function_exists('register_postsend_function')){
-      register_postsend_function(function(){
+    if (function_exists('register_postsend_function')) {
+      register_postsend_function(function() {
         Event::trigger('core.shutdown');
       });
-    } else if(function_exists('fastcgi_finish_request')) {
-      register_shutdown_function(function(){
+    } else if (function_exists('fastcgi_finish_request')) {
+      register_shutdown_function(function() {
         fastcgi_finish_request();
         Event::trigger('core.shutdown');
       });       
     } else {
-      register_shutdown_function(function(){
+      register_shutdown_function(function() {
         Event::trigger('core.shutdown');
       });
     }
@@ -121,7 +121,7 @@ 
     }
 
     public function complete() {
-        return ! $this->coroutine->valid();
+        return !$this->coroutine->valid();
     }
 
 }

Braces +12 added lines, -10 removed lines

@@ -21,9 +21,9 @@ 
   protected static $workers;
   protected static $lastID = 0;
 
-  public static function add($id, $job=null){
+  public static function add($id, $job=null) {
     self::$pool or ( self::$pool = new \SplQueue() );
-    if(is_callable($id) && $job===null){
+    if(is_callable($id) && $job===null) {
       $job = $id;
       $id = ++self::$lastID;
     }
@@ -37,7 +37,7 @@ 
      isset(self::$workers[$id]) && self::$workers[$id]->pass($passValue);
   }
 
-  public static function run(){
+  public static function run() {
     self::$pool or ( self::$pool = new \SplQueue() );
     while (!self::$pool->isEmpty()) {
       $task = self::$pool->dequeue();
@@ -54,7 +54,7 @@ 
    * Defer callback execution after script execution
    * @param callable $callback The deferred callback
    */ d
-  public static function after(callable $callback){
+  public static function after(callable $callback) {
     static::$inited_shutdown || static::install_shutdown();
     Event::on('core.shutdown', $callback);
   }
@@ -62,24 +62,26 @@ 
   /**
    * Single shot defer handeler install
    */
-  protected static function install_shutdown(){
-    if (static::$inited_shutdown) return;
+  protected static function install_shutdown() {
+    if (static::$inited_shutdown) {
+      return;
+    }
     
     // Disable time limit
     set_time_limit(0);
     
     // HHVM support
-    if(function_exists('register_postsend_function')){
-      register_postsend_function(function(){
+    if(function_exists('register_postsend_function')) {
+      register_postsend_function(function() {
         Event::trigger('core.shutdown');
       });
     } else if(function_exists('fastcgi_finish_request')) {
-      register_shutdown_function(function(){
+      register_shutdown_function(function() {
         fastcgi_finish_request();
         Event::trigger('core.shutdown');
       });       
     } else {
-      register_shutdown_function(function(){
+      register_shutdown_function(function() {
         Event::trigger('core.shutdown');
       });
     }

classes/Map.php

Spacing +24 added lines, -24 removed lines

@@ -29,11 +29,11 @@ 
      * @param  mixed $default (optional) The default value. If is a callable it will executed and the return value will be used.
      * @return mixed The value of the key or the default (resolved) value if the key not existed.
      */
-    public function get($key, $default=null){
-        if ($ptr =& $this->find($key,false)){
+    public function get($key, $default = null) {
+        if ($ptr = & $this->find($key, false)) {
             return $ptr;
         } else {
-            if ($default !== null){
+            if ($default !== null) {
                 return $this->set($key, is_callable($default) ? call_user_func($default) : $default);
             } else {
                 return null;
@@ -47,11 +47,11 @@ 
      * @param  mixed $value (optional) The value. If is a callable it will executed and the return value will be used.
      * @return mixed The value of the key or the default (resolved) value if the key not existed.
      */
-    public function set($key, $value=null){
+    public function set($key, $value = null) {
         if (is_array($key)) {
             return $this->merge($key);
         } else {
-            $ptr =& $this->find($key, true);
+            $ptr = & $this->find($key, true);
             return $ptr = $value;
         }
     }
@@ -61,7 +61,7 @@ 
      * @param  string $key The key path in dot notation
      * @param  boolean $compact (optional) Compact map removing empty paths.
      */
-    public function delete($key, $compact=true){
+    public function delete($key, $compact = true) {
         $this->set($key, null);
         if ($compact) $this->compact();
     }
@@ -71,18 +71,18 @@ 
      * @param  string $key The key path in dot notation
      * @return boolean
      */
-    public function exists($key){
+    public function exists($key) {
         return null !== $this->find($key, false);
     }
 
     /**
      * Clear all key path in map.
      */
-    public function clear(){
+    public function clear() {
         $this->fields = [];
     }
 
-    public function __construct($fields=null){
+    public function __construct($fields = null) {
         $this->load($fields);
     }
 
@@ -90,8 +90,8 @@ 
      * Load an associative array/object as the map source.
      * @param  string $fields The array to merge
      */
-    public function load($fields){
-        if ($fields) $this->fields = (array)$fields;
+    public function load($fields) {
+        if ($fields) $this->fields = (array) $fields;
     }
 
     /**
@@ -99,17 +99,17 @@ 
      * @param  array   $array The array to merge
      * @param  boolean $merge_back If `true` merge the map over the $array, if `false` (default) the reverse.
      */
-    public function merge($array, $merge_back=false){
+    public function merge($array, $merge_back = false) {
         $this->fields = $merge_back
-            ? array_replace_recursive((array)$array, $this->fields)
-            : array_replace_recursive($this->fields, (array)$array);
+            ? array_replace_recursive((array) $array, $this->fields)
+            : array_replace_recursive($this->fields, (array) $array);
     }
 
     /**
      * Compact map removing empty paths
      */
 
-    public function compact(){
+    public function compact() {
 
         $array_filter_rec = function($input, $callback = null) use (&$array_filter_rec) {
             foreach ($input as &$value) {
@@ -120,7 +120,7 @@ 
             return array_filter($input, $callback);
         };
 
-        $this->fields = $array_filter_rec($this->fields,function($a){ return $a !== null; });
+        $this->fields = $array_filter_rec($this->fields, function($a) { return $a !== null;});
     }
 
     /**
@@ -130,18 +130,18 @@ 
      * @param  callable  If passed this callback will be applied to the founded value.
      * @return mixed The founded value.
      */
-    public function & find($path, $create=false, callable $operation=null) {
-        $tok = strtok($path,'.');
-        if ( $create ) {
-            $value =& $this->fields;
+    public function & find($path, $create = false, callable $operation = null) {
+        $tok = strtok($path, '.');
+        if ($create) {
+            $value = & $this->fields;
         } else {
             $value = $this->fields;
         }
-        while ( $tok !== false ){
-            $value =& $value[$tok];
+        while ($tok !== false) {
+            $value = & $value[$tok];
             $tok = strtok('.');
         }
-        if ( is_callable($operation) ) $operation($value);
+        if (is_callable($operation)) $operation($value);
         return $value;
     }
 
@@ -152,7 +152,7 @@ 
      *
      * @return string        The json object
      */
-    public function jsonSerialize(){
+    public function jsonSerialize() {
       return $this->fields;
     }
 

Braces +22 added lines, -16 removed lines

@@ -29,11 +29,11 @@ 
      * @param  mixed $default (optional) The default value. If is a callable it will executed and the return value will be used.
      * @return mixed The value of the key or the default (resolved) value if the key not existed.
      */
-    public function get($key, $default=null){
-        if ($ptr =& $this->find($key,false)){
+    public function get($key, $default=null) {
+        if ($ptr =& $this->find($key,false)) {
             return $ptr;
         } else {
-            if ($default !== null){
+            if ($default !== null) {
                 return $this->set($key, is_callable($default) ? call_user_func($default) : $default);
             } else {
                 return null;
@@ -47,7 +47,7 @@ 
      * @param  mixed $value (optional) The value. If is a callable it will executed and the return value will be used.
      * @return mixed The value of the key or the default (resolved) value if the key not existed.
      */
-    public function set($key, $value=null){
+    public function set($key, $value=null) {
         if (is_array($key)) {
             return $this->merge($key);
         } else {
@@ -61,9 +61,11 @@ 
      * @param  string $key The key path in dot notation
      * @param  boolean $compact (optional) Compact map removing empty paths.
      */
-    public function delete($key, $compact=true){
+    public function delete($key, $compact=true) {
         $this->set($key, null);
-        if ($compact) $this->compact();
+        if ($compact) {
+          $this->compact();
+        }
     }
 
     /**
@@ -71,18 +73,18 @@ 
      * @param  string $key The key path in dot notation
      * @return boolean
      */
-    public function exists($key){
+    public function exists($key) {
         return null !== $this->find($key, false);
     }
 
     /**
      * Clear all key path in map.
      */
-    public function clear(){
+    public function clear() {
         $this->fields = [];
     }
 
-    public function __construct($fields=null){
+    public function __construct($fields=null) {
         $this->load($fields);
     }
 
@@ -90,8 +92,10 @@ 
      * Load an associative array/object as the map source.
      * @param  string $fields The array to merge
      */
-    public function load($fields){
-        if ($fields) $this->fields = (array)$fields;
+    public function load($fields) {
+        if ($fields) {
+          $this->fields = (array)$fields;
+        }
     }
 
     /**
@@ -99,7 +103,7 @@ 
      * @param  array   $array The array to merge
      * @param  boolean $merge_back If `true` merge the map over the $array, if `false` (default) the reverse.
      */
-    public function merge($array, $merge_back=false){
+    public function merge($array, $merge_back=false) {
         $this->fields = $merge_back
             ? array_replace_recursive((array)$array, $this->fields)
             : array_replace_recursive($this->fields, (array)$array);
@@ -109,7 +113,7 @@ 
      * Compact map removing empty paths
      */
 
-    public function compact(){
+    public function compact() {
 
         $array_filter_rec = function($input, $callback = null) use (&$array_filter_rec) {
             foreach ($input as &$value) {
@@ -137,11 +141,13 @@ 
         } else {
             $value = $this->fields;
         }
-        while ( $tok !== false ){
+        while ( $tok !== false ) {
             $value =& $value[$tok];
             $tok = strtok('.');
         }
-        if ( is_callable($operation) ) $operation($value);
+        if ( is_callable($operation) ) {
+          $operation($value);
+        }
         return $value;
     }
 
@@ -152,7 +158,7 @@ 
      *
      * @return string        The json object
      */
-    public function jsonSerialize(){
+    public function jsonSerialize() {
       return $this->fields;
     }