tidal / PEIP

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;

src/Service/ServiceContainerBuilder.php

Spacing +7 added lines, -7 removed lines

@@ -25,7 +25,7 @@ 
 use \PEIP\Data\InternalStoreAbstract;
 use PEIP\Factory\DedicatedFactory;
 
-class ServiceContainerBuilder extends \PEIP\Data\InternalStoreAbstract{
+class ServiceContainerBuilder extends \PEIP\Data\InternalStoreAbstract {
     
     
     
@@ -35,7 +35,7 @@ 
      * @param $factory 
      * @return 
      */
-    public function setFactory($key, DedicatedFactory $factory){
+    public function setFactory($key, DedicatedFactory $factory) {
             $this->setInternalValue($key, $factory);
     }
 
@@ -45,7 +45,7 @@ 
      * @param $key 
      * @return 
      */
-    public function getFactory($key){
+    public function getFactory($key) {
             $this->getInternalValue($key);
     }
 
@@ -55,7 +55,7 @@ 
      * @param $key 
      * @return 
      */
-    public function hasFactory($key){
+    public function hasFactory($key) {
             $this->hasInternalValue($key);
     }
 
@@ -65,7 +65,7 @@ 
      * @param $key 
      * @return 
      */
-    public function deleteFactory($key){
+    public function deleteFactory($key) {
             $this->deleteInternalValue($key);
     }
 
@@ -75,7 +75,7 @@ 
      * @param $key 
      * @return 
      */
-    public function getService($key){
+    public function getService($key) {
         return isset($this->services[$key]) ? $this->services[$key] : $this->services[$key] = $this->getFactory($key)->build();
     }
     
@@ -86,7 +86,7 @@ 
      * @param $key 
      * @return 
      */
-    public function buildService($key){
+    public function buildService($key) {
         return $this->getFactory($key)->build();
     }   
     

src/Service/ServiceContainer.php

Spacing +5 added lines, -5 removed lines

@@ -27,7 +27,7 @@ 
 class ServiceContainer
     extends \PEIP\ABS\Base\Connectable
     implements 
-        \PEIP\INF\Service\ServiceContainer{
+        \PEIP\INF\Service\ServiceContainer {
 
     protected $services = array();
     
@@ -45,7 +45,7 @@ 
      * @param $service 
      * @return 
      */
-    public function setService($key, $service){
+    public function setService($key, $service) {
         $this->services[$key] = $service;
     }
     
@@ -55,7 +55,7 @@ 
      * @param $key 
      * @return 
      */
-    public function getService($key){
+    public function getService($key) {
         return $this->services[$key];
     }
     
@@ -65,7 +65,7 @@ 
      * @param $key 
      * @return 
      */
-    public function hasService($key){
+    public function hasService($key) {
         return array_key_exists($key, $this->services); 
     }   
 
@@ -75,7 +75,7 @@ 
      * @param $key 
      * @return 
      */
-    public function deleteService($key){
+    public function deleteService($key) {
         unset($this->services[$key]);
     }
     

src/Service/HeaderServiceActivator.php

Spacing +6 added lines, -6 removed lines

@@ -12,7 +12,7 @@ 
  * @author timo
  */
 
-class HeaderServiceActivator extends \PEIP\Service\ServiceActivator{
+class HeaderServiceActivator extends \PEIP\Service\ServiceActivator {
    
     protected $headerName;
 
@@ -24,7 +24,7 @@ 
      * @param $outputChannel
      * @return
      */
-    public function __construct($serviceCallable, $headerName, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct($serviceCallable, $headerName, \PEIP\INF\Channel\Channel $inputChannel = NULL, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->headerName = $headerName;
         parent::__construct($serviceCallable, $inputChannel, $outputChannel);
     }
@@ -38,12 +38,12 @@ 
      * @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
      */
-    protected function callService(\PEIP\INF\Message\Message $message){
+    protected function callService(\PEIP\INF\Message\Message $message) {
         $res = NULL; 
-        if(is_callable($this->serviceCallable)){
+        if (is_callable($this->serviceCallable)) {
             $res = call_user_func($this->serviceCallable, $message->getHeader($this->headerName));
-        }else{
-            if(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
+        }else {
+            if (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
                 $res = $this->serviceCallable->handle($message->getHeader($this->headerName));
             }
         }

src/INF/Message/MessageDispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -26,11 +26,11 @@
 
   public function disconnect($name, \PEIP\INF\Message\MessageHandler $handler);
 
-  public function notify( $event);
+  public function notify($event);
 
-  public function notifyUntil( $event);
+  public function notifyUntil($event);
 
-  public function filter( $event, $value);
+  public function filter($event, $value);
 
   public function hasListeners($name);
 

src/INF/Dispatcher/ListDispatcher.php

Spacing +2 added lines, -2 removed lines

@@ -24,9 +24,9 @@
 
 interface ListDispatcher extends \PEIP\INF\Dispatcher\Dispatcher {
 
-  public function connect( $handler);
+  public function connect($handler);
 
-  public function disconnect( $handler);
+  public function disconnect($handler);
 
   public function hasListeners();
 

src/Listener/Wiretap.php

Spacing +3 added lines, -3 removed lines

@@ -33,10 +33,10 @@ 
      * @param $outputChannel 
      * @return 
      */
-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->setEventName('preSend');
         $this->setInputChannel($inputChannel);
-        if(is_object($outputChannel)){
+        if (is_object($outputChannel)) {
             $this->setOutputChannel($outputChannel);
         }           
     }           
@@ -47,7 +47,7 @@ 
      * @param $message 
      * @return 
      */
-    protected function doReply(\PEIP\INF\Message\Message $message){
+    protected function doReply(\PEIP\INF\Message\Message $message) {
         $this->replyMessage($message->getHeader('MESSAGE'));
     }