tidal / PEIP

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

src/Event/Observable.php

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

src/Service/ServiceProvider.php

Spacing +31 added lines, -31 removed lines

@@ -14,7 +14,7 @@ 
 use PEIP\Context\XMLContext;

 use PEIP\Plugins\BasePlugin;

 

-class ServiceProvider extends \PEIP\Service\ServiceContainer  {

+class ServiceProvider extends \PEIP\Service\ServiceContainer {

 

     const

         /* Headers */

@@ -47,7 +47,7 @@ 
     public function  __construct(array $config = array(), $idAttribute = 'id') {

         $this->idAttribute = $idAttribute;

         $this->initNodeBuilders();

-        foreach($config as $serviceConfig){

+        foreach ($config as $serviceConfig) {

             $this->addConfig($serviceConfig);

         }

         

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

      * @return array registered services

      */

-    public function getServices(){

+    public function getServices() {

         return $this->services;

     }

 

@@ -70,7 +70,7 @@ 
      * @param string $nodeName the name of the node

      * @param callable $callable a callable which creates instances for node-name

      */

-    public function registerNodeBuilder($nodeName, $callable){

+    public function registerNodeBuilder($nodeName, $callable) {

         $this->nodeBuilders[$nodeName] = $callable;

     }

   /**

@@ -83,16 +83,16 @@ 
      * @see XMLContext::includeContext

      * @access protected

      */

-    protected function initNodeBuilders(){

+    protected function initNodeBuilders() {

         $builders = array(

             'service' => 'initService'

         );

-        foreach($builders as $nodeName => $method){

+        foreach ($builders as $nodeName => $method) {

            $this->registerNodeBuilder($nodeName, array($this, $method));

         }

     }

 

-    public function addConfig($config){ 

+    public function addConfig($config) { 

         $this->doFireEvent(

             self::EVENT_BEFORE_ADD_CONFIG,

             array(

@@ -111,15 +111,15 @@ 
         );

     }

 

-    public function provideService($key){

+    public function provideService($key) {

         $this->doFireEvent(self::EVENT_BEFORE_PROVIDE_SERVICE, array(

             self::HEADER_KEY=>$key)

         );

 

-        if($this->hasService($key)){

-            $service =  $this->getService($key);

-        }else{

-            $service =  $this->createService($key);

+        if ($this->hasService($key)) {

+            $service = $this->getService($key);

+        }else {

+            $service = $this->createService($key);

         }

 

         $this->doFireEvent(self::EVENT_AFTER_PROVIDE_SERVICE, array(

@@ -130,16 +130,16 @@ 
         return $service;

     }

 

-    protected function createService($key){

+    protected function createService($key) {

         $this->doFireEvent(self::EVENT_BEFORE_CREATE_SERVICE, array(

             self::HEADER_KEY=>$key)

         );

         $errorMessage = '';

         $config = $this->getServiceConfig($key);

 

-        if($config){

+        if ($config) {

             $node = $this->buildNode($config);

-            if($node){

+            if ($node) {

                 $this->setService(

                     $key,

                     $node

@@ -150,11 +150,11 @@ 
                 ));

 

                 return $node;                

-            }else{

+            }else {

                 $errorMessage = 'COULD NOT BUILD NODE FOR KEY: '.$key;

             }

 

-        }else{

+        }else {

             $errorMessage = 'NO CONFIG FOR KEY: '.$key;

         }

         $this->doFireEvent(self::EVENT_CREATE_SERVICE_ERROR, array(

@@ -164,8 +164,8 @@ 
         return NULL;

     }

 

-    public function getServiceConfig($key){

-        if(!isset($this->ids[$key])){

+    public function getServiceConfig($key) {

+        if (!isset($this->ids[$key])) {

             return false;

         }

         return $this->config[$this->ids[$key]];

@@ -180,7 +180,7 @@ 
      * @param object $config configuration-node

      * @return void

      */

-    protected function buildNode($config){

+    protected function buildNode($config) {

         $nodeName = (string)$config['type'];

 

         $this->doFireEvent(self::EVENT_BEFORE_BUILD_NODE, array(

@@ -188,20 +188,20 @@ 
             self::HEADER_NODE_NAME=> $nodeName

         ));

         // call the builder method registered for the node.

-        if(array_key_exists($nodeName, $this->nodeBuilders)){

+        if (array_key_exists($nodeName, $this->nodeBuilders)) {

 

             $nodeInstance = call_user_func($this->nodeBuilders[$nodeName], $config);

-            if(is_object($nodeInstance)){

+            if (is_object($nodeInstance)) {

                 $this->doFireEvent(self::EVENT_BUILD_NODE_SUCCESS, array(

                     self::HEADER_NODE_CONFIG=>$config,

                     self::HEADER_NODE_NAME=> $nodeName,

                     self::HEADER_NODE => $nodeInstance

                 ));

                 return $nodeInstance;

-            }else{

+            }else {

                 $errorMessage = 'BUILDER RETURNED NO OBJECT FOR NODE-TYPE: '.$nodeName;

             }

-        }else{

+        }else {

             $errorMessage = 'NO BUILDER FOUND FOR NODE-TYPE: '.$nodeName;

         }

 

@@ -212,27 +212,27 @@ 
         ));

     }

 

-    protected function getIdFromConfig($config){

+    protected function getIdFromConfig($config) {

         $id = '';

-        if(isset($config[$this->idAttribute])){

+        if (isset($config[$this->idAttribute])) {

             $id = trim((string)($config[$this->idAttribute]));

         }

         return $id;

     }

 

-    protected function getCountConfig(){

+    protected function getCountConfig() {

         return count($this->config);

     }

 

-    protected function doAddConfig($config){

+    protected function doAddConfig($config) {

         $countConfig = $this->getCountConfig();

         $this->config[$countConfig] = $config;

         return $countConfig;

     }

 

-    protected function doRegisterConfig($config){

-        $id  = $this->getIdFromConfig($config);

-        if($id != ''){

+    protected function doRegisterConfig($config) {

+        $id = $this->getIdFromConfig($config);

+        if ($id != '') {

             $this->ids[$id] = $this->getCountConfig() - 1;

         }

         return $id;