tidal / PEIP

src/Event/Event.php

Spacing +9 added lines, -9 removed lines

@@ -51,7 +51,7 @@ 
      * @param string $name the name of the event
      * @param array|ArrayAccess $headers the headers for the event 
      */
-    public function __construct($subject, $name, $parameters = array(), $type = false){
+    public function __construct($subject, $name, $parameters = array(), $type = false) {
         parent::__construct($subject, Test::ensureArrayAccess($parameters));
         $this->name = $name;
         $this->type = $type ? $type : get_class($this);
@@ -63,7 +63,7 @@ 
      * @access public
      * @return string the name of the event
      */
-    public function getName(){
+    public function getName() {
         return $this->name;
     }
 
@@ -74,7 +74,7 @@ 
      * @access public
      * @return string the type of the event
      */
-    public function getType(){
+    public function getType() {
         return $this->name;
     }
   
@@ -84,7 +84,7 @@ 
      * @access public
      * @param mixed $value the return-value to set 
      */
-    public function setReturnValue($value){
+    public function setReturnValue($value) {
         $this->value = $value;
     }
   
@@ -94,7 +94,7 @@ 
      * @access public
      * @return mixed the return-value to set
      */
-    public function getReturnValue(){
+    public function getReturnValue() {
         return $this->value;
     }
   
@@ -104,8 +104,8 @@ 
      * @access public
      * @param boolean $processed 
      */
-    public function setProcessed($processed){
-        $this->processed = (boolean) $processed;
+    public function setProcessed($processed) {
+        $this->processed = (boolean)$processed;
     }
 
     /**
@@ -114,7 +114,7 @@ 
      * @access public
      * @return boolean wether the event is processed 
      */
-    public function isProcessed(){
+    public function isProcessed() {
         return $this->processed;
     }
 
@@ -124,7 +124,7 @@ 
      * @access public
      * @return mixed the subject/content
      */
-    public function getSubject(){
+    public function getSubject() {
         return $this->getContent();
     }
 }

src/Dispatcher/EventClassDispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -25,9 +25,9 @@ 
      * @param \PEIP\INF\Event\Event $object an event object
      * @return boolean
      */
-    public function notify($name, $object){ 
-        if($object instanceof \PEIP\INF\Event\Event){
-            if(is_object($object->getContent())){
+    public function notify($name, $object) { 
+        if ($object instanceof \PEIP\INF\Event\Event) {
+            if (is_object($object->getContent())) {
                 return self::doNotify(
                     $this->getListeners(
                         $name,
@@ -35,10 +35,10 @@ 
                      ),
                      $object->getContent()
                  );
-            }else{
+            }else {
                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');
             }
-        }else{
+        }else {
             throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');
         }
     }       //put your code here
@@ -55,8 +55,8 @@ 
      * @return
      * @see EventBuilder
      */
-    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){
-        if(!$this->hasListeners($name, ($object))){
+    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false) {
+        if (!$this->hasListeners($name, ($object))) {
             return false;
         }
 
@@ -79,7 +79,7 @@ 
      * @param object $object object to check for listeners
      * @return boolean
      */
-    public function hasListeners($name, $object){
+    public function hasListeners($name, $object) {
         return parent::hasListeners(
             $name,
             ReflectionPool::getInstance($object)

src/Dispatcher/ObjectMapDispatcher.php

Spacing +33 added lines, -33 removed lines

@@ -43,13 +43,13 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener event-handler
      * @return boolean
      */
-    public function connect($name, $object, $listener){
+    public function connect($name, $object, $listener) {
         Test::ensureHandler($listener);
         $listners = $this->doGetListeners();
-        if (!$this->listeners->contains($object)){
+        if (!$this->listeners->contains($object)) {
             $this->listeners->attach($object, new \ArrayObject);
         }
-        if (!array_key_exists($name, $listners[$object])){ 
+        if (!array_key_exists($name, $listners[$object])) { 
             $this->listeners[$object][$name] = array();
         }
         $hash = $this->getListenerHash($listener);
@@ -67,14 +67,14 @@ 
      * @param \PEIP\INF\Handler\Handler $listener event-handler
      * @return boolean
      */
-    public function disconnect($name, $object, $listener){
+    public function disconnect($name, $object, $listener) {
         $listners = $this->doGetListeners();
-        if (!$listners->contains($object) || !isset($listners[$object][$name])){
+        if (!$listners->contains($object) || !isset($listners[$object][$name])) {
             return false;
         }
         $eventListeners = $listners[$object][$name];
         $hash = $this->getListenerHash($listener);
-        if(isset($eventListeners[$hash])){
+        if (isset($eventListeners[$hash])) {
             unset($eventListeners[$hash]); 
 
             $listners[$object][$name] = $eventListeners;
@@ -83,10 +83,10 @@ 
         return false;
     }
 
-    public function disconnectAll($name, $object){
-        if(is_object($object)){
+    public function disconnectAll($name, $object) {
+        if (is_object($object)) {
             $listners = $this->doGetListeners();
-            if($listners && $this->hadListeners($name, $object)){
+            if ($listners && $this->hadListeners($name, $object)) {
                     $listners[$object][$name] = array();
             }        
         }
@@ -100,13 +100,13 @@ 
      * @param object $object object to check for listeners
      * @return boolean
      */
-    public function hasListeners($name, $object){
+    public function hasListeners($name, $object) {
         $listners = $this->doGetListeners();
-        if (!$this->hadListeners($name, $object)){
+        if (!$this->hadListeners($name, $object)) {
             $res = false;
-        }else{
+        }else {
             $listners = $this->doGetListeners();
-            $res = (boolean) count($listners[$object][$name]);
+            $res = (boolean)count($listners[$object][$name]);
         }
         return $res;
     }
@@ -119,7 +119,7 @@ 
      * @param object $object object to check for listeners
      * @return boolean
      */
-    public function hadListeners($name, $object){
+    public function hadListeners($name, $object) {
         $listners = $this->doGetListeners();
         return ($listners->contains($object) && isset($listners[$object][$name])) ? true : false;
     }
@@ -131,9 +131,9 @@ 
      * @param object $object object to get event-names for
      * @return string[] array of event-names
      */
-    public function getEventNames($object){
+    public function getEventNames($object) {
         $listeners = $this->doGetListeners();
-        if (!$listeners->contains($object)){
+        if (!$listeners->contains($object)) {
             return array();
         }
         return array_keys($listeners[$object]->getArrayCopy());
@@ -147,8 +147,8 @@ 
      * @param $object 
      * @return boolean
      */
-    public function notify($name, $object){
-        if($this->hasListeners($name, $object)){
+    public function notify($name, $object) {
+        if ($this->hasListeners($name, $object)) {
             $listners = $this->doGetListeners();
             self::doNotify($listners[$object][$name], $object);
         }
@@ -164,8 +164,8 @@ 
      * @param $subject 
      * @return mixed
      */
-    public function notifyUntil($name, $subject){
-        if($this->hasListeners($name, $subject)){       
+    public function notifyUntil($name, $subject) {
+        if ($this->hasListeners($name, $subject)) {       
             $res = self::doNotifyUntil($this->getListeners($name, $subject), $subject);   
         }
         return $res;
@@ -179,8 +179,8 @@ 
      * @param object $object object to check for listeners
      * @return array array of listeners
      */
-    public function getListeners($name, $object){
-        if (!$this->hadListeners($name, $object)){
+    public function getListeners($name, $object) {
+        if (!$this->hadListeners($name, $object)) {
             return array();
         }
         $listeners = $this->listeners[$object]->getArrayCopy();
@@ -194,7 +194,7 @@ 
      * @access protected
      * @return ObjectStorage
      */
-    protected function doGetListeners(){
+    protected function doGetListeners() {
         return isset($this->listeners) ? $this->listeners : $this->listeners = new ObjectStorage();
     }
    
@@ -207,11 +207,11 @@ 
      * @param $object 
      * @return boolean
      */    
-    protected static function doNotify(array $listeners, $subject){
-        foreach($listeners as $listener){ 
-             if($listener instanceof \PEIP\INF\Handler\Handler){
+    protected static function doNotify(array $listeners, $subject) {
+        foreach ($listeners as $listener) { 
+             if ($listener instanceof \PEIP\INF\Handler\Handler) {
                 $listener->handle($subject);
-             }elseif(is_callable($listener)){
+             }elseif (is_callable($listener)) {
                  call_user_func($listener, $subject);
              }
         }   
@@ -226,12 +226,12 @@ 
      * @param $object 
      * @return \PEIP\INF\Handler\Handler the listener which returned a boolean true value
      */     
-    protected static function doNotifyUntil(array $listeners, $subject){  
+    protected static function doNotifyUntil(array $listeners, $subject) {  
         $res = NULL; 
-        foreach ($listeners as $listener){ 
-            if($listener instanceof \PEIP\INF\Handler\Handler){
+        foreach ($listeners as $listener) { 
+            if ($listener instanceof \PEIP\INF\Handler\Handler) {
                 $res = $listener->handle($subject);
-                if ($res){ 
+                if ($res) { 
                     return $listener;
                 }
             }
@@ -239,8 +239,8 @@ 
         return $res;
     }
 
-    protected function getListenerHash($listener){
-        if(!is_object($listener)){
+    protected function getListenerHash($listener) {
+        if (!is_object($listener)) {
             $o = new \stdClass();
             $o->listener = $listener;
             $listener = $o;

src/Dispatcher/ObjectEventDispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -40,16 +40,16 @@ 
      * @param \PEIP\INF\Event\Event $object an event object
      * @return boolean
      */
-    public function notify($name, $object){
-        if($object instanceof \PEIP\INF\Event\Event){
-            if(is_object($object->getContent())){
-                if($this->hasListeners($name, $object->getContent())){
+    public function notify($name, $object) {
+        if ($object instanceof \PEIP\INF\Event\Event) {
+            if (is_object($object->getContent())) {
+                if ($this->hasListeners($name, $object->getContent())) {
                     return self::doNotify($this->getListeners($name, $object->getContent()), $object);  
                 }                   
-            }else{
+            }else {
                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');
             }   
-        }else{
+        }else {
             throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');
         }  
     }   
@@ -66,8 +66,8 @@ 
      * @return
      * @see EventBuilder 
      */
-    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){
-        if(!$this->hasListeners($name, $object)){
+    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false) {
+        if (!$this->hasListeners($name, $object)) {
             return false;
         }
         $event = EventBuilder::getInstance($eventClass)->build(

src/Dispatcher/Dispatcher.php

Spacing +12 added lines, -12 removed lines

@@ -40,7 +40,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler  $listener
      * @return void
      */
-    public function connect($listener){
+    public function connect($listener) {
         Test::ensureHandler($listener);
         $this->listeners[] = $listener;
     }
@@ -52,10 +52,10 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return void
      */
-    public function disconnect($listener){
+    public function disconnect($listener) {
         Test::ensureHandler($listener);
-        foreach ($this->listeners as $i => $callable){
-            if ($listener === $callable){
+        foreach ($this->listeners as $i => $callable) {
+            if ($listener === $callable) {
                 unset($this->listeners[$i]);
             }
         }
@@ -68,7 +68,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return void
      */
-    public function disconnectAll(){
+    public function disconnectAll() {
         $this->listeners = array();
     }
 
@@ -78,8 +78,8 @@ 
      * @access public
      * @return boolean wether any listeners are registered
      */
-    public function hasListeners(){
-        return (boolean) count($this->listeners);
+    public function hasListeners() {
+        return (boolean)count($this->listeners);
     }
     
     /**
@@ -89,9 +89,9 @@ 
      * @param mixed $subject the subject
      * @return void
      */
-    public function notify($subject){
+    public function notify($subject) {
         $res = NULL;
-        if($this->hasListeners()){
+        if ($this->hasListeners()) {
             $res = self::doNotify($this->getListeners(), $subject); 
         }   
         return $res;      
@@ -104,8 +104,8 @@ 
      * @param mixed $subject the subject 
      * @return \PEIP\INF\Handler\Handler the listener which returned a boolean true value
      */
-    public function notifyUntil($subject){
-        if($this->hasListeners()){
+    public function notifyUntil($subject) {
+        if ($this->hasListeners()) {
             $res = self::doNotifyUntil($this->getListeners(), $subject);    
         }
         return $res;
@@ -117,7 +117,7 @@ 
      * @access public
      * @return array the listeners
      */
-    public function getListeners(){
+    public function getListeners() {
         return $this->listeners;
     }
 

src/Dispatcher/IteratingDispatcher.php

Spacing +13 added lines, -13 removed lines

@@ -41,11 +41,11 @@ 
      * @param mixed array|ArrayAccess array with values to iterate over
      * @return 
      */
-    public function __construct($array = array()){
+    public function __construct($array = array()) {
         $this->init($array);
     }
 
-    protected function init($array = array()){
+    protected function init($array = array()) {
         $array = Test::assertArrayAccess($array)
             ? $array
             : array();
@@ -59,7 +59,7 @@ 
      * @param mixed $listener the listener to register
      * @return 
      */
-    public function connect($listener){
+    public function connect($listener) {
         $this->listeners[] = $listener;
     }
 
@@ -70,9 +70,9 @@ 
      * @param mixed $listener the listener to unregister
      * @return 
      */
-    public function disconnect($listener){
-        foreach ($this->listeners as $i => $callable){
-            if ($listener === $callable){
+    public function disconnect($listener) {
+        foreach ($this->listeners as $i => $callable) {
+            if ($listener === $callable) {
                 unset($this->listeners[$i]);
             }
         }
@@ -85,7 +85,7 @@ 
      * @access public
      * @return
      */
-    public function disconnectAll(){
+    public function disconnectAll() {
         $this->init();
     }
 
@@ -95,8 +95,8 @@ 
      * @access public
      * @return boolean wether any listener is registered
      */
-    public function hasListeners(){
-        return (boolean) $this->listeners->count();
+    public function hasListeners() {
+        return (boolean)$this->listeners->count();
     }
 
     /**
@@ -108,10 +108,10 @@ 
      * @param mixed $subject the subject to notify about 
      * @return 
      */
-    public function notify($subject){
+    public function notify($subject) {
         $res = NULL;
-        if($this->hasListeners()){
-            if(!$this->listeners->valid()){
+        if ($this->hasListeners()) {
+            if (!$this->listeners->valid()) {
                 $this->listeners->rewind();
             }
             $res = self::doNotifyOne($this->listeners->current(), $subject);
@@ -126,7 +126,7 @@ 
      * @access public
      * @return array registered listeners 
      */
-    public function getListeners(){
+    public function getListeners() {
         return $this->listeners->getArrayCopy();
     }
     

src/Dispatcher/ClassDispatcher.php

Spacing +13 added lines, -13 removed lines

@@ -18,11 +18,11 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect
      * @return
      */
-    public function connect($name, $listener){
+    public function connect($name, $listener) {
         $name = is_object($name) ? get_class($name) : (string)$name;
-        if(Test::assertClassOrInterfaceExists($name)){
+        if (Test::assertClassOrInterfaceExists($name)) {
             parent::connect($name, $listener);
-        }else{
+        }else {
             throw new \InvalidArgumentException($name." is not an Class nor Interface");
         }
     }
@@ -35,10 +35,10 @@ 
      * @param mixed $subject the subject
      * @return
      */
-    public function notify($name, $subject){
+    public function notify($name, $subject) {
         $res = false;
-        foreach(Reflection::getImplementedClassesAndInterfaces($name) as $cls){
-            if(parent::hasListeners($cls)){
+        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {
+            if (parent::hasListeners($cls)) {
                 self::doNotify($this->getListeners($cls), $subject);
                 $res = true;
             }
@@ -56,10 +56,10 @@ 
      * @param mixed $subject the subject
      * @return \PEIP\INF\Handler\Handler listener which returned a boolean true value
      */
-    public function notifyUntil($name, $subject){
+    public function notifyUntil($name, $subject) {
         $res = NULL;
-        foreach(Reflection::getImplementedClassesAndInterfaces($name) as $cls){
-            if(!$res && parent::hasListeners($cls)){
+        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {
+            if (!$res && parent::hasListeners($cls)) {
                 $res = self::doNotifyUntil($this->getListeners($cls), $subject);
             }
         }
@@ -75,7 +75,7 @@ 
      * @param mixed $subject the subject
      * @return
      */
-    public function notifyOfInstance($subject){
+    public function notifyOfInstance($subject) {
 
         return $this->notify(get_class($subject), $subject);
     }
@@ -86,9 +86,9 @@ 
      * @param string $name name of the event
      * @return boolean wether any listener is registered for event-name
      */
-    public function hasListeners($name){
-        foreach(Reflection::getImplementedClassesAndInterfaces($name) as $cls){
-            if(parent::hasListeners($cls)){
+    public function hasListeners($name) {
+        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {
+            if (parent::hasListeners($cls)) {
                 return true;
             }
         }

src/Util/Test.php

Spacing +29 added lines, -29 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;//throw new \Exception();
+        $res = false; //throw new \Exception();
         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);
     }
 

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