442 lines
15 KiB
PHP
442 lines
15 KiB
PHP
<?php
|
|
/*
|
|
FusionPBX
|
|
Version: MPL 1.1
|
|
|
|
The contents of this file are subject to the Mozilla Public License Version
|
|
1.1 (the "License"); you may not use this file except in compliance with
|
|
the License. You may obtain a copy of the License at
|
|
http://www.mozilla.org/MPL/
|
|
|
|
Software distributed under the License is distributed on an "AS IS" basis,
|
|
WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
|
for the specific language governing rights and limitations under the
|
|
License.
|
|
|
|
The Original Code is FusionPBX
|
|
|
|
The Initial Developer of the Original Code is
|
|
Mark J Crane <markjcrane@fusionpbx.com>
|
|
Portions created by the Initial Developer are Copyright (C) 2008-2023
|
|
the Initial Developer. All Rights Reserved.
|
|
|
|
Contributor(s):
|
|
Mark J Crane <markjcrane@fusionpbx.com>
|
|
*/
|
|
|
|
class registrations {
|
|
|
|
/**
|
|
* declare private variables
|
|
*/
|
|
private $app_name;
|
|
private $app_uuid;
|
|
private $permission_prefix;
|
|
private $list_page;
|
|
public $show;
|
|
private $domain_name;
|
|
|
|
/**
|
|
* Set in the constructor. Must be a database object and cannot be null.
|
|
* @var database Database Object
|
|
*/
|
|
private $database;
|
|
|
|
/**
|
|
* Set in the constructor. Must be an event_socket object and cannot be null.
|
|
* @var event_socket Event Socket Connection Object
|
|
*/
|
|
private $event_socket;
|
|
|
|
/**
|
|
* called when the object is created
|
|
*/
|
|
public function __construct($setting_array = []) {
|
|
|
|
//open a database connection
|
|
if (empty($setting_array['database'])) {
|
|
$this->database = database::new();
|
|
}
|
|
else {
|
|
$this->database = $setting_array['database'];
|
|
}
|
|
|
|
//trap passing a PDO object instead of the required database object
|
|
if (!($this->database instanceof database)) {
|
|
//should never happen but will trap it here just in case
|
|
throw new \InvalidArgumentException("Database object passed in the constructor is not a valid database object");
|
|
}
|
|
|
|
if (!empty($setting_array['event_socket'])) {
|
|
$this->event_socket = $setting_array['event_socket'];
|
|
}
|
|
else {
|
|
$this->event_socket = event_socket::create();
|
|
}
|
|
|
|
//trap passing an invalid connection object for communicating to the switch
|
|
if (!($this->event_socket instanceof event_socket)) {
|
|
//should never happen but will trap it here just in case
|
|
throw new \InvalidArgumentException('Event socket object passed in the constructor is not a valid event_socket object');
|
|
}
|
|
|
|
//assign private variables
|
|
$this->app_name = 'registrations';
|
|
$this->app_uuid = '5d9e7cd7-629e-3553-4cf5-f26e39fefa39';
|
|
$this->permission_prefix = 'registration_';
|
|
$this->list_page = 'registrations.php';
|
|
$this->show = 'local';
|
|
|
|
//get the domain_name
|
|
if (empty($setting_array['domain_name'])) {
|
|
$this->domain_name = $_SESSION['domain_name'];
|
|
}
|
|
else {
|
|
$this->domain_name = $setting_array['domain_name'];
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* get the registrations
|
|
*/
|
|
public function get($profile = 'all') {
|
|
|
|
//initialize the id used in the registrations array
|
|
$id = 0;
|
|
|
|
//create the event socket connection
|
|
$event_socket = $this->event_socket;
|
|
|
|
//make sure the event socket is connected
|
|
if (!$event_socket->is_connected()) {
|
|
//connect to event socket
|
|
$event_socket->connect();
|
|
|
|
//check again and throw an error if it can't connect
|
|
if (!$event_socket->is_connected()) {
|
|
message::add($text['error-event-socket'], 'negative', 5000);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
//get the default settings
|
|
$sql = "select sip_profile_name from v_sip_profiles ";
|
|
$sql .= "where sip_profile_enabled = 'true' ";
|
|
if (!empty($profile) && $profile != 'all') {
|
|
$sql .= "and sip_profile_name = :sip_profile_name ";
|
|
$parameters['sip_profile_name'] = $profile;
|
|
}
|
|
$sql .= "and sip_profile_enabled = 'true' ";
|
|
$sip_profiles = $this->database->select($sql, $parameters ?? null, 'all');
|
|
|
|
if (!empty($sip_profiles)) {
|
|
|
|
//use a while loop to ensure the event socket stays connected while communicating
|
|
$count = count($sip_profiles);
|
|
$i = 0;
|
|
while ($event_socket->is_connected() && $i < $count) {
|
|
$field = $sip_profiles[$i++];
|
|
|
|
//get sofia status profile information including registrations
|
|
$cmd = "api sofia xmlstatus profile '".$field['sip_profile_name']."' reg";
|
|
$xml_response = trim($event_socket->request($cmd));
|
|
|
|
//show an error message
|
|
if ($xml_response == "Invalid Profile!") {
|
|
//add multi-lingual support
|
|
$language = new text;
|
|
$text = $language->get(null, '/app/registrations');
|
|
|
|
//show the error message
|
|
$xml_response = "<error_msg>".escape($text['label-message'])."</error_msg>";
|
|
}
|
|
|
|
//sanitize the XML
|
|
if (function_exists('iconv')) { $xml_response = iconv("utf-8", "utf-8//IGNORE", $xml_response); }
|
|
$xml_response = preg_replace('/[\x00-\x08\x0B\x0C\x0E-\x1F\x7F]/u', '', $xml_response);
|
|
$xml_response = str_replace("<profile-info>", "<profile_info>", $xml_response);
|
|
$xml_response = str_replace("</profile-info>", "</profile_info>", $xml_response);
|
|
$xml_response = str_replace("<", "", $xml_response);
|
|
$xml_response = str_replace(">", "", $xml_response);
|
|
if (strlen($xml_response) > 101) {
|
|
try {
|
|
$xml = new SimpleXMLElement($xml_response);
|
|
}
|
|
catch(Exception $e) {
|
|
echo basename(__FILE__)."<br />\n";
|
|
echo "line: ".__line__."<br />\n";
|
|
echo "error: ".$e->getMessage()."<br />\n";
|
|
//echo $xml_response;
|
|
exit;
|
|
}
|
|
$array = json_decode(json_encode($xml), true);
|
|
}
|
|
|
|
//normalize the array
|
|
if (!empty($array) && is_array($array) && (!isset($array['registrations']['registration'][0]) || !is_array($array['registrations']['registration'][0]))) {
|
|
$row = $array['registrations']['registration'];
|
|
unset($array['registrations']['registration']);
|
|
$array['registrations']['registration'][0] = $row;
|
|
}
|
|
|
|
//set the registrations array
|
|
if (!empty($array) && is_array($array)) {
|
|
foreach ($array['registrations']['registration'] as $row) {
|
|
|
|
//build the registrations array
|
|
//$registrations[0] = $row;
|
|
$user_array = explode('@', $row['user'] ?? '');
|
|
$registrations[$id]['user'] = $row['user'] ?? '';
|
|
$registrations[$id]['call-id'] = $row['call-id'] ?? '';
|
|
$registrations[$id]['contact'] = $row['contact'] ?? '';
|
|
$registrations[$id]['sip-auth-user'] = $row['sip-auth-user'] ?? '';
|
|
$registrations[$id]['agent'] = $row['agent'] ?? '';
|
|
$registrations[$id]['host'] = $row['host'] ?? '';
|
|
$registrations[$id]['network-ip'] = $row['network-ip'] ?? '';
|
|
$registrations[$id]['network-port'] = $row['network-port'] ?? '';
|
|
$registrations[$id]['sip-auth-user'] = $row['sip-auth-user'] ?? '';
|
|
$registrations[$id]['sip-auth-realm'] = $row['sip-auth-realm'] ?? '';
|
|
$registrations[$id]['mwi-account'] = $row['mwi-account'] ?? '';
|
|
$registrations[$id]['status'] = $row['status'] ?? '';
|
|
$registrations[$id]['ping-time'] = $row['ping-time'] ?? '';
|
|
$registrations[$id]['ping-status'] = $row['ping-status'] ?? '';
|
|
$registrations[$id]['sip_profile_name'] = $field['sip_profile_name'];
|
|
|
|
//get network-ip to url or blank
|
|
if (isset($row['network-ip'])) {
|
|
$registrations[$id]['network-ip'] = $row['network-ip'];
|
|
}
|
|
else {
|
|
$registrations[$id]['network-ip'] = '';
|
|
}
|
|
|
|
//get the LAN IP address if it exists replace the external ip
|
|
$call_id_array = explode('@', $row['call-id'] ?? '');
|
|
if (isset($call_id_array[1])) {
|
|
$agent = $row['agent'];
|
|
$lan_ip = $call_id_array[1];
|
|
if (!empty($agent) && false !== stripos($agent, 'grandstream')) {
|
|
$lan_ip = str_ireplace(
|
|
array('A','B','C','D','E','F','G','H','I','J'),
|
|
array('0','1','2','3','4','5','6','7','8','9'),
|
|
$lan_ip);
|
|
}
|
|
elseif (!empty($agent) && 1 === preg_match('/\ACL750A/', $agent)) {
|
|
//required for GIGASET Sculpture CL750A puts _ in it's lan ip account
|
|
$lan_ip = preg_replace('/_/', '.', $lan_ip);
|
|
}
|
|
$registrations[$id]['lan-ip'] = $lan_ip;
|
|
}
|
|
else if (preg_match('/real=\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/', $row['contact'] ?? '', $ip_match)) {
|
|
//get ip address for snom phones
|
|
$lan_ip = str_replace('real=', '', $ip_match[0]);
|
|
$registrations[$id]['lan-ip'] = $lan_ip;
|
|
}
|
|
else if (preg_match('/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/', $row['contact'] ?? '', $ip_match)) {
|
|
$lan_ip = preg_replace('/_/', '.', $ip_match[0]);
|
|
$registrations[$id]['lan-ip'] = $lan_ip;
|
|
}
|
|
else {
|
|
$registrations[$id]['lan-ip'] = '';
|
|
}
|
|
|
|
//remove unrelated domains
|
|
if (!permission_exists('registration_all') || $this->show != 'all') {
|
|
if ($registrations[$id]['sip-auth-realm'] == $this->domain_name) {}
|
|
else if ($user_array[1] == $this->domain_name) {}
|
|
else {
|
|
unset($registrations[$id]);
|
|
}
|
|
}
|
|
|
|
//increment the array id
|
|
$id++;
|
|
}
|
|
unset($array);
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
//return the registrations array
|
|
return $registrations ?? null;
|
|
}
|
|
|
|
/**
|
|
* get the registration count
|
|
*/
|
|
public function count($profile = 'all') {
|
|
|
|
//use get the registrations to count
|
|
$registrations = $this->get($profile);
|
|
|
|
//set the count
|
|
$count = !empty($registrations) ? @sizeof($registrations) : 0;
|
|
|
|
//return the registrations count
|
|
return $count;
|
|
|
|
}
|
|
|
|
/**
|
|
* unregister registrations
|
|
*/
|
|
public function unregister($registrations) {
|
|
$this->switch_api('unregister', $registrations);
|
|
}
|
|
|
|
/**
|
|
* provision registrations
|
|
*/
|
|
public function provision($registrations) {
|
|
$this->switch_api('provision', $registrations);
|
|
}
|
|
|
|
/**
|
|
* reboot registrations
|
|
*/
|
|
public function reboot($registrations) {
|
|
$this->switch_api('reboot', $registrations);
|
|
}
|
|
|
|
/**
|
|
* switch api calls
|
|
*/
|
|
private function switch_api($action, $records) {
|
|
if (permission_exists($this->permission_prefix.'domain') || permission_exists($this->permission_prefix.'all') || if_group('superadmin')) {
|
|
|
|
//add multi-lingual support
|
|
$language = new text;
|
|
$text = $language->get();
|
|
|
|
//validate the token
|
|
$token = new token;
|
|
if (!$token->validate($_SERVER['PHP_SELF'])) {
|
|
message::add($text['message-invalid_token'],'negative');
|
|
header('Location: '.$this->list_page);
|
|
exit;
|
|
}
|
|
|
|
//filter out unchecked registrations
|
|
if (is_array($records) && @sizeof($records) != 0) {
|
|
foreach($records as $record) {
|
|
if ($record['checked'] == 'true' && !empty($record['user']) && !empty($record['profile'])) {
|
|
$registrations[] = $record;
|
|
}
|
|
}
|
|
}
|
|
|
|
//process checked registrations
|
|
if (is_array($registrations) && @sizeof($registrations) != 0) {
|
|
|
|
//retrieve sip profiles list
|
|
$sql = "select sip_profile_name as name from v_sip_profiles ";
|
|
$sip_profiles = $this->database->select($sql, null, 'all');
|
|
unset($sql);
|
|
|
|
//create the event socket connection
|
|
$event_socket = $this->event_socket;
|
|
|
|
//loop through registrations
|
|
if ($event_socket->is_connected()) {
|
|
//check if registrations exist
|
|
if (is_array($registrations)) {
|
|
foreach ($registrations as $registration) {
|
|
|
|
//validate the submitted profile
|
|
if (!empty($registration['profile']) && is_array($sip_profiles) && @sizeof($sip_profiles) != 0) {
|
|
foreach ($sip_profiles as $field) {
|
|
if ($field['name'] == $registration['profile']) {
|
|
$profile = $registration['profile'];
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
header('Location: '.$this->list_page);
|
|
exit;
|
|
}
|
|
|
|
//validate the submitted user
|
|
if (!empty($registration['user'])) {
|
|
$user = preg_replace('#[^a-zA-Z0-9_\-\.\@]#', '', $registration['user']);
|
|
}
|
|
|
|
//validate the submitted host
|
|
if (!empty($registration['host'])) {
|
|
$host = preg_replace('#[^a-zA-Z0-9_\-\.]#', '', $registration['host']);
|
|
}
|
|
|
|
//lookup vendor by agent
|
|
if (!empty($registration['agent'])) {
|
|
$vendor = device::get_vendor_by_agent($registration['agent']);
|
|
}
|
|
|
|
//prepare the api command
|
|
if (!empty($profile) && $user) {
|
|
switch ($action) {
|
|
case 'unregister':
|
|
$command = "sofia profile ".$profile." flush_inbound_reg ".$user." reboot";
|
|
$response_message = $text['message-registrations_unregistered'];
|
|
break;
|
|
case 'provision':
|
|
if ($vendor && $host) {
|
|
$command = "lua app.lua event_notify ".$profile." check_sync ".$user." ".$vendor." ".$host;
|
|
$response_message = $text['message-registrations_provisioned'];
|
|
}
|
|
break;
|
|
case 'reboot':
|
|
if ($vendor && $host) {
|
|
$command = "lua app.lua event_notify ".$profile." reboot ".$user." ".$vendor." ".$host;
|
|
$response_message = $text['message-registrations_rebooted'];
|
|
}
|
|
break;
|
|
default:
|
|
header('Location: '.$this->list_page);
|
|
exit;
|
|
}
|
|
}
|
|
|
|
//send the api command
|
|
if (!empty($command) && $event_socket->is_connected()) {
|
|
$response = $event_socket->request('api ' . $command);
|
|
$response_api[$user]['command'] = $command;
|
|
$response_api[$user]['log'] = $response;
|
|
}
|
|
}
|
|
}
|
|
|
|
//set message
|
|
if (is_array($response_api)) {
|
|
foreach ($response_api as $registration_user => $response) {
|
|
if (is_array($response['command'])) {
|
|
foreach($response['command'] as $command) {
|
|
$command = trim($command ?? '');
|
|
if ($command !== '-ERR no reply') {
|
|
$message .= "<br>\n<strong>".escape($registration_user)."</strong>: ".escape($response_message);
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
if (!empty($response['command']) && $response['command'] !== '-ERR no reply') {
|
|
$message .= "<br>\n<strong>".escape($registration_user)."</strong>: ".escape($response_message);
|
|
}
|
|
}
|
|
}
|
|
message::add($message, 'positive', '7000');
|
|
}
|
|
}
|
|
else {
|
|
message::add($text['error-event-socket'], 'negative', 5000);
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
} //method
|
|
|
|
} //class
|