tidal / PEIP

examples/Cafe/lib/messaging/DrinkRouter.php

Spacing +2 added lines, -2 removed lines

@@ -6,9 +6,9 @@
 class DrinkRouter 

 	extends Router {

 	

-	protected function selectChannels(Message $message){

+	protected function selectChannels(Message $message) {

 		$order = $message->getContent();

-		$channelName = $order['iced']  ? 'coldDrinks' : 'hotDrinks';

+		$channelName = $order['iced'] ? 'coldDrinks' : 'hotDrinks';

 		echo PEIP_LINE_SEPARATOR."DrinkRouter: routed to channel: $channelName";

 		return $channelName;

 	}	

src/Data/Store.php

Spacing +7 added lines, -7 removed lines

@@ -34,7 +34,7 @@ 
      * @param mixed $value the value to store
      * @return 
      */
-    public function setValue($key, $value){
+    public function setValue($key, $value) {
         return $this->offsetSet($key, $value);
     }
     
@@ -45,7 +45,7 @@ 
      * @param mixed $key the key to return value for 
      * @return mixed the value for the given key
      */
-    public function getValue($key){
+    public function getValue($key) {
         return $this->offsetGet($key, $value);
     }
   
@@ -56,7 +56,7 @@ 
      * @param mixed $key the key to unset value for 
      * @return 
      */
-    public function deleteValue($key){
+    public function deleteValue($key) {
         return $this->offsetUnset($key);
     }
       
@@ -67,7 +67,7 @@ 
      * @param mixed $key the key to look for a value
      * @return boolean wether a value is stored for the key
      */
-    public function hasValue($key){
+    public function hasValue($key) {
         return $this->offsetExists($key);
     }   
 
@@ -78,7 +78,7 @@ 
      * @param array $values key/value pairs to store
      * @return 
      */
-    public function setValues(array $values){
+    public function setValues(array $values) {
         $this->values = $values;        
     }
 
@@ -88,7 +88,7 @@ 
      * @access public
      * @return array stored key/value pairs
      */
-    public function getValues(){
+    public function getValues() {
         return $this->values;
     }
    
@@ -100,7 +100,7 @@ 
      * @param $values 
      * @return 
      */
-    public function addValues(array $values){
+    public function addValues(array $values) {
         array_merge($this->values, $values);
     }   
 }
\ No newline at end of file

src/ABS/Pipe/EventPipe.php

Spacing +5 added lines, -5 removed lines

@@ -38,8 +38,8 @@ 
      * @param string $eventName name of the event to listen to 
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to listen to 
      */
-    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable){
-        if(!$connectable->hasListener($eventName, $this)){
+    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable) {
+        if (!$connectable->hasListener($eventName, $this)) {
             $connectable->connect($eventName, $this);
             $this->connections[spl_object_hash($connectable)] = $connectable;   
         }   
@@ -52,8 +52,8 @@ 
      * @param string $eventName name of the event to unlisten 
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to unlisten to 
      */
-    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable){
-        if(!$connectable->hasListener($eventName, $this)){
+    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable) {
+        if (!$connectable->hasListener($eventName, $this)) {
             $connectable->disconnect($eventName, $this);
             unset($this->connections[spl_object_hash($connectable)]);   
         }   
@@ -65,7 +65,7 @@ 
      * @access public
      * @return array array of \PEIP\INF\Event\Connectable instances
      */
-    public function doGetConnected(){
+    public function doGetConnected() {
         return array_values($this->connections);
     }
     

src/ABS/Splitter/MessageSplitter.php

Spacing +6 added lines, -6 removed lines

@@ -35,9 +35,9 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the outputs-channel 
      * @return 
      */
-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){
+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {
         $this->setInputChannel($inputChannel);
-        if(is_object($outputChannel)){
+        if (is_object($outputChannel)) {
             $this->setOutputChannel($outputChannel);    
         }   
     }           
@@ -49,13 +49,13 @@ 
      * @param \PEIP\INF\Message\Message $message message to split 
      * @return 
      */
-    public function doReply(\PEIP\INF\Message\Message $message){     
+    public function doReply(\PEIP\INF\Message\Message $message) {     
         $res = $this->split($message);      
-        if(is_array($res)){
-            foreach($res as $msg){ 
+        if (is_array($res)) {
+            foreach ($res as $msg) { 
                 $this->replyMessage($msg);
             }
-        }else{
+        }else {
             $this->replyMessage($res);
         }
     }

src/Pipe/SimpleEventPipe.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
      * @param $outputChannel 
      * @return 
      */
-    public function __construct($eventName, \PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel){
+    public function __construct($eventName, \PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel) {
         $this->setEventName($eventName);
         $this->setInputChannel($inputChannel);
         $this->setOutputChannel($outputChannel);        

src/Selector/ContentTypeSelector.php

Spacing +2 added lines, -2 removed lines

@@ -47,7 +47,7 @@ 
      * @param $type 
      * @return 
      */
-    public function __construct($type){
+    public function __construct($type) {
         $this->type = $type;
     }       
             
@@ -57,7 +57,7 @@ 
      * @param $message 
      * @return 
      */
-    public function acceptMessage(\PEIP\INF\Message\Message $message){
+    public function acceptMessage(\PEIP\INF\Message\Message $message) {
         return call_user_func(self::$types[$this->type], $message->getContent());
     }           
     

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/Util/Reflection.php

Spacing +3 added lines, -3 removed lines

@@ -30,9 +30,9 @@ 
      * @return array array with interface/class info for the class
      */
 
-    public static function getImplementedClassesAndInterfaces($class, $store = true){
+    public static function getImplementedClassesAndInterfaces($class, $store = true) {
         $class = is_object($class) ? get_class($class) : (string)$class;
-        if(isset(self::$classInfo[$class])){
+        if (isset(self::$classInfo[$class])) {
             return self::$classInfo[$class];
         }
         $cls = ReflectionPool::getInstance($class);
@@ -40,7 +40,7 @@ 
         $classInfo = (array)$cls->getInterfaceNames();
         $classInfo[] = $cls->getName();
         // get names of parent-classes
-        while($cls = $cls->getParentClass()){
+        while ($cls = $cls->getParentClass()) {
             $classInfo[] = $cls->getName();
         }
         

src/Plugins/BasePlugin.php

Spacing +19 added lines, -19 removed lines

@@ -42,7 +42,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, '\PEIP\Channel\PollableChannel');
     }
 
@@ -54,7 +54,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, '\PEIP\Channel\PublishSubscribeChannel');
     }
 
@@ -67,9 +67,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);
@@ -87,7 +87,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)
@@ -111,7 +111,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,
@@ -128,7 +128,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);
     }
 
@@ -141,7 +141,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);
     }
 
@@ -154,7 +154,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);
     }
 
@@ -167,7 +167,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, '\PEIP\Listener\Wiretap');
     }
 
@@ -180,7 +180,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);
     }
 
@@ -193,12 +193,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->context->getServiceProvider()->provideService((string)$config['ref']);
-        if($method && $service){
+        if ($method && $service) {
             $args = $this->getReplyHandlerArguments($config);
-            array_unshift($args,array(
+            array_unshift($args, array(
                 $service,
                 $method
             ));
@@ -215,12 +215,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;
@@ -235,7 +235,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);
     }
 
@@ -248,7 +248,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);
     }
 
@@ -261,7 +261,7 @@ 
      * @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 = isset($config[$type."_channel"])
             ? $config[$type."_channel"]
             : $config["default_".$type."_channel"];