tidal / PEIP

examples/Cafe/lib/messaging/DrinkRouter.php

Indentation +7 added lines, -7 removed lines

@@ -1,14 +1,14 @@
 <?php
 
 class DrinkRouter 
-	extends PEIP_ABS_Router {
+    extends PEIP_ABS_Router {
 	
-	protected function selectChannels(PEIP_INF_Message $message){
-		$order = $message->getContent();
-		$channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';
-		echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";
-		return $channelName;
-	}	
+    protected function selectChannels(PEIP_INF_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

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

Indentation +28 added lines, -28 removed lines

@@ -1,38 +1,38 @@
 <?php
 
 class DrinkAggregator 
-	extends PEIP_Pipe {
+    extends PEIP_Pipe {
 
-	protected $orders = array();
-	protected $preparedDrinks = array();
+    protected $orders = array();
+    protected $preparedDrinks = array();
 	
-	public function __construct(PEIP_INF_Channel $inputChannel, PEIP_INF_Channel $outputChannel = NULL){
-		$this->setInputChannel($inputChannel);
-		if(is_object($outputChannel)){
-			$this->setOutputChannel($outputChannel);	
-		}
-		$this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));
-	}
+    public function __construct(PEIP_INF_Channel $inputChannel, PEIP_INF_Channel $outputChannel = NULL){
+        $this->setInputChannel($inputChannel);
+        if(is_object($outputChannel)){
+            $this->setOutputChannel($outputChannel);	
+        }
+        $this->registerCommand('ADD_ORDER', array($this, 'receiveOrder'));
+    }
 
-	protected function doReply(PEIP_INF_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(PEIP_INF_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

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

Indentation +7 added lines, -7 removed lines

@@ -2,13 +2,13 @@
 
 class CafeGateway extends PEIP_Simple_Messaging_Gateway {
 
-	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

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

Indentation +15 added lines, -15 removed lines

@@ -2,20 +2,20 @@
 
 class OrderSplitter extends PEIP_ABS_Message_Splitter {
 
-	public function split(PEIP_INF_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(PEIP_INF_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

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

Indentation +10 added lines, -10 removed lines

@@ -31,19 +31,19 @@
     }    
 	
     protected function prepareDrink($orderNumber, $type, $iced){
-    	$drink = new Drink($orderNumber, $type, $iced);	
-    	return $drink;
+        $drink = new Drink($orderNumber, $type, $iced);	
+        return $drink;
     }
 
     protected function printAction($cold, $orderNr){
-    	if($cold){
-    		$type = 'cold';
-    		$count = $this->coldDrinkCounter;
-    	}else{
-    		$type = 'hot';
-    		$count = $this->hotDrinkCounter;    		
-    	}
-    	$total = $this->coldDrinkCounter + $this->hotDrinkCounter;
+        if($cold){
+            $type = 'cold';
+            $count = $this->coldDrinkCounter;
+        }else{
+            $type = 'hot';
+            $count = $this->hotDrinkCounter;    		
+        }
+        $total = $this->coldDrinkCounter + $this->hotDrinkCounter;
         echo PEIP_LINE_SEPARATOR."Barista: prepared $type drink (total #$total- $type #$count) for order #$orderNr";
         flush();    
     }

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

Indentation +29 added lines, -29 removed lines

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

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

Indentation +7 added lines, -7 removed lines

@@ -2,14 +2,14 @@
 
 class Delivery {
 
-	protected 
-		$deliveredDrinks,
-		$orderNumber;
+    protected 
+        $deliveredDrinks,
+        $orderNumber;
 	
-	public function __construct(array $deliveredDrinks){
-		$this->deliveredDrinks = $deliveredDrinks;
-		$this->orderNumber = $deliveredDrinks[0]->getOrderNumber();
-	}
+    public function __construct(array $deliveredDrinks){
+        $this->deliveredDrinks = $deliveredDrinks;
+        $this->orderNumber = $deliveredDrinks[0]->getOrderNumber();
+    }
 
 
 

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

Indentation +19 added lines, -19 removed lines

@@ -3,30 +3,30 @@
 
 class Drink {
 
-	protected 
-		$orderNumber,
-		$type,
-		$iced;
+    protected 
+        $orderNumber,
+        $type,
+        $iced;
 	
-	public function __construct($orderNumber, $type, $iced){
-		$this->orderNumber = $orderNumber;
-		$this->type = $type;
-		$this->iced = $iced;
-	}
+    public function __construct($orderNumber, $type, $iced){
+        $this->orderNumber = $orderNumber;
+        $this->type = $type;
+        $this->iced = $iced;
+    }
 
-	public function getType(){
-		return $this->type; 
-	}
+    public function getType(){
+        return $this->type; 
+    }
 
-	public function getIced(){
-		return $this->iced; 
-	}	
+    public function getIced(){
+        return $this->iced; 
+    }	
 
-	public function getOrderNumber(){
-		return $this->orderNumber;
-	}
+    public function getOrderNumber(){
+        return $this->orderNumber;
+    }
 	
-	public function __sleep()
+    public function __sleep()
     {
         return array('orderNumber', 'type', 'iced');
     }

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/DrinkType.php

Indentation +5 added lines, -5 removed lines

@@ -2,11 +2,11 @@
 
 class DrinkType {
 
-	const 
-		ESPRESSO = 'ESPRESSO',
-		LATTE = 'LATTE',
-		CAPPUCCINO = 'CAPPUCCINO',
-		MOCCA = 'MOCCA'; 
+    const 
+        ESPRESSO = 'ESPRESSO',
+        LATTE = 'LATTE',
+        CAPPUCCINO = 'CAPPUCCINO',
+        MOCCA = 'MOCCA'; 
 
 }