@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | |
73 | 73 | try { |
74 | 74 | $args['build_filename'] = $this->packageGenerator->getPackageFilename($project->Name, $sha, $repository, $log); |
75 | - } catch (Exception $e) { |
|
75 | + } catch(Exception $e) { |
|
76 | 76 | $log->write($e->getMessage()); |
77 | 77 | throw $e; |
78 | 78 | } |
@@ -176,7 +176,7 @@ discard block |
||
176 | 176 | } else { |
177 | 177 | $environment = $dataTransfer->Environment(); |
178 | 178 | $project = $environment->Project(); |
179 | - $workingDir = TEMP_FOLDER . DIRECTORY_SEPARATOR . 'deploynaut-transfer-' . $dataTransfer->ID; |
|
179 | + $workingDir = TEMP_FOLDER.DIRECTORY_SEPARATOR.'deploynaut-transfer-'.$dataTransfer->ID; |
|
180 | 180 | $archive = $dataTransfer->DataArchive(); |
181 | 181 | |
182 | 182 | // extract the sspak contents, we'll need these so capistrano can restore that content |
@@ -222,7 +222,7 @@ discard block |
||
222 | 222 | if(!$args) { |
223 | 223 | $args = array(); |
224 | 224 | } |
225 | - $args['history_path'] = realpath(DEPLOYNAUT_LOG_PATH . '/'); |
|
225 | + $args['history_path'] = realpath(DEPLOYNAUT_LOG_PATH.'/'); |
|
226 | 226 | $args['environment_id'] = $environment->ID; |
227 | 227 | |
228 | 228 | // Inject env string directly into the command. |
@@ -237,7 +237,7 @@ discard block |
||
237 | 237 | |
238 | 238 | $data = DNData::inst(); |
239 | 239 | // Generate a capfile from a template |
240 | - $capTemplate = file_get_contents(BASE_PATH . '/deploynaut/Capfile.template'); |
|
240 | + $capTemplate = file_get_contents(BASE_PATH.'/deploynaut/Capfile.template'); |
|
241 | 241 | $cap = str_replace( |
242 | 242 | array('<config root>', '<ssh key>', '<base path>'), |
243 | 243 | array($data->getEnvironmentDir(), DEPLOYNAUT_SSH_KEY, BASE_PATH), |
@@ -247,13 +247,13 @@ discard block |
||
247 | 247 | if(defined('DEPLOYNAUT_CAPFILE')) { |
248 | 248 | $capFile = DEPLOYNAUT_CAPFILE; |
249 | 249 | } else { |
250 | - $capFile = ASSETS_PATH . '/Capfile'; |
|
250 | + $capFile = ASSETS_PATH.'/Capfile'; |
|
251 | 251 | } |
252 | 252 | file_put_contents($capFile, $cap); |
253 | 253 | |
254 | - $command = "{$envString}cap -f " . escapeshellarg($capFile) . " -vv $name $action ROLES=$roles"; |
|
254 | + $command = "{$envString}cap -f ".escapeshellarg($capFile)." -vv $name $action ROLES=$roles"; |
|
255 | 255 | foreach($args as $argName => $argVal) { |
256 | - $command .= ' -s ' . escapeshellarg($argName) . '=' . escapeshellarg($argVal); |
|
256 | + $command .= ' -s '.escapeshellarg($argName).'='.escapeshellarg($argVal); |
|
257 | 257 | } |
258 | 258 | |
259 | 259 | $log->write(sprintf('Running command: %s', $command)); |
@@ -287,7 +287,7 @@ discard block |
||
287 | 287 | $filepathBase = $dataArchive->generateFilepath($dataTransfer); |
288 | 288 | mkdir($filepathBase, 0700, true); |
289 | 289 | |
290 | - $databasePath = $filepathBase . DIRECTORY_SEPARATOR . 'database.sql'; |
|
290 | + $databasePath = $filepathBase.DIRECTORY_SEPARATOR.'database.sql'; |
|
291 | 291 | |
292 | 292 | // Backup database |
293 | 293 | if(in_array($dataTransfer->Mode, array('all', 'db'))) { |
@@ -325,7 +325,7 @@ discard block |
||
325 | 325 | $log->write('Creating sspak...'); |
326 | 326 | |
327 | 327 | $sspakFilename = sprintf('%s.sspak', $dataArchive->generateFilename($dataTransfer)); |
328 | - $sspakFilepath = $filepathBase . DIRECTORY_SEPARATOR . $sspakFilename; |
|
328 | + $sspakFilepath = $filepathBase.DIRECTORY_SEPARATOR.$sspakFilename; |
|
329 | 329 | |
330 | 330 | try { |
331 | 331 | $dataArchive->attachFile($sspakFilepath, $dataTransfer); |
@@ -392,7 +392,7 @@ discard block |
||
392 | 392 | // Restore database into target environment |
393 | 393 | if(in_array($dataTransfer->Mode, array('all', 'db'))) { |
394 | 394 | $log->write(sprintf('Restore of database to "%s" started', $name)); |
395 | - $args = array('data_path' => $workingDir . DIRECTORY_SEPARATOR . 'database.sql'); |
|
395 | + $args = array('data_path' => $workingDir.DIRECTORY_SEPARATOR.'database.sql'); |
|
396 | 396 | $command = $this->getCommand('data:pushdb', 'db', $environment, $args, $log); |
397 | 397 | $command->run(function($type, $buffer) use($log) { |
398 | 398 | $log->write($buffer); |
@@ -409,7 +409,7 @@ discard block |
||
409 | 409 | // Restore assets into target environment |
410 | 410 | if(in_array($dataTransfer->Mode, array('all', 'assets'))) { |
411 | 411 | $log->write(sprintf('Restore of assets to "%s" started', $name)); |
412 | - $args = array('data_path' => $workingDir . DIRECTORY_SEPARATOR . 'assets'); |
|
412 | + $args = array('data_path' => $workingDir.DIRECTORY_SEPARATOR.'assets'); |
|
413 | 413 | $command = $this->getCommand('data:pushassets', 'web', $environment, $args, $log); |
414 | 414 | $command->run(function($type, $buffer) use($log) { |
415 | 415 | $log->write($buffer); |
@@ -490,17 +490,17 @@ discard block |
||
490 | 490 | } |
491 | 491 | |
492 | 492 | // Produce an informational ticker roughly every $tick |
493 | - if (time() > $infoTick) { |
|
493 | + if(time() > $infoTick) { |
|
494 | 494 | $message = []; |
495 | 495 | |
496 | 496 | // Collect status information from different sources. |
497 | - if ($status) { |
|
497 | + if($status) { |
|
498 | 498 | $message[] = sprintf('HTTP status code is %s', $status); |
499 | 499 | } |
500 | - if (!$response) { |
|
500 | + if(!$response) { |
|
501 | 501 | $message[] = 'response is empty'; |
502 | 502 | } |
503 | - if ($error = curl_error($ch)) { |
|
503 | + if($error = curl_error($ch)) { |
|
504 | 504 | $message[] = sprintf('request error: %s', $error); |
505 | 505 | } |
506 | 506 |
@@ -124,7 +124,7 @@ |
||
124 | 124 | } |
125 | 125 | |
126 | 126 | /** |
127 | - * @return array |
|
127 | + * @return PredeployBackupOption[] |
|
128 | 128 | */ |
129 | 129 | public function getDeployOptions() { |
130 | 130 | return [ |
@@ -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 |
@@ -139,6 +139,9 @@ |
||
139 | 139 | $this->updateStatus(DNDeployment::TR_FAIL); |
140 | 140 | } |
141 | 141 | |
142 | + /** |
|
143 | + * @param DNDataTransfer|null $backupDataTransfer |
|
144 | + */ |
|
142 | 145 | protected function performBackup($backupDataTransfer, DeploynautLogFile $log) { |
143 | 146 | if (!$backupDataTransfer) { |
144 | 147 | return false; |
@@ -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 |
@@ -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 |
@@ -139,6 +139,9 @@ |
||
139 | 139 | $this->updateStatus(DNDeployment::TR_FAIL); |
140 | 140 | } |
141 | 141 | |
142 | + /** |
|
143 | + * @param DNDataTransfer|null $backupDataTransfer |
|
144 | + */ |
|
142 | 145 | protected function performBackup($backupDataTransfer, DeploynautLogFile $log) { |
143 | 146 | if (!$backupDataTransfer) { |
144 | 147 | return false; |