tidal / PEIP

examples/Cafe/lib/model/Waiter.php

Indentation +12 added lines, -12 removed lines

@@ -3,22 +3,22 @@
 
 class Waiter {
 
-	protected $orders;
+    protected $orders;
 	
-	public function prepareDelivery(array $drinks){
-		echo PEIP_LINE_SEPARATOR.'Waiter: prepareDelivery: #'.$drinks[0]->getOrderNumber();
-		return new Delivery($drinks);
-	}
+    public function prepareDelivery(array $drinks){
+        echo PEIP_LINE_SEPARATOR.'Waiter: prepareDelivery: #'.$drinks[0]->getOrderNumber();
+        return new Delivery($drinks);
+    }
 
 	
-	public function receiveOrder(Order $order){
-		echo PEIP_LINE_SEPARATOR.'Waiter: receiveOrder';
-		$this->orders[$order->getOrderNumber()] = $order;	
-	}
+    public function receiveOrder(Order $order){
+        echo PEIP_LINE_SEPARATOR.'Waiter: receiveOrder';
+        $this->orders[$order->getOrderNumber()] = $order;	
+    }
 	
-	public function getOrder($nr){
-		return $this->orders[$nr];
-	}
+    public function getOrder($nr){
+        return $this->orders[$nr];
+    }
 	
 	
 }

Spacing +3 added lines, -3 removed lines

@@ -5,18 +5,18 @@
 
 	protected $orders;
 	
-	public function prepareDelivery(array $drinks){
+	public function prepareDelivery(array $drinks) {
 		echo PEIP_LINE_SEPARATOR.'Waiter: prepareDelivery: #'.$drinks[0]->getOrderNumber();
 		return new Delivery($drinks);
 	}
 
 	
-	public function receiveOrder(Order $order){
+	public function receiveOrder(Order $order) {
 		echo PEIP_LINE_SEPARATOR.'Waiter: receiveOrder';
 		$this->orders[$order->getOrderNumber()] = $order;	
 	}
 	
-	public function getOrder($nr){
+	public function getOrder($nr) {
 		return $this->orders[$nr];
 	}
 	

src/Dispatcher/ClassEventDispatcher.php

Indentation +15 added lines, -15 removed lines

@@ -67,9 +67,9 @@ 
                         Reflection_Pool::getInstance(

                             $object->getContent()

                         )

-                     ),

-                     $object

-                 );

+                        ),

+                        $object

+                    );

             }else{

                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');

             }

@@ -78,18 +78,18 @@ 
         }

     }       //put your code here

 

-     /**

-     * Creates an event-object with given object as content/subject and notifies

-     * all registers listeners of the event.

-     *

-     * @access public

-     * @param string $name name of the event

-     * @param object $object the subject of the event

-     * @param array $headers headers of the event-object as key/value pairs

-     * @param string $eventClass event-class to create instances from

-     * @return

-     * @see EventBuilder

-     */

+        /**

+         * Creates an event-object with given object as content/subject and notifies

+         * all registers listeners of the event.

+         *

+         * @access public

+         * @param string $name name of the event

+         * @param object $object the subject of the event

+         * @param array $headers headers of the event-object as key/value pairs

+         * @param string $eventClass event-class to create instances from

+         * @return

+         * @see EventBuilder

+         */

     public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){

         if(!$this->hasListeners($name, ($object))){

             return false;

Spacing +13 added lines, -13 removed lines

@@ -27,9 +27,9 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener event-handler

      * @return boolean

      */

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

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

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

-        foreach(Reflection::getImplementedClassesAndInterfaces($object) as $cls){

+        foreach (Reflection::getImplementedClassesAndInterfaces($object) as $cls) {

             $reflection = Reflection_Pool::getInstance($class);

             parent::connect($name, $reflection, $listener);

         }

@@ -37,13 +37,13 @@ 
         return true;

     }

 

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

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

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

         $res = true;

-        foreach(Reflection::getImplementedClassesAndInterfaces($object) as $cls){

+        foreach (Reflection::getImplementedClassesAndInterfaces($object) as $cls) {

             $reflection = Reflection_Pool::getInstance($class);

             $r = parent::disconnect($name, $reflection, $listener);

-            if(!$r){

+            if (!$r) {

                 $res = false;

             }

         }

@@ -58,9 +58,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,

@@ -70,10 +70,10 @@ 
                      ),

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

         }

     }       //put your code here

@@ -90,8 +90,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;

         }

 

@@ -114,7 +114,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,

             Reflection_Pool::getInstance($object)

Braces +2 added lines, -2 removed lines

@@ -70,10 +70,10 @@
                      ),

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

         }

     }       //put your code here

Doc Comments +2 added lines, -2 removed lines

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

      * @param string $name name of the event

      * @param \PEIP\INF\Event\Event $object an event object

-     * @return boolean

+     * @return boolean|null

      */

     public function notify($name, $object){ 

         if($object instanceof \PEIP\INF\Event\Event){

@@ -53,7 +53,7 @@ 
      * @param array $headers headers of the event-object as key/value pairs

      * @param string $eventClass event-class to create instances from

      * @return

-     * @see EventBuilder

+     boolean|null @see EventBuilder

      */

     public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){

         if(!$this->hasListeners($name, ($object))){

Unused Use Statements +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
  *

  * @author timo

  */

-use PEIP\Util\Reflection;

+use PEIP\Util\Reflection;
 use PEIP\Event\EventBuilder;

 

 class ClassEventDispatcher extends \PEIP\Dispatcher\ObjectEventDispatcher {

src/Util/Test.php

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

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/ABS/Handler/DiscardingMessageHandler.php

Spacing +4 added lines, -4 removed lines

@@ -33,7 +33,7 @@ 
      * @param $discardChannel 
      * @return 
      */
-    public function setDiscardChannel(\PEIP\INF\Channel\Channel $discardChannel){
+    public function setDiscardChannel(\PEIP\INF\Channel\Channel $discardChannel) {
         $this->discardChannel = $discardChannel;    
     }   
 
@@ -42,7 +42,7 @@ 
      * @access public
      * @return 
      */
-    public function getDiscardChannel(){
+    public function getDiscardChannel() {
         return $this->discardChannel;   
     }   
 
@@ -52,8 +52,8 @@ 
      * @param $message 
      * @return 
      */
-    protected function discardMessage(\PEIP\INF\Message\Message $message){
-        if(isset($this->discardChannel)){
+    protected function discardMessage(\PEIP\INF\Message\Message $message) {
+        if (isset($this->discardChannel)) {
             $this->discardChannel->send($message);
         }
     }

src/INF/Base/Singleton.php

Spacing +1 added lines, -1 removed lines

@@ -22,6 +22,6 @@
 
 interface Singleton {
 
-    public static function getInstance ();
+    public static function getInstance();
 
 }

examples/Cafe/example.php

Indentation +10 added lines, -10 removed lines

@@ -46,19 +46,19 @@
 

 if($cafe){

 

-	for ($i = 1; $i <= 10; $i++) {

-       	// create and place orders

-		$order = new Order();

-        	$order->addItem("LATTE", 2, false);

-        	$order->addItem("MOCCA", 3, true);

-        	$cafe->placeOrder($order);

-        	// receive drinks

-		$drinks = $cafe->receiveDelivery();

+    for ($i = 1; $i <= 10; $i++) {

+            // create and place orders

+        $order = new Order();

+            $order->addItem("LATTE", 2, false);

+            $order->addItem("MOCCA", 3, true);

+            $cafe->placeOrder($order);

+            // receive drinks

+        $drinks = $cafe->receiveDelivery();

                 var_dump($drinks);

-    	}	

+        }	

 

 }else{

-	throw new RuntimeException('Could not get CafeGateway');

+    throw new RuntimeException('Could not get CafeGateway');

 }

 

 

Spacing +2 added lines, -2 removed lines

@@ -44,7 +44,7 @@ 
  */

 

 

-if($cafe){

+if ($cafe) {

 

 	for ($i = 1; $i <= 10; $i++) {

        	// create and place orders

@@ -57,7 +57,7 @@ 
                 var_dump($drinks);

     	}	

 

-}else{

+}else {

 	throw new RuntimeException('Could not get CafeGateway');

 }

 

Braces +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
                 var_dump($drinks);

     	}	

 

-}else{

+} else{

 	throw new RuntimeException('Could not get CafeGateway');

 }

 

examples/Cafe/misc/bootstrap.php

Spacing +2 added lines, -2 removed lines

@@ -2,11 +2,11 @@
 

 require_once(dirname(__FILE__).'/../../../misc/bootstrap.php');

 

-foreach (glob(realpath(dirname(__FILE__)."/../lib/model/")."/*.php") as $filename){

+foreach (glob(realpath(dirname(__FILE__)."/../lib/model/")."/*.php") as $filename) {

     require_once $filename;

 }

 

-foreach (glob(realpath(dirname(__FILE__)."/../lib/messaging/")."/*.php") as $filename){

+foreach (glob(realpath(dirname(__FILE__)."/../lib/messaging/")."/*.php") as $filename) {

     require_once $filename;

 }

 

examples/Cafe/lib/messaging/CafeGateway.php

Indentation +7 added lines, -7 removed lines

@@ -4,13 +4,13 @@
 

 class CafeGateway extends SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

-		echo "\nCafe: place order #".$order->getOrderNumber();

-		$this->send($order);

-	}

+    public function placeOrder(Order $order){

+        echo "\nCafe: place order #".$order->getOrderNumber();

+        $this->send($order);

+    }

 	

-	public function receiveDelivery(){

-		return $this->receive();

-	}

+    public function receiveDelivery(){

+        return $this->receive();

+    }

 

 }

Spacing +2 added lines, -2 removed lines

@@ -4,12 +4,12 @@
 

 class CafeGateway extends SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

+	public function placeOrder(Order $order) {

 		echo "\nCafe: place order #".$order->getOrderNumber();

 		$this->send($order);

 	}

 	

-	public function receiveDelivery(){

+	public function receiveDelivery() {

 		return $this->receive();

 	}

 

examples/Cafe/lib/messaging/DrinkAggregator.php

Indentation +28 added lines, -28 removed lines

@@ -4,38 +4,38 @@
 use PEIP\INF\Message\Message;

 

 class DrinkAggregator 

-	extends \PEIP\Pipe\Pipe {

+    extends \PEIP\Pipe\Pipe {

 

-	protected $orders = array();

-	protected $preparedDrinks = array();

+    protected $orders = array();

+    protected $preparedDrinks = array();

 	

-	public function __construct(Channel $inputChannel, Channel $outputChannel = NULL){

-		$this->setInputChannel($inputChannel);

-		if(is_object($outputChannel)){

-			$this->setOutputChannel($outputChannel);	

-		}

-		$this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));

-	}

+    public function __construct(Channel $inputChannel, Channel $outputChannel = NULL){

+        $this->setInputChannel($inputChannel);

+        if(is_object($outputChannel)){

+            $this->setOutputChannel($outputChannel);	

+        }

+        $this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));

+    }

 

-	protected function doReply(Message $message){

-		$drink = $message->getContent();

-		$nr = $drink->getOrderNumber();

-		if(!isset($this->preparedDrinks[$nr])){

-			$this->preparedDrinks[$nr] = array();

-		}

-		$this->preparedDrinks[$drink->getOrderNumber()][] = $drink;

-		if(isset($this->orders[$nr]) 

-			&& $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])){

-			$this->replyMessage($this->preparedDrinks[$nr]);

-			unset($this->preparedDrinks[$nr]);

-			echo PEIP_LINE_SEPARATOR.'DrinkAggregator : reply #'.$nr;	

-		}

-	}

+    protected function doReply(Message $message){

+        $drink = $message->getContent();

+        $nr = $drink->getOrderNumber();

+        if(!isset($this->preparedDrinks[$nr])){

+            $this->preparedDrinks[$nr] = array();

+        }

+        $this->preparedDrinks[$drink->getOrderNumber()][] = $drink;

+        if(isset($this->orders[$nr]) 

+            && $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])){

+            $this->replyMessage($this->preparedDrinks[$nr]);

+            unset($this->preparedDrinks[$nr]);

+            echo PEIP_LINE_SEPARATOR.'DrinkAggregator : reply #'.$nr;	

+        }

+    }

 

-	public function receiveOrder(Order $order){

-		echo PEIP_LINE_SEPARATOR.'DrinkAggregator: received Order';

-		$this->orders[$order->getOrderNumber()] = $order;	

-	}	

+    public function receiveOrder(Order $order){

+        echo PEIP_LINE_SEPARATOR.'DrinkAggregator: received Order';

+        $this->orders[$order->getOrderNumber()] = $order;	

+    }	

 	

 

 }

Spacing +7 added lines, -7 removed lines

@@ -9,30 +9,30 @@
 	protected $orders = array();

 	protected $preparedDrinks = array();

 	

-	public function __construct(Channel $inputChannel, Channel $outputChannel = NULL){

+	public function __construct(Channel $inputChannel, Channel $outputChannel = NULL) {

 		$this->setInputChannel($inputChannel);

-		if(is_object($outputChannel)){

+		if (is_object($outputChannel)) {

 			$this->setOutputChannel($outputChannel);	

 		}

 		$this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));

 	}

 

-	protected function doReply(Message $message){

+	protected function doReply(Message $message) {

 		$drink = $message->getContent();

 		$nr = $drink->getOrderNumber();

-		if(!isset($this->preparedDrinks[$nr])){

+		if (!isset($this->preparedDrinks[$nr])) {

 			$this->preparedDrinks[$nr] = array();

 		}

 		$this->preparedDrinks[$drink->getOrderNumber()][] = $drink;

-		if(isset($this->orders[$nr]) 

-			&& $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])){

+		if (isset($this->orders[$nr]) 

+			&& $this->orders[$nr]->getTotalCount() == count($this->preparedDrinks[$nr])) {

 			$this->replyMessage($this->preparedDrinks[$nr]);

 			unset($this->preparedDrinks[$nr]);

 			echo PEIP_LINE_SEPARATOR.'DrinkAggregator : reply #'.$nr;	

 		}

 	}

 

-	public function receiveOrder(Order $order){

+	public function receiveOrder(Order $order) {

 		echo PEIP_LINE_SEPARATOR.'DrinkAggregator: received Order';

 		$this->orders[$order->getOrderNumber()] = $order;	

 	}