297 lines
9.8 KiB
PHP
297 lines
9.8 KiB
PHP
<?php
|
||
|
||
use libphonenumber\NumberParseException;
|
||
use libphonenumber\PhoneNumberFormat;
|
||
use libphonenumber\PhoneNumberUtil;
|
||
|
||
class ModemHandler extends RequestHandler
|
||
{
|
||
|
||
public function __construct()
|
||
{
|
||
parent::__construct();
|
||
$this->tpl->add_static('modem.js');
|
||
}
|
||
|
||
public function GET_status_page() {
|
||
global $config;
|
||
|
||
$this->tpl->set([
|
||
'modems' => $config['modems'],
|
||
'js_modems' => array_keys($config['modems']),
|
||
]);
|
||
|
||
$this->tpl->set_title('Состояние модемов');
|
||
$this->tpl->render_page('modem_status_page.twig');
|
||
}
|
||
|
||
public function GET_status_get_ajax() {
|
||
global $config;
|
||
list($id) = $this->input('id');
|
||
if (!isset($config['modems'][$id]))
|
||
ajax_error('invalid modem id: '.$id);
|
||
|
||
$modem_data = self::getModemData(
|
||
$config['modems'][$id]['ip'],
|
||
$config['modems'][$id]['legacy_token_auth']);
|
||
|
||
ajax_ok([
|
||
'html' => $this->tpl->render('modem_data.twig', [
|
||
'loading' => false,
|
||
'modem' => $id,
|
||
'modem_data' => $modem_data
|
||
])
|
||
]);
|
||
}
|
||
|
||
public function GET_verbose_page() {
|
||
global $config;
|
||
|
||
list($modem) = $this->input('modem');
|
||
if (!$modem)
|
||
$modem = array_key_first($config['modems']);
|
||
|
||
list($signal, $status, $traffic, $device, $dialup_conn) = self::getModemData(
|
||
$config['modems'][$modem]['ip'],
|
||
$config['modems'][$modem]['legacy_token_auth'],
|
||
true);
|
||
|
||
$data = [
|
||
['Signal', $signal],
|
||
['Connection', $status],
|
||
['Traffic', $traffic],
|
||
['Device info', $device],
|
||
['Dialup connection', $dialup_conn]
|
||
];
|
||
$this->tpl->set([
|
||
'data' => $data,
|
||
'modem_name' => $config['modems'][$modem]['label'],
|
||
]);
|
||
$this->tpl->set_title('Подробная информация о модеме '.$modem);
|
||
$this->tpl->render_page('modem_verbose_page.twig');
|
||
}
|
||
|
||
|
||
public function GET_routing_smallhome_page() {
|
||
global $config;
|
||
|
||
list($error) = $this->input('error');
|
||
$upstream = self::getCurrentSmallHomeUpstream();
|
||
|
||
$current_upstream = [
|
||
'key' => $upstream,
|
||
'label' => $config['modems'][$upstream]['label']
|
||
];
|
||
|
||
$this->tpl->set([
|
||
'error' => $error,
|
||
'current' => $current_upstream,
|
||
'modems' => $config['modems'],
|
||
]);
|
||
$this->tpl->set_title('Маршрутизация');
|
||
$this->tpl->render_page('routing_page.twig');
|
||
}
|
||
|
||
public function GET_routing_smallhome_switch() {
|
||
global $config;
|
||
list($new_upstream) = $this->input('upstream');
|
||
if (!isset($config['modems'][$new_upstream]))
|
||
redirect('/routing/?error='.urlencode('invalid upstream'));
|
||
|
||
$current_upstream = self::getCurrentSmallHomeUpstream();
|
||
if ($current_upstream != $new_upstream) {
|
||
if ($current_upstream != $config['routing_default'])
|
||
MyOpenWrtUtils::ipsetDel($current_upstream, $config['routing_smallhome_ip']);
|
||
if ($new_upstream != $config['routing_default'])
|
||
MyOpenWrtUtils::ipsetAdd($new_upstream, $config['routing_smallhome_ip']);
|
||
}
|
||
|
||
redirect('/routing/');
|
||
}
|
||
|
||
public function GET_routing_ipsets_page() {
|
||
list($error) = $this->input('error');
|
||
|
||
$ip_sets = MyOpenWrtUtils::ipsetListAll();
|
||
$this->tpl->set([
|
||
'sets' => $ip_sets,
|
||
'error' => $error
|
||
]);
|
||
$this->tpl->set_title('Маршрутизация: IP sets');
|
||
$this->tpl->render_page('routing_ipsets_page.twig');
|
||
}
|
||
|
||
public function GET_routing_ipsets_del() {
|
||
list($set, $ip) = $this->input('set, ip');
|
||
self::validateIpsetsInput($set, $ip);
|
||
|
||
$output = MyOpenWrtUtils::ipsetDel($set, $ip);
|
||
|
||
$url = '/routing/ipsets/';
|
||
if ($output != '')
|
||
$url .= '?error='.urlencode($output);
|
||
redirect($url);
|
||
}
|
||
|
||
public function POST_routing_ipsets_add() {
|
||
list($set, $ip) = $this->input('set, ip');
|
||
self::validateIpsetsInput($set, $ip);
|
||
|
||
$output = MyOpenWrtUtils::ipsetAdd($set, $ip);
|
||
|
||
$url = '/routing/ipsets/';
|
||
if ($output != '')
|
||
$url .= '?error='.urlencode($output);
|
||
redirect($url);
|
||
}
|
||
|
||
public function GET_routing_dhcp_page() {
|
||
$overrides = config::get('dhcp_hostname_overrides');
|
||
$leases = MyOpenWrtUtils::getDHCPLeases();
|
||
foreach ($leases as &$lease) {
|
||
if ($lease['hostname'] == '?' && array_key_exists($lease['mac'], $overrides))
|
||
$lease['hostname'] = $overrides[$lease['mac']];
|
||
}
|
||
$this->tpl->set([
|
||
'leases' => $leases
|
||
]);
|
||
$this->tpl->set_title('Маршрутизация: DHCP');
|
||
$this->tpl->render_page('routing_dhcp_page.twig');
|
||
}
|
||
|
||
public function GET_sms() {
|
||
global $config;
|
||
|
||
list($selected, $is_outbox, $error, $sent) = $this->input('modem, b:outbox, error, b:sent');
|
||
if (!$selected)
|
||
$selected = array_key_first($config['modems']);
|
||
|
||
$cfg = $config['modems'][$selected];
|
||
$e3372 = new E3372($cfg['ip'], $cfg['legacy_token_auth']);
|
||
$messages = $e3372->getSMSList(1, 20, $is_outbox);
|
||
|
||
$this->tpl->set([
|
||
'modems_list' => array_keys($config['modems']),
|
||
'modems' => $config['modems'],
|
||
'selected_modem' => $selected,
|
||
'messages' => $messages,
|
||
'is_outbox' => $is_outbox,
|
||
'error' => $error,
|
||
'is_sent' => $sent
|
||
]);
|
||
|
||
$direction = $is_outbox ? 'исходящие' : 'входящие';
|
||
$this->tpl->set_title('SMS-сообщения ('.$direction.', '.$selected.')');
|
||
$this->tpl->render_page('sms_page.twig');
|
||
}
|
||
|
||
public function POST_sms() {
|
||
global $config;
|
||
|
||
list($selected, $is_outbox, $phone, $text) = $this->input('modem, b:outbox, phone, text');
|
||
if (!$selected)
|
||
$selected = array_key_first($config['modems']);
|
||
|
||
$return_url = '/sms/?modem='.$selected;
|
||
if ($is_outbox)
|
||
$return_url .= '&outbox=1';
|
||
|
||
$go_back = function(?string $error = null) use ($return_url) {
|
||
if (!is_null($error))
|
||
$return_url .= '&error='.urlencode($error);
|
||
else
|
||
$return_url .= '&sent=1';
|
||
redirect($return_url);
|
||
};
|
||
|
||
$phone = preg_replace('/\s+/', '', $phone);
|
||
|
||
// при отправке смс на короткие номера не надо использовать libphonenumber и вот это вот всё
|
||
if (strlen($phone) > 4) {
|
||
$country = null;
|
||
if (!startsWith($phone, '+'))
|
||
$country = 'RU';
|
||
|
||
$phoneUtil = PhoneNumberUtil::getInstance();
|
||
try {
|
||
$number = $phoneUtil->parse($phone, $country);
|
||
} catch (NumberParseException $e) {
|
||
debugError(__METHOD__.': failed to parse number '.$phone.': '.$e->getMessage());
|
||
$go_back('Неверный номер ('.$e->getMessage().')');
|
||
return;
|
||
}
|
||
|
||
if (!$phoneUtil->isValidNumber($number)) {
|
||
$go_back('Неверный номер');
|
||
return;
|
||
}
|
||
|
||
$phone = $phoneUtil->format($number, PhoneNumberFormat::E164);
|
||
}
|
||
|
||
$cfg = $config['modems'][$selected];
|
||
$e3372 = new E3372($cfg['ip'], $cfg['legacy_token_auth']);
|
||
|
||
$result = $e3372->sendSMS($phone, $text);
|
||
debugLog($result);
|
||
|
||
$go_back();
|
||
}
|
||
|
||
protected static function getModemData(string $ip,
|
||
bool $need_auth = true,
|
||
bool $get_raw_data = false): array {
|
||
$modem = new E3372($ip, $need_auth);
|
||
|
||
$signal = $modem->getDeviceSignal();
|
||
$status = $modem->getMonitoringStatus();
|
||
$traffic = $modem->getTrafficStats();
|
||
|
||
if ($get_raw_data) {
|
||
$device_info = $modem->getDeviceInformation();
|
||
$dialup_conn = $modem->getDialupConnection();
|
||
return [$signal, $status, $traffic, $device_info, $dialup_conn];
|
||
} else {
|
||
return [
|
||
'type' => e3372::getNetworkTypeLabel($status['CurrentNetworkType']),
|
||
'level' => $status['SignalIcon'] ?? 0,
|
||
'rssi' => $signal['rssi'],
|
||
'sinr' => $signal['sinr'],
|
||
'connected_time' => secondsToTime($traffic['CurrentConnectTime']),
|
||
'downloaded' => bytesToUnitsLabel(gmp_init($traffic['CurrentDownload'])),
|
||
'uploaded' => bytesToUnitsLabel(gmp_init($traffic['CurrentUpload'])),
|
||
];
|
||
}
|
||
}
|
||
|
||
protected static function getCurrentSmallHomeUpstream() {
|
||
global $config;
|
||
|
||
$upstream = null;
|
||
$ip_sets = MyOpenWrtUtils::ipsetListAll();
|
||
foreach ($ip_sets as $set => $ips) {
|
||
if (in_array($config['routing_smallhome_ip'], $ips)) {
|
||
$upstream = $set;
|
||
break;
|
||
}
|
||
}
|
||
if (is_null($upstream))
|
||
$upstream = $config['routing_default'];
|
||
|
||
return $upstream;
|
||
}
|
||
|
||
protected static function validateIpsetsInput($set, $ip) {
|
||
global $config;
|
||
|
||
if (!isset($config['modems'][$set]))
|
||
redirect('/routing/ipsets/?error='.urlencode('invalid set: '.$set));
|
||
|
||
if (($slashpos = strpos($ip, '/')) !== false)
|
||
$ip = substr($ip, 0, $slashpos);
|
||
|
||
if (!filter_var($ip, FILTER_VALIDATE_IP))
|
||
redirect('/routing/ipsets/?error='.urlencode('invalid ip/network: '.$ip));
|
||
}
|
||
|
||
} |