hitagi-entrada/hitagi-entrada-swoole.php

<?php
require __DIR__ . '/vendor/autoload.php';
require __DIR__ . '/includes/wrapper-swoole.php';

use Hitlabs\Hitagi\AGIEntrada;
use Swoole\Runtime;
use Swoole\Table;
use Swoole\Server;

Runtime::enableCoroutine();
$table = new Table(1024);
$table->column('agi', Swoole\Table::TYPE_INT);
$table->column('data', Swoole\Table::TYPE_STRING, 65536);
$table->column('agi_arg', Swoole\Table::TYPE_STRING, 65536);
$table->create();
$server = new Swoole\Server("0.0.0.0", 8073);
$server->table = $table;

$server->on('start', function ($server) {
    echo "LOG ======> Servidor iniciou na porta 8073...." . PHP_EOL;
});

$server->on("connect", function (Server $server, $fd) {
    echo "LOG ======> Cliente $fd conectado...." . PHP_EOL;
});

$server->on("receive", function ($server, $fd, $reactor_id, $data) {

    $table_data = $server->table->get($fd);
    // echo "LOG ======> table_data: " . print_r($table_data, true) . PHP_EOL;

    if (!is_array($table_data)) {
        // FIRST CONNECTION
        echo 'LOG ======> Receive data (FIRST): ' . PHP_EOL . $data . PHP_EOL;
        $table_data = [
            'data' => $data,
            'agi_arg' => json_encode([])
        ];
        $server->table->set($fd, $table_data);
    } else {
        // ALREADY CONNECTED
        echo 'LOG ======> Receive data (MORE): ' . PHP_EOL . $data . PHP_EOL;
        $table_data['data'] .= $data;
        $server->table->set($fd, $table_data);
    }

    // GET ARGV
    $argv = json_decode($table_data['agi_arg'], true);
    $explodido = explode(PHP_EOL, $data);
    foreach ($explodido as $linha) {
        $linha = trim($linha);
        if (empty($linha)) {
            continue;
        }
        $partes = explode(':', $linha);
        $comando = trim($partes[0]);
        if (substr($comando, 0, 8) == 'agi_arg_') {
            $number = str_replace('agi_arg_', '', $comando);
            $argv[$number] = trim($partes[1]);
        }
    }
    $table_data['agi_arg'] = json_encode($argv);
    $server->table->set($fd, $table_data);

    $server_close = false;
    if (strpos($table_data['data'], 'HANGUP') !== false) {
        $server_close = true;
    }

    if ((isset($argv['3'])) && ($table_data['agi'] != 1)) {

        $table_data = [
            'agi' => 1
        ];
        $server->table->set($fd, $table_data);

        $fgId = $argv[1]; // Numero do DID
        $hostname = $argv[2];
        $hostip = $argv[3];
        // $fgId = '8999';
        // $hostname = 'hitpbx-050';
        // $hostip = '177.107.205.248';

        $logEnabled = true;
        $isXampp = false;
        $appdir = dirname(__FILE__);
        chdir($appdir);
        date_default_timezone_set('America/Bahia');

        $agi = new AGIEntrada(
            array(
                'agiRunCmd' => agiRunCmdWrapper($fd, $server),
                'agiLog' => agiLogWrapper()
            ),
            array(
                'fgId' => $fgId,
                'hostname' => $hostname,
                'hostip' => $hostip,
                'logEnabled' => $logEnabled,
                'appdir' => $appdir,
                'isXampp' => $isXampp
            )
        );
        $agi->run();

        // agiRunCmdWrapper($fd,$server)('EXEC NOOP HITAGI2');
        // agiRunCmdWrapper($fd,$server)('ANSWER');
        // agiRunCmdWrapper($fd,$server)('EXEC WAIT 1');
        // agiRunCmdWrapper($fd,$server)('EXEC PLAYBACK beep');
        // agiRunCmdWrapper($fd,$server)('EXEC WAIT 1');
        // agiRunCmdWrapper($fd,$server)('GET VARIABLE CALLERID(all)');
        // // agiRunCmdWrapper($fd,$server)('HANGUP');

        $server_close = true;

    }

    if ($server_close) {
        $server->close($fd);
    }


});

$server->on("close", function ($server, $fd) {
    echo "LOG ======> Cliente $fd desconectado...." . PHP_EOL;
});

$server->start();