tidal / PEIP

examples/Cafe/lib/messaging/DrinkRouter.php

Spacing +2 added lines, -2 removed lines

@@ -3,9 +3,9 @@
 class DrinkRouter 
 	extends PEIP_ABS_Router {
 	
-	protected function selectChannels(PEIP_INF_Message $message){
+	protected function selectChannels(PEIP_INF_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/DrinkAggregator.php

Spacing +7 added lines, -7 removed lines

@@ -6,30 +6,30 @@
 	protected $orders = array();
 	protected $preparedDrinks = array();
 	
-	public function __construct(PEIP_INF_Channel $inputChannel, PEIP_INF_Channel $outputChannel = NULL){
+	public function __construct(PEIP_INF_Channel $inputChannel, PEIP_INF_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(PEIP_INF_Message $message){
+	protected function doReply(PEIP_INF_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/CafeGateway.php

Spacing +2 added lines, -2 removed lines

@@ -2,12 +2,12 @@
 
 class CafeGateway extends PEIP_Simple_Messaging_Gateway {
 
-	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/OrderSplitter.php

Spacing +3 added lines, -3 removed lines

@@ -2,15 +2,15 @@
 
 class OrderSplitter extends PEIP_ABS_Message_Splitter {
 
-	public function split(PEIP_INF_Message $message){
+	public function split(PEIP_INF_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/Barista.php

Spacing +4 added lines, -4 removed lines

@@ -30,16 +30,16 @@
         return $this->prepareDrink($orderItem['order'], $orderItem['type'], true);
     }    
 	
-    protected function prepareDrink($orderNumber, $type, $iced){
+    protected function prepareDrink($orderNumber, $type, $iced) {
     	$drink = new Drink($orderNumber, $type, $iced);	
     	return $drink;
     }
 
-    protected function printAction($cold, $orderNr){
-    	if($cold){
+    protected function printAction($cold, $orderNr) {
+    	if ($cold) {
     		$type = 'cold';
     		$count = $this->coldDrinkCounter;
-    	}else{
+    	}else {
     		$type = 'hot';
     		$count = $this->hotDrinkCounter;    		
     	}

examples/Cafe/lib/model/Order.php

Spacing +6 added lines, -6 removed lines

@@ -7,16 +7,16 @@ 
 		$orderNumber;
 	protected static $orderCount = 0;
 
-	public function __construct(){
+	public function __construct() {
 		self::$orderCount++;
 		$this->orderNumber = self::$orderCount;
 	}	
 
-	public function getOrderNumber(){
+	public function getOrderNumber() {
 		return $this->orderNumber;
 	}
 	
-	public function addItem($type, $number, $iced = false){
+	public function addItem($type, $number, $iced = false) {
 		$this->items[] = 
 			array(
 				'type' => $type,
@@ -25,13 +25,13 @@ 
 			);
 	}
 
-	public function getItems(){
+	public function getItems() {
 		return $this->items;
 	}
 
-	public function getTotalCount(){
+	public function getTotalCount() {
 		$x = 0;
-		foreach($this->items as $item){
+		foreach ($this->items as $item) {
 			$x += (int)$item['number'];
 		}
 		return $x;

examples/Cafe/lib/model/Delivery.php

Spacing +1 added lines, -1 removed lines

@@ -6,7 +6,7 @@
 		$deliveredDrinks,
 		$orderNumber;
 	
-	public function __construct(array $deliveredDrinks){
+	public function __construct(array $deliveredDrinks) {
 		$this->deliveredDrinks = $deliveredDrinks;
 		$this->orderNumber = $deliveredDrinks[0]->getOrderNumber();
 	}

examples/Cafe/lib/model/Drink.php

Spacing +4 added lines, -4 removed lines

@@ -8,21 +8,21 @@
 		$type,
 		$iced;
 	
-	public function __construct($orderNumber, $type, $iced){
+	public function __construct($orderNumber, $type, $iced) {
 		$this->orderNumber = $orderNumber;
 		$this->type = $type;
 		$this->iced = $iced;
 	}
 
-	public function getType(){
+	public function getType() {
 		return $this->type; 
 	}
 
-	public function getIced(){
+	public function getIced() {
 		return $this->iced; 
 	}	
 
-	public function getOrderNumber(){
+	public function getOrderNumber() {
 		return $this->orderNumber;
 	}
 	

examples/Cafe/lib/model/Cafe.php

Spacing +1 added lines, -1 removed lines

@@ -3,7 +3,7 @@
 class Cafe 
 	extends PEIA_Simple_Messaging_Gateway {
 
-	public function placeOrder(Order $order){
+	public function placeOrder(Order $order) {
 		return $this->sendAndReceive($order);	
 	}