tidal / PEIP

src/Util/Reflection.php

Spacing +3 added lines, -3 removed lines

@@ -30,9 +30,9 @@ 
      * @return array array with interface/class info for the class

      */

 

-    public static function getImplementedClassesAndInterfaces($class, $store = true){

+    public static function getImplementedClassesAndInterfaces($class, $store = true) {

         $class = is_object($class) ? get_class($class) : (string)$class;

-        if(isset(self::$classInfo[$class])){

+        if (isset(self::$classInfo[$class])) {

             return self::$classInfo[$class];

         }

         $cls = ReflectionPool::getInstance($class);

@@ -40,7 +40,7 @@ 
         $classInfo = (array)$cls->getInterfaceNames();

         $classInfo[] = $cls->getName();

         // get names of parent-classes

-        while($cls = $cls->getParentClass()){

+        while ($cls = $cls->getParentClass()) {

             $classInfo[] = $cls->getName();

         }

         

src/Util/Test.php

Spacing +28 added lines, -28 removed lines

@@ -15,11 +15,11 @@ 
 class Test {
 
 
-    public static function assertClassHasConstructor($className){
-        return (boolean) ReflectionPool::getInstance($className)->getConstructor();
+    public static function assertClassHasConstructor($className) {
+        return (boolean)ReflectionPool::getInstance($className)->getConstructor();
     }
 
-    public static function assertRequiredConstructorParameters($className, $parameters){
+    public static function assertRequiredConstructorParameters($className, $parameters) {
             return (boolean)
                 !self::assertClassHasConstructor($className) ||
                 count($parameters) >= ReflectionPool::getInstance($className)
@@ -27,55 +27,55 @@ 
                     ->getNumberOfRequiredParameters();
     }
 
-    public static function assertInstanceOf($className, $object){
-        return (boolean) ReflectionPool::getInstance($className)
+    public static function assertInstanceOf($className, $object) {
+        return (boolean)ReflectionPool::getInstance($className)
             ->isInstance($object);
     }
 
-    public static function assertClassOrInterfaceExists($className){
-        return (boolean) class_exists($className) || interface_exists($className);
+    public static function assertClassOrInterfaceExists($className) {
+        return (boolean)class_exists($className) || interface_exists($className);
     }
 
-    public static function assertImplements($className, $interfaceName){
+    public static function assertImplements($className, $interfaceName) {
         $className = is_object($className) ? get_class($className) : $className;
         $res = false;
         try { 
             class_exists($className);
-            $res =  ReflectionPool::getInstance($className)
+            $res = ReflectionPool::getInstance($className)
                 ->implementsInterface($interfaceName);            
-        }  catch (\Exception $e){
+        } catch (\Exception $e) {
             $res = false; 
         }
-        return $res;;
+        return $res; ;
     }
 
-    public static function assertMessage($message){
+    public static function assertMessage($message) {
         return self::assertImplements($message, '\PEIP\INF\Message\Message');
     }
 
-    public static function assertEvent($event){
+    public static function assertEvent($event) {
         return self::assertImplements($event, '\PEIP\INF\Event\Event');
     }
 
-    public static function assertEventSubject($event){
+    public static function assertEventSubject($event) {
         return self::assertImplements($event, '\PEIP\INF\Event\Event')
             && $event->getSubject();
     }
 
-    public static function assertEventObjectSubject($event){
+    public static function assertEventObjectSubject($event) {
         return self::assertEventSubject($event)
             && is_object($event->getSubject());
     }
-    public static function assertArrayAccess($var){
-        return (boolean) is_array($var) || $var instanceof \ArrayAccess;
+    public static function assertArrayAccess($var) {
+        return (boolean)is_array($var) || $var instanceof \ArrayAccess;
     }
 
-    public static function assertHandler($var){
-        return (boolean) is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;
+    public static function assertHandler($var) {
+        return (boolean)is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;
     }
 
-    public static function castType($var, $type){
-        switch($type){
+    public static function castType($var, $type) {
+        switch ($type) {
             case 'string':
                 $var = (string)$var;
                 break;
@@ -99,8 +99,8 @@ 
         return $var;
     }
 
-    public static function ensureArrayAccess($var){
-        if(!Test::assertArrayAccess($var)){
+    public static function ensureArrayAccess($var) {
+        if (!Test::assertArrayAccess($var)) {
             throw new \InvalidArgumentException(
                 'Value is not an array nor an instance of ArrayAccess'
             );
@@ -109,8 +109,8 @@ 
     }
 
 
-    public static function ensureHandler($var){
-        if(!Test::assertHandler($var)){
+    public static function ensureHandler($var) {
+        if (!Test::assertHandler($var)) {
             throw new \InvalidArgumentException(
                 'Value is not an callable nor an instance of \PEIP\INF\Handler\Handler'
             );
@@ -118,8 +118,8 @@ 
         return $var;
     }
 
-    public static function ensureImplements($className, $interfaceName){
-        if(!Test::assertImplements($className, $interfaceName)){
+    public static function ensureImplements($className, $interfaceName) {
+        if (!Test::assertImplements($className, $interfaceName)) {
             throw new \InvalidArgumentException(
                 'Class "'.$className.'" is not an instanceof "'.$interfaceName.'"'
             );
@@ -127,7 +127,7 @@ 
         return $className;
     }
 
-    public static function assertMethod($className, $methodname){
+    public static function assertMethod($className, $methodname) {
         return ReflectionPool::getInstance($className)->hasMethod($methodname);
     }
 

Braces +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
             class_exists($className);
             $res =  ReflectionPool::getInstance($className)
                 ->implementsInterface($interfaceName);            
-        }  catch (\Exception $e){
+        } catch (\Exception $e){
             $res = false; 
         }
         return $res;;

src/Util/ReflectionPool.php

Spacing +2 added lines, -2 removed lines

@@ -22,11 +22,11 @@
      * @param $argument

      * @return ReflectionClass

      */

-    public  static function getInstance($argument){

+    public  static function getInstance($argument) {

 

         $className = is_object($argument)

             ? get_class($argument)

-            : (string) $argument;

+            : (string)$argument;

         return isset(self::$instances[$className])

             ? self::$instances[$className]

             : self::$instances[$className] = new \ReflectionClass($className);

src/Event/Observable.php

Spacing +12 added lines, -12 removed lines

@@ -36,7 +36,7 @@ 
      * @param $observedObject 

      * @return 

      */

-    public function __construct(object $observedObject){

+    public function __construct(object $observedObject) {

         $this->observedObject = $observedObject;

     }

 

@@ -46,7 +46,7 @@ 
      * @param $observer 

      * @return 

      */

-    public function addObserver(\PEIP\INF\Event\Observer $observer){

+    public function addObserver(\PEIP\INF\Event\Observer $observer) {

         $this->observers[] = $observer;     

     }

 

@@ -56,9 +56,9 @@ 
      * @param $observer 

      * @return 

      */

-    public function deleteObserver(\PEIP\INF\Event\Observer $observer){

-        foreach($this->observers as $key=>$obs){

-            if($obs == $observer){

+    public function deleteObserver(\PEIP\INF\Event\Observer $observer) {

+        foreach ($this->observers as $key=>$obs) {

+            if ($obs == $observer) {

                 unset($this->observers[$key]);

                 return true;

             }

@@ -71,9 +71,9 @@ 
      * @param $arguments 

      * @return 

      */

-    public function notifyObservers(array $arguments = array()){

-        if($this->hasChanged()){

-            foreach($this->observers as $observer){

+    public function notifyObservers(array $arguments = array()) {

+        if ($this->hasChanged()) {

+            foreach ($this->observers as $observer) {

                 $observer->update($this->observedObject);

             }       

         }

@@ -84,7 +84,7 @@ 
      * @access public

      * @return 

      */

-    public function countObservers(){

+    public function countObservers() {

         return count($this->obeservers);

     }

     

@@ -93,7 +93,7 @@ 
      * @access public

      * @return 

      */

-    public function hasChanged(){

+    public function hasChanged() {

         return $this->hasChanged();

     }

     

@@ -102,7 +102,7 @@ 
      * @access public

      * @return 

      */

-    public function setChanged(){

+    public function setChanged() {

         $this->hasChanged = true;

     }

 

@@ -111,7 +111,7 @@ 
      * @access public

      * @return 

      */

-    public function clearChanged(){

+    public function clearChanged() {

         $this->hasChanged = true;   

     }

 

src/ABS/Dispatcher/Dispatcher.php

Indentation +2 added lines, -2 removed lines

@@ -60,9 +60,9 @@
      */     

     protected static function doNotifyUntil(array $listeners, $subject){

         foreach ($listeners as $listener){

-          if (self::doNotifyOne($listener, $subject)){

+            if (self::doNotifyOne($listener, $subject)){

             return $listener;

-          }

+            }

         }

         return NULL;

     } 

Spacing +8 added lines, -8 removed lines

@@ -33,16 +33,16 @@ 
      * @param mixed $subject subject to notify the listeners of 

      * @return void

      */ 

-    protected static function doNotify(array $listeners, $subject){

-        foreach($listeners as $listener){

+    protected static function doNotify(array $listeners, $subject) {

+        foreach ($listeners as $listener) {

             self::doNotifyOne($listener, $subject);

         }   

     }  

 

-    protected static function doNotifyOne($listener, $subject){

-        if(is_callable($listener)){

+    protected static function doNotifyOne($listener, $subject) {

+        if (is_callable($listener)) {

             $res = call_user_func($listener, $subject);

-        }else{

+        }else {

             $res = $listener->handle($subject);

         }

         return $res;

@@ -58,9 +58,9 @@ 
      * @param mixed $subject subject to notify the listeners of 

      * @return \PEIP\INF\Handler\Handler listener that returned a boolean true value

      */     

-    protected static function doNotifyUntil(array $listeners, $subject){

-        foreach ($listeners as $listener){

-          if (self::doNotifyOne($listener, $subject)){

+    protected static function doNotifyUntil(array $listeners, $subject) {

+        foreach ($listeners as $listener) {

+          if (self::doNotifyOne($listener, $subject)) {

             return $listener;

           }

         }

Braces +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
     protected function getMessage($object){

         if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){

             return $object; 

-        }else{

+        } else{

             return $object->getContent()->receive();

         }

     }

src/ABS/Base/Container.php

Spacing +2 added lines, -2 removed lines

@@ -22,7 +22,7 @@ 
 

 

 abstract class Container 

-    implements \PEIP\INF\Base\Container{

+    implements \PEIP\INF\Base\Container {

 

     protected $content;

        

@@ -33,7 +33,7 @@ 
      * @access public

      * @return 

      */

-    public function getContent(){

+    public function getContent() {

         return $this->content;

     }

     

src/ABS/Base/Connectable.php

Spacing +15 added lines, -15 removed lines

@@ -17,7 +17,7 @@ 
  * @subpackage base 

  */

 

-abstract class Connectable  implements \PEIP\INF\Event\Connectable{

+abstract class Connectable  implements \PEIP\INF\Event\Connectable {

 

     const

         DEFAULT_CLASS_MESSAGE_DISPATCHER = '\PEIP\Dispatcher\Dispatcher',

@@ -42,7 +42,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return

      */

-    public function connect($name, $listener){

+    public function connect($name, $listener) {

         \PEIP\Util\Test::ensureHandler($listener);

         $this->getEventDispatcher()->connect($name, $this, $listener);

         $this->doFireEvent(

@@ -61,7 +61,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return

      */

-    public function disconnect($name, $listener){

+    public function disconnect($name, $listener) {

         \PEIP\Util\Test::ensureHandler($listener);

         $this->getEventDispatcher()->disconnect($name, $this, $listener);

         $this->doFireEvent(

@@ -82,7 +82,7 @@ 
      * @param $name

      * @return

      */

-    public function hasListeners($name){

+    public function hasListeners($name) {

         return $this->getEventDispatcher()->hasListeners($name, $this);

     }

 

@@ -92,7 +92,7 @@ 
      * @param $name

      * @return

      */

-    public function getListeners($name){

+    public function getListeners($name) {

         return $this->getEventDispatcher()->getListeners($name, $this);

     }

 

@@ -102,7 +102,7 @@ 
      * @param $callable

      * @return

      */

-    public function disconnectAll($name){

+    public function disconnectAll($name) {

         $this->getEventDispatcher()->disconnectAll($name, $this);

     }

 

@@ -112,11 +112,11 @@ 
      * @param $transferListners

      * @return

      */

-    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true){

-        if($transferListners){

-            foreach($this->getEventDispatcher()->getEventNames($this) as $name){

-                if($this->getEventDispatcher()->hasListeners($name, $this)){

-                    foreach($this->getEventDispatcher()->getListeners($name, $this) as $listener){

+    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true) {

+        if ($transferListners) {

+            foreach ($this->getEventDispatcher()->getEventNames($this) as $name) {

+                if ($this->getEventDispatcher()->hasListeners($name, $this)) {

+                    foreach ($this->getEventDispatcher()->getListeners($name, $this) as $listener) {

                         $dispatcher->connect($name, $this, $listener);

                     }

                 }

@@ -131,11 +131,11 @@ 
      * @access public

      * @return

      */

-    public function getEventDispatcher(){

+    public function getEventDispatcher() {

         return $this->eventDispatcher ? $this->eventDispatcher : $this->eventDispatcher = self::getSharedEventDispatcher();

     }

 

-    protected static function getSharedEventDispatcher(){

+    protected static function getSharedEventDispatcher() {

         $defaultDispatcher = self::DEFAULT_CLASS_EVENT_DISPATCHER;

         return self::$sharedEventDispatcher ? self::$sharedEventDispatcher : self::$sharedEventDispatcher = new $defaultDispatcher;

     }

@@ -148,12 +148,12 @@ 
      * @param $eventClass

      * @return

      */

-    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false){

+    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false) {

         $eventClass = trim($eventClass) == '' ? static::DEFAULT_EVENT_CLASS : $eventClass;

         return $this->getEventDispatcher()->buildAndNotify($name, $this, $headers, $eventClass, $type);

     }

 

-    protected static function getDefaultEventClass(){

+    protected static function getDefaultEventClass() {

         return self::DEFAULT_EVENT_CLASS;

     }

 }

src/ABS/Base/MutableContainer.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
      * @access public

      * @return mixed content

      */

-    public function getContent(){

+    public function getContent() {

         return parent::getContent();

     } 

 }
\ No newline at end of file

src/ABS/Pipe/EventPipe.php

Spacing +5 added lines, -5 removed lines

@@ -38,8 +38,8 @@ 
      * @param string $eventName name of the event to listen to 

      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to listen to 

      */

-    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable){

-        if(!$connectable->hasListener($eventName, $this)){

+    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable) {

+        if (!$connectable->hasListener($eventName, $this)) {

             $connectable->connect($eventName, $this);

             $this->connections[spl_object_hash($connectable)] = $connectable;   

         }   

@@ -52,8 +52,8 @@ 
      * @param string $eventName name of the event to unlisten 

      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to unlisten to 

      */

-    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable){

-        if(!$connectable->hasListener($eventName, $this)){

+    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable) {

+        if (!$connectable->hasListener($eventName, $this)) {

             $connectable->disconnect($eventName, $this);

             unset($this->connections[spl_object_hash($connectable)]);   

         }   

@@ -65,7 +65,7 @@ 
      * @access public

      * @return array array of \PEIP\INF\Event\Connectable instances

      */

-    public function doGetConnected(){

+    public function doGetConnected() {

         return array_values($this->connections);

     }