nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2026-02-20 09:56:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Filter for each Event-Subclass

Browse Source
This commit is contained in:
FusionPBX
2026-02-07 14:19:34 -07:00
committed by GitHub
parent 365484f9cf
commit cd4394f0bb
1 changed files with 20 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
app/event_guard/resources/classes/event_guard_service.php
View File

@@ -118,13 +118,22 @@ class event_guard_service extends service {
if (!$this->socket->connected()) {
$this->warning('Not connected to even socket');
if ($this->socket->connect()) {
// Define the events
$switch_events = [
['Event-Subclass' => 'sofia::pre_register'],
['Event-Subclass' => 'sofia::register_failure'],
['Event-Subclass' => 'event_guard:unblock']
];
// Add the event filters
$cmd = "event json ALL";
$result = $this->socket->request($cmd);
$this->debug('subscribe to ALL events '. print_r($result, true));
$cmd = "filter Event-Name CUSTOM";
$result = $this->socket->request($cmd);
$this->debug('subscribe to CUSTOM events '. print_r($result, true));
$this->info('subscribe to ALL events '. print_r($result, true));
foreach($switch_events as $event_key => $event_value) {
$cmd = "filter ".$event_key." ".$event_value;
$result = $this->socket->request($cmd);
$this->info('subscribe to CUSTOM events '. print_r($result, true));
}
$this->info('Re-connected to event socket');
}
else {
@@ -200,6 +209,10 @@ class event_guard_service extends service {
//if not registered block the address
if (!$this->allow_access($json_array['network-ip'])) {
$this->block_add($json_array['network-ip'], 'sip-auth-ip', $json_array);
$this->info("IP address NOT allowed ".$json_array['to-host']);
}
else {
$this->info("IP address allowed ".$json_array['to-host']);
}
//debug info
@@ -228,8 +241,8 @@ class event_guard_service extends service {
//echo "\n";
//}
// Sleep for 100 ms
usleep(100000);
// Sleep for 10 ms
//usleep(10000);
}
return 0;
}