@@ -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 { |
@@ -132,7 +132,7 @@ discard block |
||
132 | 132 | } |
133 | 133 | |
134 | 134 | /** |
135 | - * @param $project |
|
135 | + * @param DNProject $project |
|
136 | 136 | * |
137 | 137 | * @return array |
138 | 138 | */ |
@@ -148,7 +148,7 @@ discard block |
||
148 | 148 | } |
149 | 149 | |
150 | 150 | /** |
151 | - * @param $project |
|
151 | + * @param DNProject $project |
|
152 | 152 | * |
153 | 153 | * @return array |
154 | 154 | */ |
@@ -164,7 +164,7 @@ discard block |
||
164 | 164 | } |
165 | 165 | |
166 | 166 | /** |
167 | - * @param $project |
|
167 | + * @param DNProject $project |
|
168 | 168 | * |
169 | 169 | * @return array |
170 | 170 | */ |
@@ -168,9 +168,9 @@ |
||
168 | 168 | $fetch->write(); |
169 | 169 | $fetch->start(); |
170 | 170 | |
171 | - $location = Director::absoluteBaseURL() . $this->Link() . '/gitupdate/' . $fetch->ID; |
|
171 | + $location = Director::absoluteBaseURL().$this->Link().'/gitupdate/'.$fetch->ID; |
|
172 | 172 | $output = array( |
173 | - 'message' => 'Fetch queued as job ' . $fetch->ResqueToken, |
|
173 | + 'message' => 'Fetch queued as job '.$fetch->ResqueToken, |
|
174 | 174 | 'href' => $location, |
175 | 175 | ); |
176 | 176 |
@@ -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 |
@@ -71,7 +71,7 @@ discard block |
||
71 | 71 | |
72 | 72 | try { |
73 | 73 | $args['build_filename'] = $this->packageGenerator->getPackageFilename($project->Name, $sha, $repository, $log); |
74 | - } catch (Exception $e) { |
|
74 | + } catch(Exception $e) { |
|
75 | 75 | $log->write($e->getMessage()); |
76 | 76 | throw $e; |
77 | 77 | } |
@@ -110,7 +110,7 @@ discard block |
||
110 | 110 | $this->extend('deployFailure', $environment, $sha, $log, $project); |
111 | 111 | |
112 | 112 | $currentBuild = $environment->CurrentBuild(); |
113 | - if (empty($currentBuild) || (!empty($options['no_rollback']) && $options['no_rollback'] !== 'false')) { |
|
113 | + if(empty($currentBuild) || (!empty($options['no_rollback']) && $options['no_rollback'] !== 'false')) { |
|
114 | 114 | throw new RuntimeException($command->getErrorOutput()); |
115 | 115 | } |
116 | 116 | |
@@ -126,7 +126,7 @@ discard block |
||
126 | 126 | // as deploying removes .htaccess |
127 | 127 | $this->enableMaintenance($environment, $log, $project); |
128 | 128 | |
129 | - if (!$command->isSuccessful() || !$this->smokeTest($environment, $log)) { |
|
129 | + if(!$command->isSuccessful() || !$this->smokeTest($environment, $log)) { |
|
130 | 130 | $this->extend('deployRollbackFailure', $environment, $currentBuild->SHA, $log, $project); |
131 | 131 | $log->write('Rollback failed'); |
132 | 132 | throw new RuntimeException($command->getErrorOutput()); |
@@ -142,7 +142,7 @@ discard block |
||
142 | 142 | |
143 | 143 | // Rolling back means the rollback succeeded, but ultimately the deployment |
144 | 144 | // has failed. Throw an exception so the job is marked as failed accordingly. |
145 | - if ($rolledBack === true) { |
|
145 | + if($rolledBack === true) { |
|
146 | 146 | throw new RuntimeException('Rollback successful'); |
147 | 147 | } |
148 | 148 | |
@@ -213,7 +213,7 @@ discard block |
||
213 | 213 | } else { |
214 | 214 | $environment = $dataTransfer->Environment(); |
215 | 215 | $project = $environment->Project(); |
216 | - $workingDir = TEMP_FOLDER . DIRECTORY_SEPARATOR . 'deploynaut-transfer-' . $dataTransfer->ID; |
|
216 | + $workingDir = TEMP_FOLDER.DIRECTORY_SEPARATOR.'deploynaut-transfer-'.$dataTransfer->ID; |
|
217 | 217 | $archive = $dataTransfer->DataArchive(); |
218 | 218 | |
219 | 219 | // extract the sspak contents, we'll need these so capistrano can restore that content |
@@ -259,7 +259,7 @@ discard block |
||
259 | 259 | if(!$args) { |
260 | 260 | $args = array(); |
261 | 261 | } |
262 | - $args['history_path'] = realpath(DEPLOYNAUT_LOG_PATH . '/'); |
|
262 | + $args['history_path'] = realpath(DEPLOYNAUT_LOG_PATH.'/'); |
|
263 | 263 | $args['environment_id'] = $environment->ID; |
264 | 264 | |
265 | 265 | // Inject env string directly into the command. |
@@ -274,7 +274,7 @@ discard block |
||
274 | 274 | |
275 | 275 | $data = DNData::inst(); |
276 | 276 | // Generate a capfile from a template |
277 | - $capTemplate = file_get_contents(BASE_PATH . '/deploynaut/Capfile.template'); |
|
277 | + $capTemplate = file_get_contents(BASE_PATH.'/deploynaut/Capfile.template'); |
|
278 | 278 | $cap = str_replace( |
279 | 279 | array('<config root>', '<ssh key>', '<base path>'), |
280 | 280 | array($data->getEnvironmentDir(), DEPLOYNAUT_SSH_KEY, BASE_PATH), |
@@ -284,13 +284,13 @@ discard block |
||
284 | 284 | if(defined('DEPLOYNAUT_CAPFILE')) { |
285 | 285 | $capFile = DEPLOYNAUT_CAPFILE; |
286 | 286 | } else { |
287 | - $capFile = ASSETS_PATH . '/Capfile'; |
|
287 | + $capFile = ASSETS_PATH.'/Capfile'; |
|
288 | 288 | } |
289 | 289 | file_put_contents($capFile, $cap); |
290 | 290 | |
291 | - $command = "{$envString}cap -f " . escapeshellarg($capFile) . " -vv $name $action ROLES=$roles"; |
|
291 | + $command = "{$envString}cap -f ".escapeshellarg($capFile)." -vv $name $action ROLES=$roles"; |
|
292 | 292 | foreach($args as $argName => $argVal) { |
293 | - $command .= ' -s ' . escapeshellarg($argName) . '=' . escapeshellarg($argVal); |
|
293 | + $command .= ' -s '.escapeshellarg($argName).'='.escapeshellarg($argVal); |
|
294 | 294 | } |
295 | 295 | |
296 | 296 | $log->write(sprintf('Running command: %s', $command)); |
@@ -324,7 +324,7 @@ discard block |
||
324 | 324 | $filepathBase = $dataArchive->generateFilepath($dataTransfer); |
325 | 325 | mkdir($filepathBase, 0700, true); |
326 | 326 | |
327 | - $databasePath = $filepathBase . DIRECTORY_SEPARATOR . 'database.sql'; |
|
327 | + $databasePath = $filepathBase.DIRECTORY_SEPARATOR.'database.sql'; |
|
328 | 328 | |
329 | 329 | // Backup database |
330 | 330 | if(in_array($dataTransfer->Mode, array('all', 'db'))) { |
@@ -362,7 +362,7 @@ discard block |
||
362 | 362 | $log->write('Creating sspak...'); |
363 | 363 | |
364 | 364 | $sspakFilename = sprintf('%s.sspak', $dataArchive->generateFilename($dataTransfer)); |
365 | - $sspakFilepath = $filepathBase . DIRECTORY_SEPARATOR . $sspakFilename; |
|
365 | + $sspakFilepath = $filepathBase.DIRECTORY_SEPARATOR.$sspakFilename; |
|
366 | 366 | |
367 | 367 | try { |
368 | 368 | $dataArchive->attachFile($sspakFilepath, $dataTransfer); |
@@ -429,7 +429,7 @@ discard block |
||
429 | 429 | // Restore database into target environment |
430 | 430 | if(in_array($dataTransfer->Mode, array('all', 'db'))) { |
431 | 431 | $log->write(sprintf('Restore of database to "%s" started', $name)); |
432 | - $args = array('data_path' => $workingDir . DIRECTORY_SEPARATOR . 'database.sql'); |
|
432 | + $args = array('data_path' => $workingDir.DIRECTORY_SEPARATOR.'database.sql'); |
|
433 | 433 | $command = $this->getCommand('data:pushdb', 'db', $environment, $args, $log); |
434 | 434 | $command->run(function($type, $buffer) use($log) { |
435 | 435 | $log->write($buffer); |
@@ -446,7 +446,7 @@ discard block |
||
446 | 446 | // Restore assets into target environment |
447 | 447 | if(in_array($dataTransfer->Mode, array('all', 'assets'))) { |
448 | 448 | $log->write(sprintf('Restore of assets to "%s" started', $name)); |
449 | - $args = array('data_path' => $workingDir . DIRECTORY_SEPARATOR . 'assets'); |
|
449 | + $args = array('data_path' => $workingDir.DIRECTORY_SEPARATOR.'assets'); |
|
450 | 450 | $command = $this->getCommand('data:pushassets', 'web', $environment, $args, $log); |
451 | 451 | $command->run(function($type, $buffer) use($log) { |
452 | 452 | $log->write($buffer); |
@@ -527,17 +527,17 @@ discard block |
||
527 | 527 | } |
528 | 528 | |
529 | 529 | // Produce an informational ticker roughly every $tick |
530 | - if (time() > $infoTick) { |
|
530 | + if(time() > $infoTick) { |
|
531 | 531 | $message = []; |
532 | 532 | |
533 | 533 | // Collect status information from different sources. |
534 | - if ($status) { |
|
534 | + if($status) { |
|
535 | 535 | $message[] = sprintf('HTTP status code is %s', $status); |
536 | 536 | } |
537 | - if (!$response) { |
|
537 | + if(!$response) { |
|
538 | 538 | $message[] = 'response is empty'; |
539 | 539 | } |
540 | - if ($error = curl_error($ch)) { |
|
540 | + if($error = curl_error($ch)) { |
|
541 | 541 | $message[] = sprintf('request error: %s', $error); |
542 | 542 | } |
543 | 543 |