tidal / PEIP

src/ABS/Handler/DiscardingMessageHandler.php

Spacing +4 added lines, -4 removed lines

@@ -33,7 +33,7 @@ 
      * @param $discardChannel 

      * @return 

      */

-    public function setDiscardChannel(\PEIP\INF\Channel\Channel $discardChannel){

+    public function setDiscardChannel(\PEIP\INF\Channel\Channel $discardChannel) {

         $this->discardChannel = $discardChannel;    

     }   

 

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

      * @return 

      */

-    public function getDiscardChannel(){

+    public function getDiscardChannel() {

         return $this->discardChannel;   

     }   

 

@@ -52,8 +52,8 @@ 
      * @param $message 

      * @return 

      */

-    protected function discardMessage(\PEIP\INF\Message\Message $message){

-        if(isset($this->discardChannel)){

+    protected function discardMessage(\PEIP\INF\Message\Message $message) {

+        if (isset($this->discardChannel)) {

             $this->discardChannel->send($message);

         }

     }

src/ABS/Service/ServiceActivator.php

Spacing +6 added lines, -6 removed lines

@@ -38,12 +38,12 @@ 
      * @param \PEIP\INF\Message\Message $message message to handle/reply for

      * @return 

      */

-    public function doReply(\PEIP\INF\Message\Message $message){

+    public function doReply(\PEIP\INF\Message\Message $message) {

         $res = $this->callService($message);

         $out = (bool)$message->hasHeader('REPLY_CHANNEL') 

             ? $message->getHeader('REPLY_CHANNEL') 

             : $this->outputChannel;    

-        if($out){

+        if ($out) {

             $this->replyMessage($res, $res);    

         }

     }  

@@ -56,12 +56,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->getContent());

-        }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->getContent());

             }

         }    

src/Translator/XMLArrayTranslator.php

Spacing +10 added lines, -10 removed lines

@@ -22,43 +22,43 @@ 
 

 class XMLArrayTranslator {

 

-    public static function translate($content){

+    public static function translate($content) {

         $array = array();

         try {

             $node = simplexml_load_string($content);

             // fix for hhvm

-            if(!($node instanceof \SimpleXMLElement)){

+            if (!($node instanceof \SimpleXMLElement)) {

                 throw new \Exception('loading XML failed');  

             }

             

         }

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

@@ -66,7 +66,7 @@ 
                         )

                     );

                 }

-            }else{

+            }else {

                 $array[$name] = array();

             }

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

src/Pipe/Pipe.php

Spacing +17 added lines, -17 removed lines

@@ -64,7 +64,7 @@ 
      * @param $name 

      * @return 

      */

-    public function setName($name){

+    public function setName($name) {

         $this->name = $name;

     }

     

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

      * @return 

      */

-    public function getName(){

+    public function getName() {

         return $this->name;

     }

 

@@ -84,7 +84,7 @@ 
      * @param $timeout 

      * @return 

      */

-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){

+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {

         return $this->handle($message);

     }

 

@@ -94,7 +94,7 @@ 
      * @param $message 

      * @return 

      */

-    protected function doSend(\PEIP\INF\Message\Message $message){

+    protected function doSend(\PEIP\INF\Message\Message $message) {

         $this->doFireEvent(self::EVENT_PRE_PUBLISH, array(self::HEADER_MESSAGE=>$message));

         $this->getMessageDispatcher()->notify($message);

         $this->doFireEvent(self::EVENT_POST_PUBLISH, array(self::HEADER_MESSAGE=>$message));

@@ -107,12 +107,12 @@ 
      * @param $content 

      * @return 

      */

-    protected function replyMessage($message){ 

+    protected function replyMessage($message) { 

         $message = $this->ensureMessage($message);

         //if(\PEIP\Util\Test::assertMessage($message)){

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

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

                 $this->getOutputChannel()->send($message);

-            }else{ 

+            }else { 

                 $this->doSend($message);

             }

         //}

@@ -124,7 +124,7 @@ 
      * @param $message 

      * @return 

      */

-    protected function doReply(\PEIP\INF\Message\Message $message){

+    protected function doReply(\PEIP\INF\Message\Message $message) {

         $this->replyMessage($message);

     }

 

@@ -134,7 +134,7 @@ 
      * @param $handler 

      * @return 

      */

-    public function subscribe($handler){

+    public function subscribe($handler) {

         Test::ensureHandler($handler);

         $this->getMessageDispatcher()->connect($handler);

         $this->doFireEvent(self::EVENT_SUBSCRIBE, array(self::HEADER_SUBSCRIBER=>$handler));

@@ -146,7 +146,7 @@ 
      * @param $handler e

      * @return 

      */

-    public function unsubscribe($handler){

+    public function unsubscribe($handler) {

         Test::ensureHandler($handler);

         $this->getMessageDispatcher()->disconnect($handler);

         $this->doFireEvent(

@@ -164,9 +164,9 @@ 
      * @param $transferListeners 

      * @return 

      */

-    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true){

-        if(isset($this->dispatcher) && $transferListeners){

-            foreach($this->dispatcher->getListeners() as $listener){

+    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true) {

+        if (isset($this->dispatcher) && $transferListeners) {

+            foreach ($this->dispatcher->getListeners() as $listener) {

                 $dispatcher->connect($listener);

                 $this->dispatcher->disconnect($listener);       

             }   

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

      * @return 

      */

-    public function getMessageDispatcher(){

+    public function getMessageDispatcher() {

         $defaultDispatcher = self::DEFAULT_CLASS_MESSAGE_DISPATCHER;

         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new $defaultDispatcher;

     }   

@@ -192,7 +192,7 @@ 
      * @param $callable 

      * @return 

      */

-    protected function registerCommand($commandName, $callable){

+    protected function registerCommand($commandName, $callable) {

         $this->commands[$commandName] = $callable;  

     }

     

@@ -202,10 +202,10 @@ 
      * @param $cmdMessage 

      * @return 

      */

-    public function command(\PEIP\INF\Message\Message $cmdMessage){

+    public function command(\PEIP\INF\Message\Message $cmdMessage) {

         $this->doFireEvent(self::EVENT_PRE_COMMAND, array(self::HEADER_MESSAGE=>$cmdMessage));

         $commandName = trim((string)$cmdMessage->getHeader('COMMAND'));

-        if($commandName != '' && array_key_exists($commandName, $this->commands)){

+        if ($commandName != '' && array_key_exists($commandName, $this->commands)) {

             call_user_func($this->commands[$commandName], $cmdMessage->getContent());   

         }

         $this->doFireEvent(self::EVENT_POST_COMMAND, array(self::HEADER_MESSAGE=>$cmdMessage));

src/Event/EventBuilder.php

Spacing +4 added lines, -4 removed lines

@@ -37,7 +37,7 @@ 
      * @param string $eventClass the event-class the builder shall create instances for 

      * @param array $defaultHeaders default headers for the created events 

      */

-    public function __construct($eventClass = '\PEIP\Event\Event', array $defaultHeaders = array()){

+    public function __construct($eventClass = '\PEIP\Event\Event', array $defaultHeaders = array()) {

         $this->eventClass = $eventClass;

         $this->defaultParameters = $defaultHeaders;

     }

@@ -49,7 +49,7 @@ 
      * @param string $eventClass the event-class the builder shall create instances for 

      * @return EventBuilder the instance of EventBuilder for the given event-class 

      */    

-    public static function getInstance($eventClass = '\PEIP\Event\Event'){ 

+    public static function getInstance($eventClass = '\PEIP\Event\Event') { 

 

         return isset(self::$instances[$eventClass]) 

             ? self::$instances[$eventClass] 

@@ -67,7 +67,7 @@ 
      * @param array $headers the headers for the event 

      * @return object event instance

      */

-    public function build($subject, $name, array $headers = array()){

+    public function build($subject, $name, array $headers = array()) {

 

         return new $this->eventClass(

             $subject,

@@ -86,7 +86,7 @@ 
      * @param array $parameters the headers for the event

      * @return 

      */

-    public function buildAndDispatch(ObjectEventDispatcher $dispatcher, $subject, $name, array $headers = array()){

+    public function buildAndDispatch(ObjectEventDispatcher $dispatcher, $subject, $name, array $headers = array()) {

   

         return $dispatcher->notify(

             $name,

src/Util/Test.php

Spacing +29 added lines, -29 removed lines

@@ -15,11 +15,11 @@ 
 class Test {

 

 

-    public static function assertClassHasConstructor($className){

-        return (boolean) ReflectionPool::getInstance($className)->getConstructor();

+    public static function assertClassHasConstructor($className) {

+        return (boolean)ReflectionPool::getInstance($className)->getConstructor();

     }

 

-    public static function assertRequiredConstructorParameters($className, $parameters){

+    public static function assertRequiredConstructorParameters($className, $parameters) {

             return (boolean)

                 !self::assertClassHasConstructor($className) ||

                 count($parameters) >= ReflectionPool::getInstance($className)

@@ -27,55 +27,55 @@ 
                     ->getNumberOfRequiredParameters();

     }

 

-    public static function assertInstanceOf($className, $object){

-        return (boolean) ReflectionPool::getInstance($className)

+    public static function assertInstanceOf($className, $object) {

+        return (boolean)ReflectionPool::getInstance($className)

             ->isInstance($object);

     }

 

-    public static function assertClassOrInterfaceExists($className){

-        return (boolean) class_exists($className) || interface_exists($className);

+    public static function assertClassOrInterfaceExists($className) {

+        return (boolean)class_exists($className) || interface_exists($className);

     }

 

-    public static function assertImplements($className, $interfaceName){

+    public static function assertImplements($className, $interfaceName) {

         $className = is_object($className) ? get_class($className) : $className;

-        $res = false;//throw new \Exception();

+        $res = false; //throw new \Exception();

         try {  

             class_exists($className); 

-            $res =  ReflectionPool::getInstance($className)

+            $res = ReflectionPool::getInstance($className)

                 ->implementsInterface($interfaceName);             

-        }  catch (\Exception $e){

+        } catch (\Exception $e) {

             $res = false; 

         } 

-        return $res;;

+        return $res; ;

     }

 

-    public static function assertMessage($message){

+    public static function assertMessage($message) {

         return self::assertImplements($message, '\PEIP\INF\Message\Message');

     }

 

-    public static function assertEvent($event){

+    public static function assertEvent($event) {

         return self::assertImplements($event, '\PEIP\INF\Event\Event');

     }

 

-    public static function assertEventSubject($event){

+    public static function assertEventSubject($event) {

         return self::assertImplements($event, '\PEIP\INF\Event\Event')

             && $event->getSubject();

     }

 

-    public static function assertEventObjectSubject($event){

+    public static function assertEventObjectSubject($event) {

         return self::assertEventSubject($event)

             && is_object($event->getSubject());

     }

-    public static function assertArrayAccess($var){

-        return (boolean) is_array($var) || $var instanceof \ArrayAccess;

+    public static function assertArrayAccess($var) {

+        return (boolean)is_array($var) || $var instanceof \ArrayAccess;

     }

 

-    public static function assertHandler($var){

-        return (boolean) is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;

+    public static function assertHandler($var) {

+        return (boolean)is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;

     }

 

-    public static function castType($var, $type){

-        switch($type){

+    public static function castType($var, $type) {

+        switch ($type) {

             case 'string':

                 $var = (string)$var;

                 break;

@@ -99,8 +99,8 @@ 
         return $var;

     }

 

-    public static function ensureArrayAccess($var){

-        if(!Test::assertArrayAccess($var)){

+    public static function ensureArrayAccess($var) {

+        if (!Test::assertArrayAccess($var)) {

             throw new \InvalidArgumentException(

                 'Value is not an array nor an instance of ArrayAccess'

             );

@@ -109,8 +109,8 @@ 
     }

 

 

-    public static function ensureHandler($var){

-        if(!Test::assertHandler($var)){

+    public static function ensureHandler($var) {

+        if (!Test::assertHandler($var)) {

             throw new \InvalidArgumentException(

                 'Value is not an callable nor an instance of \PEIP\INF\Handler\Handler'

             );

@@ -118,8 +118,8 @@ 
         return $var;

     }

 

-    public static function ensureImplements($className, $interfaceName){

-        if(!Test::assertImplements($className, $interfaceName)){

+    public static function ensureImplements($className, $interfaceName) {

+        if (!Test::assertImplements($className, $interfaceName)) {

             throw new \InvalidArgumentException(

                 'Class "'.$className.'" is not an instanceof "'.$interfaceName.'"'

             );

@@ -127,7 +127,7 @@ 
         return $className;

     }

 

-    public static function assertMethod($className, $methodname){

+    public static function assertMethod($className, $methodname) {

         return ReflectionPool::getInstance($className)->hasMethod($methodname);

     }

 

src/Base/GenericBuilder.php

Spacing +10 added lines, -10 removed lines

@@ -43,10 +43,10 @@ 
      * @param boolean $storeRef wether to store a reference for new instance. default: true 

      * @return 

      */

-    public function __construct($className, \ReflectionClass $reflectionClass = NULL, $storeRef = true){

-        if($reflectionClass ){

+    public function __construct($className, \ReflectionClass $reflectionClass = NULL, $storeRef = true) {

+        if ($reflectionClass) {

             

-            if($reflectionClass->getName() != $className){

+            if ($reflectionClass->getName() != $className) {

                 throw new \Exception(

                     'Constructing GenericBuilder with wrong ReflectionClass'

                 );

@@ -56,7 +56,7 @@ 
             $this->reflectionClass = $reflectionClass;

         }

         $this->className = $className;

-        if($storeRef){

+        if ($storeRef) {

             self::$instances[$this->className] = $this;

         }            

     }

@@ -68,8 +68,8 @@ 
      * @param string $className class-name to return builder instance for 

      * @return GenericBuilder builder instance for class

      */

-    public static function getInstance($className){

-        if(!array_key_exists((string)$className, self::$instances)) {

+    public static function getInstance($className) {

+        if (!array_key_exists((string)$className, self::$instances)) {

             new GenericBuilder($className);

         }

         return self::$instances[$className];

@@ -82,9 +82,9 @@ 
      * @param array $arguments array of constructore arguments

      * @return object the created object instance

      */

-    public function build(array $arguments = array()){      

-        if(Test::assertClassHasConstructor($this->className)){

-            if(!Test::assertRequiredConstructorParameters($this->className, $arguments)){

+    public function build(array $arguments = array()) {      

+        if (Test::assertClassHasConstructor($this->className)) {

+            if (!Test::assertRequiredConstructorParameters($this->className, $arguments)) {

                 throw new \Exception('Missing Argument '.(count($arguments) + 1).' for '.$this->className.'::__construct');

             }

             return $this->getReflectionClass()->newInstanceArgs($arguments);

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

      * @return ReflectionClass

      */

-    public function getReflectionClass(){

+    public function getReflectionClass() {

         return ReflectionPool::getInstance($this->className);

     }

     

src/INF/Base/Singleton.php

Spacing +1 added lines, -1 removed lines

@@ -22,6 +22,6 @@
 

 interface Singleton {

 

-    public static function getInstance ();

+    public static function getInstance();

 

 }

examples/Cafe/example.php

Spacing +2 added lines, -2 removed lines

@@ -44,7 +44,7 @@ 
  */

 

 

-if($cafe){

+if ($cafe) {

 

 	for ($i = 1; $i <= 10; $i++) {

        	// create and place orders

@@ -57,7 +57,7 @@ 
                 var_dump($drinks);

     	}	

 

-}else{

+}else {

 	throw new RuntimeException('Could not get CafeGateway');

 }