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

src/Dispatcher/ObjectMapDispatcher.php

Spacing +33 added lines, -33 removed lines

@@ -43,13 +43,13 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener event-handler

      * @return boolean

      */

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

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

         Test::ensureHandler($listener);

         $listners = $this->doGetListeners();

-        if (!$this->listeners->contains($object)){

+        if (!$this->listeners->contains($object)) {

             $this->listeners->attach($object, new \ArrayObject);

         }

-        if (!array_key_exists($name, $listners[$object])){ 

+        if (!array_key_exists($name, $listners[$object])) { 

             $this->listeners[$object][$name] = array();

         }

         $hash = $this->getListenerHash($listener);

@@ -67,14 +67,14 @@ 
      * @param \PEIP\INF\Handler\Handler $listener event-handler

      * @return boolean

      */

-    public function disconnect($name, $object, $listener){

+    public function disconnect($name, $object, $listener) {

         $listners = $this->doGetListeners();

-        if (!$listners->contains($object) || !isset($listners[$object][$name])){

+        if (!$listners->contains($object) || !isset($listners[$object][$name])) {

             return false;

         }

         $eventListeners = $listners[$object][$name];

         $hash = $this->getListenerHash($listener);

-        if(isset($eventListeners[$hash])){

+        if (isset($eventListeners[$hash])) {

             unset($eventListeners[$hash]); 

 

             $listners[$object][$name] = $eventListeners;

@@ -83,10 +83,10 @@ 
         return false;

     }

 

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

-        if(is_object($object)){

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

+        if (is_object($object)) {

             $listners = $this->doGetListeners();

-            if($listners && $this->hadListeners($name, $object)){

+            if ($listners && $this->hadListeners($name, $object)) {

                     $listners[$object][$name] = array();

             }        

         }

@@ -100,13 +100,13 @@ 
      * @param object $object object to check for listeners

      * @return boolean

      */

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

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

         $listners = $this->doGetListeners();

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

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

             $res = false;

-        }else{

+        }else {

             $listners = $this->doGetListeners();

-            $res = (boolean) count($listners[$object][$name]);

+            $res = (boolean)count($listners[$object][$name]);

         }

         return $res;

     }

@@ -119,7 +119,7 @@ 
      * @param object $object object to check for listeners

      * @return boolean

      */

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

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

         $listners = $this->doGetListeners();

         return ($listners->contains($object) && isset($listners[$object][$name])) ? true : false;

     }

@@ -131,9 +131,9 @@ 
      * @param object $object object to get event-names for

      * @return string[] array of event-names

      */

-    public function getEventNames($object){

+    public function getEventNames($object) {

         $listeners = $this->doGetListeners();

-        if (!$listeners->contains($object)){

+        if (!$listeners->contains($object)) {

             return array();

         }

         return array_keys($listeners[$object]->getArrayCopy());

@@ -147,8 +147,8 @@ 
      * @param $object 

      * @return boolean

      */

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

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

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

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

             $listners = $this->doGetListeners();

             self::doNotify($listners[$object][$name], $object);

         }

@@ -164,8 +164,8 @@ 
      * @param $subject 

      * @return mixed

      */

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

-        if($this->hasListeners($name, $subject)){       

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

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

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

         }

         return $res;

@@ -179,8 +179,8 @@ 
      * @param object $object object to check for listeners

      * @return array array of listeners

      */

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

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

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

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

             return array();

         }

         $listeners = $this->listeners[$object]->getArrayCopy();

@@ -194,7 +194,7 @@ 
      * @access protected

      * @return ObjectStorage

      */

-    protected function doGetListeners(){

+    protected function doGetListeners() {

         return isset($this->listeners) ? $this->listeners : $this->listeners = new ObjectStorage();

     }

    

@@ -207,11 +207,11 @@ 
      * @param $object 

      * @return boolean

      */    

-    protected static function doNotify(array $listeners, $subject){

-        foreach($listeners as $listener){ 

-             if($listener instanceof \PEIP\INF\Handler\Handler){

+    protected static function doNotify(array $listeners, $subject) {

+        foreach ($listeners as $listener) { 

+             if ($listener instanceof \PEIP\INF\Handler\Handler) {

                 $listener->handle($subject);

-             }elseif(is_callable($listener)){

+             }elseif (is_callable($listener)) {

                  call_user_func($listener, $subject);

              }

         }   

@@ -226,12 +226,12 @@ 
      * @param $object 

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

      */     

-    protected static function doNotifyUntil(array $listeners, $subject){  

+    protected static function doNotifyUntil(array $listeners, $subject) {  

         $res = NULL; 

-        foreach ($listeners as $listener){ 

-            if($listener instanceof \PEIP\INF\Handler\Handler){

+        foreach ($listeners as $listener) { 

+            if ($listener instanceof \PEIP\INF\Handler\Handler) {

                 $res = $listener->handle($subject);

-                if ($res){ 

+                if ($res) { 

                     return $listener;

                 }

             }

@@ -239,8 +239,8 @@ 
         return $res;

     }

 

-    protected function getListenerHash($listener){

-        if(!is_object($listener)){

+    protected function getListenerHash($listener) {

+        if (!is_object($listener)) {

             $o = new \stdClass();

             $o->listener = $listener;

             $listener = $o;