@@ -150,14 +150,14 @@ discard block |
||
150 | 150 | parent::start(); |
151 | 151 | |
152 | 152 | // Just in case this step is being mistakenly restarted |
153 | - if ($this->hasResponse()) { |
|
153 | + if($this->hasResponse()) { |
|
154 | 154 | $this->log("{$this->Title} has already been processed with a response of {$this->Approval}"); |
155 | 155 | $this->markFailed(); |
156 | 156 | return false; |
157 | 157 | } |
158 | 158 | |
159 | 159 | // Begin or process this step |
160 | - switch ($this->Status) { |
|
160 | + switch($this->Status) { |
|
161 | 161 | case 'Started': |
162 | 162 | return $this->checkStatus(); |
163 | 163 | case 'Queued': |
@@ -188,7 +188,7 @@ discard block |
||
188 | 188 | public function approve() |
189 | 189 | { |
190 | 190 | // Check permission |
191 | - if (!$this->canApprove()) { |
|
191 | + if(!$this->canApprove()) { |
|
192 | 192 | return Security::permissionFailure( |
193 | 193 | null, |
194 | 194 | _t("UserConfirmationStep.DENYAPPROVE", "You do not have permission to approve this deployment") |
@@ -196,7 +196,7 @@ discard block |
||
196 | 196 | } |
197 | 197 | |
198 | 198 | // Skip subsequent approvals if already approved / rejected |
199 | - if ($this->hasResponse()) { |
|
199 | + if($this->hasResponse()) { |
|
200 | 200 | return; |
201 | 201 | } |
202 | 202 | |
@@ -217,7 +217,7 @@ discard block |
||
217 | 217 | public function reject() |
218 | 218 | { |
219 | 219 | // Check permission |
220 | - if (!$this->canApprove()) { |
|
220 | + if(!$this->canApprove()) { |
|
221 | 221 | return Security::permissionFailure( |
222 | 222 | null, |
223 | 223 | _t("UserConfirmationStep.DENYREJECT", "You do not have permission to reject this deployment") |
@@ -225,7 +225,7 @@ discard block |
||
225 | 225 | } |
226 | 226 | |
227 | 227 | // Skip subsequent approvals if already approved / rejected |
228 | - if ($this->hasResponse()) { |
|
228 | + if($this->hasResponse()) { |
|
229 | 229 | return; |
230 | 230 | } |
231 | 231 | |
@@ -247,7 +247,7 @@ discard block |
||
247 | 247 | { |
248 | 248 | // For running or queued tasks ensure that we have not exceeded |
249 | 249 | // a reasonable time-elapsed to consider this job inactive |
250 | - if ($this->isTimedOut()) { |
|
250 | + if($this->isTimedOut()) { |
|
251 | 251 | $days = round($this->MaxDuration / (24.0 * 3600.0), 1); |
252 | 252 | $logMessage = "{$this->Title} took longer than {$this->MaxDuration} seconds ($days days) to be approved " |
253 | 253 | . "and has timed out"; |
@@ -258,7 +258,7 @@ discard block |
||
258 | 258 | } |
259 | 259 | |
260 | 260 | // If operating on a delayed notification schedule, determine if there are further groups who should be notified |
261 | - if ($delay = $this->getConfigSetting('RecipientsDelay')) { |
|
261 | + if($delay = $this->getConfigSetting('RecipientsDelay')) { |
|
262 | 262 | // Check group that should have been notified by now |
263 | 263 | $age = $this->getAge(); |
264 | 264 | $escallateGroup = intval($age / $delay); |
@@ -266,7 +266,7 @@ discard block |
||
266 | 266 | $lastGroup = count($recipients) - 1; |
267 | 267 | // If we can notify the next group, do so |
268 | 268 | // We only escallate one group at a time to ensure correct order is followed |
269 | - if ($this->NotifiedGroup < $lastGroup && $this->NotifiedGroup < $escallateGroup) { |
|
269 | + if($this->NotifiedGroup < $lastGroup && $this->NotifiedGroup < $escallateGroup) { |
|
270 | 270 | $this->NotifiedGroup++; |
271 | 271 | $groupDescription = is_array($recipients[$this->NotifiedGroup]) |
272 | 272 | ? implode(',', $recipients[$this->NotifiedGroup]) |
@@ -295,7 +295,7 @@ discard block |
||
295 | 295 | $this->log("Starting {$this->Title}..."); |
296 | 296 | // Determine if we should use delayed notification |
297 | 297 | $recipientGroup = 'all'; |
298 | - if ($this->getConfigSetting('RecipientsDelay')) { |
|
298 | + if($this->getConfigSetting('RecipientsDelay')) { |
|
299 | 299 | $this->NotifiedGroup = $recipientGroup = 0; |
300 | 300 | } |
301 | 301 | // Send to selected group |
@@ -358,9 +358,9 @@ discard block |
||
358 | 358 | $author = $this->Pipeline()->Author(); |
359 | 359 | |
360 | 360 | // Send message to requester |
361 | - if ($recipientGroup === 'all' || $recipientGroup === 0) { |
|
361 | + if($recipientGroup === 'all' || $recipientGroup === 0) { |
|
362 | 362 | list($subject, $message) = $this->generateMessageTemplate(self::ROLE_REQUESTER, $messageID); |
363 | - if ($subject && $message) { |
|
363 | + if($subject && $message) { |
|
364 | 364 | $this->log("{$this->Title} sending $messageID message to {$author->Email}"); |
365 | 365 | $extra = array('subject' => $subject); |
366 | 366 | $this->messagingService->sendMessage($this, $message, $author, array_merge($arguments, $extra)); |
@@ -369,19 +369,19 @@ discard block |
||
369 | 369 | |
370 | 370 | // Filter recipients based on group |
371 | 371 | $recipients = $this->getConfigSetting('Recipients'); |
372 | - if (is_array($recipients) && $recipientGroup !== 'all') { |
|
372 | + if(is_array($recipients) && $recipientGroup !== 'all') { |
|
373 | 373 | $recipients = isset($recipients[$recipientGroup]) |
374 | 374 | ? $recipients[$recipientGroup] |
375 | 375 | : null; |
376 | 376 | } |
377 | - if (empty($recipients)) { |
|
377 | + if(empty($recipients)) { |
|
378 | 378 | $this->log("Skipping sending message to empty recipients"); |
379 | 379 | return; |
380 | 380 | } |
381 | 381 | |
382 | 382 | // Send to recipients |
383 | 383 | list($subject, $message) = $this->generateMessageTemplate(self::ROLE_RECIPIENT, $messageID); |
384 | - if ($subject && $message && $recipients) { |
|
384 | + if($subject && $message && $recipients) { |
|
385 | 385 | $recipientsStr = is_array($recipients) ? implode(',', $recipients) : $recipients; |
386 | 386 | $this->log("{$this->Title} sending $messageID message to $recipientsStr"); |
387 | 387 | $extra = array('subject' => $subject); |
@@ -393,7 +393,7 @@ discard block |
||
393 | 393 | { |
394 | 394 | |
395 | 395 | // Don't show options if this step has already been confirmed |
396 | - if ($this->hasResponse() || !$this->isRunning()) { |
|
396 | + if($this->hasResponse() || !$this->isRunning()) { |
|
397 | 397 | return; |
398 | 398 | } |
399 | 399 | |
@@ -403,7 +403,7 @@ discard block |
||
403 | 403 | public function allowedActions() |
404 | 404 | { |
405 | 405 | // Don't show options if this step has already been confirmed or can't be confirmed |
406 | - if ($this->hasResponse() || !$this->isRunning() || !$this->canApprove()) { |
|
406 | + if($this->hasResponse() || !$this->isRunning() || !$this->canApprove()) { |
|
407 | 407 | return parent::allowedActions(); |
408 | 408 | } |
409 | 409 |
@@ -68,7 +68,7 @@ |
||
68 | 68 | */ |
69 | 69 | public function __get($property) |
70 | 70 | { |
71 | - if (isset($this->record[$property])) { |
|
71 | + if(isset($this->record[$property])) { |
|
72 | 72 | return $this->record[$property]; |
73 | 73 | } |
74 | 74 | return null; |
@@ -55,16 +55,16 @@ discard block |
||
55 | 55 | $jobs = new ArrayList(); |
56 | 56 | |
57 | 57 | $resqueJobs = Resque::redis()->lrange('queue:' . $this->Name, 0, -1); |
58 | - if (!$resqueJobs) { |
|
58 | + if(!$resqueJobs) { |
|
59 | 59 | $jobs->push(new ResqueJob(array( |
60 | 60 | 'Name' => 'null', |
61 | 61 | 'Value' => 'null', |
62 | 62 | ))); |
63 | 63 | return $jobs; |
64 | 64 | } |
65 | - foreach ($resqueJobs as $idx => $job) { |
|
65 | + foreach($resqueJobs as $idx => $job) { |
|
66 | 66 | $stdClass = json_decode($job); |
67 | - if ($stdClass->class === 'CapistranoDeploy' || $stdClass->class === 'DeployJob') { |
|
67 | + if($stdClass->class === 'CapistranoDeploy' || $stdClass->class === 'DeployJob') { |
|
68 | 68 | $value = $stdClass->args[0]->projectName |
69 | 69 | . ':' . $stdClass->args[0]->environment |
70 | 70 | . ' - ' . $stdClass->args[0]->sha; |
@@ -121,7 +121,7 @@ discard block |
||
121 | 121 | */ |
122 | 122 | public function __get($property) |
123 | 123 | { |
124 | - if (isset($this->record[$property])) { |
|
124 | + if(isset($this->record[$property])) { |
|
125 | 125 | return $this->record[$property]; |
126 | 126 | } |
127 | 127 | return null; |
@@ -56,7 +56,7 @@ |
||
56 | 56 | { |
57 | 57 | $queues = Resque::queues(); |
58 | 58 | $queueList = new ArrayList(); |
59 | - foreach ($queues as $idx => $queue) { |
|
59 | + foreach($queues as $idx => $queue) { |
|
60 | 60 | $queueList->push(new ResqueQueue(array( |
61 | 61 | 'ID' => ($idx + 1), |
62 | 62 | 'Name' => $queue, |
@@ -12,11 +12,11 @@ discard block |
||
12 | 12 | { |
13 | 13 | $projects = DNProject::get(); |
14 | 14 | |
15 | - foreach ($projects as $project) { |
|
15 | + foreach($projects as $project) { |
|
16 | 16 | $environments = $project->DNEnvironmentList(); |
17 | - foreach ($environments as $environment) { |
|
17 | + foreach($environments as $environment) { |
|
18 | 18 | $newFilename = basename($environment->Filename); |
19 | - if ($environment->Filename != $newFilename) { |
|
19 | + if($environment->Filename != $newFilename) { |
|
20 | 20 | echo 'Migrating "' . $environment->Filename . '" to ' . $newFilename . PHP_EOL; |
21 | 21 | $environment->Filename = $newFilename; |
22 | 22 | $environment->write(); |
@@ -26,13 +26,13 @@ discard block |
||
26 | 26 | |
27 | 27 | $warnings = false; |
28 | 28 | // Check if all project folders exists |
29 | - foreach ($projects as $project) { |
|
30 | - if (!$project->projectFolderExists()) { |
|
29 | + foreach($projects as $project) { |
|
30 | + if(!$project->projectFolderExists()) { |
|
31 | 31 | $warnings = true; |
32 | 32 | echo 'Project ' . $project->Name . ' don\'t have a cap project folder' . PHP_EOL; |
33 | 33 | } |
34 | 34 | } |
35 | - if ($warnings) { |
|
35 | + if($warnings) { |
|
36 | 36 | exit(1); |
37 | 37 | } |
38 | 38 | } |
@@ -11,15 +11,15 @@ discard block |
||
11 | 11 | $remove = true; |
12 | 12 | $dryRun = true; |
13 | 13 | |
14 | - if ($request && $request->requestVar('remove') !== null) { |
|
14 | + if($request && $request->requestVar('remove') !== null) { |
|
15 | 15 | $remove = (bool)$request->requestVar('remove'); |
16 | 16 | } |
17 | 17 | |
18 | - if ($request && $request->requestVar('dryrun') !== null) { |
|
18 | + if($request && $request->requestVar('dryrun') !== null) { |
|
19 | 19 | $dryRun = (bool)$request->requestVar('dryrun'); |
20 | 20 | } |
21 | 21 | |
22 | - if ($dryRun) { |
|
22 | + if($dryRun) { |
|
23 | 23 | echo "Running in dry run mode, no changes commited, "; |
24 | 24 | echo "the output shows a prediction on what will happen." . PHP_EOL; |
25 | 25 | echo "To skip dryrun, run the task like this:" . PHP_EOL; |
@@ -32,7 +32,7 @@ discard block |
||
32 | 32 | |
33 | 33 | // Sync projects |
34 | 34 | $projects = DNProject::get(); |
35 | - if ($remove) { |
|
35 | + if($remove) { |
|
36 | 36 | $this->echoHeader('Removing obsolete projects'); |
37 | 37 | $this->removeObsoleteProjects($projectPaths, $dryRun); |
38 | 38 | } |
@@ -40,7 +40,7 @@ discard block |
||
40 | 40 | $this->syncProjectPaths($projectPaths, $dryRun); |
41 | 41 | |
42 | 42 | $this->echoHeader('Syncing environment files'); |
43 | - foreach ($projects as $project) { |
|
43 | + foreach($projects as $project) { |
|
44 | 44 | $this->echoHeader($project->Name); |
45 | 45 | // Sync environments for each project |
46 | 46 | $environmentPaths = $data->getEnvironmentPaths($project->Name); |
@@ -60,18 +60,18 @@ discard block |
||
60 | 60 | { |
61 | 61 | $list = $project->Environments(); |
62 | 62 | |
63 | - $basePaths = array_map(function ($path) { |
|
63 | + $basePaths = array_map(function($path) { |
|
64 | 64 | return basename($path); |
65 | 65 | }, $paths); |
66 | 66 | |
67 | 67 | $removeList = $list->filter('Filename:not', $basePaths); |
68 | - if ($removeList->count() === 0) { |
|
68 | + if($removeList->count() === 0) { |
|
69 | 69 | return; |
70 | 70 | } |
71 | 71 | |
72 | - foreach ($removeList as $remove) { |
|
72 | + foreach($removeList as $remove) { |
|
73 | 73 | $this->message('Removing "' . basename($remove->Name) . '" from db'); |
74 | - if (!$dryRun) { |
|
74 | + if(!$dryRun) { |
|
75 | 75 | $removeList->remove($remove); |
76 | 76 | } |
77 | 77 | } |
@@ -87,13 +87,13 @@ discard block |
||
87 | 87 | protected function removeObsoleteProjects($paths, $dryrun = false) |
88 | 88 | { |
89 | 89 | $removeList = DNProject::get()->filter('Name:not', $paths); |
90 | - if ($removeList->count() == 0) { |
|
90 | + if($removeList->count() == 0) { |
|
91 | 91 | return; |
92 | 92 | } |
93 | 93 | |
94 | - foreach ($removeList as $remove) { |
|
94 | + foreach($removeList as $remove) { |
|
95 | 95 | $this->message($remove->Name . ' ' . $remove->Path); |
96 | - if (!$dryrun) { |
|
96 | + if(!$dryrun) { |
|
97 | 97 | $removeList->remove($remove); |
98 | 98 | } |
99 | 99 | } |
@@ -111,22 +111,22 @@ discard block |
||
111 | 111 | $list = $project->Environments(); |
112 | 112 | |
113 | 113 | // Normalise paths in DB |
114 | - foreach ($list as $item) { |
|
114 | + foreach($list as $item) { |
|
115 | 115 | $real = realpath($item->Filename); |
116 | - if ($real && $real != $item->Filename) { |
|
116 | + if($real && $real != $item->Filename) { |
|
117 | 117 | $item->Filename = $real; |
118 | 118 | $item->write(); |
119 | 119 | } |
120 | 120 | } |
121 | 121 | |
122 | - foreach ($paths as $path) { |
|
122 | + foreach($paths as $path) { |
|
123 | 123 | $path = basename($path); |
124 | - if ($list->filter('Filename', $path)->count()) { |
|
124 | + if($list->filter('Filename', $path)->count()) { |
|
125 | 125 | continue; |
126 | 126 | } |
127 | 127 | |
128 | 128 | $this->message('Adding "' . basename($path) . '" to db'); |
129 | - if (!$dryRun) { |
|
129 | + if(!$dryRun) { |
|
130 | 130 | $environment = DNEnvironment::create_from_path($path); |
131 | 131 | $environment->ProjectID = $project->ID; |
132 | 132 | $environment->write(); |
@@ -142,10 +142,10 @@ discard block |
||
142 | 142 | */ |
143 | 143 | public function syncProjectPaths($paths, $dryRun = false) |
144 | 144 | { |
145 | - foreach ($paths as $path) { |
|
146 | - if (!DNProject::get()->filter('Name', $path)->count()) { |
|
145 | + foreach($paths as $path) { |
|
146 | + if(!DNProject::get()->filter('Name', $path)->count()) { |
|
147 | 147 | $this->message($path); |
148 | - if (!$dryRun) { |
|
148 | + if(!$dryRun) { |
|
149 | 149 | DNProject::create_from_path($path)->write(); |
150 | 150 | } |
151 | 151 | } |
@@ -157,7 +157,7 @@ discard block |
||
157 | 157 | */ |
158 | 158 | protected function message($text) |
159 | 159 | { |
160 | - if (PHP_SAPI !== 'cli') { |
|
160 | + if(PHP_SAPI !== 'cli') { |
|
161 | 161 | $text = '<p>' . $text . '</p>' . PHP_EOL; |
162 | 162 | } |
163 | 163 | echo ' - ' . $text . PHP_EOL; |
@@ -168,7 +168,7 @@ discard block |
||
168 | 168 | */ |
169 | 169 | protected function echoHeader($text) |
170 | 170 | { |
171 | - if (PHP_SAPI !== 'cli') { |
|
171 | + if(PHP_SAPI !== 'cli') { |
|
172 | 172 | echo '<h2>' . $text . '</h2>' . PHP_EOL; |
173 | 173 | } else { |
174 | 174 | echo '# ' . $text . PHP_EOL; |