tidal / PEIP

src/Context/XMLContext.php

Spacing +107 added lines, -107 removed lines

@@ -56,24 +56,24 @@ 
      * @param string $string the configuration string 

      * @return 

      */

-    public function __construct($string){

+    public function __construct($string) {

         $this->initNodeBuilders();

         $reader = new XMLContextReader($string);

  

 

         $serviceActivator = new HeaderServiceActivator(array($this, 'addConfig'), 'NODE');

 

-        $reader->connect('read_node',  $serviceActivator);

+        $reader->connect('read_node', $serviceActivator);

         $reader->read();

 

        

     }

 

-    public function addConfig($config){ 

+    public function addConfig($config) { 

         return $this->getServiceProvider()->addConfig($config);

     }

 

-    public function handleReadConfig(\PEIP\INF\Event\Event $event){

+    public function handleReadConfig(\PEIP\INF\Event\Event $event) {

         $this->addConfig($event->getHeader('NODE'));

     }

 

@@ -85,7 +85,7 @@ 
      * @return XMLContext the context instance

      * @throws RuntimeException 

      */      

-    public static function createFromString($string){

+    public static function createFromString($string) {

         return new XMLContext($string);

     }

 

@@ -97,10 +97,10 @@ 
      * @return XMLContext the context instance

      * @throws RuntimeException 

      */    

-    public static function createFromFile($file){

-        if(file_exists($file)){

+    public static function createFromFile($file) {

+        if (file_exists($file)) {

             return self::createFromString(file_get_contents($file));

-        }else{

+        }else {

             throw new \RuntimeException('Cannot open file  "'.$file.'".');

         }

     }

@@ -111,15 +111,15 @@ 
      * @access protected

      * @return void

      */

-    protected function init(){

+    protected function init() {

         $xml = $this->simpleXML;

         $this->channelRegistry = ChannelRegistry::getInstance();

         // register this context as a service if id is set.

-        if($xml['id']){

+        if ($xml['id']) {

             $this->services[(string)$xml['id']] = $this;    

         }

         // build services

-        foreach($xml->children() as $entry){

+        foreach ($xml->children() as $entry) {

             $this->buildNode($entry);

         }

     }    

@@ -132,7 +132,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) {

        return  $this->getServiceProvider()->registerNodeBuilder($nodeName, $callable);

     }

    

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

      * @param \PEIP\INF\Context\Context_Plugin $plugin a plugin instance

      */

-    public function addPlugin(\PEIP\INF\Context\ContextPlugin $plugin){ 

+    public function addPlugin(\PEIP\INF\Context\ContextPlugin $plugin) { 

         $plugin->init($this);   

     }

   

@@ -154,7 +154,7 @@ 
      * @param object $config configuration object for the plugin 

      * @return 

      */

-    public function createPlugin($config){

+    public function createPlugin($config) {

         $plugin = $this->createService($config);    

         $this->addPlugin($plugin);

     }

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

      * @param XMLContext $config the config to include

      */    

-    public function includeContext(XMLContext $context){

+    public function includeContext(XMLContext $context) {

         $this->services = array_merge($this->services, $context->getServices());

     }

 

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

      * @param XMLContext $context the config to include

      */    

-    public function includeContextFromFile($filePath){

-        if(file_exists($filePath)){

+    public function includeContextFromFile($filePath) {

+        if (file_exists($filePath)) {

             $this->includeContextFromString(file_get_contents($filePath));

         }           

     }

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

      * @param string $configString the config to include

      */    

-    public function includeContextFromString($configString){

+    public function includeContextFromString($configString) {

         $context = new XMLContext($configString);

         $this->includeContext($context);            

     }   

@@ -211,14 +211,14 @@ 
      * @access protected

      * @param object $config the configuration for the context

      */    

-    protected function createContext($config){

-        if((string)$config['file'] != ''){

+    protected function createContext($config) {

+        if ((string)$config['file'] != '') {

             $this->includeContextFromFile((string)$config['file']);

         }           

     }   

      

 

-    public function getServiceProvider(){

+    public function getServiceProvider() {

         return isset($this->serviceProvider)

             ? $this->serviceProvider

             : $this->serviceProvider = new ServiceProvider();

@@ -234,7 +234,7 @@ 
      * @see XMLContext::includeContext

      * @access protected

      */     

-    protected function initNodeBuilders(){

+    protected function initNodeBuilders() {

         $builders = array(

             'include' => 'createContext',

             'plugin' => 'createPlugin',

@@ -252,7 +252,7 @@ 
         );

         $plugin = new BasePlugin();

         $this->addPlugin($plugin); return;

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

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

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

         }       

     }

@@ -266,10 +266,10 @@ 
      * @param object $node configuration-node

      * @return void

      */

-    protected function buildNode($node){

+    protected function buildNode($node) {

         $nodeName = $node->getName();

         // call the builder method registered for the node.

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

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

             call_user_func($this->nodeBuilders[$nodeName], $node);

         }           

     }

@@ -288,7 +288,7 @@ 
      * @param string $channelName the name/id of the channel to return 

      * @return \PEIP\INF\Channel\Channel

      */

-    public function resolveChannelName($channelName){

+    public function resolveChannelName($channelName) {

         return $this->channelRegistry->get($channelName);

     }   

      

@@ -300,7 +300,7 @@ 
      * @param mixed $id the id for the service

      * @return object the service instance if found

      */

-    public function getService($id){     

+    public function getService($id) {     

         return $this->getServiceProvider()->provideService($id);

     }

              

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

      * @return array registered services

      */

-    public function getServices(){    

+    public function getServices() {    

         return $this->getServiceProvider()->getServices();

     }  

     

@@ -321,7 +321,7 @@ 
      * @param mixed $id the id for the service 

      * @return boolean wether service is registered

      */

-    public function hasService($id){

+    public function hasService($id) {

         return isset($this->services[$id]);

     }

       

@@ -335,9 +335,9 @@ 
      * @return object the service instance if found

      * 

      */

-    protected function requestService($id){

+    protected function requestService($id) {

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

-        if($service === NULL){

+        if ($service === NULL) {

             throw new \RuntimeException('Service "'.$id.'" not found.');

         } 

         return $service;

@@ -351,9 +351,9 @@ 
      * @param object $config 

      * @return object the initialized service instance

      */

-    protected function initService($config){

+    protected function initService($config) {

         $id = trim((string)$config['id']);

-        if($id != ''){

+        if ($id != '') {

             return $this->services[$id] = $this->createService($config);    

         }   

     }

@@ -365,7 +365,7 @@ 
      * @param $config 

      * @return object the initialized service instance

      */

-    public function createService($config){

+    public function createService($config) {

         return ServiceFactory::createService($config);      

     }

  

@@ -382,29 +382,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) { 

         $reflection = GenericBuilder::getInstance(get_class($service))->getReflectionClass();

         // set instance properties

-        if($config->property){          

-            foreach($config->property as $property){                          

+        if ($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($config->action){            

-            foreach($config->action as $action){

+        if ($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);

@@ -412,9 +412,9 @@ 
             }

         }       

         // register instance listeners

-        if($service instanceof \PEIP\INF\Event\Connectable){

-            if($config->listener){

-                foreach($config->listener as $listenerConf){

+        if ($service instanceof \PEIP\INF\Event\Connectable) {

+            if ($config->listener) {

+                foreach ($config->listener as $listenerConf) {

                     $event = (string)$listenerConf['event'];

                     $listener = $this->provideService($listenerConf);  

                     $service->connect($event, $listener);   

@@ -433,7 +433,7 @@ 
      * @param mixed $id the id ofthe gateway 

      * @return object the gateway instance

      */

-    public function getGateway($id){ 

+    public function getGateway($id) { 

         return $this->getServiceProvider()->provideService($id); 

     }   

   

@@ -445,7 +445,7 @@ 
      * @param object $config configuration object for the pollable channel. 

      * @return \PEIP\INF\Channel\Channel the created pollable channel instance

      */

-    public function createChannel($config){

+    public function createChannel($config) {

         return $this->doCreateChannel($config, 'PollableChannel');        

     }

   

@@ -457,7 +457,7 @@ 
      * @param object $config configuration object for the subscribable channel. 

      * @return \PEIP\INF\Channel\Channel the created subscribable channel instance

      */

-    public function createSubscribableChannel($config){

+    public function createSubscribableChannel($config) {

         return $this->doCreateChannel($config, 'PublishSubscribeChannel');       

     }   

    

@@ -470,9 +470,9 @@ 
      * @param $additionalArguments additional arguments for the channel constructor (without first arg = id)

      * @return \PEIP\INF\Channel\Channel the created channel instance

      */

-    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()){

+    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()) {

         $id = (string)$config['id'];

-        if($id != ''){ 

+        if ($id != '') { 

             array_unshift($additionalArguments, $id);

             $channel = $this->buildAndModify($config, $additionalArguments, $defaultChannelClass);

             $this->channelRegistry->register($channel);

@@ -489,7 +489,7 @@ 
      * @param string $defaultClass the class to use if none is set in config. 

      * @return object the gateway instance

      */

-    public function createGateway($config, $defaultClass = false){

+    public function createGateway($config, $defaultClass = false) {

         $args = array(

             $this->getRequestChannel($config), 

             $this->getReplyChannel($config)

@@ -513,7 +513,7 @@ 
      * @param string $defaultClass the class to use if none is set in config. 

      * @return object the router instance

      */

-    public function createRouter($config, $defaultClass = false){

+    public function createRouter($config, $defaultClass = false) {

         $resolver = $config['channel_resolver'] ? (string)$config['channel_resolver'] : $this->channelRegistry;

         return $this->buildAndModify($config, array(

             $resolver,

@@ -530,7 +530,7 @@ 
      * @param object $config configuration object for the splitter. 

      * @return object the splitter instance

      */    

-    public function createSplitter($config){

+    public function createSplitter($config) {

         return $this->createReplyMessageHandler($config);           

     }   

  

@@ -543,7 +543,7 @@ 
      * @param object $config configuration object for the transformer. 

      * @return object the transformer instance

      */    

-    public function createTransformer($config){

+    public function createTransformer($config) {

         return $this->createReplyMessageHandler($config);           

     } 

       

@@ -556,7 +556,7 @@ 
      * @param object $config configuration object for the aggregator. 

      * @return object the aggregator instance

      */  

-    public function createAggregator($config){

+    public function createAggregator($config) {

         return $this->createReplyMessageHandler($config);       

     }

   

@@ -569,7 +569,7 @@ 
      * @param object $config configuration object for the wiretap. 

      * @return object the wiretap instance

      */ 

-    public function createWiretap($config){

+    public function createWiretap($config) {

         return $this->createReplyMessageHandler($config, 'Wiretap');       

     }

   

@@ -582,7 +582,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.

      * @return object the reply-message-handler instance

      */ 

-    public function createReplyMessageHandler($config, $defaultClass = false){

+    public function createReplyMessageHandler($config, $defaultClass = false) {

         return $this->buildAndModify($config, $this->getReplyHandlerArguments($config), $defaultClass); 

     }

     

@@ -595,12 +595,12 @@ 
      * @param string $defaultClass the class to use if none is set in config. 

      * @return object the service-activator instance

      */

-    public function createServiceActivator($config, $defaultClass = false){

+    public function createServiceActivator($config, $defaultClass = false) {

         $method = (string)$config['method'];

         $service = $this->getService((string)$config['ref']);

-        if($method && $service){        

+        if ($method && $service) {        

             $args = $this->getReplyHandlerArguments($config);

-            array_unshift($args,array(

+            array_unshift($args, array(

                 $service,

                 $method             

             )); 

@@ -621,11 +621,11 @@ 
      * @param object $config configuration object for the service. 

      * @return 

      */

-    protected function provideService($config){

+    protected function provideService($config) {

         $ref = trim((string)$config['ref']);

-        if($ref != ''){

+        if ($ref != '') {

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

-        }else{

+        }else {

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

         }

         return $service;

@@ -642,10 +642,10 @@ 
      * @param object $config configuration object for the setter-method. 

      * @return string camel-cased 

      */    

-    protected static function getSetter($config){

-        if($config['setter']){

+    protected static function getSetter($config) {

+        if ($config['setter']) {

             $setter = (string)$config['setter'];

-        }elseif($config['name']){

+        }elseif ($config['name']) {

             $setter = 'set'.ucfirst((string)$config['name']);   

         }

         return $setter;     

@@ -658,29 +658,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 = $this->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; 

@@ -694,12 +694,12 @@ 
      * @param object $config configuration object to create arguments from.  

      * @return mixed build arguments 

      */

-    protected function getReplyHandlerArguments($config){

+    protected function getReplyHandlerArguments($config) {

         $args = array(

             $this->doGetChannel('input', $config),

             $this->doGetChannel('output', $config)

         );

-        if($args[0] == NULL){

+        if ($args[0] == NULL) {

             throw new \RuntimeException('Could not receive input channel.');

         }

         return $args;

@@ -714,7 +714,7 @@ 
      * @param object $config configuration object to return request-channel from. 

      * @return \PEIP\INF\Channel\Channel request-channel

      */

-    protected function getRequestChannel($config){

+    protected function getRequestChannel($config) {

         return $this->doGetChannel('request', $config); 

     }

     

@@ -727,7 +727,7 @@ 
      * @param object $config configuration object to return reply-channel from. 

      * @return \PEIP\INF\Channel\Channel reply-channel

      */

-    protected function getReplyChannel($config){

+    protected function getReplyChannel($config) {

         return $this->doGetChannel('reply', $config);   

     }

     

@@ -740,15 +740,15 @@ 
      * @param object $config configuration object to return channel from. 

      * @return \PEIP\INF\Channel\Channel reply-channel

      */

-    public function doGetChannel($type, $config){

+    public function doGetChannel($type, $config) {

         $channelName = $config[$type."_channel"] 

             ? $config[$type."_channel"] 

             : $config["default_".$type."_channel"];

         return $this->serviceProvider->provideService(trim((string)$channelName));

-        $channel =  $this->services[trim((string)$channelName)];

-        if($channel instanceof \PEIP\INF\Channel\Channel){

+        $channel = $this->services[trim((string)$channelName)];

+        if ($channel instanceof \PEIP\INF\Channel\Channel) {

             return $channel;    

-        }else{

+        }else {

             return NULL;

         }       

     }

@@ -766,31 +766,31 @@ 
      * @param string $defaultClass class to create instance for if none is set in config 

      * @return object build and modified srvice instance

      */

-    public function buildAndModify($config, $arguments, $defaultClass = false){

-        if("" != (string)$config["class"]  || $defaultClass){

+    public function buildAndModify($config, $arguments, $defaultClass = false) {

+        if ("" != (string)$config["class"] || $defaultClass) {

              $service = ServiceFactory::doBuild($config, $arguments, $defaultClass);

-        }elseif($config["ref"]){

+        }elseif ($config["ref"]) {

             $service = $this->getService((string)$config['ref']);

-        }else{

+        }else {

             throw new \RuntimeException('Could not create Service. no class or reference given.');

         }

-        if($config["ref_property"]){

+        if ($config["ref_property"]) {

             $service = $service->{(string)$config["ref_property"]}; 

-        }elseif($config["ref_method"]){

+        }elseif ($config["ref_method"]) {

                 $args = array();

-            if($config->argument){

-                        foreach($config->argument as $arg){

+            if ($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 = $this->modifyService($service, $config);

         $id = trim((string)$config['id']);

-        if($service && $id != ''){

+        if ($service && $id != '') {

             $this->services[$id] = $service;    

         }

         return $service;

@@ -806,21 +806,21 @@ 
      * @param string $defaultClass class to create instance for if none is set in config 

      * @return object build and modified srvice instance

      */    

-    protected static function doBuild($config, $arguments, $defaultClass = false){

+    protected static function doBuild($config, $arguments, $defaultClass = false) {

         $cls = $config["class"] ? trim((string)$config["class"]) : (string)$defaultClass;

-        if($cls != ''){

+        if ($cls != '') {

             try {

                 $constructor = (string)$config["constructor"];

-        if($constructor != ''){

+        if ($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.');           

@@ -836,13 +836,13 @@ 
      * @param array $arguments arguments for the constructor 

      * @return object build and modified srvice instance

      */     

-    protected static function build($className, $arguments){

+    protected static function build($className, $arguments) {

         return GenericBuilder::getInstance($className)->build($arguments);

     }

 

-    protected static function hasPublicProperty($service, $type, $name){

+    protected static function hasPublicProperty($service, $type, $name) {

         $reflection = GenericBuilder::getInstance(get_class($service))->getReflectionClass();

-        if($reflection->{'has'.$type}($name) && $reflection->{'get'.$type}($name)->isPublic()){

+        if ($reflection->{'has'.$type}($name) && $reflection->{'get'.$type}($name)->isPublic()) {

                 return true;

         }

         return false;