sportarchive / CloudProcessingEngine-SDK

src/SA/CpeSdk/CpeJsonValidator.php

Braces +6 added lines, -4 removed lines

@@ -18,12 +18,14 @@
         $validator    = new JsonSchema\Validator();
         $validator->check($json, $json_schemas);
 
-        if ($validator->isValid())
-            return false;
+        if ($validator->isValid()) {
+                    return false;
+        }
     
         $details = "";
-        foreach ($validator->getErrors() as $error)
-            $details .= sprintf("[%s] %s\n", $error['property'], $error['message']);
+        foreach ($validator->getErrors() as $error) {
+                    $details .= sprintf("[%s] %s\n", $error['property'], $error['message']);
+        }
     
         return $details;
     }

src/SA/CpeSdk/Sqs/CpeSqsListener.php

Braces +11 added lines, -8 removed lines

@@ -31,10 +31,11 @@ 
         $this->sqs = $aws->get('Sqs');
 
         // Logger
-        if (!$cpeLogger)
-            $this->cpeLogger = new CpeSdk\CpeLogger();
-        else
-            $this->cpeLogger = $cpeLogger;
+        if (!$cpeLogger) {
+                    $this->cpeLogger = new CpeSdk\CpeLogger();
+        } else {
+                    $this->cpeLogger = $cpeLogger;
+        }
     }
     
     /**
@@ -45,12 +46,13 @@ 
     // Poll one message at a time from the provided SQS queue
     public function receive_message($queue, $timeout)
     {
-        if ($this->debug)
-            $this->cpeLogger->log_out(
+        if ($this->debug) {
+                    $this->cpeLogger->log_out(
                 "DEBUG", 
                 basename(__FILE__),
                 "Polling from '$queue' ..."
             );
+        }
             
         // Poll from SQS to check for new message 
         $result = $this->sqs->receiveMessage(array(
@@ -62,12 +64,13 @@ 
         if (($messages = $result->get('Messages')) &&
             count($messages))
         {
-            if ($this->debug)
-                $this->cpeLogger->log_out(
+            if ($this->debug) {
+                            $this->cpeLogger->log_out(
                     "DEBUG", 
                     basename(__FILE__),
                     "New messages recieved in queue: '$queue'"
                 );
+            }
             
             return $messages[0];
         }

src/SA/CpeSdk/Sqs/CpeSqsWriter.php

Braces +9 added lines, -6 removed lines

@@ -175,9 +175,10 @@ 
         $sendInput = null, 
         $result = null)
     {
-        if (!($input = json_decode($activityTask->get('input'))))
-            throw new CpeException("Task input JSON is invalid!\n".$activityTask->get('input'),
+        if (!($input = json_decode($activityTask->get('input')))) {
+                    throw new CpeException("Task input JSON is invalid!\n".$activityTask->get('input'),
                 INVALID_JSON);
+        }
         
         $activity = [
             'activityId'   => $activityTask->get('activityId'),
@@ -185,12 +186,14 @@ 
         ];
         
         // Want to send back the input data ?
-        if ($sendInput)
-            $activity['input'] = $input;
+        if ($sendInput) {
+                    $activity['input'] = $input;
+        }
         
         // Extra data? Concat to data array.
-        if ($result)
-            $activity['result'] = $result;
+        if ($result) {
+                    $activity['result'] = $result;
+        }
         
         // Initial data structure
         $data = array(

src/SA/CpeSdk/Swf/CpeSwfHandler.php

Braces +3 added lines, -2 removed lines

@@ -18,8 +18,9 @@
     public function __construct()
     {
         # Check if preper env vars are setup
-        if (!($region = getenv("AWS_DEFAULT_REGION")))
-            throw new CpeSdk\CpeException("Set 'AWS_DEFAULT_REGION' environment variable!");
+        if (!($region = getenv("AWS_DEFAULT_REGION"))) {
+                    throw new CpeSdk\CpeException("Set 'AWS_DEFAULT_REGION' environment variable!");
+        }
 
         // SWF client
         $this->swf = SwfClient::factory(array(

src/SA/CpeSdk/CpeLogger.php

Braces +27 added lines, -18 removed lines

@@ -28,15 +28,18 @@ 
         $this->printout = $printout;
         $this->logPath = "/var/tmp/logs/cpe/";
                 
-        if ($logPath)
-            $this->logPath = $logPath;
+        if ($logPath) {
+                    $this->logPath = $logPath;
+        }
 
-        if (!file_exists($this->logPath))
-            mkdir($this->logPath, 0755, true);
+        if (!file_exists($this->logPath)) {
+                    mkdir($this->logPath, 0755, true);
+        }
 
         $file = basename($argv[0]);
-        if ($suffix)
-            $file .= "-".$suffix;
+        if ($suffix) {
+                    $file .= "-".$suffix;
+        }
         // Append progname to the path
         $this->logPath .= "/".$file.".log";
 
@@ -60,13 +63,15 @@ 
             "message" => $message
         ];
     
-        if ($workflowId)
-            $log["workflowId"] = $workflowId;
+        if ($workflowId) {
+                    $log["workflowId"] = $workflowId;
+        }
 
         // Open Syslog. Use programe name as key
-        if (!openlog (__FILE__, LOG_CONS|LOG_PID, LOG_LOCAL1))
-            throw new CpeException("Unable to connect to Syslog!",
+        if (!openlog (__FILE__, LOG_CONS|LOG_PID, LOG_LOCAL1)) {
+                    throw new CpeException("Unable to connect to Syslog!",
                 OPENLOG_ERROR);
+        }
         
         // Change Syslog priority level
         switch ($type)
@@ -103,22 +108,26 @@ 
     // Write log in file
     private function print_to_file($log, $workflowId)
     {
-        if (!is_string($log['message']))
-            $log['message'] = json_encode($log['message']);
+        if (!is_string($log['message'])) {
+                    $log['message'] = json_encode($log['message']);
+        }
         
         $toPrint = $log['time'] . " [" . $log['type'] . "] [" . $log['source'] . "] ";
         // If there is a workflow ID. We append it.
-        if ($workflowId)
-            $toPrint .= "[$workflowId] ";
+        if ($workflowId) {
+                    $toPrint .= "[$workflowId] ";
+        }
         $toPrint .= $log['message'] . "\n";
 
-        if ($this->printout)
-            print $toPrint;
+        if ($this->printout) {
+                    print $toPrint;
+        }
         
         if (file_put_contents(
                 $this->logPath,
                 $toPrint,
-                FILE_APPEND) === false)
-            print "ERROR: Can't write into log file!\n";
+                FILE_APPEND) === false) {
+                    print "ERROR: Can't write into log file!\n";
+        }
     }
 }
\ No newline at end of file

src/SA/CpeSdk/CpeActivity.php

Braces +21 added lines, -15 removed lines

@@ -47,21 +47,24 @@ 
         $this->params        = $params;
 
         // Check if there is an activity name
-        if (!isset($params["name"]) || !$params["name"])
-            throw new CpeSdk\CpeException("Can't instantiate BasicActivity: 'name' is not provided or empty !\n", 
+        if (!isset($params["name"]) || !$params["name"]) {
+                    throw new CpeSdk\CpeException("Can't instantiate BasicActivity: 'name' is not provided or empty !\n", 
 			    self::NO_ACTIVITY_NAME);
+        }
         
-        if (!$cpeLogger)
-            $this->cpeLogger = new CpeSdk\CpeLogger(null, $params["name"], $debug); 
-        else
-            $this->cpeLogger = $cpeLogger;
+        if (!$cpeLogger) {
+                    $this->cpeLogger = new CpeSdk\CpeLogger(null, $params["name"], $debug);
+        } else {
+                    $this->cpeLogger = $cpeLogger;
+        }
         
         // Create logger object. Use activity name for logger
 
         // Check if there is a version name
-        if (!isset($params["version"]) || !$params["version"])
-            throw new CpeSdk\CpeException("Can't instantiate BasicActivity: 'version' is not provided or empty !\n", 
+        if (!isset($params["version"]) || !$params["version"]) {
+                    throw new CpeSdk\CpeException("Can't instantiate BasicActivity: 'version' is not provided or empty !\n", 
 			    self::NO_ACTIVITY_VERSION);
+        }
 
         // Initialize the activity in SWF if necessary
         $this->init_activity();
@@ -104,14 +107,16 @@ 
      */
     public function do_task_check($task)
     {
-        if (!$task)
-            throw new CpeSdk\CpeException("Activity Task empty !", 
-			    self::ACTIVITY_TASK_EMPTY); 
+        if (!$task) {
+                    throw new CpeSdk\CpeException("Activity Task empty !", 
+			    self::ACTIVITY_TASK_EMPTY);
+        }
         
         if (!isset($task["input"]) || !$task["input"] ||
-            $task["input"] == "")
-            throw new CpeSdk\CpeException("No input provided to 'Activity'", 
+            $task["input"] == "") {
+                    throw new CpeSdk\CpeException("No input provided to 'Activity'", 
 			    self::NO_INPUT);
+        }
         
         // Save input string
         $this->input_str      = $task["input"];
@@ -133,9 +138,10 @@ 
     public function do_input_validation()
     {
         // Check JSON input
-        if (!($this->input = json_decode($this->input_str)))
-            throw new CpeSdk\CpeException("JSON input is invalid !", 
+        if (!($this->input = json_decode($this->input_str))) {
+                    throw new CpeSdk\CpeException("JSON input is invalid !", 
 			    self::INPUT_INVALID);
+        }
     }
     
     /**