Dialing and getting DIALSTATUS

#!/usr/bin/env php

<?php

echo "EXEC Dial \"PJSIP/6002,7\"\n";

echo "GET VARIABLE DIALSTATUS\n";

$dstatus=null;

while($line= fgets(STDIN)){

if (strpos($line, "result=1") !== false) {

echo "EXEC Verbose \"$line \"\n";

$dstatus=explode(')',$line);

$dstatus=explode('(',$dstatus[0])[1];

echo "EXEC Verbose \"$dstatus\"\n";

break;

}

}

if($dstatus!='ANSWER'){

echo "EXEC Playback im-sorry\n";

}

?>

;;;;;;;;;;;;;;;;;;;

[dial_AGI]

exten=>2001,1,AGi(/root/agi.php)

same=>n,hangup()

Custom Ringroup

[internal]

exten=>2000,1,Answer()

same=>n,Agi(/var/www/html/mysql_class/extensions_list.php)

same=>n(restart),Set(i=0)

same=>n,NoOp(Ext=${HASH(extension,${i})})

same=>n,NoOp(Timeout=${HASH(timeout,${i})})

same=>n,NoOp(-------------- Total number of extensions to call $[${lastExten}+1] -------)

same=>n,While($["${DIALSTATUS}" != "ANSWER"])

same=>n,NoOp(Calling extension ${HASH(extension,${i})} / Last status ${DIALSTATUS})

same=>n,Dial(PJSIP/${HASH(extension,${i})},${HASH(timeout,${i})})

same=>n,ExecIf($["${DIALSTATUS}"="ANSWER"]?Hangup())

same=>n,GotoIf($[${i}>=${lastExten}]?restart)

same=>n,Set(i=$[${i}+1])

same=>n,NoOp(Next extension ${HASH(extension,${i})} | Total $[${lastExten}+1])

same=>n,EndWhile()

same=>n,Hangup()

;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;

#!/usr/bin/env php

<?php

require_once(__DIR__."/dbManager.php");

$db=new dbManager(

    host:'127.0.0.1',

    user:'root',

    password:'7136',

    db:'test_db'

);

$extensions=$db->select("SELECT * FROM extensions ORDER BY position ASC");

echo "Answer\n";

$i=0;

foreach($extensions as $ext){

    echo "{$ext['number']} {$ext['position']}\n";

    echo "SET VARIABLE HASH(extension,{$i}) \"{$ext['number']}\"\n";

    echo "SET VARIABLE HASH(timeout,{$i}) \"{$ext['timeout']}\"\n";

    $i++;

}

$lastExten=count($extensions)-1;

echo "SET VARIABLE lastExten \"{$lastExten}\"\n";

echo "EXEC Verbose \"Total of extensions to call: from 0 to {$lastExten}\" 1\n";

?>

;;;;;;;;;;;;;;;;;;;;;;;;;;;CLASS

<?php

declare(strict_types=1);

class dbManager
{
    private string $host;
    private string $user;
    private string $password;
    private string $db;

    private ?PDO $pdo = null;

    /**
     * Internal documentation array for methods
     */
    private static array $docs = [
        '__construct' => [
            'description' => 'Create a database connection.',
            'example' => "new dbManager(host: '127.0.0.1', user: 'root', password: 'pass', db: 'test')"
        ],
        'updateConnection' => [
            'description' => 'Update the connection configuration; only provided parameters are updated.',
            'example' => "\$db->updateConnection(user: 'newuser')"
        ],
        'insert' => [
            'description' => 'Insert a row and return last insert ID.',
            'example' => "\$db->insert(\"INSERT INTO users (name,status) VALUES (:name,:status)\", ['name'=>'John','status'=>'active'])"
        ],
        'select' => [
            'description' => 'Select multiple rows.',
            'example' => "\$db->select(\"SELECT * FROM users WHERE status = :status\", ['status'=>'active'])"
        ],
        'selectOne' => [
            'description' => 'Select single row or null.',
            'example' => "\$db->selectOne(\"SELECT * FROM users WHERE id = :id\", ['id'=>1])"
        ],
        'update' => [
            'description' => 'Update rows and return affected count.',
            'example' => "\$db->update(\"UPDATE users SET status=:status WHERE id=:id\", ['status'=>'inactive','id'=>1])"
        ],
        'delete' => [
            'description' => 'Delete rows and return affected count.',
            'example' => "\$db->delete(\"DELETE FROM users WHERE id=:id\", ['id'=>1])"
        ],
        'getConInfo' => [
            'description' => 'Return current connection information.',
            'example' => "\$db->getConInfo()"
        ],
        'printMethods' => [
            'description' => 'Print all documented public methods with description and usage.',
            'example' => "dbManager::printMethods()"
        ]
    ];

    /**
     * Constructor
     */
    public function __construct(string $host, string $user, string $password, string $db)
    {
        $this->validateHost($host);

        if (trim($user) === '' || strlen($user) < 3) {
            throw new InvalidArgumentException('Username must be at least 3 characters long');
        }

        $this->host = $host;
        $this->user = $user;
        $this->password = $password;
        $this->db = $db;

        $this->connect();
    }

    /**
     * Connect to the database
     */
    private function connect(): void
    {
        $dsn = "mysql:host={$this->host};dbname={$this->db};charset=utf8mb4";
        try {
            $this->pdo = new PDO($dsn, $this->user, $this->password, [
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
            ]);
        } catch (PDOException $e) {
            echo $e->getMessage();
            exit;
        }
    }

    /**
     * Update connection configuration
     */
    public function updateConnection(?string $host = null, ?string $user = null, ?string $password = null, ?string $db = null): void
    {
        if ($host !== null) {
            $this->validateHost($host);
            $this->host = $host;
        }

        if ($user !== null) {
            if (trim($user) === '' || strlen($user) < 3) {
                throw new InvalidArgumentException('Username must be at least 3 characters long');
            }
            $this->user = $user;
        }

        if ($password !== null) {
            $this->password = $password;
        }

        if ($db !== null) {
            $this->db = $db;
        }

        $this->connect();
    }

    /**
     * CRUD Methods
     */
    public function insert(string $sql, array $params = []): int
    {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return (int)$this->pdo->lastInsertId();
    }

    public function select(string $sql, array $params = []): array
    {
       
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt->fetchAll();
    }

    public function selectOne(string $sql, array $params = []): ?array
    {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        $result = $stmt->fetch();
        return $result === false ? null : $result;
    }

    public function update(string $sql, array $params = []): int
    {    
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt->rowCount();
    

     }

    public function delete(string $sql, array $params = []): int
    {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt->rowCount();
    }

    /**
     * Get connection info
     */
    public function getConInfo(): array
    {
        return [
            'host' => $this->host,
            'user' => $this->user,
            'database' => $this->db
        ];
    }

    /**
     * Print all documented public methods with description and usage
     */
    public static function printMethods(): void
    {
        foreach (self::$docs as $method => $info) {
            echo $method . "()\n";
            echo "  Description: " . $info['description'] . "\n";
            echo "  Example: " . $info['example'] . "\n\n";
        }
    }

    /**
     * Validate host/IP
     */
    private function validateHost(string $host): void
    {
        if (!filter_var($host, FILTER_VALIDATE_IP) &&
            !filter_var($host, FILTER_VALIDATE_DOMAIN, FILTER_FLAG_HOSTNAME)
        ) {
            throw new InvalidArgumentException('Invalid host or IP address');
        }
    }
}
?>

click to call

 <?php

//https://pbxncom/asterisk_api/click_to_call.php?key=A7f9K2bX4qP1Lz7a&src=100&dst=13052341212&cid=11302846&trunk=1

//error_reporting(E_ALL & ~E_USER_WARNING & ~E_USER_NOTICE);


//ini_set('display_errors', 1);

header('Content-Type: application/json');
$key="kA7f9Mze";

if($_GET['key']!="$key"){


echo json_encode(["Auth"=>401],JSON_PRETTY_PRINT);
exit();
}

print_r(json_encode($_REQUEST, JSON_PRETTY_PRINT));

$timeout=100;

$host="127.0.0.1";

$port=5038;



$src = preg_replace('/\D/', '', $_GET['src']); // remove non-digits
$dst = preg_replace('/\D/', '', $_GET['dst']); // remove non-digits

$trunkId = preg_replace('/\D/', '', $_GET['trunk']); // remove non-digits


$trunks=[1=>"Twilio",2=>"Telnyx",3=>"Didlogic"];

$trunk=$trunks[$trunkId]??$trunks[1];  // set  a default trunk if none is selected



$cid = preg_replace('/\s+/', '', $_GET['cid']);

$id = preg_replace('/\s+/', '', $_GET['id']);


$socket = fsockopen("$host","$port", $errno, $errstr, 10);

      if (!$socket){

      //If network connection fails; 
      print_r(json_encode([$errstr=>$errno],JSON_PRETTY_PRINT));

        }else{

            fputs($socket, "Action: Login\r\n");

            fputs($socket, "UserName: admin\r\n");

            fputs($socket, "Secret: L29481uKCU\r\n\r\n");



          $wrets=fgets($socket,128);

                
              fputs($socket, "Action: Originate\r\n" );

              fputs($socket, "Channel: Local/$src@click_to_call_api_src\r\n" );

              fputs($socket, "Exten: $dst\r\n" );

               fputs($socket, "Context: click_to_call_api_dst\r\n" );

               fputs($socket, "Priority: 1\r\n" );

               fputs($socket, "CallerID: $cid\r\n" );

                fputs($socket, "Variable: __src=$src\r\n" );

               fputs($socket, "Variable: __dst=$dst\r\n" );

               fputs($socket, "Variable: __cid=$cid\r\n" );

                fputs($socket, "Variable: __trunk=$trunk\r\n" );

             fputs($socket, "Async: yes\r\n\r\n" );   

        fputs($socket, "Action: Logoff\r\n\r\n");

           while (!feof($socket)){
  $result=fgets($socket);

                   print_r(json_encode(["API"=>"$wrets","MSG"=>$result],JSON_PRETTY_PRINT));




}



fclose($socket);

 }



?>

-------------

 [click_to_call_api_src]

exten=>_x.,1,Noop("DST : ${src}, DST : ${dst}, CID : ${CID} , TRUNK : ${trunk}");

same=>n,Set(CALLERID(num)=${dst})

same=>n,Dial(PJSIP/${src})

same=>n,hangup()

[click_to_call_api_dst]

exten=>_x.,1,Noop("DST : ${src}, DST : ${dst}, CID : ${CID} , TRUNK : ${trunk}");

same=>n,Set(CALLERID(num)=+${cid})

same => n,GotoIf($["${trunk}"="Telnyx"]?Telnyx)

same=>n,Dial(PJSIP/+${dst}@${trunk})

same=>n,hangup()

same => n(Telnyx),Set(dst=9817+${dst})  ;;add a prefix if trunk is Telnyx

same=>n,Dial(PJSIP/${dst}@${trunk})

same=>n,hangup()

-----------------

Configuring res_pjsip to work through NAT

Overview¶

Here we can show some examples of working configuration for Asterisk's SIP channel driver when Asterisk is behind NAT (Network Address Translation).

If you are migrating from chan_sip to chan_pjsip, then also read the NAT section in Migrating from chan_sip to res_pjsip for helpful tips.

Asterisk and Phones Connecting Through NAT to an ITSP¶

This example should apply for most simple NAT scenarios that meet the following criteria:

• Asterisk and the phones are on a private network.
• There is a router interfacing the private and public networks. Where the public network is the Internet.
• The router is performing Network Address Translation and Firewall functions.
• The router is configured for port-forwarding, where it is mapping the necessary ranges of SIP and RTP traffic to your internal Asterisk server.
  In this example the router is port-forwarding WAN inbound TCP/UDP 5060 and UDP 10000-20000 to LAN 192.0.2.10

This example was based on a configuration for the ITSP SIP.US and assuming you swap out the addresses and credentials for real ones, it should work for a SIP.US SIP account.

Devices Involved in the Example¶

Using RFC5737 documentation addresses

Device	IP in example
VOIP Phone(6001)	192.0.2.20
PC/Asterisk	192.0.2.10
Router	LAN: 192.0.2.1 WAN: 198.51.100.5
ITSP SIP gateway	203.0.113.1 (gw1.example.com) 203.0.113.2 (gw2.example.com)

For the sake of a complete example and clarity, in this example we use the following fake details:

ITSP Account number: 1112223333

DID number provided by ITSP: 19998887777

pjsip.conf Configuration¶

We are assuming you have already read the Configuring res_pjsip page and have a basic understanding of Asterisk. For this NAT example, the important config options to note are local_net, external_media_address and external_signaling_address in the transport type section and direct_media in the endpoint section. The rest of the options may depend on your particular configuration, phone model, network settings, ITSP, etc. The key is to make sure you have those three options set appropriately.

local_net¶

This is the IP network that we want to consider our local network. For communication to addresses within this range, we won't apply any NAT-related settings, such as the external* options below.

external_media_address¶

This is the external IP address to use in RTP handling. When a request or response is sent out from Asterisk, if the destination of the message is outside the IP network defined in the option 'local_net', and the media address in the SDP is within the localnet network, then the media address in the SDP will be rewritten to the value defined for 'external_media_address'.

external_signaling_address¶

This is much like the external_media_address setting, but for SIP signaling instead of RTP media. The two external* options mentioned here should be set to the same address unless you separate your signaling and media to different addresses or servers.

direct_media¶

Determines whether media may flow directly between endpoints

Together these options make sure the far end knows where to send back SIP and RTP packets, and direct_media ensures Asterisk stays in the media path. This is important, because our Asterisk system has a private IP address that the ITSP cannot route to. We want to make sure the SIP and RTP traffic comes back to the WAN/Public internet address of our router. The sections prefixed with "sipus" are all configuration needed for inbound and outbound connectivity of the SIP trunk, and the sections named 6001 are all for the VOIP phone.

[transport-udp-nat]
type=transport
protocol=udp
bind=0.0.0.0
local_net=192.0.2.0/24
local_net=127.0.0.1/32
external_media_address=198.51.100.5
external_signaling_address=198.51.100.5

[sipus_reg]
type=registration
transport=transport-udp-nat
outbound_auth=sipus_auth
server_uri=sip:gw1.example.com
client_uri=sip:1112223333@gw1.example.com
contact_user=19998887777
retry_interval=60

[sipus_auth]
type=auth
auth_type=userpass
password=************
username=1112223333
realm=gw1.example.com

[sipus_endpoint]
type=endpoint
transport=transport-udp-nat
context=from-external
disallow=all
allow=ulaw
outbound_auth=sipus_auth
aors=sipus_aor
direct_media=no
from_domain=gw1.example.com

[sipus_aor]
type=aor
contact=sip:gw1.example.com
contact=sip:gw2.example.com

[sipus_identify]
type=identify
endpoint=sipus_endpoint
match=203.0.113.1
match=203.0.113.2

[6001]
type=endpoint
context=from-internal
disallow=all
allow=ulaw
transport=transport-udp-nat
auth=6001
aors=6001
direct_media=no

[6001]
type=auth
auth_type=userpass
password=************
username=6001

[6001]
type=aor
max_contacts=2

For Remote Phones Behind NAT¶

In the above example we assumed the phone was on the same local network as Asterisk. Now, perhaps Asterisk is exposed on a public address, and instead your phones are remote and behind NAT, or maybe you have a double NAT scenario?

In these cases you will want to consider the below settings for the remote endpoints.

media_address¶

IP address used in SDP for media handling

At the time of SDP creation, the IP address defined here will be used as

rtp_symmetric¶

Enforce that RTP must be symmetric. Send RTP back to the same address/port we received it from.

force_rport¶

Force RFC3581 compliant behavior even when no rport parameter exists. Basically always send SIP responses back to the same port we received SIP requests from.

direct_media¶

Determines whether media may flow directly between endpoints.

rewrite_contact¶

Determine whether SIP requests will be sent to the source IP address and port, instead of the address provided by the endpoint.

Clients Supporting ICE,STUN,TURN¶

This is really relevant to media, so look to the section here for basic information on enabling this support and we'll add relevant examples later.

https://docs.asterisk.org/Configuration/Channel-Drivers/SIP/Configuring-res_pjsip/Configuring-res_pjsip-to-work-through-NAT/#overview

sox convertion

 sox tarotgama.wav -t ul -r 8000 -c 1 tarotgama.ulaw

sox tarotgama.wav -r 8000 -c 1 -e signed -b 16 -t wav tarotgama_asterisk.wav

while endwhile

 exten => 100,1,Answer()

 same => n,Set(i=1)   ; counter

 same => n,AGI(getTotal.php,${userID})  ; sets vmtotal, body, mdate, recipient, etc.

 same => n,While($[${i} <= ${vmtotal}])

   same => n,Playback(message-number)

   same => n,SayDigits(${i})

   same => n,Playback(from)

   same => n,Playback(${recipient})

   same => n,Playback(at)

   same => n,SayTime(${mtime})

   same => n,Playback(${body})

   same => n,Set(i=$[${i} + 1])

 same => n,EndWhile()

 same => n,Playback(no-more-msg)

 same => n,Hangup()

 same => n,ExecIf($["${isyou}" != "1" || "${isyou}"!="2"]?Playback(${audio_path_general}/no-valid-option))

same=>n,ExecIf($["${LEN(${userPin})}" < "4" && "${userPin}"!="#"]?Playback(${audio_path_general}/4-digits-required))

same => n,GotoIf($[${action}=9]?user-menu,100,1)

same=>n,ExecIf($[${LEN(${opt})} ="0"]?playback(${audio_path_general}/no-valid-option))

same => n,GotoIf($[${LEN(${opt})}="0]"?update-lang)

same => n,GotoIf($[${opt}>3]?update-lang)

same=>n,goto(personal-menu)

same=>n,ExecIf($["${opt}" = "1" || "${opt}" = "2" || "${opt}" = "3" ]?Playback(${audio_path_general}/lang-updated&${audio_path_general}/sent-prev-menu):Playback(${audio_path_general}/no-valid-option))