tidal / PEIP

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/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/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/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/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,17 +83,17 @@ 
      * @see XMLContext::includeContext

      * @access protected

      */

-    protected function initNodeBuilders(){ return;

+    protected function initNodeBuilders() { return;

         $builders = array(

             'service' => 'initService'

         );

         $plugin = new BasePlugin();

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

@@ -112,15 +112,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(

@@ -131,16 +131,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

@@ -151,11 +151,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(

@@ -165,8 +165,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]];

@@ -181,7 +181,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(

@@ -189,20 +189,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;

         }

 

@@ -213,27 +213,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/Translator/XMLArrayTranslator.php

Spacing +9 added lines, -9 removed lines

@@ -22,38 +22,38 @@ 
 

 class XMLArrayTranslator {

 

-    public static function translate($content){

+    public static function translate($content) {

         $array = array();

         try {

             $node = simplexml_load_string($content);

         }

-        catch(\Exception $e){

+        catch (\Exception $e) {

             return false;

         }     

         

         return self::doTranslate($node);

     }

 

-    protected static function doTranslate(\SimpleXMLElement $node){

+    protected static function doTranslate(\SimpleXMLElement $node) {

         

         $array = array();

         $array['type'] = $node['type']

             ? (string)$node['type']

             : (string)$node->getName();

         $value = (string)$node;

-        if($value != ''){

+        if ($value != '') {

             $array['value'] = $value;

         }

 

-        foreach($node->attributes() as $name=>$value){

+        foreach ($node->attributes() as $name=>$value) {

             $array[$name] = (string)$value;

         }

-        foreach($node->children() as $nr=>$child){

+        foreach ($node->children() as $nr=>$child) {

             $name = $child->getName();

             $res = self::doTranslate($child);

 

-            if(isset($array[$name])){

-                if(is_string($array[$name])){

+            if (isset($array[$name])) {

+                if (is_string($array[$name])) {

                     $array[$name] = array(

                         array(

                             'type'=>$name,

@@ -61,7 +61,7 @@ 
                         )

                     );

                 }

-            }else{

+            }else {

                 $array[$name] = array();

             }

             $array[$name][] = $res;

src/Dispatcher/ClassDispatcher.php

Spacing +13 added lines, -13 removed lines

@@ -18,11 +18,11 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect

      * @return

      */

-    public function connect($name, $listener){

+    public function connect($name, $listener) {

         $name = is_object($name) ? get_class($name) : (string)$name;

-        if(Test::assertClassOrInterfaceExists($name)){

+        if (Test::assertClassOrInterfaceExists($name)) {

             parent::connect($name, $listener);

-        }else{

+        }else {

             throw new \InvalidArgumentException($name." is not an Class nor Interface");

         }

     }

@@ -35,10 +35,10 @@ 
      * @param mixed $subject the subject

      * @return

      */

-    public function notify($name, $subject){

+    public function notify($name, $subject) {

         $res = false;

-        foreach(Reflection::getImplementedClassesAndInterfaces($name) as $cls){

-            if(parent::hasListeners($cls)){

+        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {

+            if (parent::hasListeners($cls)) {

                 self::doNotify($this->getListeners($cls), $subject);

                 $res = true;

             }

@@ -56,10 +56,10 @@ 
      * @param mixed $subject the subject

      * @return \PEIP\INF\Handler\Handler listener which returned a boolean true value

      */

-    public function notifyUntil($name, $subject){

+    public function notifyUntil($name, $subject) {

         $res = NULL;

-        foreach(Reflection::getImplementedClassesAndInterfaces($name) as $cls){

-            if(!$res && parent::hasListeners($cls)){

+        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {

+            if (!$res && parent::hasListeners($cls)) {

                 $res = self::doNotifyUntil($this->getListeners($cls), $subject);

             }

         }

@@ -75,7 +75,7 @@ 
      * @param mixed $subject the subject

      * @return

      */

-    public function notifyOfInstance($subject){

+    public function notifyOfInstance($subject) {

 

         return $this->notify(get_class($subject), $subject);

     }

@@ -86,9 +86,9 @@ 
      * @param string $name name of the event

      * @return boolean wether any listener is registered for event-name

      */

-    public function hasListeners($name){

-        foreach(Reflection::getImplementedClassesAndInterfaces($name) as $cls){

-            if(parent::hasListeners($cls)){

+    public function hasListeners($name) {

+        foreach (Reflection::getImplementedClassesAndInterfaces($name) as $cls) {

+            if (parent::hasListeners($cls)) {

                 return true;

             }

         }

src/Dispatcher/Dispatcher.php

Spacing +12 added lines, -12 removed lines

@@ -40,7 +40,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler  $listener

      * @return void

      */

-    public function connect($listener){

+    public function connect($listener) {

         Test::ensureHandler($listener);

         $this->listeners[] = $listener;

     }

@@ -52,10 +52,10 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return void

      */

-    public function disconnect($listener){

+    public function disconnect($listener) {

         Test::ensureHandler($listener);

-        foreach ($this->listeners as $i => $callable){

-            if ($listener === $callable){

+        foreach ($this->listeners as $i => $callable) {

+            if ($listener === $callable) {

                 unset($this->listeners[$i]);

             }

         }

@@ -68,7 +68,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener

      * @return void

      */

-    public function disconnectAll(){

+    public function disconnectAll() {

         $this->listeners = array();

     }

 

@@ -78,8 +78,8 @@ 
      * @access public

      * @return boolean wether any listeners are registered

      */

-    public function hasListeners(){

-        return (boolean) count($this->listeners);

+    public function hasListeners() {

+        return (boolean)count($this->listeners);

     }

     

     /**

@@ -89,9 +89,9 @@ 
      * @param mixed $subject the subject

      * @return void

      */

-    public function notify($subject){

+    public function notify($subject) {

         $res = NULL;

-        if($this->hasListeners()){

+        if ($this->hasListeners()) {

             $res = self::doNotify($this->getListeners(), $subject); 

         }   

         return $res;      

@@ -104,8 +104,8 @@ 
      * @param mixed $subject the subject 

      * @return \PEIP\INF\Handler\Handler the listener which returned a boolean true value

      */

-    public function notifyUntil($subject){

-        if($this->hasListeners()){

+    public function notifyUntil($subject) {

+        if ($this->hasListeners()) {

             $res = self::doNotifyUntil($this->getListeners(), $subject);    

         }

         return $res;

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

      * @return array the listeners

      */

-    public function getListeners(){

+    public function getListeners() {

         return $this->listeners;

     }

 

src/Dispatcher/ObjectEventDispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -40,16 +40,16 @@ 
      * @param \PEIP\INF\Event\Event $object an event object

      * @return boolean

      */

-    public function notify($name, $object){

-        if($object instanceof \PEIP\INF\Event\Event){

-            if(is_object($object->getContent())){

-                if($this->hasListeners($name, $object->getContent())){

+    public function notify($name, $object) {

+        if ($object instanceof \PEIP\INF\Event\Event) {

+            if (is_object($object->getContent())) {

+                if ($this->hasListeners($name, $object->getContent())) {

                     return self::doNotify($this->getListeners($name, $object->getContent()), $object);  

                 }                   

-            }else{

+            }else {

                 throw new \InvalidArgumentException('instance of \PEIP\INF\Event\Event must contain subject');

             }   

-        }else{

+        }else {

             throw new \InvalidArgumentException('object must be instance of \PEIP\INF\Event\Event');

         }  

     }   

@@ -66,8 +66,8 @@ 
      * @return

      * @see EventBuilder 

      */

-    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false){

-        if(!$this->hasListeners($name, $object)){

+    public function buildAndNotify($name, $object, array $headers = array(), $eventClass = false, $type = false) {

+        if (!$this->hasListeners($name, $object)) {

             return false;

         }

         $event = EventBuilder::getInstance($eventClass)->build(