Browse Source

refactor: interface of ntp check

master
Dnomd343 3 years ago
parent
commit
860687de69
  1. 2
      cmdRoute.php
  2. 4
      models/ipInfo.php
  3. 181
      models/ntpCheck.php

2
cmdRoute.php

@ -28,7 +28,7 @@ function route($cmd, $rawParam) { // 命令请求路由
$entry = new kmsCheckEntry; $entry = new kmsCheckEntry;
break; break;
case 'ntp': case 'ntp':
ntpCheck($rawParam); $entry = new ntpCheckEntry;
break; break;
case 'cfop': case 'cfop':
cfopPic($rawParam); cfopPic($rawParam);

4
models/ipInfo.php

@ -184,6 +184,10 @@ class ipInfoEntry {
if (filter_var($rawParam, FILTER_VALIDATE_IP)) { // 参数为IP地址 if (filter_var($rawParam, FILTER_VALIDATE_IP)) { // 参数为IP地址
$this->query($rawParam); $this->query($rawParam);
} else { // 参数为域名 } else { // 参数为域名
global $tgEnv;
tgApi::deleteMessage(array(
'message_id' => $tgEnv['messageId']
));
$ips = $this->dnsResolve($rawParam); $ips = $this->dnsResolve($rawParam);
foreach ($ips as $ip) { foreach ($ips as $ip) {
$this->query($ip); // 逐个输出 $this->query($ip); // 逐个输出

181
models/ntpCheck.php

@ -13,7 +13,7 @@ class ntpList {
return $res->fetchArray(SQLITE3_ASSOC)['name']; return $res->fetchArray(SQLITE3_ASSOC)['name'];
} }
private function getNtpList() { // 获取所有NTP服务器地址 public function getNtpList() { // 获取所有NTP服务器地址
$db = new ntpDB; $db = new ntpDB;
$res = $db->query('SELECT * FROM `ntp_host`;'); $res = $db->query('SELECT * FROM `ntp_host`;');
while ($row = $res->fetchArray(SQLITE3_ASSOC)) { while ($row = $res->fetchArray(SQLITE3_ASSOC)) {
@ -23,62 +23,16 @@ class ntpList {
} }
return $data; return $data;
} }
private function hashGroupName($str) { // 计算组名的哈希值 取前12位
return substr(md5($str), 0, 12);
}
public function showList() { // 列出所有NTP服务器组
$ntpList = $this->getNtpList();
foreach ($ntpList as $index => $ntpHosts) {
$buttons[] = array([ // 生成按钮列表
'text' => $index,
'callback_data' => '/ntp ' . $this->hashGroupName($index)
]);
}
return array(
'text' => 'Which one did you like?',
'reply_markup' => json_encode(array( // 列表按钮
'inline_keyboard' => $buttons
))
);
}
public function showNtpServer($targetGroup) { // 列出指定组的NTP服务器
$ntpList = $this->getNtpList();
foreach ($ntpList as $index => $ntpHosts) {
if ($this->hashGroupName($index) === $targetGroup) { break; }
}
$msg = '*' . $index . '*' . PHP_EOL;
foreach ($ntpHosts as $ntpHost) {
if ($ntpHost['desc'] !== '') {
$msg .= $ntpHost['desc'] . ':';
}
$msg .= '`' . $ntpHost['host'] . '`' . PHP_EOL;
}
return array(
'parse_mode' => 'Markdown',
'text' => $msg,
'reply_markup' => json_encode(array(
'inline_keyboard' => array([[
'text' => ' << Go back <<',
'callback_data' => '/ntp servers'
]])
))
);
}
} }
class ntpCheck { class ntpCheck {
private function isHost($host) { // 判断host是否合法 private function formatOffset($str) { // 格式化Offset
preg_match('/^(?=^.{3,255}$)[a-zA-Z0-9][-a-zA-Z0-9]{0,62}(\.[a-zA-Z0-9][-a-zA-Z0-9]{0,62})+$/', $host, $match); $num = number_format($str, 6) * 1000; // s -> ms
if (count($match) !== 0) { // 域名 $str = sprintf("%1\$.3f", $num); // 补零到小数点后3位
if (!is_numeric(substr($host, -1))) { return true; } // 域名最后一位不为数字 if ($num > 0) {
} $str = '+' . $str; // 正数前加+
if (filter_var($host, FILTER_VALIDATE_IP)) { // IP地址
return true;
} }
return false; return $str . 'ms';
} }
private function curlPost($url, $data) { // curl模拟post操作 40s超时 private function curlPost($url, $data) { // curl模拟post操作 40s超时
@ -130,29 +84,13 @@ class ntpCheck {
if (!filter_var($group['Server'], FILTER_VALIDATE_IP)) { continue; } if (!filter_var($group['Server'], FILTER_VALIDATE_IP)) { continue; }
unset($group['Result']); unset($group['Result']);
unset($group['ok']); unset($group['ok']);
$group['Offset'] = $this->formatOffset($group['Offset']); // 转换为ms
$data[] = $group; $data[] = $group;
} }
return ($data === null) ? array() : $data; return ($data === null) ? array() : $data;
} }
public function checkHost($host) { // 检测host合法性 public function ntpStatus($host) { // 检测NTP服务器状态 带缓存
if ($this->isHost($host)) {
return array('status' => 'ok');
} else {
return array('status' => 'error');
}
}
private function formatOffset($str) { // 格式化Offset
$num = number_format($str, 6) * 1000; // s -> ms
$str = sprintf("%1\$.3f", $num); // 补零到小数点后3位
if ($num > 0) {
$str = '+' . $str; // 正数前加+
}
return $str . 'ms';
}
private function ntpStatus($host) { // 检测NTP服务器状态 带缓存
$redis = new redisCache('ntp'); $redis = new redisCache('ntp');
$servers = $redis->getData($host); // 查询缓存数据 $servers = $redis->getData($host); // 查询缓存数据
if (!$servers) { // 缓存未命中 if (!$servers) { // 缓存未命中
@ -163,9 +101,66 @@ class ntpCheck {
} }
return $servers; return $servers;
} }
}
public function checkNtp($host) { class ntpCheckEntry {
$servers = $this->ntpStatus($host); private function isHost($host) { // 判断host是否合法
preg_match('/^(?=^.{3,255}$)[a-zA-Z0-9][-a-zA-Z0-9]{0,62}(\.[a-zA-Z0-9][-a-zA-Z0-9]{0,62})+$/', $host, $match);
if (count($match) !== 0) { // 域名
if (!is_numeric(substr($host, -1))) { return true; } // 域名最后一位不为数字
}
if (filter_var($host, FILTER_VALIDATE_IP)) { // IP地址
return true;
}
return false;
}
private function hashGroupName($str) { // 计算组名的哈希值 取前12位
return substr(md5($str), 0, 12);
}
private function showList() { // 列出所有NTP服务器组
$ntpList = (new ntpList)->getNtpList();
foreach ($ntpList as $index => $ntpHosts) {
$buttons[] = array([ // 生成按钮列表
'text' => $index,
'callback_data' => '/ntp ' . $this->hashGroupName($index)
]);
}
return array(
'text' => 'Which one did you like?',
'reply_markup' => json_encode(array( // 列表按钮
'inline_keyboard' => $buttons
))
);
}
private function showNtpServer($targetGroup) { // 列出指定组的NTP服务器
$ntpList = (new ntpList)->getNtpList();
foreach ($ntpList as $index => $ntpHosts) {
if ($this->hashGroupName($index) === $targetGroup) { break; }
}
$msg = '*' . $index . '*' . PHP_EOL;
foreach ($ntpHosts as $ntpHost) {
if ($ntpHost['desc'] !== '') {
$msg .= $ntpHost['desc'] . ':';
}
$msg .= '`' . $ntpHost['host'] . '`' . PHP_EOL;
}
return array(
'parse_mode' => 'Markdown',
'text' => $msg,
'reply_markup' => json_encode(array(
'inline_keyboard' => array([[
'text' => ' << Go back <<',
'callback_data' => '/ntp servers'
]])
))
);
}
private function checkNtp($host) { // 检查NTP服务器状态
$servers = (new ntpCheck)->ntpStatus($host);
if (count($servers) === 0) { if (count($servers) === 0) {
$msg = '`' . $host . '`' . PHP_EOL; $msg = '`' . $host . '`' . PHP_EOL;
$msg .= 'NTP Server *Offline*' . PHP_EOL . PHP_EOL; $msg .= 'NTP Server *Offline*' . PHP_EOL . PHP_EOL;
@ -179,7 +174,7 @@ class ntpCheck {
foreach ($servers as $server) { foreach ($servers as $server) {
$msg .= '`' . $server['Server'] . '`' . PHP_EOL; $msg .= '`' . $server['Server'] . '`' . PHP_EOL;
$msg .= '_Stratum:_ ' . $server['Stratum'] . PHP_EOL; $msg .= '_Stratum:_ ' . $server['Stratum'] . PHP_EOL;
$msg .= '_Offset:_ ' . $this->formatOffset($server['Offset']) . PHP_EOL; $msg .= '_Offset:_ ' . $server['Offset'] . PHP_EOL;
$msg .= PHP_EOL; $msg .= PHP_EOL;
} }
return array( return array(
@ -187,12 +182,10 @@ class ntpCheck {
'text' => $msg 'text' => $msg
); );
} }
}
function ntpCheck($rawParam) { // NTP测试入口 public function query($rawParam) { // NTP测试查询入口
global $chatId;
if ($rawParam == '' || $rawParam === 'help') { // 显示使用说明 if ($rawParam == '' || $rawParam === 'help') { // 显示使用说明
sendMessage($chatId, array( tgApi::sendMessage(array(
'parse_mode' => 'Markdown', 'parse_mode' => 'Markdown',
'text' => '*Usage:* `/ntp IP/Domain`', 'text' => '*Usage:* `/ntp IP/Domain`',
'reply_markup' => json_encode(array( // 获取NTP服务列表 'reply_markup' => json_encode(array( // 获取NTP服务列表
@ -204,33 +197,31 @@ function ntpCheck($rawParam) { // NTP测试入口
)); ));
return; return;
} }
if ((new ntpCheck)->checkHost($rawParam)['status'] === 'error') { if (!$this->isHost($rawParam)) {
sendText($chatId, 'Illegal host'); // 输入错误 tgApi::sendText('Illegal host'); // 输入错误
return; return;
} }
$message = json_decode(sendMessage($chatId, array( $message = json_decode(tgApi::sendMessage(array(
'parse_mode' => 'Markdown', 'parse_mode' => 'Markdown',
'text' => '`' . $rawParam . '`' . PHP_EOL . 'NTP Server Checking...' 'text' => '`' . $rawParam . '`' . PHP_EOL . 'NTP Server Checking...'
)), true); )), true);
sendPayload(array( fastcgi_finish_request(); // 断开连接
'method' => 'editMessageText', tgApi::editMessage(array(
'chat_id' => $chatId,
'message_id' => $message['result']['message_id'], 'message_id' => $message['result']['message_id'],
) + (new ntpCheck)->checkNtp($rawParam)); // 发起查询并返回结果 ) + $this->checkNtp($rawParam)); // 发起查询并返回结果
} }
function ntpCheckCallback($rawParam) { // NTP测试回调入口 public function callback($rawParam) { // NTP测试回调入口
global $chatId, $messageId; global $tgEnv;
if ($rawParam === 'servers') { if ($rawParam === 'servers') {
$content = (new ntpList)->showList(); // 显示可选组 $content = $this->showList(); // 显示可选组
} else { } else {
$content = (new ntpList)->showNtpServer($rawParam); // 显示指定组的服务器列表 $content = $this->showNtpServer($rawParam); // 显示指定组的服务器列表
}
tgApi::editMessage(array(
'message_id' => $tgEnv['messageId']
) + $content); // 输出结果
} }
sendPayload(array(
'method' => 'editMessageText',
'chat_id' => $chatId,
'message_id' => $messageId
) + $content);
} }
?> ?>

Loading…
Cancel
Save