|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
/** |
|
4
|
|
|
* Runs a deployment via the most appropriate backend |
|
5
|
|
|
*/ |
|
6
|
|
|
class DeployJob extends DeploynautJob { |
|
7
|
|
|
|
|
8
|
|
|
/** |
|
9
|
|
|
* @var array |
|
10
|
|
|
*/ |
|
11
|
|
|
public $args; |
|
12
|
|
|
|
|
13
|
|
|
/** |
|
14
|
|
|
* Poll the sigFile looking for a signal to self-deliver. |
|
15
|
|
|
* This is useful if we don't know the PID of the worker - we can easily deliver signals |
|
16
|
|
|
* if we only know the ClassName and ID of the DataObject. |
|
17
|
|
|
*/ |
|
18
|
|
|
public function alarmHandler() { |
|
19
|
|
|
$sigFile = $this->args['sigFile']; |
|
20
|
|
|
if (file_exists($sigFile) && is_readable($sigFile) && is_writable($sigFile)) { |
|
21
|
|
|
$signal = (int)file_get_contents($sigFile); |
|
22
|
|
|
if (is_int($signal) && in_array((int)$signal, [ |
|
23
|
|
|
// The following signals are trapped by both Resque and Rainforest. |
|
24
|
|
|
SIGTERM, |
|
25
|
|
|
SIGINT, |
|
26
|
|
|
SIGQUIT, |
|
27
|
|
|
// The following are Resque only. |
|
28
|
|
|
SIGUSR1, |
|
29
|
|
|
SIGUSR2, |
|
30
|
|
|
SIGCONT |
|
31
|
|
|
])) { |
|
32
|
|
|
echo sprintf( |
|
33
|
|
|
'[-] Signal "%s" received, delivering to own process group, PID "%s".' . PHP_EOL, |
|
34
|
|
|
$signal, |
|
35
|
|
|
getmypid() |
|
36
|
|
|
); |
|
37
|
|
|
|
|
38
|
|
|
// Mark the signal as received. |
|
39
|
|
|
unlink($sigFile); |
|
40
|
|
|
|
|
41
|
|
|
// Dispatch to own process group. |
|
42
|
|
|
$pgid = posix_getpgid(getmypid()); |
|
43
|
|
|
if ($pgid<=0) { |
|
44
|
|
|
echo sprintf( |
|
45
|
|
|
'[-] Unable to send signal to invalid PGID "%s".' . PHP_EOL, |
|
46
|
|
|
$pgid |
|
47
|
|
|
); |
|
48
|
|
|
} else { |
|
49
|
|
|
posix_kill(-$pgid, $signal); |
|
50
|
|
|
} |
|
51
|
|
|
} |
|
52
|
|
|
} |
|
53
|
|
|
|
|
54
|
|
|
// Wake up again soon. |
|
55
|
|
|
pcntl_alarm(1); |
|
56
|
|
|
} |
|
57
|
|
|
|
|
58
|
|
|
public function setUp() { |
|
59
|
|
|
// Make this process a session leader so we can send signals |
|
60
|
|
|
// to this job as a whole (including any subprocesses such as spawned by Symfony). |
|
61
|
|
|
posix_setsid(); |
|
62
|
|
|
|
|
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']); |
|
66
|
|
|
declare(ticks = 1); |
|
67
|
|
|
pcntl_signal(SIGALRM, [$this, 'alarmHandler']); |
|
68
|
|
|
pcntl_alarm(1); |
|
69
|
|
|
} |
|
70
|
|
|
} |
|
71
|
|
|
|
|
72
|
|
|
$this->updateStatus(DNDeployment::TR_DEPLOY); |
|
73
|
|
|
chdir(BASE_PATH); |
|
74
|
|
|
} |
|
75
|
|
|
|
|
76
|
|
|
public function perform() { |
|
77
|
|
|
echo "[-] DeployJob starting" . PHP_EOL; |
|
78
|
|
|
$log = new DeploynautLogFile($this->args['logfile']); |
|
79
|
|
|
|
|
80
|
|
|
$deployment = DNDeployment::get()->byID($this->args['deploymentID']); |
|
81
|
|
|
$environment = $deployment->Environment(); |
|
82
|
|
|
$project = $environment->Project(); |
|
83
|
|
|
$backupDataTransfer = null; |
|
84
|
|
|
$backupMode = !empty($this->args['backup_mode']) ? $this->args['backup_mode'] : 'db'; |
|
85
|
|
|
|
|
86
|
|
|
// Perform pre-deploy backup here if required. Note that the backup is done here within |
|
87
|
|
|
// the deploy job, so that the order of backup is done before deployment, and so it |
|
88
|
|
|
// doesn't tie up another worker. It also puts the backup output into |
|
89
|
|
|
// the same log as the deployment so there is visibility on what is going on. |
|
90
|
|
View Code Duplication |
if(!empty($this->args['predeploy_backup'])) { |
|
|
|
|
|
|
91
|
|
|
$backupDataTransfer = DNDataTransfer::create(); |
|
92
|
|
|
$backupDataTransfer->EnvironmentID = $environment->ID; |
|
93
|
|
|
$backupDataTransfer->Direction = 'get'; |
|
94
|
|
|
$backupDataTransfer->Mode = $backupMode; |
|
95
|
|
|
$backupDataTransfer->ResqueToken = $deployment->ResqueToken; |
|
96
|
|
|
$backupDataTransfer->AuthorID = $deployment->DeployerID; |
|
97
|
|
|
$backupDataTransfer->write(); |
|
98
|
|
|
|
|
99
|
|
|
$deployment->BackupDataTransferID = $backupDataTransfer->ID; |
|
100
|
|
|
$deployment->write(); |
|
101
|
|
|
} |
|
102
|
|
|
|
|
103
|
|
|
// This is a bit icky, but there is no easy way of capturing a failed deploy by using the PHP Resque |
|
104
|
|
|
try { |
|
105
|
|
|
// Disallow concurrent deployments (don't rely on queuing implementation to restrict this) |
|
106
|
|
|
// Only consider deployments started in the last 30 minutes (older jobs probably got stuck) |
|
107
|
|
|
$runningDeployments = $environment->runningDeployments()->exclude('ID', $this->args['deploymentID']); |
|
108
|
|
|
if($runningDeployments->count()) { |
|
109
|
|
|
$runningDeployment = $runningDeployments->first(); |
|
110
|
|
|
$message = sprintf( |
|
111
|
|
|
'Error: another deployment is in progress (started at %s by %s)', |
|
112
|
|
|
$runningDeployment->dbObject('Created')->Nice(), |
|
113
|
|
|
$runningDeployment->Deployer()->Title |
|
114
|
|
|
); |
|
115
|
|
|
$log->write($message); |
|
116
|
|
|
throw new \RuntimeException($message); |
|
117
|
|
|
} |
|
118
|
|
|
|
|
119
|
|
View Code Duplication |
if($backupDataTransfer) { |
|
|
|
|
|
|
120
|
|
|
$log->write('Backing up existing data'); |
|
121
|
|
|
try { |
|
122
|
|
|
$environment->Backend()->dataTransfer($backupDataTransfer, $log); |
|
123
|
|
|
$this->updateBackupStatus('Finished'); |
|
124
|
|
|
} catch(Exception $e) { |
|
125
|
|
|
$this->updateBackupStatus('Failed'); |
|
126
|
|
|
} |
|
127
|
|
|
} |
|
128
|
|
|
|
|
129
|
|
|
$environment->Backend()->deploy( |
|
130
|
|
|
$environment, |
|
131
|
|
|
$log, |
|
132
|
|
|
$project, |
|
133
|
|
|
// Pass all args to give the backend full visibility. These args also contain |
|
134
|
|
|
// all options from the DeploymentStrategy merged in, including sha. |
|
135
|
|
|
$this->args |
|
136
|
|
|
); |
|
137
|
|
|
} catch(Exception $e) { |
|
138
|
|
|
// DeploynautJob will automatically trigger onFailure. |
|
139
|
|
|
echo "[-] DeployJob failed" . PHP_EOL; |
|
140
|
|
|
throw $e; |
|
141
|
|
|
} |
|
142
|
|
|
$this->updateStatus(DNDeployment::TR_COMPLETE); |
|
143
|
|
|
echo "[-] DeployJob finished" . PHP_EOL; |
|
144
|
|
|
} |
|
145
|
|
|
|
|
146
|
|
|
public function onFailure(Exception $exception) { |
|
147
|
|
|
$this->updateStatus(DNDeployment::TR_FAIL); |
|
148
|
|
|
} |
|
149
|
|
|
|
|
150
|
|
|
/** |
|
151
|
|
|
* @param string $status Transition |
|
152
|
|
|
* @global array $databaseConfig |
|
153
|
|
|
*/ |
|
154
|
|
|
protected function updateStatus($status) { |
|
155
|
|
|
global $databaseConfig; |
|
156
|
|
|
DB::connect($databaseConfig); |
|
157
|
|
|
$deployment = DNDeployment::get()->byID($this->args['deploymentID']); |
|
158
|
|
|
$deployment->getMachine()->apply($status); |
|
159
|
|
|
} |
|
160
|
|
|
|
|
161
|
|
|
/** |
|
162
|
|
|
* @param string $status Status of DNDataTransfer |
|
163
|
|
|
* @global array $databaseConfig |
|
164
|
|
|
*/ |
|
165
|
|
View Code Duplication |
protected function updateBackupStatus($status) { |
|
|
|
|
|
|
166
|
|
|
global $databaseConfig; |
|
167
|
|
|
DB::connect($databaseConfig); |
|
168
|
|
|
$deployment = DNDeployment::get()->byID($this->args['deploymentID']); |
|
169
|
|
|
$backup = $deployment->BackupDataTransfer(); |
|
170
|
|
|
if($backup && $backup->exists()) { |
|
171
|
|
|
$backup->Status = $status; |
|
172
|
|
|
$backup->write(); |
|
173
|
|
|
} |
|
174
|
|
|
} |
|
175
|
|
|
|
|
176
|
|
|
/** |
|
177
|
|
|
* @return DNData |
|
178
|
|
|
*/ |
|
179
|
|
|
protected function DNData() { |
|
180
|
|
|
return DNData::inst(); |
|
181
|
|
|
} |
|
182
|
|
|
} |
|
183
|
|
|
|
silverstripe /
deploynaut
Loading history...
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.