@@ -73,7 +73,7 @@ discard block |
||
| 73 | 73 | substr($sha, 0, 8), |
| 74 | 74 | $branch->LastUpdated()->TimeDiff() |
| 75 | 75 | ); |
| 76 | - $branches[$sha . '-' . $name] = $branchValue; |
|
| 76 | + $branches[$sha.'-'.$name] = $branchValue; |
|
| 77 | 77 | } |
| 78 | 78 | |
| 79 | 79 | // Tags |
@@ -86,7 +86,7 @@ discard block |
||
| 86 | 86 | substr($sha, 0, 8), |
| 87 | 87 | $branch->LastUpdated()->TimeDiff() |
| 88 | 88 | ); |
| 89 | - $tags[$sha . '-' . $tag] = $tagValue; |
|
| 89 | + $tags[$sha.'-'.$tag] = $tagValue; |
|
| 90 | 90 | } |
| 91 | 91 | $tags = array_reverse($tags); |
| 92 | 92 | |
@@ -58,17 +58,17 @@ |
||
| 58 | 58 | |
| 59 | 59 | protected function addHandlers($machine) { |
| 60 | 60 | $class = get_class($machine->getObject()); |
| 61 | - if (empty($this->config()->handlers[$class])) return; |
|
| 61 | + if(empty($this->config()->handlers[$class])) return; |
|
| 62 | 62 | |
| 63 | 63 | $transitions = $this->config()->handlers[$class]; |
| 64 | - foreach ($transitions as $transName => $handlers) { |
|
| 65 | - if (!is_array($handlers)) { |
|
| 64 | + foreach($transitions as $transName => $handlers) { |
|
| 65 | + if(!is_array($handlers)) { |
|
| 66 | 66 | throw new Exception(sprintf('Transition %s must be configured as an assoc array.', $transName)); |
| 67 | 67 | } |
| 68 | 68 | |
| 69 | - foreach ($handlers as $handlerClass => $handlerMethod) { |
|
| 69 | + foreach($handlers as $handlerClass => $handlerMethod) { |
|
| 70 | 70 | $handlerObj = Injector::inst()->get($handlerClass); |
| 71 | - if (!is_callable([$handlerObj, $handlerMethod])) { |
|
| 71 | + if(!is_callable([$handlerObj, $handlerMethod])) { |
|
| 72 | 72 | throw new Exception(sprintf('Handler %s is not callable on %s.', $handlerMethod, $handlerClass)); |
| 73 | 73 | } |
| 74 | 74 | $machine->getDispatcher()->addListener( |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | protected function sendEmailToApprover(DNDeployment $deployment) { |
| 13 | 13 | $deployer = $deployment->Deployer(); |
| 14 | 14 | $approver = $deployment->Approver(); |
| 15 | - if (!$approver || !$approver->exists()) { |
|
| 15 | + if(!$approver || !$approver->exists()) { |
|
| 16 | 16 | return false; |
| 17 | 17 | } |
| 18 | 18 | |
@@ -4,28 +4,28 @@ |
||
| 4 | 4 | |
| 5 | 5 | public function run($request) { |
| 6 | 6 | $log = function($message) { |
| 7 | - $message = sprintf('[%s] ', date('Y-m-d H:i:s')) . $message; |
|
| 8 | - echo $message . PHP_EOL; |
|
| 7 | + $message = sprintf('[%s] ', date('Y-m-d H:i:s')).$message; |
|
| 8 | + echo $message.PHP_EOL; |
|
| 9 | 9 | }; |
| 10 | 10 | |
| 11 | - if (!Director::is_cli()) { |
|
| 11 | + if(!Director::is_cli()) { |
|
| 12 | 12 | $log('This command can only run via CLI'); |
| 13 | 13 | return; |
| 14 | 14 | } |
| 15 | 15 | |
| 16 | 16 | $columns = DB::query('SHOW COLUMNS FROM "DNDeployment"')->column(); |
| 17 | - if (!in_array('Status', $columns)) { |
|
| 17 | + if(!in_array('Status', $columns)) { |
|
| 18 | 18 | $log('Migration has already been run'); |
| 19 | 19 | return; |
| 20 | 20 | } |
| 21 | 21 | |
| 22 | - foreach (DB::query('SELECT "ID", "Status" FROM "DNDeployment"') as $record) { |
|
| 22 | + foreach(DB::query('SELECT "ID", "Status" FROM "DNDeployment"') as $record) { |
|
| 23 | 23 | // This record looks to be already migrated |
| 24 | - if (empty($record['Status'])) { |
|
| 24 | + if(empty($record['Status'])) { |
|
| 25 | 25 | continue; |
| 26 | 26 | } |
| 27 | 27 | |
| 28 | - switch ($record['Status']) { |
|
| 28 | + switch($record['Status']) { |
|
| 29 | 29 | case 'Queued': |
| 30 | 30 | DB::query(sprintf('UPDATE "DNDeployment" SET "State" = \'Queued\' WHERE "ID" = %s', $record['ID'])); |
| 31 | 31 | break; |
@@ -30,7 +30,7 @@ discard block |
||
| 30 | 30 | * Generate the package |
| 31 | 31 | */ |
| 32 | 32 | public function generatePackage($sha, $baseDir, $outputFilename, DeploynautLogFile $log) { |
| 33 | - $tempPath = TEMP_FOLDER . "/" . str_replace(".tar.gz", "", basename($outputFilename)); |
|
| 33 | + $tempPath = TEMP_FOLDER."/".str_replace(".tar.gz", "", basename($outputFilename)); |
|
| 34 | 34 | if(!file_exists($tempPath)) { |
| 35 | 35 | mkdir($tempPath); |
| 36 | 36 | } |
@@ -42,17 +42,17 @@ discard block |
||
| 42 | 42 | // Execute these in sequence until there's a failure |
| 43 | 43 | $processes = array( |
| 44 | 44 | // Export the relevant SHA into a temp folder |
| 45 | - new AbortableProcess("git archive $sha | tar -x -C " . $escapedTempPath, $baseDir), |
|
| 45 | + new AbortableProcess("git archive $sha | tar -x -C ".$escapedTempPath, $baseDir), |
|
| 46 | 46 | // Run build script |
| 47 | 47 | new AbortableProcess($this->buildScript, $tempPath, null, null, 3600), |
| 48 | 48 | // Compress the result |
| 49 | - new AbortableProcess("tar -czf " . $escapedOutputFile . " " . $escapedTempDir, dirname($tempPath)), |
|
| 49 | + new AbortableProcess("tar -czf ".$escapedOutputFile." ".$escapedTempDir, dirname($tempPath)), |
|
| 50 | 50 | ); |
| 51 | 51 | |
| 52 | 52 | // Call at the end, regardless of success or failure |
| 53 | 53 | $cleanup = array( |
| 54 | 54 | // Delete the temporary staging folder |
| 55 | - new AbortableProcess("rm -rf " . $escapedTempPath), |
|
| 55 | + new AbortableProcess("rm -rf ".$escapedTempPath), |
|
| 56 | 56 | ); |
| 57 | 57 | |
| 58 | 58 | try { |
@@ -20,7 +20,7 @@ |
||
| 20 | 20 | sleep(1); |
| 21 | 21 | } |
| 22 | 22 | |
| 23 | - if ($this->hasBeenSignaled()) { |
|
| 23 | + if($this->hasBeenSignaled()) { |
|
| 24 | 24 | throw new RuntimeException(sprintf('The process has been signaled with signal "%s".', $this->getTermSignal)); |
| 25 | 25 | } |
| 26 | 26 | |
@@ -112,7 +112,7 @@ discard block |
||
| 112 | 112 | } |
| 113 | 113 | |
| 114 | 114 | public function getTitle() { |
| 115 | - return $this->dbObject('Created')->Nice() . " (Status: {$this->Status})"; |
|
| 115 | + return $this->dbObject('Created')->Nice()." (Status: {$this->Status})"; |
|
| 116 | 116 | } |
| 117 | 117 | |
| 118 | 118 | public function Link() { |
@@ -233,14 +233,14 @@ discard block |
||
| 233 | 233 | $envName = $this->Environment()->getFullName(); |
| 234 | 234 | if($this->Direction == 'get') { |
| 235 | 235 | if($this->Origin == 'ManualUpload') { |
| 236 | - $description = 'Manual upload of ' . $this->getModeNice() . ' to ' . $envName; |
|
| 236 | + $description = 'Manual upload of '.$this->getModeNice().' to '.$envName; |
|
| 237 | 237 | } elseif($this->IsBackupDataTransfer()) { |
| 238 | - $description = 'Automated backup of ' . $this->getModeNice() . ' from ' . $envName; |
|
| 238 | + $description = 'Automated backup of '.$this->getModeNice().' from '.$envName; |
|
| 239 | 239 | } else { |
| 240 | - $description = 'Backup of ' . $this->getModeNice() . ' to ' . $envName; |
|
| 240 | + $description = 'Backup of '.$this->getModeNice().' to '.$envName; |
|
| 241 | 241 | } |
| 242 | 242 | } else { |
| 243 | - $description = 'Restore ' . $this->getModeNice() . ' to ' . $envName; |
|
| 243 | + $description = 'Restore '.$this->getModeNice().' to '.$envName; |
|
| 244 | 244 | } |
| 245 | 245 | |
| 246 | 246 | return $description; |
@@ -263,7 +263,7 @@ discard block |
||
| 263 | 263 | 'SELECT COUNT("ID") FROM "DNDeployment" WHERE "BackupDataTransferID" = %d', |
| 264 | 264 | $this->ID |
| 265 | 265 | ))->value(); |
| 266 | - if ($deploymentBackup) { |
|
| 266 | + if($deploymentBackup) { |
|
| 267 | 267 | return true; |
| 268 | 268 | } |
| 269 | 269 | |
@@ -271,7 +271,7 @@ discard block |
||
| 271 | 271 | 'SELECT COUNT("ID") FROM "DNDataTransfer" WHERE "BackupDataTransferID" = %d', |
| 272 | 272 | $this->ID |
| 273 | 273 | ))->value(); |
| 274 | - if ($transferBackup) { |
|
| 274 | + if($transferBackup) { |
|
| 275 | 275 | return true; |
| 276 | 276 | } |
| 277 | 277 | |
@@ -20,7 +20,7 @@ discard block |
||
| 20 | 20 | } |
| 21 | 21 | |
| 22 | 22 | public function perform() { |
| 23 | - echo "[-] DataTransferJob starting" . PHP_EOL; |
|
| 23 | + echo "[-] DataTransferJob starting".PHP_EOL; |
|
| 24 | 24 | $log = new DeploynautLogFile($this->args['logfile']); |
| 25 | 25 | $dataTransfer = DNDataTransfer::get()->byID($this->args['dataTransferID']); |
| 26 | 26 | $environment = $dataTransfer->Environment(); |
@@ -64,16 +64,16 @@ discard block |
||
| 64 | 64 | $this->performBackup($backupDataTransfer, $log); |
| 65 | 65 | $environment->Backend()->dataTransfer($dataTransfer, $log); |
| 66 | 66 | } catch(Exception $e) { |
| 67 | - echo "[-] DataTransferJob failed" . PHP_EOL; |
|
| 67 | + echo "[-] DataTransferJob failed".PHP_EOL; |
|
| 68 | 68 | throw $e; |
| 69 | 69 | } |
| 70 | 70 | |
| 71 | 71 | $this->updateStatus('Finished'); |
| 72 | - echo "[-] DataTransferJob finished" . PHP_EOL; |
|
| 72 | + echo "[-] DataTransferJob finished".PHP_EOL; |
|
| 73 | 73 | } |
| 74 | 74 | |
| 75 | 75 | protected function performBackup($backupDataTransfer, DeploynautLogFile $log) { |
| 76 | - if (!$backupDataTransfer) { |
|
| 76 | + if(!$backupDataTransfer) { |
|
| 77 | 77 | return false; |
| 78 | 78 | } |
| 79 | 79 | |
@@ -17,9 +17,9 @@ discard block |
||
| 17 | 17 | */ |
| 18 | 18 | public function alarmHandler() { |
| 19 | 19 | $sigFile = $this->args['sigFile']; |
| 20 | - if (file_exists($sigFile) && is_readable($sigFile) && is_writable($sigFile)) { |
|
| 20 | + if(file_exists($sigFile) && is_readable($sigFile) && is_writable($sigFile)) { |
|
| 21 | 21 | $signal = (int)file_get_contents($sigFile); |
| 22 | - if (is_int($signal) && in_array((int)$signal, [ |
|
| 22 | + if(is_int($signal) && in_array((int)$signal, [ |
|
| 23 | 23 | // The following signals are trapped by both Resque and Rainforest. |
| 24 | 24 | SIGTERM, |
| 25 | 25 | SIGINT, |
@@ -30,7 +30,7 @@ discard block |
||
| 30 | 30 | SIGCONT |
| 31 | 31 | ])) { |
| 32 | 32 | echo sprintf( |
| 33 | - '[-] Signal "%s" received, delivering to own process group, PID "%s".' . PHP_EOL, |
|
| 33 | + '[-] Signal "%s" received, delivering to own process group, PID "%s".'.PHP_EOL, |
|
| 34 | 34 | $signal, |
| 35 | 35 | getmypid() |
| 36 | 36 | ); |
@@ -40,9 +40,9 @@ discard block |
||
| 40 | 40 | |
| 41 | 41 | // Dispatch to own process group. |
| 42 | 42 | $pgid = posix_getpgid(getmypid()); |
| 43 | - if ($pgid<=0) { |
|
| 43 | + if($pgid <= 0) { |
|
| 44 | 44 | echo sprintf( |
| 45 | - '[-] Unable to send signal to invalid PGID "%s".' . PHP_EOL, |
|
| 45 | + '[-] Unable to send signal to invalid PGID "%s".'.PHP_EOL, |
|
| 46 | 46 | $pgid |
| 47 | 47 | ); |
| 48 | 48 | } else { |
@@ -61,8 +61,8 @@ discard block |
||
| 61 | 61 | posix_setsid(); |
| 62 | 62 | |
| 63 | 63 | if(function_exists('pcntl_alarm') && function_exists('pcntl_signal')) { |
| 64 | - if (!empty($this->args['sigFile'])) { |
|
| 65 | - echo sprintf('[-] Signal file requested, polling "%s".' . PHP_EOL, $this->args['sigFile']); |
|
| 64 | + if(!empty($this->args['sigFile'])) { |
|
| 65 | + echo sprintf('[-] Signal file requested, polling "%s".'.PHP_EOL, $this->args['sigFile']); |
|
| 66 | 66 | declare(ticks = 1); |
| 67 | 67 | pcntl_signal(SIGALRM, [$this, 'alarmHandler']); |
| 68 | 68 | pcntl_alarm(1); |
@@ -74,7 +74,7 @@ discard block |
||
| 74 | 74 | } |
| 75 | 75 | |
| 76 | 76 | public function perform() { |
| 77 | - echo "[-] DeployJob starting" . PHP_EOL; |
|
| 77 | + echo "[-] DeployJob starting".PHP_EOL; |
|
| 78 | 78 | $log = new DeploynautLogFile($this->args['logfile']); |
| 79 | 79 | |
| 80 | 80 | $deployment = DNDeployment::get()->byID($this->args['deploymentID']); |
@@ -127,12 +127,12 @@ discard block |
||
| 127 | 127 | ); |
| 128 | 128 | } catch(Exception $e) { |
| 129 | 129 | // DeploynautJob will automatically trigger onFailure. |
| 130 | - echo "[-] DeployJob failed" . PHP_EOL; |
|
| 130 | + echo "[-] DeployJob failed".PHP_EOL; |
|
| 131 | 131 | throw $e; |
| 132 | 132 | } |
| 133 | 133 | |
| 134 | 134 | $this->updateStatus(DNDeployment::TR_COMPLETE); |
| 135 | - echo "[-] DeployJob finished" . PHP_EOL; |
|
| 135 | + echo "[-] DeployJob finished".PHP_EOL; |
|
| 136 | 136 | } |
| 137 | 137 | |
| 138 | 138 | public function onFailure(Exception $exception) { |
@@ -140,7 +140,7 @@ discard block |
||
| 140 | 140 | } |
| 141 | 141 | |
| 142 | 142 | protected function performBackup($backupDataTransfer, DeploynautLogFile $log) { |
| 143 | - if (!$backupDataTransfer) { |
|
| 143 | + if(!$backupDataTransfer) { |
|
| 144 | 144 | return false; |
| 145 | 145 | } |
| 146 | 146 | |