tidal / PEIP

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;	

 	}	

examples/Cafe/lib/messaging/DrinkRouter.php

Indentation +7 added lines, -7 removed lines

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

 

 class DrinkRouter 

-	extends Router {

+    extends Router {

 	

-	protected function selectChannels(Message $message){

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

-		$channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';

-		echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";

-		return $channelName;

-	}	

+    protected function selectChannels(Message $message){

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

+        $channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';

+        echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";

+        return $channelName;

+    }	

 

 	

 }

Spacing +2 added lines, -2 removed lines

@@ -6,9 +6,9 @@
 class DrinkRouter 

 	extends Router {

 	

-	protected function selectChannels(Message $message){

+	protected function selectChannels(Message $message) {

 		$order = $message->getContent();

-		$channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';

+		$channelName = $order['iced'] ? 'coldDrinks' : 'hotDrinks';

 		echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";

 		return $channelName;

 	}	

examples/Cafe/lib/messaging/OrderSplitter.php

Indentation +15 added lines, -15 removed lines

@@ -5,20 +5,20 @@
 

 class OrderSplitter extends MessageSplitter {

 

-	public function split(Message $message){

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

-		$orderItems = $order->getItems();

-		$items = array();

-		foreach($orderItems as $item){

-			$nr = $item['number'];

-			unset($item['number']);

-			$item['order'] = $order->getOrderNumber();

-			for($x = 0; $x < $nr; $x++){

-				$items[] = $item;	

-			}

-		}

-		echo PEIP_LINE_SEPARATOR."OrderSplitter: split order #: ".$order->getOrderNumber();

-		return $items;

-	}

+    public function split(Message $message){

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

+        $orderItems = $order->getItems();

+        $items = array();

+        foreach($orderItems as $item){

+            $nr = $item['number'];

+            unset($item['number']);

+            $item['order'] = $order->getOrderNumber();

+            for($x = 0; $x < $nr; $x++){

+                $items[] = $item;	

+            }

+        }

+        echo PEIP_LINE_SEPARATOR."OrderSplitter: split order #: ".$order->getOrderNumber();

+        return $items;

+    }

 	

 }

Spacing +3 added lines, -3 removed lines

@@ -5,15 +5,15 @@
 

 class OrderSplitter extends MessageSplitter {

 

-	public function split(Message $message){

+	public function split(Message $message) {

 		$order = $message->getContent();

 		$orderItems = $order->getItems();

 		$items = array();

-		foreach($orderItems as $item){

+		foreach ($orderItems as $item) {

 			$nr = $item['number'];

 			unset($item['number']);

 			$item['order'] = $order->getOrderNumber();

-			for($x = 0; $x < $nr; $x++){

+			for ($x = 0; $x < $nr; $x++) {

 				$items[] = $item;	

 			}

 		}

examples/Cafe/lib/model/Cafe.php

Indentation +4 added lines, -4 removed lines

@@ -1,11 +1,11 @@
 <?php

 

 class Cafe 

-	extends \PEIP\Gateway\SimpleMessagingGateway {

+    extends \PEIP\Gateway\SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

-		return $this->sendAndReceive($order);	

-	}

+    public function placeOrder(Order $order){

+        return $this->sendAndReceive($order);	

+    }

 

 }

 

Spacing +1 added lines, -1 removed lines

@@ -3,7 +3,7 @@
 class Cafe 

 	extends \PEIP\Gateway\SimpleMessagingGateway {

 

-	public function placeOrder(Order $order){

+	public function placeOrder(Order $order) {

 		return $this->sendAndReceive($order);	

 	}

 

examples/HelloWorld/hello_world_scripted.php

Indentation +3 added lines, -3 removed lines

@@ -9,9 +9,9 @@
 // simple service class

 class HelloService {

 

-	public function greet($name){

-		return 'Hello '.$name;

-	}

+    public function greet($name){

+        return 'Hello '.$name;

+    }

 

 }

 

Spacing +1 added lines, -1 removed lines

@@ -9,7 +9,7 @@
 // simple service class

 class HelloService {

 

-	public function greet($name){

+	public function greet($name) {

 		return 'Hello '.$name;

 	}

 

src/Data/ArrayAccess.php

Spacing +4 added lines, -4 removed lines

@@ -32,7 +32,7 @@ 
      * @param mixed $offset the offset  

      * @return 

      */

-    public function offsetExists($offset){

+    public function offsetExists($offset) {

         return array_key_exists($name, $this->values);

     }   

        

@@ -43,7 +43,7 @@ 
      * @param mixed $offset the offset 

      * @return 

      */

-    public function offsetGet($offset){

+    public function offsetGet($offset) {

         return array_key_exists($name, $this->values) ? $this->values[$offset] : NULL;

     }

      

@@ -54,7 +54,7 @@ 
      * @param mixed $offset the offset 

      * @return 

      */

-    public function offsetUnset($offset){

+    public function offsetUnset($offset) {

         unset($this->values[$offset]);

     }   

   

@@ -66,7 +66,7 @@ 
      * @param mixed $value value for the offset 

      * @return 

      */

-    public function offsetSet($offset, $value){

+    public function offsetSet($offset, $value) {

         $this->values[$offset] = $value;

     }

 

src/Service/SplittingServiceActivator.php

Spacing +3 added lines, -3 removed lines

@@ -33,10 +33,10 @@
      * @param \PEIP\INF\Message\Message $message message to call the service with it�s content/payload

      * @return mixed result of calling the registered service callable with message content/payload

      */

-    public function callService(\PEIP\INF\Message\Message $message){

-        if(is_callable($this->serviceCallable)){

+    public function callService(\PEIP\INF\Message\Message $message) {

+        if (is_callable($this->serviceCallable)) {

             $res = call_user_func_array($this->serviceCallable, $message->getContent());

-        }elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){

+        }elseif (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {

             $res = call_user_func_array(array($this->serviceCallable, 'handle'), $message->getContent());               

         }

         return $res;

Braces +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
     public function callService(\PEIP\INF\Message\Message $message){

         if(is_callable($this->serviceCallable)){

             $res = call_user_func_array($this->serviceCallable, $message->getContent());

-        }elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){

+        } elseif(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){

             $res = call_user_func_array(array($this->serviceCallable, 'handle'), $message->getContent());               

         }

         return $res;

src/Event/Observable.php

Indentation +4 added lines, -4 removed lines

@@ -49,10 +49,10 @@
     }

 

         /**

-     * @access public

-     * @param $observer 

-     * @return 

-     */

+         * @access public

+         * @param $observer 

+         * @return 

+         */

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

         $this->observers[] = $observer;     

     }

Spacing +14 added lines, -14 removed lines

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

      * @return 

      */

-    public function __construct($observedObject){

+    public function __construct($observedObject) {

         $this->setObserved($observedObject);

     }

 

-    protected function setObserved($observedObject){

-        if(!is_object($observedObject)){

+    protected function setObserved($observedObject) {

+        if (!is_object($observedObject)) {

             throw new \InvalidArgumentException("$observedObject must be an object. ".gettype($var)." given.");

         }

         

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

      * @return 

      */

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

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

         $this->observers[] = $observer;     

     }

 

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

             }

@@ -78,9 +78,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);

             }       

         }

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

      * @return 

      */

-    public function countObservers(){

+    public function countObservers() {

         return count($this->obeservers);

     }

     

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

      * @return 

      */

-    public function hasChanged(){

+    public function hasChanged() {

         return $this->hasChanged();

     }

     

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

      * @return 

      */

-    public function setChanged(){

+    public function setChanged() {

         $this->hasChanged = true;

     }

 

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

      * @return 

      */

-    public function clearChanged(){

+    public function clearChanged() {

         $this->hasChanged = true;   

     }

 

src/INF/Channel/Channel.php

Doc Comments +3 added lines, -3 removed lines

@@ -33,10 +33,10 @@
      * Send a message, blocking until either the message is accepted or the

      * specified timeout period elapses.

      * 

-     * @param message the {@link Message} to send

-     * @param timeout the timeout in milliseconds

+     * @param message \PEIP\INF\Message\Message {@link Message} to send

+     * @param timeout integer timeout in milliseconds

      * 

-     * @return <code>true</code> if the message is sent successfully,

+     * @return null|boolean if the message is sent successfully,

      * <code>false</false> if the specified timeout period elapses or

      * the send is interrupted

      */