tidal / PEIP

examples/Cafe/example.php

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

 }

 

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

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

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

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

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

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

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/Factory/ServiceFactory.php

Spacing +44 added lines, -44 removed lines

@@ -23,11 +23,11 @@ 
      * @param $config configuration of the service
      * @return object the initialized service instance
      */
-    public static function createService(array $config){
+    public static function createService(array $config) {
         $args = array();
         //build arguments for constructor
-        if(isset($config['constructor_arg'])){
-            foreach($config['constructor_arg'] as $arg){
+        if (isset($config['constructor_arg'])) {
+            foreach ($config['constructor_arg'] as $arg) {
                 $args[] = self::buildArg($arg);
             }
         }
@@ -44,21 +44,21 @@ 
      * @param string $defaultClass class to create instance for if none is set in config
      * @return object build and modified srvice instance
      */
-    public static function doBuild($config, $arguments, $defaultClass = false){
+    public static function doBuild($config, $arguments, $defaultClass = false) {
         $cls = isset($config["class"]) ? trim((string)$config["class"]) : (string)$defaultClass;
-        if($cls != ''){
+        if ($cls != '') {
             try {
-                $constructor = isset($config["constructor"])?(string)$config["constructor"]:"";
-                if($constructor != '' && Test::assertMethod($cls, $constructor)){
+                $constructor = isset($config["constructor"]) ? (string)$config["constructor"] : "";
+                if ($constructor != '' && Test::assertMethod($cls, $constructor)) {
                     $service = call_user_func_array(array($cls, $constructor), $arguments);
-                }else{
+                }else {
                     $service = self::build($cls, $arguments);
                 }
-            }catch(\Exception $e){
+            } catch (\Exception $e) {
                 throw new \RuntimeException('Could not create Service "'.$cls.'" -> '.$e->getMessage());
             }
         }
-        if(is_object($service)){
+        if (is_object($service)) {
             return $service;
         }
         throw new \RuntimeException('Could not create Service "'.$cls.'". Class does not exist.');
@@ -75,7 +75,7 @@ 
      * @param array $arguments arguments for the constructor
      * @return object build and modified srvice instance
      */
-    public static function build($className, $arguments){
+    public static function build($className, $arguments) {
         return GenericBuilder::getInstance($className)->build($arguments);
     }
 
@@ -86,29 +86,29 @@ 
      * @param object $config configuration object to create argument from.
      * @return mixed build argument
      */
-    protected function buildArg($config){
-        if(trim((string)$config['value']) != ''){
+    protected function buildArg($config) {
+        if (trim((string)$config['value']) != '') {
             $arg = (string)$config['value'];
-        }elseif($config->getName() == 'value'){
+        }elseif ($config->getName() == 'value') {
             $arg = (string)$config;
-        }elseif($config->getName() == 'list'){
+        }elseif ($config->getName() == 'list') {
             $arg = array();
-            foreach($config->children() as $entry){
-                if($entry->getName() == 'value'){
-                    if($entry['key']){
+            foreach ($config->children() as $entry) {
+                if ($entry->getName() == 'value') {
+                    if ($entry['key']) {
                         $arg[(string)$entry['key']] = (string)$entry;
-                    }else{
+                    }else {
                         $arg[] = (string)$entry;
                     }
-                }elseif($entry->getName() == 'service'){
+                }elseif ($entry->getName() == 'service') {
                     $arg[] = $this->provideService($entry);
                 }
             }
-        }elseif($config->getName() == 'service'){
+        }elseif ($config->getName() == 'service') {
             $arg = self::provideService($config);
-        }elseif($config->list){
+        }elseif ($config->list) {
             $arg = $this->buildArg($config->list);
-        }elseif($config->service){
+        }elseif ($config->service) {
             $arg = $this->buildArg($config->service);
         }
         return $arg;
@@ -126,24 +126,24 @@ 
      * @param string $defaultClass class to create instance for if none is set in config
      * @return object build and modified srvice instance
      */
-    public static function buildAndModify(array $config, $arguments, $defaultClass = ""){
-        if((isset($config["class"]) && "" != (string)$config["class"])  || $defaultClass !== ""){
+    public static function buildAndModify(array $config, $arguments, $defaultClass = "") {
+        if ((isset($config["class"]) && "" != (string)$config["class"]) || $defaultClass !== "") {
              $service = ServiceFactory::doBuild($config, $arguments, $defaultClass);
-        }else{
+        }else {
             throw new \RuntimeException('Could not create Service. no class or reference given.');
         }
-        if(isset($config["ref_property"])){
+        if (isset($config["ref_property"])) {
             $service = $service->{(string)$config["ref_property"]};
-        }elseif(isset($config["ref_method"])){
+        }elseif (isset($config["ref_method"])) {
                 $args = array();
-            if(isset($config['argument'])){
-                        foreach($config['argument'] as $arg){
+            if (isset($config['argument'])) {
+                        foreach ($config['argument'] as $arg) {
                             $args[] = $this->buildArg($arg);
                         }
                 }
             $service = call_user_func_array(array($service, (string)$config["ref_method"]), $args);
         }
-        if(!is_object($service)){
+        if (!is_object($service)) {
             throw new \RuntimeException('Could not create Service.');
         }
         $service = self::modifyService($service, $config);
@@ -165,29 +165,29 @@ 
      * @param object $config configuration to get the modification instructions from.
      * @return object the modificated service
      */
-    protected function modifyService($service, $config){        
+    protected function modifyService($service, $config) {        
         $config = is_array($config) ? new \ArrayObject($config) : $config;
         // set instance properties
-        if(isset($config->property)){
-            foreach($config->property as $property){
+        if (isset($config->property)) {
+            foreach ($config->property as $property) {
                 $arg = $this->buildArg($property);
-                if($arg){
+                if ($arg) {
                     $setter = self::getSetter($property);
-                    if($setter &&  self::hasPublicProperty($service, 'Method', $setter)){
+                    if ($setter && self::hasPublicProperty($service, 'Method', $setter)) {
                         $service->{$setter}($arg);
-                    }elseif(in_array($property, self::hasPublicProperty($service, 'Property', $setter))){
+                    }elseif (in_array($property, self::hasPublicProperty($service, 'Property', $setter))) {
                         $service->$setter = $arg;
                     }
                 }
             }
         }
         // call instance methods
-        if(isset($config->action)){
-            foreach($config->action as $action){
+        if (isset($config->action)) {
+            foreach ($config->action as $action) {
                 $method = (string)$action['method'] != '' ? (string)$action['method'] : NULL;
-                if($method && self::hasPublicProperty($service, 'Method', $method)){
+                if ($method && self::hasPublicProperty($service, 'Method', $method)) {
                     $args = array();
-                    foreach($action->children() as $argument){
+                    foreach ($action->children() as $argument) {
                         $args[] = $this->buildArg($argument);
                     }
                     call_user_func_array(array($service, (string)$action['method']), $args);
@@ -195,9 +195,9 @@ 
             }
         }
         // register instance listeners
-        if($service instanceof \PEIP\INF\Event\Connectable){
-            if(isset($config->listener)){
-                foreach($config->listener as $listenerConf){
+        if ($service instanceof \PEIP\INF\Event\Connectable) {
+            if (isset($config->listener)) {
+                foreach ($config->listener as $listenerConf) {
                     $event = (string)$listenerConf['event'];
                     $listener = $this->provideService($listenerConf);
                     $service->connect($event, $listener);