tidal / PEIP

src/Base/DynamicAdapter.php

Spacing +3 added lines, -3 removed lines

@@ -36,7 +36,7 @@ 
      * @param $subject 
      * @return 
      */
-    public function __construct(\ArrayAccess $methodMap, $subject){
+    public function __construct(\ArrayAccess $methodMap, $subject) {
         $this->methodMap = $methodMap;
         $this->subject = $subject;      
     }
@@ -48,8 +48,8 @@ 
      * @param $arguments 
      * @return 
      */
-    public function __call($method, array $arguments){
-        if(array_key_exists($method, $this->methodMap)){
+    public function __call($method, array $arguments) {
+        if (array_key_exists($method, $this->methodMap)) {
             return call_user_func_array(array($this->subject, $this->methodMap[$method]), $arguments);
         }
     }

src/Base/FlyAdapter.php

Spacing +4 added lines, -4 removed lines

@@ -30,7 +30,7 @@ 
      * @param $methodMap 
      * @return 
      */
-    public function __construct(ArrayAccess $methodMap){        
+    public function __construct(ArrayAccess $methodMap) {        
         $this->methodMap = $methodMap;  
     }
     
@@ -40,7 +40,7 @@ 
      * @param $subject 
      * @return 
      */
-    public function setSubject($subject){
+    public function setSubject($subject) {
         $this->subject = $subject;
         return $this;
     }
@@ -52,8 +52,8 @@ 
      * @param $arguments 
      * @return 
      */
-    public function __call($method, $arguments){
-        if(array_key_exists($method, $this->methodMap)){
+    public function __call($method, $arguments) {
+        if (array_key_exists($method, $this->methodMap)) {
             return call_user_func_array(array($this->subject, $this->methodMap[$method]), $arguments);
         }
     }

src/Gateway/SimpleMessagingGateway.php

Spacing +15 added lines, -15 removed lines

@@ -42,9 +42,9 @@ 
      * @param \PEIP\INF\Channel\PollableChannel $replyChannel The default channel to receive requests from the gateway
      * @param array $defaultHeaders The default headers to apply to request messages 
      */
-    public function __construct(\PEIP\INF\Channel\Channel $requestChannel, \PEIP\INF\Channel\Channel $replyChannel = NULL, array $defaultHeaders = array()){
+    public function __construct(\PEIP\INF\Channel\Channel $requestChannel, \PEIP\INF\Channel\Channel $replyChannel = NULL, array $defaultHeaders = array()) {
         $this->setRequestChannel($requestChannel);
-        if($replyChannel){
+        if ($replyChannel) {
             $this->setReplyChannel($replyChannel);
         }     
         $this->defaultHeaders = $defaultHeaders;
@@ -58,7 +58,7 @@ 
      * @param \PEIP\INF\Channel\Channel $replyChannel The default channel to receive requests from the gateway
      * @return 
      */
-    public function setRequestChannel(\PEIP\INF\Channel\Channel $requestChannel){
+    public function setRequestChannel(\PEIP\INF\Channel\Channel $requestChannel) {
         $this->requestChannel = $requestChannel;
     }
   
@@ -69,8 +69,8 @@ 
      * @param \PEIP\INF\Channel\PollableChannel $replyChannel The default channel to receive requests from the gateway
      * @return 
      */
-    public function setReplyChannel(\PEIP\INF\Channel\Channel $replyChannel){
-        if(!($replyChannel instanceof \PEIP\INF\Channel\PollableChannel)){
+    public function setReplyChannel(\PEIP\INF\Channel\Channel $replyChannel) {
+        if (!($replyChannel instanceof \PEIP\INF\Channel\PollableChannel)) {
             throw new \InvalidArgumentException('reply channel must be instance of \PEIP\INF\Channel\PollableChannel.');
         }       
         $this->replyChannel = $replyChannel;
@@ -83,7 +83,7 @@ 
      * @param mixed $content the content/payload for the message to send 
      * @return 
      */
-    public function send($content){
+    public function send($content) {
         return $this->requestChannel->send($this->buildMessage($content));
     }
    
@@ -93,12 +93,12 @@ 
      * @access public
      * @return mixed content/payload of the received message
      */
-    public function receive(){
-        if(!isset($this->replyChannel)){
+    public function receive() {
+        if (!isset($this->replyChannel)) {
             throw new \LogicException('No replyChannel set.');
         }       
         $message = $this->replyChannel->receive();
-        if($message){
+        if ($message) {
             return $message->getContent();
         }
         return NULL;
@@ -111,12 +111,12 @@ 
      * @param mixed $content the content/payload for the message to send 
      * @return mixed content/payload of the received message
      */
-    public function sendAndReceive($content){
+    public function sendAndReceive($content) {
         $this->send($content);
         try {
             $res = $this->receive();
         }
-        catch(\Exception $e){
+        catch (\Exception $e) {
             return NULL;
         }
         return $res;
@@ -129,7 +129,7 @@ 
      * @param mixed $content the content/payload for the message to send 
      * @return \PEIP\INF\Message\Message the built message
      */
-    protected function buildMessage($content){
+    protected function buildMessage($content) {
         return $this->getMessageBuilder()->setContent($content)->build();   
     }   
       
@@ -139,7 +139,7 @@ 
      * @access protected
      * @return MessageBuilder message builder instance for the registerd message class
      */
-    protected function getMessageBuilder(){
+    protected function getMessageBuilder() {
         return isset($this->messageBuilder) && ($this->messageBuilder->getMessageClass() == $this->getMessageClass())
             ? $this->messageBuilder
             : $this->messageBuilder = MessageBuilder::getInstance($this->messageClass)->setHeaders($this->defaultHeaders);
@@ -152,7 +152,7 @@ 
      * @param   string $messageClass message class to create instances from
      * @return 
      */
-    public function setMessageClass($messageClass){
+    public function setMessageClass($messageClass) {
         $this->messageClass = $messageClass;
     }
     
@@ -162,7 +162,7 @@ 
      * @access public
      * @return string message class to create instances from
      */
-    public function getMessageClass(){
+    public function getMessageClass() {
         return $this->messageClass;
     }   
 

src/Selector/ContentClassSelector.php

Spacing +2 added lines, -2 removed lines

@@ -33,7 +33,7 @@ 
      * @param $className 
      * @return 
      */
-    public function __construct($className){
+    public function __construct($className) {
         $this->className = $className;
     }       
             
@@ -43,7 +43,7 @@ 
      * @param $message 
      * @return 
      */
-    public function acceptMessage(\PEIP\INF\Message\Message $message){
+    public function acceptMessage(\PEIP\INF\Message\Message $message) {
         return $message->getContent() instanceof $className;
     }           
     

src/Selector/ContentTypeSelector.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
      * @param $type 
      * @return 
      */
-    public function __construct($type){
+    public function __construct($type) {
         $this->type = $type;
     }       
             
@@ -57,7 +57,7 @@ 
      * @param $message 
      * @return 
      */
-    public function acceptMessage(\PEIP\INF\Message\Message $message){
+    public function acceptMessage(\PEIP\INF\Message\Message $message) {
         return call_user_func(self::$types[$this->type], $message->getContent());
     }           
     

src/Command/Command.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param $params 
      * @return 
      */
-    public function __construct($callable, array $params = array()){
+    public function __construct($callable, array $params = array()) {
         $this->callable = $callable;
         $this->setParameters($params);
     }

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;

src/Service/ServiceActivator.php

Spacing +3 added lines, -3 removed lines

@@ -33,12 +33,12 @@
      * @param $outputChannel 
      * @return 
      */
-    public function __construct($serviceCallable, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct($serviceCallable, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->serviceCallable = $serviceCallable;
-        if(is_object($inputChannel)){
+        if (is_object($inputChannel)) {
             $this->setInputChannel($inputChannel);
         }
-        if(is_object($outputChannel)){
+        if (is_object($outputChannel)) {
             $this->setOutputChannel($outputChannel);    
         }   
     }       

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;