Lib/AsteriskManager.php - master - mikopbx/ModuleMonitorActiveCalls

Lib/AsteriskManager.php
1 695 строк53 KB
Alexey Portnov
Исправление зависания каналов после перезагрузки Asterisk
31 мар 2026, 12:26
31 мар 2026, 12:26fdc725c
<?php

/*
 * MikoPBX - free phone system for small business
 * Copyright © 2017-2023 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace Modules\ModuleMonitorActiveCalls\Lib;
use MikoPBX\Core\System\Processes;
use MikoPBX\Core\System\SystemMessages;
use MikoPBX\Core\System\Util;
use Throwable;

/**
 * Asterisk Manager class
 *
 * @link    http://www.voip-info.org/wiki-Asterisk+config+manager.conf
 * @link    http://www.voip-info.org/wiki-Asterisk+manager+API
 * @example examples/sip_show_peer.php Get information about a sip peer
 * @package phpAGI
 */
class AsteriskManager
{
    /**
     * Config variables
     *
     * @var array
     * @access public
     */
    public array $config;

    /** @var string  */
    private string $listenEvents;

    /**
     * Socket
     *
     * @var resource|false $socket
     * @access public
     */
    public $socket = false;

    /**
     * Server we are connected to
     *
     * @access public
     * @var string
     */
    public string $server;

    /**
     * Port on the server we are connected to
     *
     * @access public
     * @var int
     */
    public int $port;

    /**
     * Parent AGI
     *
     * @access public
     * @var AGI
     */
    public AGI $pagi;

    /**
     * Event Handlers
     *
     * @access private
     * @var array
     */
    private array $event_handlers;

    /**
     * Whether we're successfully logged in
     *
     * @access private
     * @var bool
     */
    private bool $_loggedIn = false;

    /** @var callable|null Callback invoked periodically when AMI connection is alive and idle */
    private $onIdleCallback = null;

    /** @var int Timestamp of last idle callback invocation */
    private int $lastIdleCall = 0;

    /** @var int Minimum interval between idle callback calls (seconds) */
    private int $idleInterval = 30;

    /**
     * Constructor
     *
     * @param ?string $config    is the name of the config file to parse or a parent agi from which to read the config
     * @param array  $optconfig is an array of configuration vars and vals, stuffed into $this->config['asmanager']
     */
    public function __construct(?string $config = null, array $optconfig = [])
    {
        // load config
        if (!is_null($config) && file_exists($config)) {
            $arrData = parse_ini_file($config, true);
            $this->config = ($arrData === false) ? [] : $arrData;
        }

        // If optconfig is specified, stuff vals and vars into 'asmanager' config array.
        foreach ($optconfig as $var => $val) {
            $this->config['asmanager'][$var] = $val;
        }

        // add default values to config for uninitialized values
        if (! isset($this->config['asmanager']['server'])) {
            $this->config['asmanager']['server'] = 'localhost';
        }
        if (! isset($this->config['asmanager']['port'])) {
            $this->config['asmanager']['port'] = 5038;
        }
        if (! isset($this->config['asmanager']['username'])) {
            $this->config['asmanager']['username'] = 'phpagi';
        }
        if (! isset($this->config['asmanager']['secret'])) {
            $this->config['asmanager']['secret'] = 'phpagi';
        }
    }

    /**
     * Ping the AMI listener and wait for a response.
     *
     * @param string $pingTube The name of the ping tube.
     * @return bool True if a response is received within the timeout, false otherwise.
     */
    public function pingAMIListener(string $pingTube = 'CdrConnector'): bool
    {
        $pingTubePong = $pingTube."Pong";
        // Set event filter.
        $params = ['Operation' => 'Add', 'Filter' => "UserEvent: $pingTubePong"];
        $this->sendRequestTimeout('Filter', $params);
        // Send the ping.
        $req        = '';
        $parameters = [
            'Action'    => 'UserEvent',
            'UserEvent' => $pingTube,
        ];
        foreach ($parameters as $var => $val) {
            $req .= "$var: $val\r\n";
        }
        $req .= "\r\n";
        if (! is_resource($this->socket)) {
            return false;
        }
        $this->sendDataToSocket($req);

        // Measure the time.
        $time_start = $this->microtimeFloat();
        $result     = false;
        $timeout    = false;

        // Listen for events and wait for a response.
        do {
            $type       = '';
            $parameters = [];
            if (! is_resource($this->socket)) {
                return false;
            }
            $buffer = $this->getStringDataFromSocket();
            while (!empty($buffer)) {
                $a = strpos($buffer, ':');
                if ($a) {
                    if (! count($parameters)) {
                        $type = strtolower(substr($buffer, 0, $a));
                    }
                    $parameters[substr($buffer, 0, $a)] = substr($buffer, $a + 2);
                }
                $buffer = $this->getStringDataFromSocket();
            }

            if ($type === '' && count($this->ping()) === 0) {
                $timeout = true;
            } elseif ( 'event' === $type
                && $parameters['Event'] === 'UserEvent'
                && $pingTubePong === $parameters['UserEvent']
            ) {
                // Response received.
                $result = true;
                break;
            }
            $time = $this->microtimeFloat() - $time_start;
            if ($time > 5) {
                // Timeout reached.
                break;
            }
        } while (! $timeout);

        return $result;
    }

    /**
     * Send a request with timeout to the socket.
     *
     * @param string $action The action to perform.
     * @param array $parameters The parameters for the request (optional).
     * @return array The response from the socket.
     */
    public function sendRequestTimeout(string $action, array $parameters = [], int $waitDuration = 0): array
    {
        if (! is_resource($this->socket) && !$this->connectDefault()) {
            return [];
        }
        // Set the mandatory fields.
        $parameters['Action']   = $action;
        $parameters['ActionID'] = $parameters['ActionID'] ?? "{$action}_" . getmypid();
        $req = "";
        foreach ($parameters as $var => $val) {
            $req .= "$var: $val\r\n";
        }
        $req .= "\r\n";

        $result = $this->sendDataToSocket($req);
        if (!$result) {
            usleep(500000);
            if ($this->connectDefault()) {
                $result = $this->sendDataToSocket($req);
            }
        }

        $response = [];
        if ($result) {
            if($waitDuration>0){
                usleep($waitDuration);
            }
            $response = $this->waitResponse(true);
        }
        return $response;
    }

    /**
     * Connect to the default socket.
     *
     * @return bool True if the connection to the default socket is successful and logged in, false otherwise.
     */
    private function connectDefault(): bool
    {
        $this->connect(null, null, null, $this->listenEvents);
        return $this->loggedIn();
    }

    /**
     * Wait for a response
     *
     * If a request was just sent, this will return the response.
     * Otherwise, it will loop forever, handling events.
     *
     * @param bool $allow_timeout if the socket times out, return an empty array
     *
     * @return array of parameters, empty on timeout
     */
    public function waitResponse(bool $allow_timeout = false): array
    {
        $timeout = false;
        do {
            $type       = '';
            $parameters = [];
            $response   = [];
            if (!$this->waitResponseGetInitialData($response)) {
                return $parameters;
            }
            if (isset($response['data']) && empty($response['data']) && !$this->waitResponseGetInitialData($response)) {
                return $parameters;
            }
            $buffer = $response['data'] ?? '';
            while ($buffer !== '') {
                $a = strpos($buffer, ':');
                if ($a) {
                    $event_text = substr($buffer, $a + 2);
                    $this->waitResponseGetEventType($parameters, $buffer, $a, $type);
                    $this->waitResponseReadFollowsPart($event_text, $parameters);
                    $this->waitResponseReadCompletePart($event_text, $parameters);
                    $parameters[substr($buffer, 0, $a)] = $event_text;
                }
                $buffer = $this->getStringDataFromSocket();
            }
            $this->waitResponseProcessResponse($type, $timeout, $allow_timeout, $parameters);
        } while ($type !== 'response' && ! $timeout);

        return $parameters;
    }

    /**
     * Get the initial data from the socket response.
     *
     * @param array $response The variable to store the response data.
     * @return bool True if the initial data was obtained successfully, false otherwise.
     */
    private function waitResponseGetInitialData(array &$response): bool
    {
        if (!is_resource($this->socket) && !$this->connectDefault()) {
            return false;
        }
        $result = true;
        $response = $this->getDataFromSocket();
        if (isset($response['error'])) {
            usleep(500000);
            if ($this->connectDefault()) {
                $response = $this->getDataFromSocket();
            }
        }
        if (isset($response['error'])) {
            $result = false;
        }
        return $result;
    }

    /**
     * Process the response based on the event type.
     *
     * @param string $type The event type.
     * @param bool $timeout The timeout.
     * @param bool $allow_timeout Indicates whether the timeout is allowed.
     * @param array $parameters The parameters containing the sub-data.
     * @return void
     */
    private function waitResponseProcessResponse(string $type, bool &$timeout, bool $allow_timeout, array $parameters): void
    {
        switch ($type) {
            case '':
                // Timeout occured
                $timeout = $allow_timeout;
                break;
            case 'event':
                $this->processEvent($parameters);
                break;
            case 'response':
                break;
        }
    }

    /**
     * Get the event type from the response buffer.
     *
     * @param array $parameters The parameters containing the sub-data.
     * @param string $buffer The response buffer.
     * @param int $a The position of the colon character in the buffer.
     * @param string $type The variable to store the event type.
     * @return void
     */
    private function waitResponseGetEventType(array $parameters, string $buffer, int $a, string &$type): void
    {
        if (! count($parameters)) {
            $type = strtolower(substr($buffer, 0, $a));
        }
    }

    /**
     * Wait for the follows part of a specific event and retrieve the data.
     *
     * @param string $event_text The text of the event.
     * @param array $parameters The parameters to store the data.
     * @return void
     */
    private function waitResponseReadFollowsPart(string $event_text, array &$parameters): void
    {
        if (($event_text === 'Follows') && !count($parameters)) {
            // A follows response means there is a miltiline field that follows.
            $parameters['data'] = '';
            $buff               = $this->getStringDataFromSocket();
            while (strpos($buff, '--END ') !== 0) {
                $parameters['data'] .= $buff;
                $buff               = $this->getStringDataFromSocket();
            }
        }
    }

    /**
     * Wait for the complete part of a specific event and retrieve the sub-data.
     *
     * @param string $event_text The text of the event.
     * @param array $parameters The parameters to store the sub-data.
     * @return void
     */
    private function waitResponseReadCompletePart(string $event_text, array &$parameters): void
    {
        $settings = [
            'Bridge channel listing will follow'=> ['BridgeInfoComplete'],
            'Bridge listing will follow'        => ['BridgeListComplete'],
            'Queue status will follow'          => ['QueueStatusComplete'],
            'Channels will follow'              => ['CoreShowChannelsComplete'],
            'Result will follow'                => ['DBGetComplete', 'DBGetTreeComplete'],
            'Parked calls will follow'          => ['ParkedCallsComplete'],
            'Peer status list will follow'      => ['PeerlistComplete'],
            'IAX Peer status list will follow'  => ['PeerlistComplete'],
            'Registrations will follow'         => ['RegistrationsComplete'],
            'Meetme user list will follow'      => ['MeetmeListComplete'],
            'Meetme conferences will follow'    => ['MeetmeListRoomsComplete'],
            'Following are Events for each object associated with the Endpoint' => ['EndpointDetailComplete'],
            'Following are Events for each Outbound registration'               => ['OutboundRegistrationDetailComplete'],
            'A listing of Endpoints follows, presented as EndpointList events'  => ['EndpointListComplete']
        ];
        if (isset($settings[$event_text])) {
            $this->waitResponseGetSubData($parameters, $settings[$event_text]);
        }
    }

    /**
     * Get data from the socket.
     *
     * @return array An array containing the data from the socket response or an error message.
     */
    private function getDataFromSocket(): array
    {
        $response = [];
        if (!is_resource($this->socket)) {
            $response['error'] = 'Socket not init.';
            return $response;
        }
        try {
            $resultFgets = fgets($this->socket, 4096);
            if ($resultFgets !== false) {
                $buffer = trim($resultFgets);
                $response['data']  = $buffer;
            } else {
                $response['error'] = 'Read data error.';
            }
        } catch (Throwable $e) {
            $response['error'] = $e->getMessage();
        }

        return $response;
    }

    /**
     * Get string data from the socket response.
     *
     * @return string The string data from the socket response.
     */
    private function getStringDataFromSocket(): string
    {
        $response = $this->getDataFromSocket();
        return $response['data'] ?? '';
    }

    /**
     * Send data to the socket.
     *
     * @param string $req The data to send.
     * @return bool True if the data was sent successfully, false otherwise.
     */
    private function sendDataToSocket(string $req): bool
    {
        if (!is_resource($this->socket)) {
            return false;
        }
        $result = true;
        try {
            $resultWrite = fwrite($this->socket, $req);
            if ($resultWrite === false) {
                $result = false;
            }
        } catch (Throwable $e) {
            $result = false;
        }
        return $result;
    }

    /**
     * Wait for response and get sub-data from the socket.
     *
     * @param array $parameters The parameters to store the sub-data.
     * @param array $end_string The string indicating the end of the response (optional).
     * @return void
     */
    private function waitResponseGetSubData(array &$parameters, array $end_string): void
    {
        if (empty($end_string)) {
            return;
        }
        $parameters['data'] = [];
        $m                  = [];
        do {
            $value = '';
            $buff  = $this->getStringDataFromSocket() . $value;
            $a_pos = strpos($buff, ':');
            if (!$a_pos) {
                if (empty($m)) {
                    continue;
                }
                if ($parameters['ActionID'] === $m['ActionID']) {
                    // This is the event for the last request of the current worker
                    if (array_key_exists('Event', $m)) {
                        $parameters['data'][$m['Event']][] = $m;
                    } else {
                        SystemMessages::sysLogMsg(__METHOD__, "No key Event on AMI Answer:" . implode(' ', $m), LOG_DEBUG);
                    }
                    $m = [];
                } elseif (isset($m['Event'])) {
                    // These are other events not related to the last request
                    $this->processEvent($parameters);
                }
                continue;
            }
            $key   = trim(substr($buff, 0, $a_pos));
            $value = trim(substr($buff, $a_pos + 1));
            $m[$key] = $value;
        } while (!in_array($value, $end_string, true));
    }

    /**
     * Process event
     *
     * @access private
     *
     * @param array $parameters
     *
     * @return mixed result of event handler or false if no handler was found
     */
    public function processEvent(array $parameters)
    {
        $ret = false;
        $e   = strtolower($parameters['Event']);
        $handler = '';
        if (isset($this->event_handlers[$e])) {
            $handler = $this->event_handlers[$e];
        } elseif (isset($this->event_handlers['*'])) {
            $handler = $this->event_handlers['*'];
        }
        if (is_array($handler)) {
            call_user_func($handler, $parameters);
        } elseif (function_exists($handler)) {
            $ret = $handler($e, $parameters, $this->server, $this->port);
        }

        return $ret;
    }

    public function microtimeFloat(): float
    {
        [$usec, $sec] = explode(" ", microtime());

        return ((float)$usec + (float)$sec);
    }

    /**
     * Ping
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Ping
     */
    public function ping(): array
    {
        return $this->sendRequestTimeout('Ping');
    }

    /**
     * Sets socket read timeout.
     *
     * @param int $seconds Timeout in seconds
     * @param int $microseconds Timeout in microseconds (optional)
     * @return bool True if socket is valid and timeout was set
     */
    public function setSocketTimeout(int $seconds, int $microseconds = 0): bool
    {
        if (!is_resource($this->socket)) {
            return false;
        }
        return stream_set_timeout($this->socket, $seconds, $microseconds);
    }

    /**
     * Wait for a user events.
     *
     * @param $allow_timeout bool
     *
     * @return array of parameters, empty on timeout
     */
    public function setOnIdleCallback(callable $callback, int $interval = 30): void
    {
        $this->onIdleCallback = $callback;
        $this->idleInterval = $interval;
    }

    /**
     * Wait for a user events.
     *
     * @param $allow_timeout bool
     *
     * @return array of parameters, empty on timeout
     */
    public function waitUserEvent(bool $allow_timeout = false): array
    {
        $timeout = false;
        do {
            $type       = '';
            $parameters = [];
            $buffer = $this->getStringDataFromSocket();
            while ($buffer !== '') {
                $pos = strpos($buffer, ':');
                if ($pos) {
                    if (! count($parameters)) {
                        $type = strtolower(substr($buffer, 0, $pos));
                    }
                    $parameters[substr($buffer, 0, $pos)] = substr($buffer, $pos + 2);
                }
                $buffer = $this->getStringDataFromSocket();
            }
            if ($type === '' && count($this->ping()) === 0) {
                $timeout = $allow_timeout;
            } elseif ($type === '' && $this->onIdleCallback !== null
                && time() - $this->lastIdleCall >= $this->idleInterval
            ) {
                $this->lastIdleCall = time();
                call_user_func($this->onIdleCallback);
            } elseif (stripos($type, 'event') !== false) {
                $this->processEvent($parameters);
            }
        } while (! $timeout);

        return $parameters;
    }

    // *********************************************************************************************************
    // **                       COMMANDS                                                                      **
    // *********************************************************************************************************

    /**
     * Connect to Asterisk
     *
     * @param ?string $server
     * @param ?string $username
     * @param ?string $secret
     * @param string $events
     *
     * @return bool true on success
     * @example examples/sip_show_peer.php Get information about a sip peer
     *
     */
    public function connect(?string $server = null, ?string $username = null, ?string $secret = null, string $events = 'on'): bool
    {
        $this->listenEvents = $events;
        // use config if not specified
        if (is_null($server)) {
            $server = $this->config['asmanager']['server'];
        }
        if (is_null($username)) {
            $username = $this->config['asmanager']['username'];
        }
        if (is_null($secret)) {
            $secret = $this->config['asmanager']['secret'];
        }

        // get port from server if specified
        if (strpos($server, ':') !== false) {
            $c            = explode(':', $server);
            $this->server = $c[0];
            $this->port   = (int)$c[1];
        } else {
            $this->server = $server;
            $this->port   = $this->config['asmanager']['port'];
        }

        // connect the socket
        $errno   = $errStr = null;
        $timeout = 2;

        $busyBoxPath = Util::which('busybox');
        $chkCommand = "$busyBoxPath netstat -ntap | $busyBoxPath grep '0.0.0.0:$this->port ' | $busyBoxPath grep LISTEN | $busyBoxPath grep asterisk";
        if (Processes::mwExec($chkCommand) === 1) {
            SystemMessages::sysLogMsg('AMI', "Exceptions, Unable to connect to $server: the asterisk process is not running", LOG_ERR);
            return false;
        }
        try {
            $this->socket = fsockopen($this->server, $this->port, $errno, $errStr, $timeout);
        } catch (Throwable $e) {
            SystemMessages::sysLogMsg('AMI', "Exceptions, Unable to connect to manager $server ($errno): $errStr", LOG_ERR);
            return false;
        }
        if ($this->socket === false) {
            SystemMessages::sysLogMsg('AMI', "Unable to connect to manager $server ($errno): $errStr", LOG_ERR);
            return false;
        }
        stream_set_timeout($this->socket, 5, 0);

        // read the header
        $str = $this->getStringDataFromSocket();
        if ($str === '') {
            // a problem.
            SystemMessages::sysLogMsg('AMI', "Asterisk Manager header not received.", LOG_ERR);
            return false;
        }

        // login
        $res = $this->sendRequest('login', ['Username' => $username, 'Secret' => $secret, 'Events' => $events]);
        if ($res['Response'] !== 'Success') {
            $this->_loggedIn = false;
            SystemMessages::sysLogMsg('AMI', "Failed to login.", LOG_ERR);
            $this->disconnect();
            return false;
        }
        $this->_loggedIn = true;

        return true;
    }

    /**
     * Send a request
     *
     * @param string $action
     * @param array $parameters
     *
     * @return array of parameters
     */
    public function sendRequest(string $action, array $parameters = []): array
    {
        $req = "Action: $action\r\n";
        foreach ($parameters as $var => $val) {
            $req .= "$var: $val\r\n";
        }
        $req .= "\r\n";
        if (! is_resource($this->socket)) {
            return [];
        }
        $this->sendDataToSocket($req);

        return $this->waitResponse();
    }

    /**
     * Disconnect
     *
     * @example examples/sip_show_peer.php Get information about a sip peer
     */
    public function disconnect(): void
    {
        if ($this->_loggedIn === true) {
            $this->logoff();
        }
        if (is_resource($this->socket)) {
            fclose($this->socket);
        }
    }

    /**
     * Logoff Manager
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Logoff
     */
    private function logoff(): void
    {
        $this->sendRequestTimeout('Logoff');
    }

    public function loggedIn(): bool
    {
        return $this->_loggedIn;
    }

    /**
     * Set Absolute Timeout
     *
     * Hangup a channel after a certain time.
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+AbsoluteTimeout
     *
     * @param string $channel Channel name to hangup
     * @param int $timeout Maximum duration of the call (sec)
     *
     * @return array
     */
    public function AbsoluteTimeout(string $channel, int $timeout): array
    {
        return $this->sendRequest('AbsoluteTimeout', ['Channel' => $channel, 'Timeout' => $timeout]);
    }

    /**
     * Change monitoring filename of a channel
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+ChangeMonitor
     *
     * @param string $channel the channel to record.
     * @param string $file    the new name of the file created in the monitor spool directory.
     *
     * @return array
     */
    public function ChangeMonitor(string $channel, string $file): array
    {
        return $this->sendRequest('ChangeMontior', ['Channel' => $channel, 'File' => $file]);
    }

    /**
     * Execute Command
     *
     * @param string $command
     * @param ?string $actionId message matching variable
     *
     * @return array
     * @example examples/sip_show_peer.php Get information about a sip peer
     * @link    http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Command
     * @link    http://www.voip-info.org/wiki-Asterisk+CLI
     */
    public function Command(string $command, ?string $actionId = null): array
    {
        $parameters = ['Command' => $command];
        if ($actionId) {
            $parameters['ActionID'] = $actionId;
        }
        return $this->sendRequest('Command', $parameters);
    }

    /**
     * Enable/Disable sending of events to this manager
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Events
     *
     * @param string $eventMask is either 'on', 'off', or 'system,call,log'
     *
     * @return array
     */
    public function Events(string $eventMask): array
    {
        return $this->sendRequest('Events', ['EventMask' => $eventMask]);
    }

    /**
     * Check Extension Status
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+ExtensionState
     *
     * @param string $exten    Extension to check state on
     * @param string $context  Context for extension
     * @param ?string $actionid message matching variable
     *
     * @return array
     */
    public function ExtensionState(string $exten, string $context, ?string $actionid = null): array
    {
        $parameters = ['Exten' => $exten, 'Context' => $context];
        if ($actionid) {
            $parameters['ActionID'] = $actionid;
        }

        return $this->sendRequest('ExtensionState', $parameters);
    }

    /**
     * Get the channels information.
     *
     * @param bool $group Indicates whether to group the channels by Linkedid (optional, default is true).
     * @return array|null The channels information, or null on AMI communication error.
     */
    public function GetChannels(bool $group = true)
    {
        $res      = $this->sendRequestTimeout('CoreShowChannels');
        if (empty($res)) {
            return null;
        }
        $channels = null;
        if (isset($res['data']['CoreShowChannel'])) {
            $channels = $res['data']['CoreShowChannel'];
        }
        $channels_id = [];
        if (null !== $channels) {
            foreach ($channels as $chan) {
                if ($group === true) {
                    if (! isset($chan['Linkedid'])) {
                        continue;
                    }
                    $channels_id[$chan['Linkedid']][] = $chan['Channel'];
                } else {
                    $channels_id[] = $chan['Channel'];
                }
            }
        }

        return $channels_id;
    }

    /**
     * Hangup Channel
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Hangup
     *
     * @param string $channel The channel name to be hungup
     *
     * @return array
     */
    public function Hangup(string $channel): array
    {
        return $this->sendRequest('Hangup', ['Channel' => $channel]);
    }

    /**
     * List IAX Peers
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+IAXpeers
     * @return array
     */
    public function IAXpeerlist(): array
    {
        $result   = $this->sendRequestTimeout('IAXpeerlist');
        $data     = (isset($result['data']) && is_array($result['data'])) ? $result['data'] : [];
        $arr_peer = (isset($data['PeerEntry']) && is_array($data['PeerEntry'])) ? $data['PeerEntry'] : [];

        return $arr_peer;
    }

    /**
     * Get the IAX registry information.
     *
     * @return array The IAX registry information.
     */
    public function IAXregistry(): array
    {
        $result   = $this->sendRequestTimeout('IAXregistry');
        $data     = (isset($result['data']) && is_array($result['data'])) ? $result['data'] : [];
        $arr_peer = (isset($data['RegistryEntry']) && is_array($data['RegistryEntry'])) ? $data['RegistryEntry'] : [];

        return $arr_peer;
    }

    /**
     * List available manager commands
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+ListCommands
     *
     * @param string|null $actionid message matching variable
     *
     * @return array
     */
    public function ListCommands(?string $actionid = null): array
    {
        if ($actionid) {
            return $this->sendRequest('ListCommands', ['ActionID' => $actionid]);
        } else {
            return $this->sendRequest('ListCommands');
        }
    }

    /**
     * Send a UserEvent to Asterisk.
     *
     * @param string $name The name of the UserEvent.
     * @param array $headers The headers for the UserEvent.
     * @return array The response from Asterisk.
     */
    public function UserEvent(string $name, array $headers): array
    {
        $headers['UserEvent'] = $name;

        return $this->sendRequestTimeout('UserEvent', $headers);
    }

    /**
     * Check Mailbox Message Count
     *
     * Returns number of new and old messages.
     *   Message: Mailbox Message Count
     *   Mailbox: <mailboxid>
     *   NewMessages: <count>
     *   OldMessages: <count>
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+MailboxCount
     *
     * @param string $mailbox  Full mailbox ID <mailbox>@<vm-context>
     * @param string|null $actionid message matching variable
     *
     * @return array
     */
    public function MailboxCount(string $mailbox, ?string $actionid = null): array
    {
        $parameters = ['Mailbox' => $mailbox];
        if ($actionid) {
            $parameters['ActionID'] = $actionid;
        }

        return $this->sendRequest('MailboxCount', $parameters);
    }

    /**
     * Check Mailbox
     *
     * Returns number of messages.
     *   Message: Mailbox Status
     *   Mailbox: <mailboxid>
     *   Waiting: <count>
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+MailboxStatus
     *
     * @param string $mailbox  Full mailbox ID <mailbox>@<vm-context>
     * @param string|null $actionid message matching variable
     *
     * @return array
     */
    public function MailboxStatus(string $mailbox, ?string $actionid = null): array
    {
        $parameters = ['Mailbox' => $mailbox];
        if ($actionid) {
            $parameters['ActionID'] = $actionid;
        }

        return $this->sendRequest('MailboxStatus', $parameters);
    }

    /**
     * Monitor a channel
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Monitor
     *
     * @param string $channel
     * @param string|null $file
     * @param string|null $format
     * @param bool|null $mix
     *
     * @return array
     */
    public function Monitor(string $channel, ?string $file = null, ?string $format = null, ?bool $mix = null): array
    {
        $parameters = ['Channel' => $channel];
        if ($file) {
            $parameters['File'] = $file;
        }
        if ($format) {
            $parameters['Format'] = $format;
        }
        if (! is_null($file)) {
            $parameters['Mix'] = ($mix) ? 'true' : 'false';
        }

        return $this->sendRequest('Monitor', $parameters);
    }

    /**
     * MixMonitor a channel
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Monitor
     *
     * @param string $channel
     * @param string $file
     * @param string $options
     * @param string $command
     * @param string $ActionID
     * @return array
     */
    public function MixMonitor(string $channel, string $file, string $options, string $command = '', string $ActionID = ''): array
    {
        $parameters            = [
            'Channel' => $channel,
            'File'    => $file,
            'options' => $options,
            'ActionID' => $ActionID
        ];
        if (!empty($command)) {
            $parameters['Command'] = $command;
        }
        return $this->sendRequestTimeout('MixMonitor', $parameters);
    }

    /**
     * StopMixMonitor a channel
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Monitor
     *
     * @param string $channel
     * @param string $ActionID
     *
     * @return array
     */
    public function StopMixMonitor(string $channel, string $ActionID = ''): array
    {
        $parameters = [
            'Channel' => $channel,
            'ActionID' => $ActionID
        ];
        return $this->sendRequestTimeout('StopMixMonitor', $parameters);
    }

    /**
     * DBGet a channel
     *
     * @param string $Family
     * @param string $Key
     * @param string $Val
     *
     * @return array
     */
    public function DBPut(string $Family, string $Key, string $Val = ''): array
    {
        $parameters = ['Family' => $Family, 'Key' => $Key, 'Val' => $Val];
        return $this->sendRequestTimeout('DBPut', $parameters);
    }

    /**
     * MeetmeListRooms
     *
     * @param string $ActionID
     *
     * @return array
     */
    public function MeetmeListRooms(string $ActionID = ''): array
    {
        if (empty($ActionID)) {
            $ActionID = Util::generateRandomString(5);
        }
        $parameters = [
            'ActionID' => $ActionID,
        ];

        return $this->sendRequestTimeout('MeetmeListRooms', $parameters);
    }

    /**
     * DBGet a channel
     *
     * @param string $Family
     * @param string $Key
     *
     * @return array
     */
    public function DBGet(string $Family, string $Key): array
    {
        $parameters = ['Family' => $Family, 'Key' => $Key];

        return $this->sendRequestTimeout('DBGet', $parameters);
    }

    /**
     * Originate Call
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Originate
     *
     * @param string|null $channel Channel name to call
     * @param ?string $exten Extension to use (requires 'Context' and 'Priority')
     * @param ?string $context Context to use (requires 'Exten' and 'Priority')
     * @param int|null $priority Priority to use (requires 'Exten' and 'Context')
     * @param ?string $application Application to use
     * @param ?string $data Data to use (requires 'Application')
     * @param ?int $timeout How long to wait for call to be answered (in ms)
     * @param ?string $callerid Caller ID to be set on the outgoing channel
     * @param ?string $variable Channel variable to set (VAR1=value1|VAR2=value2)
     * @param ?string $account Account code
     * @param bool $async true fast origination
     * @param ?string $actionid message matching variable
     *
     * @return array
     */
    public function Originate(
        ?string $channel,
        ?string $exten = null,
        ?string $context = null,
        ?int $priority = null,
        ?string $application = null,
        ?string $data = null,
        ?int $timeout = null,
        ?string $callerid = null,
        ?string $variable = null,
        ?string $account = null,
        bool $async = true,
        ?string $actionid = null
    ): array {

        $parameters = [
            'Exten'         => $exten,
            'Context'       => $context,
            'Priority'      => $priority,
            'Application'   => $application,
            'Data'          => $data,
            'Timeout'       => $timeout,
            'CallerID'      => $callerid,
            'Variable'      => $variable,
            'Account'       => $account,
            'ActionID'      => $actionid
        ];
        $keys = array_keys($parameters);
        foreach ($keys as $key) {
            if (empty($parameters[$key])) {
                unset($parameters[$key]);
            }
        }
        $parameters['Channel'] = $channel;
        $parameters['Async']   = ($async === true) ? 'true' : 'false';

        return $this->sendRequest('Originate', $parameters);
    }

    /**
     * List parked calls
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+ParkedCalls
     *
     * @param string|null $actionid   message matching variable
     * @param string|null $parkinglot message matching variable
     *
     * @return array
     */
    public function ParkedCalls(?string $parkinglot = null, ?string $actionid = null): array
    {
        $parameters = [];
        if ($actionid) {
            $parameters['ActionID'] = $actionid;
        }
        if ($parkinglot) {
            $parameters['ParkingLot'] = $parkinglot;
        }
        $result = $this->sendRequestTimeout('ParkedCalls', $parameters);

        return $result;
    }

    /**
     * Queue Add
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+QueueAdd
     *
     * @param string $queue
     * @param string $interface
     * @param int $penalty
     *
     * @return array
     */
    public function QueueAdd(string $queue, string $interface, int $penalty = 0): array
    {
        $parameters = ['Queue' => $queue, 'Interface' => $interface];
        if ($penalty) {
            $parameters['Penalty'] = $penalty;
        }

        return $this->sendRequest('QueueAdd', $parameters);
    }

    /**
     * Queue Remove
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+QueueRemove
     *
     * @param string $queue
     * @param string $interface
     *
     * @return array
     */
    public function QueueRemove(string $queue, string $interface): array
    {
        return $this->sendRequest('QueueRemove', ['Queue' => $queue, 'Interface' => $interface]);
    }

    /**
     * Queues
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Queues
     */
    public function Queues(): array
    {
        return $this->sendRequest('Queues');
    }

    /**
     * Queue Status
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+QueueStatus
     *
     * @param $actionid message matching variable
     *
     * @return array
     */
    public function QueueStatus(?string $actionid = null): array
    {
        if ($actionid) {
            return $this->sendRequest('QueueStatus', ['ActionID' => $actionid]);
        } else {
            return $this->sendRequest('QueueStatus');
        }
    }

    /**
     * Redirect
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Redirect
     *
     * @param string $channel
     * @param string $extrachannel
     * @param string $exten
     * @param string $context
     * @param int $priority
     *
     * @return array
     */
    public function Redirect(string $channel, string $extrachannel, string $exten, string $context, int $priority): array
    {
        return $this->sendRequest(
            'Redirect',
            [
                'Channel'      => $channel,
                'ExtraChannel' => $extrachannel,
                'Exten'        => $exten,
                'Context'      => $context,
                'Priority'     => $priority,
            ]
        );
    }

    /**
     * Set the CDR UserField
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+SetCDRUserField
     *
     * @param string $userfield
     * @param string $channel
     * @param $append
     *
     * @return array
     */
    public function SetCDRUserField(string $userfield, string $channel, ?string $append = null): array
    {
        $parameters = ['UserField' => $userfield, 'Channel' => $channel];
        if ($append) {
            $parameters['Append'] = $append;
        }

        return $this->sendRequest('SetCDRUserField', $parameters);
    }

    /**
     * Set Channel Variable
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+SetVar
     *
     * @param string $channel  Channel to set variable for
     * @param string $variable name
     * @param string $value
     *
     * @return array
     */
    public function SetVar(string $channel, string $variable, string $value): array
    {
        $params = [
            'Channel'   => $channel,
            'Variable'  => $variable,
            'Value'     => $value
        ];
        return $this->sendRequestTimeout('SetVar', $params);
    }

    /**
     * Channel Status
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+Status
     *
     * @param string $channel
     * @param $actionid message matching variable
     *
     * @return array
     */
    public function Status(string $channel, $actionid = null): array
    {
        $parameters = ['Channel' => $channel];
        if ($actionid) {
            $parameters['ActionID'] = $actionid;
        }

        return $this->sendRequest('Status', $parameters);
    }

    /*
    * MIKO Start.
    */

    /**
     * Stop monitoring a channel
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+StopMonitor
     *
     * @param string $channel
     *
     * @return array
     */
    public function StopMonitor(string $channel): array
    {
        return $this->sendRequest('StopMonitor', ['Channel' => $channel]);
    }

    /**
     * Get the SIP registry information.
     *
     * @return array The SIP registry information.
     */
    public function getSipRegistry(): array
    {
        $peers  = [];
        $result = $this->sendRequestTimeout('SIPshowregistry');
        if ($result['data'] !== null && $result['data']['RegistryEntry'] !== null) {
            foreach ($result['data']['RegistryEntry'] as $peer) {
                $peers[] = [
                    'id'       => $peer['Username'],
                    'state'    => strtoupper($peer['State']),
                    'host'     => $peer['Host'],
                    'username' => $peer['Username'],
                ];
            }
        }

        return $peers;
    }

    /**
     * Get the PJSIP registry information.
     *
     * @return array The PJSIP registry information.
     */
    public function getPjSipRegistry(): array
    {
        $peers  = [];
        $result = $this->sendRequestTimeout('PJSIPShowRegistrationsOutbound');
        if (isset($result['data']['OutboundRegistrationDetail'])) {
            foreach ($result['data']['OutboundRegistrationDetail'] as $peer) {
                [$sip, $host, $port] = explode(':', $peer['ServerUri']);
                $peers[] = [
                    'id'       => str_replace('REG-', '', $peer['ObjectName']),
                    'state'    => strtoupper($peer['Status']),
                    'host'     => $host,
                    'username' => $peer['ContactUser'],
                ];
                unset($sip, $port);
            }
        }

        return $peers;
    }

    /**
     * Get the PJSIP peers information.
     *
     * @return array The PJSIP peers information.
     */
    public function getPjSipPeers(): array
    {
        $peers  = [];
        $result = $this->sendRequestTimeout('PJSIPShowEndpoints');
        $endpoints = $result['data']['EndpointList'] ?? [];
        foreach ($endpoints as $peer) {
            if ($peer['ObjectName'] === 'anonymous') {
                continue;
            }
            $state_array = [
                'Not in use' => 'OK',
                'Busy'       => 'OK',
                'Ringing'    => 'OK'
            ];
            $state       = $state_array[$peer['DeviceState']] ?? 'UNKNOWN';
            $oldAState   = $peers[$peer['Auths']]['state'] ?? '';

            if ('OK' === $oldAState || empty($peer['Auths'])) {
                continue;
            }

            $peers[$peer['Auths']] = [
                'id'             => $peer['Auths'],
                'state'          => strtoupper($state),
                'detailed-state' => $peer['DeviceState']
            ];
        }
        return array_values($peers);
    }

    /**
     * Get the SIP peers information.
     *
     * @return array The SIP peers information.
     */
    public function getSipPeers(): array
    {
        $peers = [];
        $res   = $this->sendRequestTimeout('SIPpeers');
        if (isset($res['data']) && $res['data'] != null && $res['data']['PeerEntry'] != null) {
            foreach ($res['data']['PeerEntry'] as $peer) {
                if (! is_numeric($peer['ObjectName'])) {
                    continue;
                }
                // if ('Unmonitored' == $peer['Status']) continue;
                $arr_status = explode(' ', $peer['Status']);
                $peers[]    = ['id' => $peer['ObjectName'], 'state' => strtoupper($arr_status[0]),];
            }
        }

        return $peers;
    }

    /**
     * Get the SIP peer information.
     *
     * @param string $peer The peer name.
     * @return array The SIP peer information.
     */
    public function getSipPeer(string $peer): array
    {
        $parameters           = ['Peer' => trim($peer)];
        $res                  = $this->sendRequestTimeout('SIPshowpeer', $parameters);
        $arr_status           = explode(' ', $res['Status']);
        $res['state']         = strtoupper($arr_status[0]);
        $res['time-response'] = strtoupper(str_replace(['(', ')'], '', $arr_status[1]));

        return $res;
    }

    /**
     * Get the PJSIP peer information.
     *
     * @param string $peer The peer name.
     * @param string $prefix The prefix for the peer (optional).
     * @return array The PJSIP peer information.
     */
    public function getPjSipPeer(string $peer, string $prefix = ''): array
    {
        $result     = [];
        if (empty($prefix)) {
            $wsResult     = $this->getPjSipPeer($peer, "WS");
            if ($wsResult['state'] !== 'UNKNOWN') {
                $result = $wsResult;
            }
            $parameters = ['Endpoint' => trim($peer)];
            unset($wsResult);
        } else {
            $parameters = ['Endpoint' => trim($peer) . "-$prefix"];
        }

        $res        = $this->sendRequestTimeout('PJSIPShowEndpoint', $parameters);
        $generalRecordFound = !empty($result);
        foreach ($res['data']['ContactStatusDetail'] ?? [] as $index => $data) {
            $suffix = "-$prefix$index";
            if (!empty($data['URI']) && !$generalRecordFound) {
                $generalRecordFound = true;
                $suffix = '';
            }
            foreach ($data as $key => $value) {
                $result["$key$suffix"] = $value;
            }
        }
        $result['state'] = ! empty($result['URI']) ? 'OK' : 'UNKNOWN';
        return $result;
    }

    /**
     * Get all PJSIP contacts for an endpoint (supports multiple registrations)
     *
     * @param string $peer Extension number
     * @return array Array of all contacts for the extension
     */
    public function getPjSipPeerContacts(string $peer): array
    {
        $contacts = [];
        $parameters = ['Endpoint' => trim($peer)];

        // Get endpoint information with all contacts
        $res = $this->sendRequestTimeout('PJSIPShowEndpoint', $parameters);

        // Process all ContactStatusDetail entries
        foreach ($res['data']['ContactStatusDetail'] ?? [] as $contactData) {
            if (!empty($contactData['URI'])) {
                $contacts[] = $contactData;
            }
        }

        // Also check for WebRTC endpoint
        $wsParameters = ['Endpoint' => trim($peer) . "-WS"];
        $wsRes = $this->sendRequestTimeout('PJSIPShowEndpoint', $wsParameters);

        foreach ($wsRes['data']['ContactStatusDetail'] ?? [] as $contactData) {
            if (!empty($contactData['URI'])) {
                $contactData['IsWebRTC'] = true;
                $contacts[] = $contactData;
            }
        }

        return $contacts;
    }

    /*
    * MIKO End.
    */

    // *********************************************************************************************************
    // **                       MISC                                                                          **
    // *********************************************************************************************************

    /**
     * @param  string $conference
     * @param array $vars
     *
     * @return array
     */
    public function meetMeCollectInfo(string $conference, array $vars = []): array
    {
        $result    = [];
        $conf_data = $this->MeetmeList($conference);
        if (! isset($conf_data['data']['MeetmeList'])) {
            return $result;
        }
        foreach ($conf_data['data']['MeetmeList'] as $user_data) {
            $user_data['linkedid']  = $this->GetVar($user_data['Channel'], 'CHANNEL(linkedid)', null, false);
            $user_data['meetme_id'] = $this->GetVar($user_data['Channel'], 'MEETMEUNIQUEID', null, false);

            foreach ($vars as $var) {
                $user_data[$var] = $this->GetVar($user_data['Channel'], $var, null, false);
            }

            $result[] = $user_data;
        }

        return $result;
    }

    /**
     * MeetmeList
     *
     * @param string $Conference
     * @param string $ActionID
     *
     * @return array
     */
    public function MeetmeList(string $Conference, string $ActionID = ''): array
    {
        if (empty($ActionID)) {
            $ActionID = Util::generateRandomString(5);
        }
        $parameters = [
            'Conference' => $Conference,
            'ActionID'   => $ActionID,
        ];

        return $this->sendRequestTimeout('MeetmeList', $parameters);
    }

    /**
     * Gets a Channel Variable
     *
     * @link http://www.voip-info.org/wiki-Asterisk+Manager+API+Action+GetVar
     * @link http://www.voip-info.org/wiki-Asterisk+variables
     *
     * @param string $channel  Channel to read variable from
     * @param string $variable
     * @param $actionId message matching variable
     * @param bool $retArray
     *
     * @return string | array
     */
    public function GetVar(string $channel, string $variable, $actionId = null, bool $retArray = true)
    {
        $parameters = ['Channel' => $channel, 'Variable' => $variable];
        if ($actionId) {
            $parameters['ActionID'] = $actionId;
        }

        $data = $this->sendRequestTimeout('GetVar', $parameters);
        if ($retArray !== true) {
            $data = (isset($data['Value']) && $data['Value']) ? $data['Value'] : '';
        }

        return $data;
    }

    /**
     * Add event handler
     *
     * Known Events include ( http://www.voip-info.org/wiki-asterisk+manager+events )
     *   Link - Fired when two voice channels are linked together and voice data exchange commences.
     *   Unlink - Fired when a link between two voice channels is discontinued, for example, just before call
     *   completion. Newexten - Hangup - Newchannel - Newstate - Reload - Fired when the "RELOAD" console command is
     *   executed. Shutdown - ExtensionStatus - Rename - Newcallerid - Alarm - AlarmClear - Agentcallbacklogoff -
     *   Agentcallbacklogin - Agentlogoff - MeetmeJoin - MessageWaiting - join - leave - AgentCalled - ParkedCall -
     *   Fired after ParkedCalls Cdr - ParkedCallsComplete - QueueParams - QueueMember - QueueStatusEnd - Status -
     *   StatusComplete - ZapShowChannels - Fired after ZapShowChannels ZapShowChannelsComplete -
     *
     * @param string $event    type or * for default handler
     * @param array | string $callback function
     *
     * @return bool sucess
     */
    public function addEventHandler(string $event, $callback): bool
    {
        $event = strtolower($event);
        if (isset($this->event_handlers[$event])) {
            return false;
        }
        $this->event_handlers[$event] = $callback;

        return true;
    }
}