sportarchive / CloudProcessingEngine

client_example/ClientPoller.php

Spacing +3 added lines, -3 removed lines

@@ -9,7 +9,7 @@ 
  * Using the CpeClientSdk you can easily listen to the SQS
  */
 
-require __DIR__ . "/vendor/autoload.php";
+require __DIR__."/vendor/autoload.php";
 
 function poll_SQS_queues($CpeClientSdk, $decodedClient)
 {
@@ -24,7 +24,7 @@ 
             }
         }
     } catch (Exception $e) {
-        print("[ERROR] " . $e->getMessage() . "\n");
+        print("[ERROR] ".$e->getMessage()."\n");
     }
                     
     // Message polled. We delete it from SQS
@@ -53,7 +53,7 @@ 
 
 function usage()
 {
-    echo("Usage: php " . basename(__FILE__) . " -c configFile [-h] [-k <key>] [-s <secret>] [-r <region>]\n");
+    echo("Usage: php ".basename(__FILE__)." -c configFile [-h] [-k <key>] [-s <secret>] [-r <region>]\n");
     echo("-h: Print this help\n");
     echo("-d: Debug mode\n");
     echo("-c: configFile\n");

client_example/ClientCommander.php

Spacing +4 added lines, -4 removed lines

@@ -11,7 +11,7 @@ 
  * Such as: Start a new workflow
  **/
 
-require __DIR__ . "/vendor/autoload.php";
+require __DIR__."/vendor/autoload.php";
 
 function start_job($args)
 {
@@ -42,7 +42,7 @@ 
         $CpeClientSdk->start_job($decodedClient, $content);
     }
     catch (Exception $e) {
-        print("[ERROR] " . $e->getMessage() . "\n");
+        print("[ERROR] ".$e->getMessage()."\n");
     }
 }
 
@@ -111,7 +111,7 @@ 
     {
         global $help;
     
-        echo("Usage: php ". basename(__FILE__) . " -c configFile [-h] [-k <key>] [-s <secret>] [-r <region>]\n");
+        echo("Usage: php ".basename(__FILE__)." -c configFile [-h] [-k <key>] [-s <secret>] [-r <region>]\n");
         echo("-h: Print this help\n");
         echo("-d: Debug mode\n");
         echo("-c: configFile\n");
@@ -127,7 +127,7 @@ 
     check_input_parameters();
 } 
 catch (Exception $e) {
-    print "[ERROR] " . $e->getMessage() . "\n";
+    print "[ERROR] ".$e->getMessage()."\n";
     exit(2);
 }
 

pollers/src/InputPoller.php

Spacing +12 added lines, -12 removed lines

@@ -34,7 +34,7 @@ 
  * It opens the JSON input and starts a execute a callback corresponding to the command
  */
 
-require_once __DIR__ . "/../vendor/autoload.php";
+require_once __DIR__."/../vendor/autoload.php";
 
 use Aws\Swf\Exception;
 use SA\CpeSdk;
@@ -95,7 +95,7 @@ 
         foreach ($this->config->{'clients'} as $client)
         {
             $msg = null;
-            $this->cpeLogger->log_out("DEBUG", __DIR__, "Polling from client: " . print_r($client, true));
+            $this->cpeLogger->log_out("DEBUG", __DIR__, "Polling from client: ".print_r($client, true));
             
             // Long Polling messages from client input queue
             $queue = $client->{'queues'}->{'input'};
@@ -139,7 +139,7 @@ 
             $this->cpeLogger->log_out(
                 "ERROR", 
                 basename(__FILE__), 
-                "Command '" . $message->{"type"} . "' is unknown! Ignoring ..."
+                "Command '".$message->{"type"}."' is unknown! Ignoring ..."
             );
             return;
         }
@@ -147,13 +147,13 @@ 
         $this->cpeLogger->log_out(
             "INFO", 
             basename(__FILE__), 
-            "Received message '" . $message->{"type"}  . "'"
+            "Received message '".$message->{"type"}."'"
         );
         if ($this->debug)
             $this->cpeLogger->log_out(
                 "DEBUG", 
                 basename(__FILE__), 
-                "Details:\n" . json_encode($message, JSON_PRETTY_PRINT)
+                "Details:\n".json_encode($message, JSON_PRETTY_PRINT)
             );
 
         // We call the callback function that handles this message  
@@ -226,10 +226,10 @@ 
     private function validate_message($message)
     {
         if (!isset($message) || 
-            !isset($message->{"time"})   || $message->{"time"} == "" || 
-            !isset($message->{"jobId"})  || $message->{"jobId"} == "" || 
-            !isset($message->{"type"})   || $message->{"type"} == "" || 
-            !isset($message->{"data"})   || $message->{"data"} == "")
+            !isset($message->{"time"}) || $message->{"time"} == "" || 
+            !isset($message->{"jobId"}) || $message->{"jobId"} == "" || 
+            !isset($message->{"type"}) || $message->{"type"} == "" || 
+            !isset($message->{"data"}) || $message->{"data"} == "")
             throw new CpeSdk\CpeException("'time', 'type', 'jobId' or 'data' fields missing in JSON message file!",
                 self::INVALID_JSON);
         
@@ -250,7 +250,7 @@ 
 function usage($defaultConfigFile)
 {
     echo("# Description\nThe InputPoller connects your client applications to your stack. It handles communication over the two SQS channels you created for your client application.\n\n");
-    echo("Usage: php ". basename(__FILE__) . " [-h] [-d] -n <client_name> [-l <log path>]\n");
+    echo("Usage: php ".basename(__FILE__)." [-h] [-d] -n <client_name> [-l <log path>]\n");
     echo("-h: Print this help\n");
     echo("-d: Debug mode\n");
     echo("-l <log_path>: Location where logs will be dumped in (folder).\n");
@@ -287,9 +287,9 @@ 
     $cpeLogger = new CpeSdk\CpeLogger($logPath, $options['n'], $debug);
         
     $config = new \stdClass;
-    $config->clients = [(object)[
+    $config->clients = [(object) [
             'name' => $options['n'],
-            'queues' => (object)[
+            'queues' => (object) [
                 'input' => getenv('INPUT_QUEUE'),
                 'output' => getenv('OUTPUT_QUEUE'),
             ],

pollers/src/ActivityPoller.php

Spacing +12 added lines, -12 removed lines

@@ -36,7 +36,7 @@ 
  * It will process tasks only coming in the TaskList
  */
 
-require_once __DIR__ . "/../vendor/autoload.php";
+require_once __DIR__."/../vendor/autoload.php";
 
 use Aws\Swf\Exception;
 use SA\CpeSdk;
@@ -100,7 +100,7 @@ 
         // Poll from all the taskList registered for each activities 
         if ($this->debug)
             $this->cpeLogger->log_out("DEBUG", basename(__FILE__),
-                "Polling activity taskList '" . $this->taskList  . "' ... ");
+                "Polling activity taskList '".$this->taskList."' ... ");
             
         try {
             // Call SWF and poll for incoming tasks
@@ -113,7 +113,7 @@ 
             $this->process_activity_task($activityTask);
         } catch (CpeSdk\CpeException $e) {
             $this->cpeLogger->log_out("ERROR", basename(__FILE__),
-                "Unable to poll activity tasks! " . $e->getMessage());
+                "Unable to poll activity tasks! ".$e->getMessage());
         }
         
         return true;
@@ -130,7 +130,7 @@ 
         $this->cpeLogger->log_out("INFO",
             basename(__FILE__),
             "Starting activity: name=" 
-            . $activityType['name'] . ",version=" . $activityType['version'],
+            . $activityType['name'].",version=".$activityType['version'],
             $workflowExecution['workflowId']);
 
         // Has activity handler object been instantiated ?
@@ -154,14 +154,14 @@ 
 
             if ($this->debug)
                 $this->cpeLogger->log_out("DEBUG", basename(__FILE__), 
-                    "Activity input:\n" . print_r($this->activityHandler->input, true));
+                    "Activity input:\n".print_r($this->activityHandler->input, true));
         
             // Run activity task
             $result = $this->activityHandler->do_activity($activityTask);
 
             if ($this->debug && $result)
                 $this->cpeLogger->log_out("DEBUG", basename(__FILE__), 
-                    "Activity output:\n" . print_r($result, true));
+                    "Activity output:\n".print_r($result, true));
         
         } catch (CpeSdk\CpeException $e) {
             $reason  = $e->ref;
@@ -202,7 +202,7 @@ 
                 {
                     $this->cpeLogger->log_out("ERROR", basename(__FILE__),
                         "The code file '".$activityToHandle->{"file"}."' for activity: name=" 
-                        . $activityToHandle->{"name"} . ",version=" 
+                        . $activityToHandle->{"name"}.",version=" 
                         . $activityToHandle->{"version"}." doesn't exists! Check if the file is accessible and if the path is correct in your config file.");
                     return false;
                 }
@@ -232,7 +232,7 @@ 
                 
                 $this->cpeLogger->log_out("INFO", basename(__FILE__),
                     "Activity handler registered: name=" 
-                    . $activityToHandle->{"name"} . ",version=" 
+                    . $activityToHandle->{"name"}.",version=" 
                     . $activityToHandle->{"version"});
 
                 return true;
@@ -241,7 +241,7 @@ 
         
         $this->cpeLogger->log_out("ERROR", basename(__FILE__),
             "No Activity handler was found for: name=" 
-            . $this->activityName . ",version=" 
+            . $this->activityName.",version=" 
             . $this->activityVersion.". Check your config file and ensure your 'activity' name AND 'version' is there.");    
         return false;
     }
@@ -262,7 +262,7 @@ 
 // Usage
 function usage($defaultConfigFile)
 {
-    echo("Usage: php ". basename(__FILE__) . " -D <domain> -A <activity_name> -V <activity_version> [-T <task_list>] [-h] [-d] [-c <config_file path>] [-l <log path>]\n");
+    echo("Usage: php ".basename(__FILE__)." -D <domain> -A <activity_name> -V <activity_version> [-T <task_list>] [-h] [-d] [-c <config_file path>] [-l <log path>]\n");
     echo("-h: Print this help\n");
     echo("-d: Debug mode\n");
     echo("-c <config_file path>: Optional parameter to override the default configuration file: '$defaultConfigFile'.\n");
@@ -342,7 +342,7 @@ 
         $cpeLogger->log_out(
             "INFO",
             basename(__FILE__),
-            "Config file: '" . $options['c'] . "'");
+            "Config file: '".$options['c']."'");
         $defaultConfigFile = $options['c'];
     }
 
@@ -368,7 +368,7 @@ 
 
 // Get config file
 $defaultConfigFile =
-    realpath(dirname(__FILE__)) . "/../config/cpeConfig.json";
+    realpath(dirname(__FILE__))."/../config/cpeConfig.json";
 $config = check_input_parameters($defaultConfigFile);
 
 // Instantiate ActivityPoller