sportarchive / CloudProcessingEngine-SDK

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);
+        }
     }
     
     /**