sportarchive / CloudTranscode

src/activities/TranscodeAssetActivity.php

Indentation +9 added lines, -9 removed lines

@@ -79,7 +79,7 @@ 
                 break;
             default:
                 throw new CpeSdk\CpeException("Unknown input asset 'type'! Abording ...",
-                                              self::UNKOWN_INPUT_TYPE);
+                                                self::UNKOWN_INPUT_TYPE);
             }
 
             // Upload resulting file
@@ -178,7 +178,7 @@ 
         // Open '$outputFilesPath' to read it and send all files to S3 bucket
         if (!$handle = opendir($this->outputFilesPath)) {
             throw new CpeSdk\CpeException("Can't open tmp path '$this->outputFilesPath'!",
-                                          self::TMP_PATH_OPEN_FAIL);
+                                            self::TMP_PATH_OPEN_FAIL);
         }
 
         // Upload all resulting files sitting in $outputFilesPath to S3
@@ -205,15 +205,15 @@ 
             unlink("$this->outputFilesPath/$entry");
 
             $this->cpeLogger->logOut("INFO", basename(__FILE__),
-                                     $s3Output['msg'],
-                                     $this->logKey);
+                                        $s3Output['msg'],
+                                        $this->logKey);
         }
     }
 
     private function getOutputPath($output)
     {
         $outputFilesPath = self::TMP_FOLDER
-                         . $this->name."/".$this->logKey;
+                            . $this->name."/".$this->logKey;
 
         $output->{'key'} = $output->{'path'}."/".$output->{'file'};
 
@@ -226,8 +226,8 @@ 
         {
             if ($this->debug)
                 $this->cpeLogger->logOut("INFO", basename(__FILE__),
-                                         "Creating TMP output folder '".$outputFilesPath."'",
-                                         $this->logKey);
+                                            "Creating TMP output folder '".$outputFilesPath."'",
+                                            $this->logKey);
 
             if (!mkdir($outputFilesPath, 0750, true))
                 throw new CpeSdk\CpeException(
@@ -266,7 +266,7 @@ 
             ))
         {
             throw new CpeSdk\CpeException("Can't convert that input asset 'type' (".$this->input->{'input_asset'}->{'type'}.") into this output asset 'type' (".$output->{'type'}.")! Abording.",
-                                          self::CONVERSION_TYPE_ERROR);
+                                            self::CONVERSION_TYPE_ERROR);
         }
     }
 }
@@ -350,7 +350,7 @@ 
 
 $cpeLogger = new SA\CpeSdk\CpeLogger($name, $logPath);
 $cpeLogger->logOut("INFO", basename(__FILE__),
-                   "\033[1mStarting activity\033[0m: $name");
+                    "\033[1mStarting activity\033[0m: $name");
 
 // We instanciate the Activity 'ValidateAsset' and give it a name for Snf
 $activityPoller = new TranscodeAssetActivity(

src/activities/transcoders/VideoTranscoder.php

Indentation +20 added lines, -20 removed lines

@@ -208,9 +208,9 @@ 
         // Process options for watermark
         if (isset($outputWanted->{'watermark'}) && $outputWanted->{'watermark'}) {
             $watermarkOptions =
-                              $this->get_watermark_options(
-                                  $tmpInputPath,
-                                  $outputWanted->{'watermark'});
+                                $this->get_watermark_options(
+                                    $tmpInputPath,
+                                    $outputWanted->{'watermark'});
             // Replace ${watermark_options} by watermark options
             $ffmpegCmd = preg_replace('/\$\{watermark_options\}/', $watermarkOptions, $ffmpegCmd);
         }
@@ -263,16 +263,16 @@ 
         $formattedOptions = "";
         if (isset($outputWanted->{'preset_values'}->{'video_codec_options'})) {
             $formattedOptions =
-                              $this->set_output_video_codec_options($outputWanted->{'preset_values'}->{'video_codec_options'});
+                                $this->set_output_video_codec_options($outputWanted->{'preset_values'}->{'video_codec_options'});
         }
 
         $watermarkOptions = "";
         // Process options for watermark
         if (isset($outputWanted->{'watermark'}) && $outputWanted->{'watermark'}) {
             $watermarkOptions =
-                              $this->get_watermark_options(
-                                  $tmpInputPath,
-                                  $outputWanted->{'watermark'});
+                                $this->get_watermark_options(
+                                    $tmpInputPath,
+                                    $outputWanted->{'watermark'});
         }
 
         // Create FFMpeg arguments
@@ -329,7 +329,7 @@ 
             }
 
             $outputFilesPath .= "/" . $outputFileInfo['filename'] . "%06d."
-                             . $outputFileInfo['extension'];
+                                . $outputFileInfo['extension'];
             $frameOptions = " -vf fps=fps=1/$intervals";
         }
 
@@ -361,9 +361,9 @@ 
             $watermarkPath);
 
         $this->cpeLogger->logOut("INFO",
-                                 basename(__FILE__),
-                                 $s3Output['msg'],
-                                 $this->logKey);
+                                    basename(__FILE__),
+                                    $s3Output['msg'],
+                                    $this->logKey);
 
         // Transform watermark for opacity
         $convertCmd = "convert $watermarkPath -alpha on -channel A -evaluate Multiply " . $watermarkOptions->{'opacity'} . " +channel $newWatermarkPath";
@@ -550,12 +550,12 @@ 
     {
         if (!$output_wanted) {
             throw new CpeSdk\CpeException("No output data provided to transcoder !",
-                                          self::NO_OUTPUT);
+                                            self::NO_OUTPUT);
         }
 
         if (!isset($output_wanted->{"preset"})) {
             throw new CpeSdk\CpeException("No preset selected for output !",
-                                          self::BAD_PRESETS_DIR);
+                                            self::BAD_PRESETS_DIR);
         }
 
         $preset     = $output_wanted->{"preset"};
@@ -563,12 +563,12 @@ 
 
         if (!($presetContent = file_get_contents($presetPath.$preset.".json"))) {
             throw new CpeSdk\CpeException("Can't open preset file !",
-                                          self::OPEN_PRESET_FAILED);
+                                            self::OPEN_PRESET_FAILED);
         }
 
         if (!($decodedPreset = json_decode($presetContent))) {
             throw new CpeSdk\CpeException("Bad preset JSON format !",
-                                          self::BAD_PRESET_FORMAT);
+                                            self::BAD_PRESET_FORMAT);
         }
 
         return ($decodedPreset);
@@ -579,7 +579,7 @@ 
     {
         if (!isset($output->{"preset"})) {
             throw new CpeSdk\CpeException("No preset selected for output !",
-                                          self::BAD_PRESETS_DIR);
+                                            self::BAD_PRESETS_DIR);
         }
 
         $preset     = $output->{"preset"};
@@ -587,7 +587,7 @@ 
 
         if (!($files = scandir($presetPath))) {
             throw new CpeSdk\CpeException("Unable to open preset directory '$presetPath' !",
-                                          self::BAD_PRESETS_DIR);
+                                            self::BAD_PRESETS_DIR);
         }
 
         foreach ($files as $presetFile)
@@ -600,12 +600,12 @@ 
                 {
                     if (!($presetContent = file_get_contents("$presetPath/$presetFile"))) {
                         throw new CpeSdk\CpeException("Can't open preset file '$presetPath/$presetFile'!",
-                                                      self::OPEN_PRESET_FAILED);
+                                                        self::OPEN_PRESET_FAILED);
                     }
 
                     if (!($decodedPreset = json_decode($presetContent))) {
                         throw new CpeSdk\CpeException("Bad preset JSON format '$presetPath/$presetFile'!",
-                                                      self::BAD_PRESET_FORMAT);
+                                                        self::BAD_PRESET_FORMAT);
                     }
 
                     return true;
@@ -614,7 +614,7 @@ 
         }
 
         throw new CpeSdk\CpeException("Unkown preset file '$preset' !",
-                                      self::UNKNOWN_PRESET);
+                                        self::UNKNOWN_PRESET);
     }
 
     // Extract Metadata from ffprobe

src/activities/ValidateAssetActivity.php

Indentation +1 added lines, -1 removed lines

@@ -237,7 +237,7 @@
 
 $cpeLogger = new SA\CpeSdk\CpeLogger($name, $logPath);
 $cpeLogger->logOut("INFO", basename(__FILE__),
-                   "\033[1mStarting activity\033[0m: $name");
+                    "\033[1mStarting activity\033[0m: $name");
 
 // We instanciate the Activity 'ValidateAsset' and give it a name for Snf
 $activityPoller = new ValidateAssetActivity(

src/activities/BasicActivity.php

Indentation +9 added lines, -9 removed lines

@@ -78,8 +78,8 @@ 
         {
             if ($this->debug)
                 $this->cpeLogger->logOut("DEBUG", basename(__FILE__), 
-                                         "Creating TMP input folder '".$this->tmpInputPath."'",
-                                         $this->logKey);
+                                            "Creating TMP input folder '".$this->tmpInputPath."'",
+                                            $this->logKey);
             
             if (!mkdir($this->tmpInputPath, 0750, true))
                 throw new CpeSdk\CpeException(
@@ -117,9 +117,9 @@ 
     {        
         // Get file from S3 or local copy if any
         $this->cpeLogger->logOut("INFO", 
-                                 basename(__FILE__), 
-                                 "Downloading '$inputBuket/$inputFile' to '$saveFileTo' ...",
-                                 $this->logKey);
+                                    basename(__FILE__), 
+                                    "Downloading '$inputBuket/$inputFile' to '$saveFileTo' ...",
+                                    $this->logKey);
         
         // Use the S3 utils to initiate the download
         $s3Output = $this->s3Utils->get_file_from_s3(
@@ -132,12 +132,12 @@ 
         );
         
         $this->cpeLogger->logOut("INFO", basename(__FILE__), 
-                                 $s3Output['msg'],
-                                 $this->logKey);
+                                    $s3Output['msg'],
+                                    $this->logKey);
         
         $this->cpeLogger->logOut("INFO", basename(__FILE__), 
-                                 "Input file successfully downloaded into local TMP folder '$saveFileTo' !",
-                                 $this->logKey);
+                                    "Input file successfully downloaded into local TMP folder '$saveFileTo' !",
+                                    $this->logKey);
         
         return $saveFileTo;
     }

src/scripts/getFromS3.php

Indentation +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
     filesize($options['to']))
 {
     $out = [ "status" => "SUCCESS",
-             "msg" => "[".__FILE__."] Using local copy: '" . $options['to']  . "'" ];
+                "msg" => "[".__FILE__."] Using local copy: '" . $options['to']  . "'" ];
     print json_encode($out)."\n";
     exit(0);
 }
@@ -60,6 +60,6 @@ 
 ));
 
 $out = [ "status" => "SUCCESS",
-         "msg" => "[".__FILE__."] Download '" . $options['bucket'] . "/" . $options['file'] . "' successful !" ];
+            "msg" => "[".__FILE__."] Download '" . $options['bucket'] . "/" . $options['file'] . "' successful !" ];
 
 print json_encode($out)."\n";

src/utils/CommandExecuter.php

Indentation +11 added lines, -11 removed lines

@@ -44,10 +44,10 @@ 
         if (!($process = proc_open($cmd, $descriptors, $pipes)) ||
             !is_resource($process)) {
             $this->cpeLogger->logOut("ERROR",
-                                     basename(__FILE__), "Unable to execute command:\n$cmd",
-                                     $this->logKey);
+                                        basename(__FILE__), "Unable to execute command:\n$cmd",
+                                        $this->logKey);
             throw new CpeSdk\CpeException("Unable to execute command:\n$cmd\n",
-                                          self::EXEC_FAILED);
+                                            self::EXEC_FAILED);
         }
 
         // Set the pipes as non-blocking
@@ -83,7 +83,7 @@ 
                 // Type 3: Object method call
                 if (isset($progressCallback) && $progressCallback) {
                     call_user_func($progressCallback, $progressCallbackParams,
-                                   $allOut, $allOutErr);
+                                    $allOut, $allOutErr);
                 }
 
                 $i = 0;
@@ -119,17 +119,17 @@ 
         if ($procStatus['exitcode'] > 0)
         {
             $this->cpeLogger->logOut("ERROR",
-                                     basename(__FILE__),
-                                     "Can't execute: $cmd. Exit Code: ".$procStatus['exitcode'],
-                                     $this->logKey);
+                                        basename(__FILE__),
+                                        "Can't execute: $cmd. Exit Code: ".$procStatus['exitcode'],
+                                        $this->logKey);
             if ($allOut)
                 $this->cpeLogger->logOut("ERROR",
-                                         basename(__FILE__), "COMMAND STDOUT: ".$allOut,
-                                         $this->logKey);
+                                            basename(__FILE__), "COMMAND STDOUT: ".$allOut,
+                                            $this->logKey);
             if ($allOutErr)
                 $this->cpeLogger->logOut("ERROR",
-                                         basename(__FILE__), "COMMAND STDERR: ".$allOutErr,
-                                         $this->logKey);
+                                            basename(__FILE__), "COMMAND STDERR: ".$allOutErr,
+                                            $this->logKey);
         }
 
         if ($showProgress) {

src/utils/S3Utils.php

Indentation +2 added lines, -2 removed lines

@@ -3,7 +3,7 @@ 
  * This class allows you to call the two S3 scripts
  * to download and upload files.
  * The scripts are executed using the CommandExecuter
-  */
+ */
 
 require_once __DIR__ . '/CommandExecuter.php';
 
@@ -89,7 +89,7 @@ 
             $cmd,
             1,
             array(1 => array("pipe", "w"),
-                  2 => array("pipe", "w")),
+                    2 => array("pipe", "w")),
             $callback,
             $callbackParams, 
             true,