dbxe
/
fusionpbx
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add is_array and hide irrelevant -ERR no reply

This commit is contained in:
FusionPBX 2021-06-02 17:12:01 -06:00 committed by GitHub
parent 661035f8fb
commit d24d5c1676
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 63 additions and 58 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

121
app/registrations/resources/classes/registrations.php
View File

@ -17,7 +17,7 @@
The Initial Developer of the Original Code is The Initial Developer of the Original Code is
Mark J Crane <markjcrane@fusionpbx.com> Mark J Crane <markjcrane@fusionpbx.com>
Portions created by the Initial Developer are Copyright (C) 2008-2020 Portions created by the Initial Developer are Copyright (C) 2008-2021
the Initial Developer. All Rights Reserved. the Initial Developer. All Rights Reserved.
Contributor(s): Contributor(s):
@ -311,75 +311,80 @@ if (!class_exists('registrations')) {
//loop through registrations //loop through registrations
if ($fp) { if ($fp) {
foreach ($registrations as $registration) { //check if registrations exist
if (is_array($registrations)) {
foreach ($registrations as $registration) {
//validate the submitted profile //validate the submitted profile
if ($registration['profile'] != '' && is_array($sip_profiles) && @sizeof($sip_profiles) != 0) { if ($registration['profile'] != '' && is_array($sip_profiles) && @sizeof($sip_profiles) != 0) {
foreach ($sip_profiles as $field) { foreach ($sip_profiles as $field) {
if ($field['name'] == $registration['profile']) { if ($field['name'] == $registration['profile']) {
$profile = $registration['profile']; $profile = $registration['profile'];
break; break;
}
} }
} }
} else {
else { header('Location: '.$this->list_page);
header('Location: '.$this->list_page); exit;
exit;
}
//validate the submitted user
if ($registration['user'] != '') {
$user = preg_replace('#[^a-zA-Z0-9_\-\.\@]#', '', $registration['user']);
}
//validate the submitted host
if ($registration['host'] != '') {
$host = preg_replace('#[^a-zA-Z0-9_\-\.]#', '', $registration['host']);
}
//lookup vendor by agent
if ($registration['agent'] != '') {
$vendor = device::get_vendor_by_agent($registration['agent']);
}
//prepare the api command
if ($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 //validate the submitted user
if ($command && $fp) { if ($registration['user'] != '') {
$response_api[$registration['user']]['command'] = event_socket_request($fp, "api ".$command); $user = preg_replace('#[^a-zA-Z0-9_\-\.\@]#', '', $registration['user']);
$response_api[$registration['user']]['log'] = event_socket_request($fp, "api log notice ".$command); }
}
//validate the submitted host
if ($registration['host'] != '') {
$host = preg_replace('#[^a-zA-Z0-9_\-\.]#', '', $registration['host']);
}
//lookup vendor by agent
if ($registration['agent'] != '') {
$vendor = device::get_vendor_by_agent($registration['agent']);
}
//prepare the api command
if ($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 ($command && $fp) {
$response_api[$registration['user']]['command'] = event_socket_request($fp, "api ".$command);
$response_api[$registration['user']]['log'] = event_socket_request($fp, "api log notice ".$command);
}
}
} }
//set message //set message
if (is_array($response_api)) { if (is_array($response_api)) {
$message = $response_message; $message = $response_message;
foreach ($response_api as $registration_user => $response) { foreach ($response_api as $registration_user => $response) {
$message .= "<br>\n<strong>".$registration_user."</strong>: ".$response['command']; if (trim($response['command']) != '-ERR no reply') {
$message .= "<br>\n<strong>".$registration_user."</strong>: ".$response['command'];
}
} }
message::add($message, 'positive', '7000'); message::add($message, 'positive', '7000');
} }