sportarchive / CloudProcessingEngine-SDK

src/SA/CpeSdk/CpeActivity.php

Spacing +16 added lines, -16 removed lines

@@ -11,20 +11,20 @@ 
 
 class CpeActivity
 {
-    public $params;          // Activity params coming from ActivityPoller
-    public $debug;           // Debug flag
+    public $params; // Activity params coming from ActivityPoller
+    public $debug; // Debug flag
     
-    public $activityId;      // ID of the activity
-    public $activityType;    // Type of activity
+    public $activityId; // ID of the activity
+    public $activityType; // Type of activity
     
-    public $cpeLogger;       // Logger
-    public $cpeSqsWriter;    // Used to write messages in SQS
-    public $cpeSwfHandler;   // USed to control SWF
-    public $cpeJsonValidator;// Run JSON schemas validation
+    public $cpeLogger; // Logger
+    public $cpeSqsWriter; // Used to write messages in SQS
+    public $cpeSwfHandler; // USed to control SWF
+    public $cpeJsonValidator; // Run JSON schemas validation
     
-    public $input_str;       // Complete activity input string
-    public $input;           // Complete activity input JSON object
-    public $activityLogKey;  // Create a key workflowId:activityId to put in logs
+    public $input_str; // Complete activity input string
+    public $input; // Complete activity input JSON object
+    public $activityLogKey; // Create a key workflowId:activityId to put in logs
     
     const HEARTBEAT_FAILED     = "HEARTBEAT_FAILED";
     const NO_ACTIVITY_NAME     = "NO_ACTIVITY_NAME";
@@ -44,7 +44,7 @@ 
         // For listening to the Input SQS queue 
         $this->cpeJsonValidator = new CpeSdk\CpeJsonValidator();     
         // Save activity params
-        $this->params        = $params;
+        $this->params = $params;
 
         // Check if there is an activity name
         if (!isset($params["name"]) || !$params["name"])
@@ -90,7 +90,7 @@ 
             return true;
         } catch (\Aws\Swf\Exception\UnknownResourceException $e) {
             $this->cpeLogger->log_out("ERROR", basename(__FILE__), 
-                "Activity '" . $this->params["name"] . "' doesn't exists. Creating it ...\n");
+                "Activity '".$this->params["name"]."' doesn't exists. Creating it ...\n");
         }
         
         // Register activites if doesn't exists in SWF
@@ -170,7 +170,7 @@ 
                 ));
         } catch (\Exception $e) {
             $this->cpeLogger->log_out("ERROR", basename(__FILE__), 
-                "Unable to send 'Task Failed' response ! " . $e->getMessage(),
+                "Unable to send 'Task Failed' response ! ".$e->getMessage(),
                 $this->activityLogKey);
             return false;
         }
@@ -195,7 +195,7 @@ 
                 ));
         } catch (\Exception $e) {
             $this->cpeLogger->log_out("ERROR", basename(__FILE__), 
-                "Unable to send 'Task Completed' response ! " . $e->getMessage(),
+                "Unable to send 'Task Completed' response ! ".$e->getMessage(),
                 $this->activityLogKey);
             return false;
         }
@@ -223,7 +223,7 @@ 
             if ($info->get("cancelRequested") == true)
             {
                 $this->cpeLogger->log_out("WARNING", basename(__FILE__), 
-                    "Cancel has been requested for this task '" . $task->get("activityId") . "' ! Killing task ...",
+                    "Cancel has been requested for this task '".$task->get("activityId")."' ! Killing task ...",
                     $this->activityLogKey);
                 throw new CpeSdk\CpeException("Cancel request. No heartbeat, leaving!",
                     self::HEARTBEAT_FAILED);

src/SA/CpeSdk/CpeException.php

Spacing +1 added lines, -1 removed lines

@@ -16,6 +16,6 @@
     
     // custom string representation of object
     public function __toString() {
-        return __CLASS__ . ": [{$this->ref}]: {$this->message}\n";
+        return __CLASS__.": [{$this->ref}]: {$this->message}\n";
     }
 }

src/SA/CpeSdk/CpeJsonValidator.php

Spacing +2 added lines, -2 removed lines

@@ -10,10 +10,10 @@
         $schemas_path)
     {
         $retriever    = new JsonSchema\Uri\UriRetriever;
-        $json_schemas = $retriever->retrieve('file://' . $schemas_path . "/$schemas_name");
+        $json_schemas = $retriever->retrieve('file://'.$schemas_path."/$schemas_name");
 
         $refResolver  = new JsonSchema\RefResolver($retriever);
-        $refResolver->resolve($json_schemas, 'file://' . $schemas_path . "/");
+        $refResolver->resolve($json_schemas, 'file://'.$schemas_path."/");
 
         $validator    = new JsonSchema\Validator();
         $validator->check($json, $json_schemas);

src/SA/CpeSdk/CpeLogger.php

Spacing +3 added lines, -3 removed lines

@@ -54,7 +54,7 @@ 
             $log["workflowId"] = $workflowId;
 
         // Open Syslog. Use programe name as key
-        if (!openlog (__FILE__, LOG_CONS|LOG_PID, LOG_LOCAL1))
+        if (!openlog(__FILE__, LOG_CONS|LOG_PID, LOG_LOCAL1))
             throw new CpeException("Unable to connect to Syslog!",
                 OPENLOG_ERROR);
         
@@ -96,11 +96,11 @@ 
         if (!is_string($log['message']))
             $log['message'] = json_encode($log['message']);
         
-        $toPrint = $log['time'] . " [" . $log['type'] . "] [" . $log['source'] . "] ";
+        $toPrint = $log['time']." [".$log['type']."] [".$log['source']."] ";
         // If there is a workflow ID. We append it.
         if ($workflowId)
             $toPrint .= "[$workflowId] ";
-        $toPrint .= $log['message'] . "\n";
+        $toPrint .= $log['message']."\n";
             
         if (file_put_contents(
                 $this->logPath,