Repository navigation
Expand file tree
/
Copy pathsiteMonitor.php
More file actions
160 lines (128 loc) · 6.08 KB
/
Copy pathsiteMonitor.php
File metadata and controls
160 lines (128 loc) · 6.08 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
<?php
// Создаем дочерний процесс
$child_pid = pcntl_fork();
if ($child_pid) {
// Выходим из родительского, привязанного к консоли, процесса
exit();
}
// Делаем основным процессом дочерний.
posix_setsid();
$baseDir = dirname(__FILE__);
// Переопределяем вывод
ini_set('error_log',$baseDir.'/error.log');
fclose(STDIN);
fclose(STDOUT);
fclose(STDERR);
$STDIN = fopen('/dev/null', 'r');
$STDOUT = fopen($baseDir.'/application.log', 'ab');
$STDERR = fopen($baseDir.'/daemon.log', 'ab');
require_once $baseDir.'/vendor/autoload.php';
use Noodlehaus\Config;
use GuzzleHttp\Client;
// Получаем аргументы команды
$options = getopt('l:s::');
$link = $options['l'];
// Загружаем конфиг
if (!empty($options['s'])) {
$settings = Config::load($baseDir.'/settings/'.$options['s']);
} else {
$settings = Config::load($baseDir.'/settings/default.json');
}
// Создаем HTTP клиент
$httpClient = new Client();
// Создаем экземпляр транспорта сообщений
$messageTransportClassName = 'Monitor\Transport\\'.$settings->get('message_transport');
$messageTransport = new $messageTransportClassName($settings);
// Тут храним информацию об уже отправленных сообщениях
$sent = [];
// Тут храним время, когда обнаружено падение сайта
$failedTime = null;
while (1) {
try {
// Дергаем заголовки
// Ответы с ошибкой вызовут Exception.
$res = $httpClient->request('HEAD', $link);
// На случай если получим ответ 2**, который не вызовет Exception.
if ($res->getStatusCode() != 200) {
throw new \Exception('Status code isnot 200', $res->getStatusCode());
}
// Если до этого сайт лежал, а теперь поднялся
if ($failedTime !== null) {
// Если уже отправляли сообщения о падении
if (!empty($sent)) {
// то отправляем письмо о починке
if ($messageTransport->send(
"Server UP!\r\n" .
"link: $link\r\n" .
'Was failed from: ' . getFormattedTime($failedTime) . "\r\n",
'Server UP!'
)
) {
echo getFormattedTime(time())." - $link - Status: {$res->getStatusCode()} The positive message was sent\n";
// Обнуляем данные об отправленных сообщениях
$sent = [];
// Обнуляем время падения
$failedTime = null;
} else {
echo getFormattedTime(time())." - $link - Status: {$res->getStatusCode()} The positive message wasn`t sent\n";
}
} else {
// Обнуляем время падения
$failedTime = null;
}
} else {
echo getFormattedTime(time()).' - '.$link.' - Status: '.$res->getStatusCode()."\n";
}
} catch (\Exception $e) {
// Если это первый ответ с ошибкой, то просто запоминаем время его получения.
if ($failedTime === null) {
$failedTime = time();
// Если это НЕ первый ответ с ошибкой
// И если количество уже отправленных сообщений меньше количества возможных сообщений в конфиге
} elseif (count($sent) < count($settings->get('time'))) {
$time = time();
// Считаем сколько времени сайт лежит
$difference = $time - $failedTime;
// Если время простоя больше времени отправки следующего письма
if ($difference >= $settings->get('time')[count($sent)]) {
// отсылаем письмо о падении
if ($messageTransport->send(
"The server is down!\r\n".
"link: $link\r\n".
"code: {$e->getCode()}\r\n".
"message: {$e->getMessage()}\r\n".
'Is failed from: '.getFormattedTime($failedTime)."\r\n".
'Down time: '.getFormattedInterval($difference)."\r\n".
'Notification #'.(count($sent)+1)."\r\n",
'Server down'
)
){
// Запоминаем время отправки письма
echo getFormattedTime(time())." - $link - Status: {$e->getCode()} The negative message was sent\n";
$sent[] = $time;
} else {
echo getFormattedTime(time())." - $link - Status: {$e->getCode()} The negative message wasn`t sent\n";
}
}
}
}
sleep($settings->get('delay'));
}
/**
* Отформатировать юникс время в читаемую дату-время
*
* @param $timestamp
* @return string
*/
function getFormattedTime($timestamp) {
return \DateTime::createFromFormat('U', $timestamp)->format('H:i:s d.m.Y');
}
/**
* Отформатировать юникс время в читаемый интервал времени
*
* @param $timestamp
* @return string
*/
function getFormattedInterval($timestamp) {
return (new \DateInterval('PT'.$timestamp.'S'))->format('%d days %H hours %i minutes');
}