sportarchive / CloudProcessingEngine

client_example/ClientCommander.php

Spacing +1 added lines, -1 removed lines

@@ -109,7 +109,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");

pollers/src/InputPoller.php

Spacing +11 added lines, -11 removed lines

@@ -107,12 +107,12 @@ 
                 $this->cpeLogger->log_out(
                     "ERROR", 
                     basename(__FILE__), 
-                    $e->getMessage().print_r($msg, true));
+                    $e->getMessage() . print_r($msg, true));
             } catch (\Exception $e) {
                 $this->cpeLogger->log_out(
                     "ERROR", 
                     basename(__FILE__), 
-                    $e->getMessage().print_r($msg, true));
+                    $e->getMessage() . print_r($msg, true));
             }
             
             // Message polled. Valid or not, we delete it from SQS
@@ -140,7 +140,7 @@ 
         $this->cpeLogger->log_out(
             "INFO", 
             basename(__FILE__), 
-            "Received message '" . $message->{"type"}  . "'"
+            "Received message '" . $message->{"type"} . "'"
         );
         if ($this->debug)
             $this->cpeLogger->log_out(
@@ -189,7 +189,7 @@ 
             $this->cpeLogger->log_out(
                 "INFO",
                 basename(__FILE__),
-                "New workflow submitted to SWF: ".$workflowRunId->get('runId'));
+                "New workflow submitted to SWF: " . $workflowRunId->get('runId'));
 
             // Send WORKFLOW_SCHEDULED message back to client
             $this->cpeSqsWriter->workflow_scheduled($workflowType, $workflowRunId->get('runId'), $workflowId, $message);
@@ -215,10 +215,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);
         
@@ -238,7 +238,7 @@ 
 
 function usage($defaultConfigFile)
 {
-    echo("Usage: php ". basename(__FILE__) . " [-h] [-d] [-n <client_name>] [-l <log path>] -c <config_file path>\n");
+    echo("Usage: php " . basename(__FILE__) . " [-h] [-d] [-n <client_name>] [-l <log path>] -c <config_file 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");
@@ -289,9 +289,9 @@ 
 
     if (isset($options['n']))
     {
-        $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 +5 added lines, -5 removed lines

@@ -90,7 +90,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
@@ -191,9 +191,9 @@ 
                 if (!file_exists($activityToHandle->{"file"}))
                 {
                     $this->cpeLogger->log_out("ERROR", basename(__FILE__),
-                        "The code file '".$activityToHandle->{"file"}."' for activity: name=" 
+                        "The code file '" . $activityToHandle->{"file"} . "' for activity: name=" 
                         . $activityToHandle->{"name"} . ",version=" 
-                        . $activityToHandle->{"version"}." doesn't exists! Check if the file is accessible and if the path is correct in your config file.");
+                        . $activityToHandle->{"version"} . " doesn't exists! Check if the file is accessible and if the path is correct in your config file.");
                     return false;
                 }
                 
@@ -227,7 +227,7 @@ 
         $this->cpeLogger->log_out("ERROR", basename(__FILE__),
             "No Activity handler was found for: name=" 
             . $this->activityName . ",version=" 
-            . $this->activityVersion.". Check your config file and ensure your 'activity' name AND 'version' is there.");    
+            . $this->activityVersion . ". Check your config file and ensure your 'activity' name AND 'version' is there.");    
         return false;
     }
 }
@@ -245,7 +245,7 @@ 
 // Usage
 function usage($defaultConfigFile)
 {
-    echo("Usage: php ". basename(__FILE__) . " -D <domain> -T <task_list> -A <activity_name> -V <activity_version> [-h] [-d] [-c <config_file path>] [-l <log path>]\n");
+    echo("Usage: php " . basename(__FILE__) . " -D <domain> -T <task_list> -A <activity_name> -V <activity_version> [-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");