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/ActivityPoller.php

Spacing +6 added lines, -6 removed lines

@@ -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
@@ -201,9 +201,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;
                 }
                 
@@ -242,7 +242,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;
     }
 }
@@ -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");
@@ -331,7 +331,7 @@ 
     // Tasklist
     if (!isset($options['T']))
     {
-        $taskList = $options['A'].'-'.$options['V'];
+        $taskList = $options['A'] . '-' . $options['V'];
     } else {
         $taskList = $options['T'];
     }

pollers/src/InputPoller.php

Spacing +11 added lines, -11 removed lines

@@ -114,12 +114,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
@@ -147,7 +147,7 @@ 
         $this->cpeLogger->log_out(
             "INFO", 
             basename(__FILE__), 
-            "Received message '" . $message->{"type"}  . "'"
+            "Received message '" . $message->{"type"} . "'"
         );
         if ($this->debug)
             $this->cpeLogger->log_out(
@@ -196,7 +196,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);
@@ -222,10 +222,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);
         
@@ -246,7 +246,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");
@@ -283,9 +283,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'),
             ],