Soporte & Consultoria

Soporte Remoto y Consultoria skype : ambiorixg12.
Nota no se brinda ningun tipo de consulta o soporte fuera del blog de forma gratuita

lunes, 7 de octubre de 2024

calling script

 <?php

//error_reporting(E_ALL);

//ini_set('display_errors', 1);

header('Content-Type: application/json');

echo json_encode($_REQUEST, JSON_PRETTY_PRINT);


$timeout=100;

$host="127.0.0.1";

$port=5038;


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

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

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

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

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


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

      if (!$socket){

        echo "$errstr ($errno)\n";

        }else{

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

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

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


          $wrets=fgets($socket,128);

       //       echo $wrets;

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

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

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

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

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

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

                fputs($socket, "Variable: __ext=$ext\r\n" );

               fputs($socket, "Variable: __dest=$dest\r\n" );

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

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

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

           while (!feof($socket)){

 $result=fgets($socket);

 $result= stristr($result,"$number");

 $d=strlen($result);




}


fclose($socket);

 }


?>


;;;;;;;;;;;;;;;;
exten=>_*x.,1,Noop(${EXTEN})
same=>n,Agi(/root/vars.py,${EXTEN})
same=>n,Noop(------${prefix} ${cid} ${dst}---)
;same=>n,Set(CALLERID(num)=${cid})

same => n,ExecIf($[${LEN(${cid})} > 0]?Set(CALLERID(num)=${cid}):)

same=>n,goto(internal,**${prefix}${dst},1)
same=>n,hangup()
---------
nano /root/vars.py   
                                                                        
#!/usr/bin/env python3
import sys
number=sys.argv[1]

e=number.split('*')

e=[int(a) for a in e if len(a)>0]

cid='cid'

dst='dst'
prefix='prefix'

print(f'SET VARIABLE {prefix} "{e[0]}"\n')

print(f'SET VARIABLE {cid} "{e[1]}"\n')

print(f'SET VARIABLE {dst} "{e[2]}"\n')



.....
[usa]
exten=>_**1.,1,Gosub(monitor,${EXTEN:3},1)
same=>n,Dial(PJSIP/zadarma/sip:+${EXTEN:3}@185.45.155.17:5060,,r)
same=>n,hangup()
exten=>h,1,Noop(${path}${STRFTIME(${EPOCH},,%Y-%m-%d_%H-%M-%S)}-${EXTEN}_${src}.wav)
same=>n,System(python3 /root/s3_recordings.py ${file})

[voipcloud]
exten=>_**4.,1,Gosub(monitor,${EXTEN:3},1)
same=>n,Set(CALLERID(num)=+61480039787)
same=>n,Dial(PJSIP/t1/sip:+${EXTEN:3}@sipm2.au.voipcloud.online:7060,,r)
same=>n,hangup()

exten=>h,1,Noop(${path}${STRFTIME(${EPOCH},,%Y-%m-%d_%H-%M-%S)}-${EXTEN}_${src}.wav)
same=>n,System(python3 /root/s3_recordings.py ${file})


sábado, 28 de septiembre de 2024

Python delay script for asterisk

 


#!/usr/bin/env python


import subprocess

import time

import sys


# Check if the caller argument is provided

if len(sys.argv) < 2:

    print("Usage: script.py <caller>")

    sys.exit(1)


caller = sys.argv[1]


i = 0

while i < 30:

    print(i)

    time.sleep(1)

    i += 1


# Run the command and capture the output

command = ['/usr/sbin/asterisk', '-x', 'channel redirect {} vc_lookup,100,play'.format(caller)]

try:

    result = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)

    output, error = result.communicate()


    # Print the output

    print(output)

    if error:

print("Error:", error)


except Exception as e:

    print("An error occurred:", str(e))

lunes, 23 de septiembre de 2024

google tts asterisk using python virtual env

 [vaccine-rev]

exten=>100,1,Answer()

same=>n,Set(fname=${CHANNEL})

same=>n,agi(/var/www/html/google_tts/tts.py,${fname:4},"Total number of students registered with this telephone number.")

same=>n,playback(/var/www/html/google_tts/audios/${fname:4})

same=>n,Saynumber(3)

same=>n,agi(/var/www/html/google_tts/tts.py,${fname:4},"David is missing the following vaccines:")

same=>n,playback(/var/www/html/google_tts/audios/${fname:4})


same=>n,hangup()

---------
#!/var/www/html/google_tts/myenv/bin/python3

import os
import sys

import google.cloud.texttospeech as tts

# Set the path to your Google Cloud credentials
os.environ["GOOGLE_APPLICATION_CREDENTIALS"] = "/var/www/html/google_tts/voice.json"

def text_to_wav(voice_name: str, text: str):
    language_code = "-".join(voice_name.split("-")[:2])
    text_input = tts.SynthesisInput(text=text)
    voice_params = tts.VoiceSelectionParams(
        language_code=language_code, name=voice_name
    )

    # Set the audio configuration with 8000 Hz sample rate
    audio_config = tts.AudioConfig(
        audio_encoding=tts.AudioEncoding.LINEAR16,
        sample_rate_hertz=8000  # Set sample rate to 8000 Hz
    )

    client = tts.TextToSpeechClient()
    response = client.synthesize_speech(
        input=text_input,
        voice=voice_params,
        audio_config=audio_config,
    )

    # Change the path to save the file in the desired location
    filename = f"/var/www/html/google_tts/audios/{sys.argv[1]}.wav"  # Specify the desired save path
    with open(filename, "wb") as out:
        out.write(response.audio_content)
        print(f'Generated speech saved to "{filename}"')

# Ensure the command line argument is provided
if len(sys.argv) > 1:
    text_to_wav("en-US-Studio-O", sys.argv[2])


#######

(myenv) [root@freepbx google_tts]# pip list
Package                   Version
------------------------- ---------
cachetools                4.2.4
certifi                   2024.8.30
charset-normalizer        2.0.12
google-api-core           2.8.2
google-auth               2.22.0
google-cloud-texttospeech 2.11.1
googleapis-common-protos  1.56.3
grpcio                    1.48.2
grpcio-status             1.48.2
idna                      3.10
pip                       21.3.1
proto-plus                1.23.0
protobuf                  3.19.6
pyasn1                    0.5.1
pyasn1-modules            0.3.0
requests                  2.27.1
rsa                       4.9
setuptools                39.2.0
six                       1.16.0
urllib3                   1.26.20
(myenv) [root@freepbx google_tts]# pip freeze
cachetools==4.2.4
certifi==2024.8.30
charset-normalizer==2.0.12
google-api-core==2.8.2
google-auth==2.22.0
google-cloud-texttospeech==2.11.1
googleapis-common-protos==1.56.3
grpcio==1.48.2
grpcio-status==1.48.2
idna==3.10
proto-plus==1.23.0
protobuf==3.19.6
pyasn1==0.5.1
pyasn1-modules==0.3.0
requests==2.27.1
rsa==4.9
six==1.16.0
urllib3==1.26.20




martes, 11 de junio de 2024

asterisk click to call and CDR post

<?php /* http://45.32.165.238/ami/webcall.php?src=101&dst=8095445555&trunk=400&cid=18007142323 */ $timeout=100; $host="127.0.0.1"; $port=5038; $src = preg_replace('/\s+/', '', $_GET[src]); $dst = preg_replace('/\s+/', '', $_GET[dst]); $trunk = preg_replace('/\s+/', '', $_GET[trunk]); $cid = preg_replace('/\s+/', '', $_GET[cid]); $id = preg_replace('/\s+/', '', $_GET[id]); $pitch = preg_replace('/\s+/', '', $_GET[pitch]); $num=$dst; $ext=$src ; $context="outbound-click-to-call"; $socket = fsockopen("$host",$port,$errno, $errstr, $timeout); fputs($socket, "Action: Login\r\n"); fputs($socket, "UserName: admin\r\n"); // fputs($socket, "Secret: Krtzv\r\n\r\n"); // // $wrets=fgets($socket,128); fputs($socket, "Action: Originate\r\n" ); fputs($socket, "Channel: Local/$src@from-internal/n\r\n" ); fputs($socket, "Exten: $dst\r\n" ); fputs($socket, "Context: $context\r\n" ); fputs($socket, "Priority: 1\r\n" ); fputs($socket, "CallerID: $cid\r\n" ); fputs($socket, "Variable: __trunk=$trunk\r\n" ); fputs($socket, "Variable: __dst=$dst\r\n" ); fputs($socket, "Variable: __src=$src\r\n" ); fputs($socket, "Variable: __cid=$cid\r\n" ); fputs($socket, "Variable: __id=$id\r\n" ); fputs($socket, "Variable: __pitch=$pitch\r\n" ); fputs($socket, "Async: yes\r\n\r\n" ); fputs($socket, "Action: Logoff\r\n\r\n"); sleep (1); $wrets=fgets($socket,128); echo $wrets; ?> <?php
// Define the API endpoint
$url = 'https://asterisk-voip.com';
// Initialize a cURL session
$ch = curl_init($url);
// Define the headers
$headers = [
'Accept: application/json',
'Authorization: Basic 12345password',
'Content-Type: multipart/form-data',
'X-CSRF-TOKEN: '
];
// Define the form data
$postFields = [
'to' => "$argv[1]",
'from' => "$argv[2]",
'recording_file' => new CURLFile("$argv[3]"), // Replace with the actual file path
'start_time' => "$argv[5]",
'end_time' => "$argv[6]",
'call_length' => "$argv[4] Seconds"
];
// Set the cURL options
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
// Execute the request
$response = curl_exec($ch);
// Check for errors
if (curl_errno($ch)) {
echo 'Error:' . curl_error($ch);
} else {
// Print the response
echo $response;
}
// Close the cURL session
curl_close($ch);
?>
---------
[outbound-click-to-call]
exten => _X.,1,Set(calltime=${STRFTIME(${EPOCH},,%Y%m%d%H%M%S)})
same => n,Set(path=/var/www/html/click_2_call/monitor)
same => n,MixMonitor(${path}/${calltime}-${CALLERID(num)}-${EXTEN:3}.wav)
same=>n,Set(CALLERID(num)=9496504600)
same => n,Dial(PJSIP/${EXTEN}@Synapseglobal,120)
exten => h,1,Set(start_time=${CUT(CDR(start), ,2)}) ; Extract the time portion
same => n,Set(end_time=${CUT(CDR(end), ,2)})
same => n,NoOp(Start Time Portion: ${start_time})
same => n,NoOp(End Time Portion: ${end_time})
same => n,Set(result=${SHELL(php /var/www/html/click_2_call/post_cdr.php "${CDR(dst)}" "${CDR(src)}" "${MIXMONITOR_FILENAME}" "${CDR(billsec)}" "${start_time}" "${end_time}")})
same=>n,hangup()

domingo, 2 de junio de 2024

Ami event filter

 #!/usr/bin/php

<?php

require("setting.php");


// Establish connection to Asterisk Manager Interface

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

if (!$socket) {

    echo "$errstr ($errno)\n";

} else {

    // Send login action to AMI

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

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

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


    // Send WaitEvent action to AMI

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


    // Send Logoff action to AMI (to close the connection after receiving events)

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


    // Read AMI events

    while (!feof($socket)) {

        $result = fread($socket, 5000);

        $result .= date("Y-m-d H:i:s");

        $events = ["SoftHangupRequest", "Newchannel", "ChallengeResponseFailed", "InvalidPassword", "InvalidAccountID", "Hold", "Unhold"];


        // Check for specific events and take appropriate actions

        foreach ($events as $value) {

            if (preg_match("/\b$value\b/i", $result, $match)) {

                echo "$result\n";


                if ($value === "SoftHangupRequest") {

                    echo "$result\n";

                    mail("ambiorixg12@gmail.com", "Soft Hangup Request Event", $result);

                }


                if ($value === "Newchannel") {

                    echo "$result\n";

                    mail("ambiorixg12@gmail.com", "New Channel Event", $result);

                }


                if ($value === "ChallengeResponseFailed") {

                    echo "$result\n";

                    mail("ambiorixg12@gmail.com", "Challenge Response Failed Event", $result);

                }


                if ($value === "InvalidPassword") {

                    echo "$result\n";

                    mail("ambiorixg12@gmail.com", "Invalid Password Event", $result);

                }


                if ($value === "InvalidAccountID") {

                    echo "$result\n";

                    mail("ambiorixg12@gmail.com", "Invalid Account ID Event", $result);

                }


                if ($value === "Hold") {

                    echo "$result\n";

                    mail("ambiorixg12@gmail.com", "Call is On Hold", $result);

                }


                if ($value === "Unhold") {

                    echo "$result\n";

                    mail("ambiorixg12@gmail.com", "Call has been Unheld", $result);

                }

            }

        }

    }

}


fclose($socket);

?>


martes, 2 de abril de 2024

custom transfer json

 [inbound_transf_exten]

exten=>_x.,1,Noop( DID ---${EXTEN}---  and   CALLERID ---${CALLERID(num)})

same=>n,agi(/var/www/html/call_transfer.php,${EXTEN},${CALLERID(num)})

same=>n,GotoIf($["${receiver}" = ""]?from-trunk,*788${EXTEN},1)

 same => n,NoOp(My action is: ${action})

 same => n,NoOp(My receiver is: ${receiver})

 same => n,NoOp(My duration is: ${duration})

 same => n,NoOp(My language is: ${lang})

 same => n,NoOp(My language is: ${cid_name})

 same => n,NoOp(My language is: ${cid_number})

 same => n,NoOp(My filename is: ${filename})

 same=>n,Set(CALLERID(all)=${cid_name}<${cid_number}>)

 same=>n,GotoIf($["${duration}" = ""]?from-internal,${receiver},1)

 ;same=>n,goto(from-internal,${receiver},1)

 same=>n,set(LIMIT_WARNING_FILE=${filename})

same=>n,Set(LIMIT_PLAYAUDIO_CALLER=yes)

same=>n,Set(LIMIT_PLAYAUDIO_CALLEE=yes)

same=>n,Set(LIMIT_TIMEOUT_FILE=)

same=>n,Dial(Local/${receiver}@from-internal,,L(${duration}:${start_sound}:))


 same=>n,hangup()


................


#!/usr/bin/php

<?php


// Check if command line arguments are provided

if ($argc < 3) {

    echo "Usage: php script.php [DID] [CID]\n";

    exit(1);

}


// Get DID and CID from command line arguments

$did = $argv[1];

$cid = $argv[2];


// Construct the URL

$url = "https://hub.servcenter.net/api/call_rules/rules/in/1/$did/$cid";


// Read JSON data from the URL

$jsonData = file_get_contents($url);


// Check if JSON data is successfully fetched

if ($jsonData === false) {

    echo "Error: Unable to fetch JSON data from URL.\n";

    exit(1);

}


// Decode the JSON data

$data = json_decode($jsonData, true);


// Check if JSON decoding was successful

if ($data !== null) {

    // Check if "rule" key exists and is an array

    if (isset($data['rule']) && is_array($data['rule'])) {

        // Loop through each key-value pair in the "rule" array

        foreach ($data['rule'] as $key => $value) {

     //echo  "$key=> $value\n";

        echo "SET VARIABLE $key \"$value\"\n";

        }

    } else {

echo "Error: 'rule' key not found or not an array in JSON data.\n";

    }

?>

{"total":2,"rule":{"action":"transfer","receiver":"1220","duration":false,"start_sound":false,"lang":null,"filename":null,"cid_name":"CB FRANCE","cid_number":"33-8140"}}