|
1
|
|
|
<?php |
|
2
|
|
|
/** |
|
3
|
|
|
* This class will queue a ping job and also proxy to the log file of that output |
|
4
|
|
|
* |
|
5
|
|
|
* @property string $ResqueToken |
|
6
|
|
|
* |
|
7
|
|
|
* @method DNEnvironment Environment() |
|
8
|
|
|
* @property int EnvironmentID |
|
9
|
|
|
* @method Member Deployer() |
|
10
|
|
|
* @property int DeployerID |
|
11
|
|
|
*/ |
|
12
|
|
|
class DNPing extends DataObject { |
|
|
|
|
|
|
13
|
|
|
|
|
14
|
|
|
/** |
|
15
|
|
|
* @var array |
|
16
|
|
|
*/ |
|
17
|
|
|
private static $db = array( |
|
18
|
|
|
"ResqueToken" => "Varchar(255)", |
|
19
|
|
|
); |
|
20
|
|
|
|
|
21
|
|
|
/** |
|
22
|
|
|
* @var array |
|
23
|
|
|
*/ |
|
24
|
|
|
private static $has_one = array( |
|
25
|
|
|
"Environment" => "DNEnvironment", |
|
26
|
|
|
"Deployer" =>"Member", |
|
27
|
|
|
); |
|
28
|
|
|
|
|
29
|
|
|
/** |
|
30
|
|
|
* @return string |
|
31
|
|
|
*/ |
|
32
|
|
|
public function Link() { |
|
33
|
|
|
return Controller::join_links($this->Environment()->Link(), 'ping', $this->ID); |
|
34
|
|
|
} |
|
35
|
|
|
|
|
36
|
|
|
/** |
|
37
|
|
|
* @return string |
|
38
|
|
|
*/ |
|
39
|
|
|
public function LogLink() { |
|
40
|
|
|
return $this->Link() . '/log'; |
|
41
|
|
|
} |
|
42
|
|
|
|
|
43
|
|
|
/** |
|
44
|
|
|
* @param Member|null $member |
|
45
|
|
|
* @return bool |
|
46
|
|
|
*/ |
|
47
|
|
|
public function canView($member = null) { |
|
48
|
|
|
return $this->Environment()->canView($member); |
|
49
|
|
|
} |
|
50
|
|
|
|
|
51
|
|
|
/** |
|
52
|
|
|
* Return a path to the log file. |
|
53
|
|
|
* @return string |
|
54
|
|
|
*/ |
|
55
|
|
|
protected function logfile() { |
|
56
|
|
|
return sprintf( |
|
57
|
|
|
'%s.ping.%s.log', |
|
58
|
|
|
$this->Environment()->getFullName('.'), |
|
59
|
|
|
$this->ID |
|
60
|
|
|
); |
|
61
|
|
|
} |
|
62
|
|
|
|
|
63
|
|
|
/** |
|
64
|
|
|
* @return \DeploynautLogFile |
|
65
|
|
|
*/ |
|
66
|
|
|
public function log() { |
|
67
|
|
|
return new DeploynautLogFile($this->logfile()); |
|
68
|
|
|
} |
|
69
|
|
|
|
|
70
|
|
|
/** |
|
71
|
|
|
* @return string |
|
72
|
|
|
*/ |
|
73
|
|
|
public function LogContent() { |
|
74
|
|
|
return $this->log()->content(); |
|
75
|
|
|
} |
|
76
|
|
|
|
|
77
|
|
|
/** |
|
78
|
|
|
* @return string |
|
79
|
|
|
*/ |
|
80
|
|
View Code Duplication |
public function ResqueStatus() { |
|
|
|
|
|
|
81
|
|
|
$status = new Resque_Job_Status($this->ResqueToken); |
|
|
|
|
|
|
82
|
|
|
|
|
83
|
|
|
$remap = array( |
|
84
|
|
|
Resque_Job_Status::STATUS_WAITING => "Queued", |
|
85
|
|
|
Resque_Job_Status::STATUS_RUNNING => "Running", |
|
86
|
|
|
Resque_Job_Status::STATUS_FAILED => "Failed", |
|
87
|
|
|
Resque_Job_Status::STATUS_COMPLETE => "Complete", |
|
88
|
|
|
false => "Invalid", |
|
89
|
|
|
); |
|
90
|
|
|
|
|
91
|
|
|
return $remap[$status->get()]; |
|
92
|
|
|
} |
|
93
|
|
|
|
|
94
|
|
|
/** |
|
95
|
|
|
* Queue a ping job |
|
96
|
|
|
*/ |
|
97
|
|
|
public function start() { |
|
98
|
|
|
$environment = $this->Environment(); |
|
99
|
|
|
$project = $environment->Project(); |
|
100
|
|
|
$log = $this->log(); |
|
101
|
|
|
|
|
102
|
|
|
$args = array( |
|
103
|
|
|
'environmentName' => $environment->Name, |
|
104
|
|
|
'logfile' => $this->logfile(), |
|
105
|
|
|
'projectName' => $project->Name, |
|
106
|
|
|
'env' => $project->getProcessEnv(), |
|
107
|
|
|
'pingID' => $this->ID |
|
108
|
|
|
); |
|
109
|
|
|
|
|
110
|
|
|
if(!$this->DeployerID) { |
|
111
|
|
|
$this->DeployerID = Member::currentUserID(); |
|
112
|
|
|
} |
|
113
|
|
|
|
|
114
|
|
View Code Duplication |
if($this->DeployerID) { |
|
|
|
|
|
|
115
|
|
|
$deployer = $this->Deployer(); |
|
116
|
|
|
$message = sprintf( |
|
117
|
|
|
'Ping to %s initiated by %s (%s)', |
|
118
|
|
|
$environment->getFullName(), |
|
119
|
|
|
$deployer->getName(), |
|
120
|
|
|
$deployer->Email |
|
121
|
|
|
); |
|
122
|
|
|
$log->write($message); |
|
123
|
|
|
} |
|
124
|
|
|
|
|
125
|
|
|
$token = Resque::enqueue('deploy', 'PingJob', $args, true); |
|
126
|
|
|
$this->ResqueToken = $token; |
|
127
|
|
|
$this->write(); |
|
128
|
|
|
|
|
129
|
|
|
$message = sprintf('Ping queued as job %s', $token); |
|
130
|
|
|
$log->write($message); |
|
131
|
|
|
} |
|
132
|
|
|
} |
|
133
|
|
|
|
silverstripe /
deploynaut
Loading history...
This check marks property names that have not been written in camelCase.
In camelCase names are written without any punctuation, the start of each new word being marked by a capital letter. Thus the name database connection string becomes
databaseConnectionString.