sportarchive / CloudTranscode

src/activities/BasicActivity.php

Braces +10 added lines, -8 removed lines

@@ -79,22 +79,25 @@ 
         
         $inputFileInfo = null;
         // Create TMP storage to store input file to transcode
-        if (isset($this->input->{'input_asset'}->{'file'}))
-            $inputFileInfo = pathinfo($this->input->{'input_asset'}->{'file'});
+        if (isset($this->input->{'input_asset'}->{'file'})) {
+                    $inputFileInfo = pathinfo($this->input->{'input_asset'}->{'file'});
+        }
         
         // Create the tmp folder if doesn't exist
         if (!file_exists($this->tmpPathInput)) 
         {
-            if ($this->debug)
-                $this->cpeLogger->log_out("INFO", basename(__FILE__), 
+            if ($this->debug) {
+                            $this->cpeLogger->log_out("INFO", basename(__FILE__), 
                     "Creating TMP input folder '".$this->tmpPathInput."'",
                     $this->activityLogKey);
+            }
             
-            if (!mkdir($this->tmpPathInput, 0750, true))
-                throw new CpeSdk\CpeException(
+            if (!mkdir($this->tmpPathInput, 0750, true)) {
+                            throw new CpeSdk\CpeException(
                     "Unable to create temporary folder '$this->tmpPathInput' !",
                     self::TMP_FOLDER_FAIL
                 );
+            }
         }
             
         $this->pathToInputFile = null;
@@ -107,8 +110,7 @@ 
                     'Bucket' => $this->input->{'input_asset'}->{'bucket'},
                     'Key' => $this->input->{'input_asset'}->{'file'}
                 ])->createPresignedUrl('+1 day');
-        }
-        else if ($this->input->{'input_asset'}->{'http'})
+        } else if ($this->input->{'input_asset'}->{'http'})
         {
             // Pad HTTP input so it is cached in case of full encodes
             $this->pathToInputFile = 'cache:' . $this->input->{'input_asset'}->{'http'};

src/activities/TranscodeAssetActivity.php

Braces +6 added lines, -4 removed lines

@@ -167,16 +167,18 @@
         
         if (!file_exists($this->pathToOutputFiles)) 
         {
-            if ($this->debug)
-                $this->cpeLogger->log_out("INFO", basename(__FILE__), 
+            if ($this->debug) {
+                            $this->cpeLogger->log_out("INFO", basename(__FILE__), 
                     "Creating TMP output folder '".$this->pathToOutputFiles."'",
                     $this->activityLogKey);
+            }
 
-            if (!mkdir($this->pathToOutputFiles, 0750, true))
-                throw new CpeSdk\CpeException(
+            if (!mkdir($this->pathToOutputFiles, 0750, true)) {
+                            throw new CpeSdk\CpeException(
                     "Unable to create temporary folder '$this->pathToOutputFiles' !",
                     self::TMP_FOLDER_FAIL
                 );
+            }
         }
     }
     

src/activities/transcoders/BasicTranscoder.php

Braces +3 added lines, -1 removed lines

@@ -45,7 +45,9 @@
 
     public function is_dir_empty($dir)
     {
-        if (!is_readable($dir)) return null; 
+        if (!is_readable($dir)) {
+            return null;
+        }
         $handle = opendir($dir);
         while (false !== ($entry = readdir($handle))) {
             if ($entry !== '.' && $entry !== '..') { 

src/scripts/getFromS3.php

Braces +4 added lines, -4 removed lines

@@ -22,8 +22,9 @@ 
 function check_input_parameters($options)
 {
     if (!count($options) || isset($options['h']) ||
-        isset($options['help']))
-        usage();
+        isset($options['help'])) {
+            usage();
+    }
     
     if (!isset($options['bucket']) || !isset($options['file']) ||
         !isset($options['to']))
@@ -60,8 +61,7 @@ 
     // Print JSON error output
     print json_encode([ "status" => "SUCCESS",
             "msg" => "[".__FILE__."] Download '" . $options['bucket'] . "/" . $options['file'] . "' successful !" ]);
-} 
-catch (Exception $e) {
+} catch (Exception $e) {
     $err = "Unable to get '" . $options['bucket'] . "/" . $options['file'] . "' file from S3 ! " . $e->getMessage();
     // Print JSON error output
     print json_encode([ "status" => "ERROR",

src/scripts/putInS3.php

Braces +10 added lines, -8 removed lines

@@ -23,8 +23,9 @@ 
 function check_input_parameters(&$options)
 {
     if (!count($options) || isset($options['h']) ||
-        isset($options['help']))
-        usage();
+        isset($options['help'])) {
+            usage();
+    }
     
     if (!isset($options['bucket']) || !isset($options['file']) ||
         !isset($options['from']))
@@ -57,10 +58,12 @@ 
     );
 
     // StorageClass and Encryption ?
-    if (isset($options['rrs']))
-        $params['StorageClass'] = 'REDUCED_REDUNDANCY';
-    if (isset($options['encrypt']))
-        $params['ServerSideEncryption'] = 'AES256';
+    if (isset($options['rrs'])) {
+            $params['StorageClass'] = 'REDUCED_REDUNDANCY';
+    }
+    if (isset($options['encrypt'])) {
+            $params['ServerSideEncryption'] = 'AES256';
+    }
     
     // Upload and Save file to S3
     $s3->putObject($params); 
@@ -68,8 +71,7 @@ 
     // Print JSON error output
     print json_encode([ "status" => "SUCCESS",
             "msg" => "[".__FILE__."] Upload '" . $options['from'] . "' to '" . $options['bucket'] . "/" . $options['file']  . "' successful !" ]);
-} 
-catch (Exception $e) {
+} catch (Exception $e) {
     $err = "Unable to put file '" . $options['from']  . "' into S3: '" . $options['bucket'] . "/" . $options['file']  . "'! " . $e->getMessage();
     
     // Print JSON error output

src/utils/CommandExecuter.php

Braces +9 added lines, -6 removed lines

@@ -17,8 +17,9 @@ 
     
     public function __construct($cpeLogger = null)
     {
-        if (!$cpeLogger)
-            $this->cpeLogger = new CpeSdk\CpeLogger(null, 'CommandExecuter');
+        if (!$cpeLogger) {
+                    $this->cpeLogger = new CpeSdk\CpeLogger(null, 'CommandExecuter');
+        }
         $this->cpeLogger = $cpeLogger;
     }
     
@@ -112,10 +113,12 @@ 
         if ($procStatus['exitcode'] > 0)
         {
             $this->cpeLogger->log_out("ERROR", basename(__FILE__), "Can't execute: $cmd. Exit Code: ".$procStatus['exitcode']);
-            if ($allOut)
-                $this->cpeLogger->log_out("ERROR", basename(__FILE__), "COMMAND STDOUT: ".$allOut);
-            if ($allOutErr)
-                $this->cpeLogger->log_out("ERROR", basename(__FILE__), "COMMAND STDERR: ".$allOutErr);
+            if ($allOut) {
+                            $this->cpeLogger->log_out("ERROR", basename(__FILE__), "COMMAND STDOUT: ".$allOut);
+            }
+            if ($allOutErr) {
+                            $this->cpeLogger->log_out("ERROR", basename(__FILE__), "COMMAND STDERR: ".$allOutErr);
+            }
         }
         
         if ($showProgress) {

src/utils/S3Utils.php

Braces +21 added lines, -14 removed lines

@@ -22,8 +22,9 @@ 
     
     public function __construct($cpeLogger = null)
     {
-        if (!$cpeLogger)
-            $this->cpeLogger = new CpeSdk\CpeLogger(null, 'S3Utils');
+        if (!$cpeLogger) {
+                    $this->cpeLogger = new CpeSdk\CpeLogger(null, 'S3Utils');
+        }
         $this->cpeLogger = $cpeLogger;
     }
 
@@ -61,10 +62,12 @@ 
         $cmd .= " --bucket $bucket";
         $cmd .= " --file $filename";
         $cmd .= " --from $pathToFileToSend";
-        if ($options['rrs'])
-            $cmd .= " --rrs";
-        if ($options['encrypt'])
-            $cmd .= " --encrypt";
+        if ($options['rrs']) {
+                    $cmd .= " --rrs";
+        }
+        if ($options['encrypt']) {
+                    $cmd .= " --encrypt";
+        }
     
         // HAndle execution
         return ($this->handle_s3_ops(
@@ -91,21 +94,25 @@ 
             true,
             5);
         
-        if ($out['outErr'])
-            throw new CpeSdk\CpeException($out['outErr'],
+        if ($out['outErr']) {
+                    throw new CpeSdk\CpeException($out['outErr'],
                 self::S3_OPS_FAILED);
+        }
 
-        if (!$out['out'])
-            throw new CpeSdk\CpeException("Script '$caller' didn't return any data !",
+        if (!$out['out']) {
+                    throw new CpeSdk\CpeException("Script '$caller' didn't return any data !",
                 self::NO_OUTPUT_DATA);
+        }
     
-        if (!($decoded = json_decode($out['out'], true)))
-            throw new CpeSdk\CpeException($out['out'],
+        if (!($decoded = json_decode($out['out'], true))) {
+                    throw new CpeSdk\CpeException($out['out'],
                 self::S3_OPS_FAILED);
+        }
     
-        if ($decoded["status"] == "ERROR")
-            throw new CpeSdk\CpeException($decoded["msg"],
+        if ($decoded["status"] == "ERROR") {
+                    throw new CpeSdk\CpeException($decoded["msg"],
                 self::S3_OPS_FAILED);
+        }
 
         return ($decoded);
     }

src/activities/transcoders/VideoTranscoder.php

Braces +11 added lines, -14 removed lines

@@ -49,11 +49,12 @@ 
         $metadata = null, 
         $outputWanted)
     {
-        if (!$metadata)
-            throw new CpeSdk\CpeException(
+        if (!$metadata) {
+                    throw new CpeSdk\CpeException(
                 "NO Input Video metadata! We can't transcode an asset without probing it first. Use ValidateAsset activity to probe it and pass a 'metadata' field containing the input metadata to this TranscodeAsset activity.",
                 self::TRANSCODE_FAIL
             );
+        }
         // Extract an sanitize metadata
         $metadata = $this->_extractFileInfo($metadata);
 
@@ -101,13 +102,14 @@ 
             $this->activityLogKey
         );
         
-        if ($metadata)
-            $this->cpeLogger->log_out(
+        if ($metadata) {
+                    $this->cpeLogger->log_out(
                 "INFO", 
                 basename(__FILE__), 
                 "Input Video metadata: " . print_r($metadata, true),
                 $this->activityLogKey
             );
+        }
         
         try {
             // Use executer to start FFMpeg command
@@ -137,8 +139,7 @@ 
             // FFProbe the output file and return its information
             $output_info =
                 $this->get_asset_info($pathToOutputFiles."/".$outputWanted->{'output_file_info'}['basename']);
-        }
-        catch (\Exception $e) {
+        } catch (\Exception $e) {
             $this->cpeLogger->log_out(
                 "ERROR", 
                 basename(__FILE__), 
@@ -288,8 +289,7 @@ 
             $time = gmdate("H:i:s", $snapshot_sec) . ".000";
             $pathToOutputFiles .= "/" . $outputFileInfo['basename'];
             $frameOptions = " -ss $time -vframes 1";
-        }
-        else if ($outputWanted->{'mode'} == 'intervals')
+        } else if ($outputWanted->{'mode'} == 'intervals')
         {
             $intervals = self::INTERVALS_DEFAULT;
             if (isset($outputWanted->{'intervals'}) &&
@@ -342,8 +342,7 @@ 
                 array(1 => array("pipe", "w"), 2 => array("pipe", "w")),
                 false, false, 
                 false, 1);
-        }
-        catch (\Exception $e) {
+        } catch (\Exception $e) {
             $this->cpeLogger->log_out(
                 "ERROR", 
                 basename(__FILE__), 
@@ -601,8 +600,7 @@ 
         foreach ($metadata->streams as $key => $value) {
             if ($value->codec_type === 'video') {
                 $videoStreams = $value;
-            }
-            else if ($value->codec_type === 'audio') {
+            } else if ($value->codec_type === 'audio') {
                 $audioStreams = $value;
             }
         }
@@ -653,8 +651,7 @@ 
                 false, false, 
                 false, 1
             );
-        }
-        catch (\Exception $e) {
+        } catch (\Exception $e) {
             $this->cpeLogger->log_out(
                 "ERROR", 
                 basename(__FILE__),