Created lib directory to hold vicidial library files.
Moved vicidial.pm to the lib directory. Created vicilib-testcode.pl to test the new vicidial.pm library. Fixed vicidail.pm so it is no longer experimental. git-svn-id: svn://192.168.202.10@809 3d104415-ff17-0410-8863-d5cf3c621b8a
This commit is contained in:
mikec
-458
@@ -1,458 +0,0 @@
|
||||
package vicidial;
|
||||
|
||||
# vicidial.pm version 2.0.5
|
||||
#
|
||||
# Experimental library for general vicidial things
|
||||
#
|
||||
# DO NOT USE!!! CURRENTLY UNTESTED!!!
|
||||
#
|
||||
# Copyright (C) 2008 VICIDIAL-GROUP <info@vicidial-group.com> LICENSE: AGPLv2
|
||||
#
|
||||
# CHANGELOG:
|
||||
# 80311-1611 - First test build
|
||||
|
||||
use 5.008;
|
||||
use strict;
|
||||
use warnings;
|
||||
use Switch;
|
||||
|
||||
# function to perform logging for agi scripts
|
||||
# ARG0 is the logging level of the script (0-3)
|
||||
# ARG1 is the time stamp to go along with this log
|
||||
# ARG2 is the name of the script that is currently logging
|
||||
# ARG3 is the stage that script is currently in
|
||||
# ARG4 is the log file's name
|
||||
# ARG5 is the string that is going into the log
|
||||
# this function does not return a value
|
||||
sub agi_output {
|
||||
my $agi_log_level = $_[0];
|
||||
my $now_date = $_[1];
|
||||
my $script_name = $_[2];
|
||||
my $process_stage = $_[3];
|
||||
my $log_file_name = $_[4];
|
||||
my $log_string = $_[5];
|
||||
|
||||
my $write_string "$now_date|$script_name|$process_stage|$log_string";
|
||||
|
||||
# logging to file
|
||||
if ( $agi_log_level >= 2 ) {
|
||||
# open the log file for writing
|
||||
my $file_opened = 1;
|
||||
open( Lout, ">>$log_file_name" ) || $file_opened = 0;
|
||||
if ( $file_opened ) { # if the file was opened print to it and then close
|
||||
print Lout "$write_string\n";
|
||||
close(Lout);
|
||||
} else { # else print a message to STDERR
|
||||
print STDERR "Can't open $log_file_name to write $write_string: $!\n";
|
||||
}
|
||||
}
|
||||
|
||||
# loggin to STDERR
|
||||
if ( ( $agi_log_level == '1' ) || ( $agi_log_level == '3' ) ) {
|
||||
print STDERR "$write_string\n";
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
# function to get the localtime as a date hash
|
||||
# does not take any arguments
|
||||
# this function returns a hash with the localtime in it
|
||||
# the has has the following values:
|
||||
# 'sec' = the seconds
|
||||
# 'min' = the minutes
|
||||
# 'hour' = the hours
|
||||
# 'Fhour' = the hours with a 0 infront if it it less than 10
|
||||
# 'mday' = the day of the month
|
||||
# 'mon' = the month of the year
|
||||
# 'year' = the year
|
||||
# 'wday' = the day of the week
|
||||
# 'yday' = the day of the year
|
||||
# 'isdst' = if day light savings time is in effect
|
||||
sub get_date_hash {
|
||||
# init the hash
|
||||
my %date_hash = ();
|
||||
|
||||
# assign the values
|
||||
(
|
||||
$date_hash{ 'sec' },
|
||||
$date_hash{ 'min' },
|
||||
$date_hash{ 'hour' },
|
||||
$date_hash{ 'mday' },
|
||||
$date_hash{ 'mon' },
|
||||
$date_hash{ 'year' },
|
||||
$date_hash{ 'wday' },
|
||||
$date_hash{ 'yday' },
|
||||
$date_hash{ 'isdst' }
|
||||
) = localtime( time );
|
||||
|
||||
# make the values more useful
|
||||
$date_hash{ 'year' } = ( $date_hash{ 'year' } + 1900 );
|
||||
$date_hash{ 'mon' }++;
|
||||
if ( $date_hash{ 'mon' } < 10 ) {
|
||||
$date_hash{ 'mon' } = "0$date_hash{ 'mon' }";
|
||||
}
|
||||
if ( $date_hash{ 'mday' } < 10 ) {
|
||||
$date_hash{ 'mday' } = "0$date_hash{ 'mday' }";
|
||||
}
|
||||
if ( $date_hash{ 'min' } < 10 ) {
|
||||
$date_hash{ 'min' } = "0$date_hash{ 'min' }";
|
||||
}
|
||||
if ( $date_hash{ 'sec' } < 10 ) {
|
||||
$date_hash{ 'sec' } = "0$date_hash{ 'sec' }";
|
||||
}
|
||||
if ( $date_hash{ 'hour' } < 10 ) {
|
||||
$date_hash{ 'Fhour' } = "0$date_hash{ 'hour' }";
|
||||
} else {
|
||||
$date_hash{ 'Fhour' } = $date_hash{ 'hour' };
|
||||
}
|
||||
|
||||
# return the hash
|
||||
return \%date_hash;
|
||||
}
|
||||
|
||||
|
||||
# function to convert a date hash to a date string
|
||||
# ARG1 is a date_hash to convert
|
||||
# this function returns a date string
|
||||
sub get_now_date {
|
||||
my %date_hash = %$_[0];
|
||||
|
||||
# build the string
|
||||
my $now_date =
|
||||
"$date_hash{ 'year' }-$date_hash{ 'mon' }-$date_hash{ 'mday' } $date_hash{ 'Fhour' }:$date_hash{ 'min' }:$date_hash{ 'sec' }";
|
||||
|
||||
return $now_date;
|
||||
}
|
||||
|
||||
# function to load the astguicleint config file
|
||||
# ARG0 the path to the astguiclient config file
|
||||
# this function returns a hash with all of the config file values
|
||||
# the has has the following values:
|
||||
# 'logs_path' = the path to the log directory
|
||||
# 'home_path' = the location of the astguiclient scripts
|
||||
# 'agi_path' = the path to the asteirsk agi directory
|
||||
# 'web_path' = the path to the apache web directory vicidial is in
|
||||
# 'sounds_path' = the path to the asterisk sounds directory
|
||||
# 'monitor_path' = the path to where asterisk stores the recordings
|
||||
# 'done_monitor_path' = the path to put the recordings after where done compressing them
|
||||
# 'fagi_log_min_servers' = minimum number of server threads for the FAGI
|
||||
# 'fagi_log_max_servers' = maximum number of server threads for the FAGI
|
||||
# 'fagi_log_min_spare_servers' = minimum number of spare server threads for the FAGI
|
||||
# 'fagi_log_max_spare_servers' = maximum number of spare server threads for the FAGI
|
||||
# 'fagi_log_max_requests' = maximum number of requests a thread should handle before dieing
|
||||
# 'fagi_log_checkfordead' = seconds before looking for dead threads to kill
|
||||
# 'fagi_log_checkforwait' = seconds before looking if the FAGI can kill some waitng threads
|
||||
# 'server_ip' = IP address of the server
|
||||
# 'active_keepalives' = which processes should be check to see if they are alive
|
||||
# 'db_server' = the IP or Hostname of the database server
|
||||
# 'db_database' = the database that vicidial uses
|
||||
# 'db_user' = the username that is used to connect to the database
|
||||
# 'db_pass' = the password that is used to connect to the database
|
||||
# 'db_port' = the port number to connect to the database
|
||||
# 'ftp_host' = the IP or Hostname of the ftp server to store the recordings on
|
||||
# 'ftp_user' = the username that is used to connect to the recording ftp server
|
||||
# 'ftp_pass' = the password that is used to connect to the recording ftp server
|
||||
# 'ftp_port' = the port number to connect to the recording ftp server
|
||||
# 'ftp_dir' = the directory to place the recording into on the recording ftp server
|
||||
# 'ftp_http_path' = the web address to access the recording that are on the recording ftp server
|
||||
# 'report_host' = the IP or Hostname of the ftp server to store the reports on
|
||||
# 'report_user' = the username that is used to connect to the report ftp server
|
||||
# 'report_pass' = the password that is used to connect to the report ftp server
|
||||
# 'report_port' = the port number to connect to the report ftp server
|
||||
# 'report_dir' = the directory to place the reports into on the report ftp server
|
||||
sub load_config_file {
|
||||
my $file_path = $_[0];
|
||||
|
||||
# init the hash
|
||||
my %config_hash = ();
|
||||
|
||||
# open the config file and read it in
|
||||
open( conf, "$file_path" ) || die "can't open $file_path: $!\n";
|
||||
my @conf = <conf>;
|
||||
close(conf);
|
||||
|
||||
# loop through the configs and set the apportiate value in the config_hash
|
||||
my $i = 0;
|
||||
foreach (@conf) {
|
||||
my $line = $conf[$i];
|
||||
$line =~ s/ |>|\n|\r|\t|\#.*|;.*//gi;
|
||||
|
||||
switch ( $line ) {
|
||||
# Paths to various directories
|
||||
case /^PATHlogs/ {
|
||||
%config_hash{ 'logs_path' } = $line;
|
||||
%config_hash{ 'logs_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^PATHhome/ {
|
||||
%config_hash{ 'home_path' } = $line;
|
||||
%config_hash{ 'home_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^PATHagi/ {
|
||||
%config_hash{ 'agi_path' } = $line;
|
||||
%config_hash{ 'agi_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^PATHweb/ {
|
||||
%config_hash{ 'web_path' } = $line;
|
||||
%config_hash{ 'web_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^PATHsounds/ {
|
||||
%config_hash{ 'sounds_path' } = $line;
|
||||
%config_hash{ 'sounds_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^PATHmonitor/ {
|
||||
%config_hash{ 'monitor_path' } = $line;
|
||||
%config_hash{ 'monitor_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^PATHDONEmonitor/ {
|
||||
%config_hash{ 'done_monitor_path' } = $line;
|
||||
%config_hash{ 'done_monitor_path' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# FAGI log server settings
|
||||
case /^VARfastagi_log_min_servers/ {
|
||||
%config_hash{ 'fagi_log_min_servers' } = $line;
|
||||
%config_hash{ 'fagi_log_min_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARfastagi_log_max_servers/ {
|
||||
%config_hash{ 'fagi_log_max_servers' } = $line;
|
||||
%config_hash{ 'fagi_log_max_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARfastagi_log_min_spare_servers/ {
|
||||
%config_hash{ 'fagi_log_min_spare_servers' } = $line;
|
||||
%config_hash{ 'fagi_log_min_spare_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARfastagi_log_max_spare_servers/ {
|
||||
%config_hash{ 'fagi_log_max_spare_servers' } = $line;
|
||||
%config_hash{ 'fagi_log_max_spare_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARfastagi_log_max_requests/ {
|
||||
%config_hash{ 'fagi_log_max_requests' } = $line;
|
||||
%config_hash{ 'fagi_log_max_requests' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARfastagi_log_checkfordead/ {
|
||||
%config_hash{ 'fastagi_log_checkfordead' } = $line;
|
||||
%config_hash{ 'fastagi_log_checkfordead' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARfastagi_log_checkforwait/ {
|
||||
%config_hash{ 'fastagi_log_checkforwait' } = $line;
|
||||
%config_hash{ 'fastagi_log_checkforwait' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# general server settings
|
||||
case /^VARserver_ip/ {
|
||||
%config_hash{ 'server_ip' } = $line;
|
||||
%config_hash{ 'server_ip' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARactive_keepalives/ {
|
||||
%config_hash{ 'active_keepalives' } = $line;
|
||||
%config_hash{ 'active_keepalives' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# Database server connection information
|
||||
case /^VARDB_server/ {
|
||||
%config_hash{ 'db_server' } = $line;
|
||||
%config_hash{ 'db_server' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARDB_database/ {
|
||||
%config_hash{ 'db_database' } = $line;
|
||||
%config_hash{ 'db_database' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARDB_user/ {
|
||||
%config_hash{ 'db_user' } = $line;
|
||||
%config_hash{ 'db_user' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARDB_pass/ {
|
||||
%config_hash{ 'db_pass' } = $line;
|
||||
%config_hash{ 'db_pass' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARDB_port/ {
|
||||
%config_hash{ 'db_port' } = $line;
|
||||
%config_hash{ 'db_port' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# FTP recording archive connection information
|
||||
case /^VARFTP_host/ {
|
||||
%config_hash{ 'ftp_host' } = $line;
|
||||
%config_hash{ 'ftp_host' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARFTP_user/ {
|
||||
%config_hash{ 'ftp_user' } = $line;
|
||||
%config_hash{ 'ftp_user' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARFTP_pass/ {
|
||||
%config_hash{ 'ftp_pass' } = $line;
|
||||
%config_hash{ 'ftp_pass' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARFTP_port/ {
|
||||
%config_hash{ 'ftp_port' } = $line;
|
||||
%config_hash{ 'ftp_port' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARFTP_dir/ {
|
||||
%config_hash{ 'ftp_dir' } = $line;
|
||||
%config_hash{ 'ftp_dir' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARHTTP_path/ {
|
||||
%config_hash{ 'ftp_http_path' } = $line;
|
||||
%config_hash{ 'ftp_http_path' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# REPORT server connection information
|
||||
case /^VARREPORT_host/ {
|
||||
%config_hash{ 'report_host' } = $line;
|
||||
%config_hash{ 'report_host' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARREPORT_user/ {
|
||||
%config_hash{ 'report_user/' } = $line;
|
||||
%config_hash{ 'report_user/' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARREPORT_pass/ {
|
||||
%config_hash{ 'report_pass' } = $line;
|
||||
%config_hash{ 'report_pass' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARREPORT_port/ {
|
||||
%config_hash{ 'report_port' } = $line;
|
||||
%config_hash{ 'report_port' } =~ s/.*=//gi;
|
||||
}
|
||||
case /^VARREPORT_dir/ {
|
||||
%config_hash{ 'report_dir' } = $line;
|
||||
%config_hash{ 'report_dir' } =~ s/.*=//gi;
|
||||
}
|
||||
}
|
||||
$i++;
|
||||
}"$now_date|$script_name|$process_stage|$log_string\n";
|
||||
|
||||
# return the hash
|
||||
return \%config_hash;
|
||||
}
|
||||
|
||||
|
||||
# function to load the system configs from the db
|
||||
# ARG0 is an already connected database handle
|
||||
# this function returns a hash with the servers configs in it
|
||||
# the hash has the following values:
|
||||
# version = the version of astguiclient that is being used
|
||||
# install_date = the date that the orginal installation was done
|
||||
# use_utf8 = if to use UTF8 instead of latin characters
|
||||
# webroot_writable = if to place temp files in the webroot directory
|
||||
# enable_qm_logging = if to use QueueMetrics
|
||||
# qm_server_ip = QM servers ip address
|
||||
# qm_dbname = QM DB name
|
||||
# qm_login = QM DB username
|
||||
# qm_pass = QM DB password
|
||||
# qm_url = url to get to QM
|
||||
# qm_log_id = the server ID that all VICIDIAL logs will use as an id for each record in QM
|
||||
# qm_eq_prepend = field from vicidial_list to prepend to the cust. phone number in QM
|
||||
# vd_agent_disable = if to disable manager actions on agents screens
|
||||
# allow_sipsak_msgs = if to use sipsak
|
||||
# admin_home_url = url to go to if you click the HOME link on the top of the admin page
|
||||
# agent_xfer_weblog = log to a text logfile on the webserver every time call is xfered to agent
|
||||
sub load_sys_config_db {
|
||||
my $dbh = $_[0];
|
||||
|
||||
# init the hash
|
||||
my %system_hash = ();
|
||||
|
||||
# fetch data from db
|
||||
my $stmt =
|
||||
"SELECT version, install_date, use_non_latin, webroot_writable, enable_queuemetrics_logging, queuemetrics_server_ip, queuemetrics_dbname, queuemetrics_login, queuemetrics_pass, queuemetrics_url, queuemetrics_log_id, queuemetrics_eq_prepend, vicidial_agent_disable, allow_sipsak_messages, admin_home_url, enable_agc_xfer_log FROM system_settingsqueuemetric LIMIT 1;";
|
||||
my $sth = $dbh->prepare($stmt) or die "preparing: ", $dbh->errstr;
|
||||
$sth->execute or die "executing: $stmt ", $dbh->errstr;
|
||||
@ary = $sth->fetchrow_array;
|
||||
$sth->finish();
|
||||
|
||||
# assign the hash values
|
||||
%system_hash{ 'version' } = $ary[0]; # version db field
|
||||
%system_hash{ 'install_date' } = $ary[1]; # install_date db field
|
||||
%system_hash{ 'use_utf8' } = $ary[2]; # use_non_latin db field
|
||||
%system_hash{ 'webroot_writable' } = $ary[3]; # webroot_writable db field
|
||||
%system_hash{ 'enable_qm_log' } = $ary[4]; # enable_queuemetrics_logging db field
|
||||
%system_hash{ 'qm_server_ip' } = $ary[5]; # queuemetrics_server_ip db field
|
||||
%system_hash{ 'qm_dbname' } = $ary[6]; # queuemetrics_dbname db field
|
||||
%system_hash{ 'qm_login' } = $ary[7]; # queuemetrics_login db field
|
||||
%system_hash{ 'qm_pass' } = $ary[8]; # queuemetrics_pass db field
|
||||
%system_hash{ 'qm_url' } = $ary[9]; # queuemetrics_url db field
|
||||
%system_hash{ 'qm_log_id' } = $ary[10]; # queuemetrics_log_id db field
|
||||
%system_hash{ 'qm_eq_prepend' } = $ary[11]; # queuemetrics_eq_prepend db field
|
||||
%system_hash{ 'vd_agent_disable' } = $ary[12]; # vicidial_agent_disable db field
|
||||
%system_hash{ 'allow_sipsak_msgs' } = $ary[13]; # allow_sipsak_messages db field
|
||||
%system_hash{ 'admin_home_url' } = $ary[14]; # admin_home_url db field
|
||||
%system_hash{ 'agent_xfer_weblog' } = $ary[15]; # enable_agc_xfer_log db field
|
||||
|
||||
# return the hash
|
||||
return \%system_hash;
|
||||
}
|
||||
|
||||
|
||||
# function to load a servers configs from the db
|
||||
# ARG0 is the ip of the server to load configs for
|
||||
# ARG1 is an already connected database handle
|
||||
# this function returns a hash with the servers configs in it
|
||||
# the hash has the following values:
|
||||
# server_id = the id for the server in the DB
|
||||
# server_desc = the description of the server
|
||||
# server_ip = the IP address of the server
|
||||
# active = if the server is active or not
|
||||
# ast_version = the version of asterisk used on the server
|
||||
# max_vd_trunks = the maximum number of trunks vicidial can use on this server
|
||||
# ast_mgr_host = the telnet host to connect to this servers Asterisk Manager interface
|
||||
# localhost = what this server thinks localhost should be (usually 127.0.0.1)
|
||||
# ast_mgr_port = the telnet port to connect to this servers Asterisk Manager interface
|
||||
# ast_mgr_user = the username for the general connection to the manager interface
|
||||
# ast_mgr_pass = the secret used to connect to the manager inferface for all of the usernames
|
||||
# ast_mgr_update_user = the username to run updates from on the manager interface
|
||||
# ast_mgr_listen_user = the username to listen on the manager interface
|
||||
# ast_mgr_send_user = the username to send actions on the manager interface
|
||||
# local_gmt = the gmt offset for this server
|
||||
# vm_dump_exten = the extension to send voicemail to on this server
|
||||
# dft_xfer_exten = default extension to send calls to for VICIDIAL auto dialing
|
||||
# ext_context = the context where to find the vicidial extension
|
||||
# sys_perf_log = if vicidial should do performance logging for this server
|
||||
# vd_server_logs = if vicidial should do normal logging for this server
|
||||
# agi_output = what style of logging should be done for this server
|
||||
# vd_balance_active = if vicidial should do balanced dialing with this server
|
||||
# vd_balance_free_trunks = the number of trunks balanced dialing must keep free
|
||||
sub load_server_config_db {
|
||||
my $server_ip = $_[0];
|
||||
my $dbh = $_[1];
|
||||
|
||||
# init the hash
|
||||
my %server_hash = ();
|
||||
|
||||
# fetch data from the DB
|
||||
my $stmt =
|
||||
"SELECT server_id, server_description, server_ip, active, asterisk_version, max_vicidial_trunks, telnet_host, localhost, telnet_port, ASTmgrUSERNAME, ASTmgrSECRET, ASTmgrUSERNAMEupdate, ASTmgrUSERNAMElisten, ASTmgrUSERNAMEsend, local_gmt, voicemail_dump_exten, answer_transfer_agent, ext_context, sys_perf_log, vd_server_logs, agi_output, vicidial_balance_active, balance_trunks_offlimits FROM SERVERS WHERE server_ip = '$server_ip' LIMIT 1;";
|
||||
my $sth = $dbh->prepare($stmt) or die "preparing: ", $dbh->errstr;
|
||||
$sth->execute or die "executing: $stmt ", $dbh->errstr;
|
||||
@ary = $sth->fetchrow_array;
|
||||
$sth->finish();
|
||||
|
||||
# assign the hash values
|
||||
%server_hash{ 'server_id' } = "$ary[0]"; # server_id db field
|
||||
%server_hash{ 'server_desc' } = "$ary[1]"; # server_description db field
|
||||
%server_hash{ 'server_ip' } = "$ary[2]"; # server_ip db field
|
||||
%server_hash{ 'active' } = "$ary[3]"; # active db field
|
||||
%server_hash{ 'ast_version' } = "$ary[4]"; # asterisk_version db field
|
||||
%server_hash{ 'max_vd_trunks' } = "$ary[5]"; # max_vicidial_trunks db field
|
||||
%server_hash{ 'ast_mgr_host' } = "$ary[6]"; # telnet_host db field
|
||||
%server_hash{ 'localhost' } = "$ary[7]"; # localhost db field
|
||||
%server_hash{ 'ast_mgr_port' } = "$ary[8]"; # telnet_port db field
|
||||
%server_hash{ 'ast_mgr_user' } = "$ary[9]"; # ASTmgrUSERNAME db field
|
||||
%server_hash{ 'ast_mgr_pass' } = "$ary[10]"; # ASTmgrSECRET db field
|
||||
%server_hash{ 'ast_mgr_update_user' } = "$ary[11]"; # ASTmgrUSERNAMEupdate db field
|
||||
%server_hash{ 'ast_mgr_listen_user' } = "$ary[12]"; # ASTmgrUSERNAMElisten db field
|
||||
%server_hash{ 'ast_mgr_send_user' } = "$ary[13]"; # ASTmgrUSERNAMEsend db field
|
||||
%server_hash{ 'local_gmt' } = "$ary[14]"; # local_gmt db field
|
||||
%server_hash{ 'vm_dump_exten' } = "$ary[15]"; # voicemail_dump_exten db field
|
||||
%server_hash{ 'dft_xfer_exten' } = "$ary[16]"; # answer_transfer_agent db field
|
||||
%server_hash{ 'ext_context' } = "$ary[17]"; # ext_context db field
|
||||
%server_hash{ 'sys_perf_log' } = "$ary[18]"; # sys_perf_log db field
|
||||
%server_hash{ 'vd_server_logs' } = "$ary[19]"; # vd_server_logs db field
|
||||
%server_hash{ 'agi_output' } = "$ary[20]"; # agi_output db field
|
||||
%server_hash{ 'vd_balance_active' } = "$ary[21]"; # vicidial_balance_active db field
|
||||
%server_hash{ 'vd_balance_free_trunks' } = "$ary[22]"; # balance_trunks_offlimits db field
|
||||
|
||||
#return the hash
|
||||
return \%server_hash;
|
||||
}
|
||||
|
||||
1;
|
||||
+630
@@ -0,0 +1,630 @@
|
||||
package vicidial;
|
||||
|
||||
# vicidial.pm version 2.0.5
|
||||
#
|
||||
# Experimental library for general vicidial things
|
||||
#
|
||||
# This library has not been tested in a production level enviroment.
|
||||
#
|
||||
# Copyright (C) 2008 VICIDIAL-GROUP <info@vicidial-group.com> LICENSE: AGPLv2
|
||||
#
|
||||
# CHANGELOG:
|
||||
# 80311-1611 - First test build
|
||||
# 80324-1435 - Fixed minor issues and tested all functions.
|
||||
|
||||
# Export our symbols
|
||||
require Exporter;
|
||||
@ISA = qw(Exporter);
|
||||
@EXPORT = qw(agi_output get_date_hash_current get_date_hash_value get_now_date load_config_file load_sys_config_db load_server_config_db load_all_servers_config_db);
|
||||
|
||||
# USE FLAGS
|
||||
use 5.008;
|
||||
use strict;
|
||||
use warnings;
|
||||
use Switch;
|
||||
use DBI;
|
||||
|
||||
# function to perform logging for agi scripts
|
||||
# ARG0 is the logging level of the script (0-3)
|
||||
# ARG1 is the time stamp to go along with this log
|
||||
# ARG2 is the name of the script that is currently logging
|
||||
# ARG3 is the stage that script is currently in
|
||||
# ARG4 is the log file's name
|
||||
# ARG5 is the string that is going into the log
|
||||
# this function does not return a value
|
||||
sub agi_output {
|
||||
my $agi_log_level = $_[0];
|
||||
my $now_date = $_[1];
|
||||
my $script_name = $_[2];
|
||||
my $process_stage = $_[3];
|
||||
my $log_file_name = $_[4];
|
||||
my $log_string = $_[5];
|
||||
|
||||
my $write_string = "$now_date|$script_name|$process_stage|$log_string";
|
||||
|
||||
# loggin to STDERR
|
||||
if ( ( $agi_log_level == '1' ) || ( $agi_log_level == '3' ) ) {
|
||||
print STDERR "$write_string\n";
|
||||
}
|
||||
|
||||
# logging to file
|
||||
if ( $agi_log_level >= 2 ) {
|
||||
# open the log file for writing
|
||||
my $file_opened = 1;
|
||||
(open( Lout, ">>$log_file_name" )) || ($file_opened = 0);
|
||||
if ( $file_opened ) { # if the file was opened print to it and then close
|
||||
print Lout "$write_string\n";
|
||||
close(Lout);
|
||||
} else { # else print a message to STDERR
|
||||
print STDERR "Can't open $log_file_name to write $write_string: $!\n";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
# function to get a date hash that represents the current time
|
||||
# this function does not take any arguments
|
||||
# this function returns a reference to a hash with the localtime in it
|
||||
# the has has the following values:
|
||||
# 'sec' = the seconds
|
||||
# 'min' = the minutes
|
||||
# 'hour' = the hours
|
||||
# 'Fhour' = the hours with a 0 infront if it it less than 10
|
||||
# 'mday' = the day of the month
|
||||
# 'mon' = the month of the year
|
||||
# 'year' = the year
|
||||
# 'wday' = the day of the week
|
||||
# 'yday' = the day of the year
|
||||
# 'isdst' = if day light savings time is in effect
|
||||
sub get_date_hash_current {
|
||||
return get_date_hash_value(time());
|
||||
}
|
||||
|
||||
|
||||
# function to get a date hash that represents a time value
|
||||
# ARG1 a time value in seconds since epoch
|
||||
# this function returns a reference to a hash with the localtime in it
|
||||
# the has has the following values:
|
||||
# 'sec' = the seconds
|
||||
# 'min' = the minutes
|
||||
# 'hour' = the hours
|
||||
# 'Fhour' = the hours with a 0 infront if it it less than 10
|
||||
# 'mday' = the day of the month
|
||||
# 'mon' = the month of the year
|
||||
# 'year' = the year
|
||||
# 'wday' = the day of the week
|
||||
# 'yday' = the day of the year
|
||||
# 'isdst' = if day light savings time is in effect
|
||||
sub get_date_hash_value {
|
||||
# the time to compute
|
||||
my $time_val = $_[0];
|
||||
|
||||
# init the hash
|
||||
my %date_hash = ();
|
||||
|
||||
# assign the values
|
||||
(
|
||||
$date_hash{ 'sec' },
|
||||
$date_hash{ 'min' },
|
||||
$date_hash{ 'hour' },
|
||||
$date_hash{ 'mday' },
|
||||
$date_hash{ 'month' },
|
||||
$date_hash{ 'year' },
|
||||
$date_hash{ 'wday' },
|
||||
$date_hash{ 'yday' },
|
||||
$date_hash{ 'isdst' }
|
||||
) = localtime( $time_val );
|
||||
|
||||
# make the values more useful
|
||||
$date_hash{ 'year' } = ( $date_hash{ 'year' } + 1900 );
|
||||
$date_hash{ 'month' }++;
|
||||
if ( $date_hash{ 'month' } < 10 ) {
|
||||
$date_hash{ 'month' } = "0$date_hash{ 'month' }";
|
||||
}
|
||||
if ( $date_hash{ 'mday' } < 10 ) {
|
||||
$date_hash{ 'mday' } = "0$date_hash{ 'mday' }";
|
||||
}
|
||||
if ( $date_hash{ 'min' } < 10 ) {
|
||||
$date_hash{ 'min' } = "0$date_hash{ 'min' }";
|
||||
}
|
||||
if ( $date_hash{ 'sec' } < 10 ) {
|
||||
$date_hash{ 'sec' } = "0$date_hash{ 'sec' }";
|
||||
}
|
||||
if ( $date_hash{ 'hour' } < 10 ) {
|
||||
$date_hash{ 'Fhour' } = "0$date_hash{ 'hour' }";
|
||||
} else {
|
||||
$date_hash{ 'Fhour' } = $date_hash{ 'hour' };
|
||||
}
|
||||
|
||||
# return the hash
|
||||
return \%date_hash;
|
||||
}
|
||||
|
||||
|
||||
# function to convert a date hash to a date string
|
||||
# ARG1 is a reference to a date_hash to convert
|
||||
# this function returns a reference to a date string
|
||||
sub get_now_date {
|
||||
my $date_hash_ref = $_[0];
|
||||
my %date_hash = %$date_hash_ref;
|
||||
|
||||
# build the string
|
||||
my $now_date =
|
||||
"$date_hash{ 'year' }-$date_hash{ 'month' }-$date_hash{ 'mday' } $date_hash{ 'Fhour' }:$date_hash{ 'min' }:$date_hash{ 'sec' }";
|
||||
|
||||
return \$now_date;
|
||||
}
|
||||
|
||||
# function to load the astguicleint config file
|
||||
# ARG0 the path to the astguiclient config file
|
||||
# this function returns a reference to a hash with all of the config file values
|
||||
# the has has the following values:
|
||||
# 'logs_path' = the path to the log directory
|
||||
# 'home_path' = the location of the astguiclient scripts
|
||||
# 'agi_path' = the path to the asteirsk agi directory
|
||||
# 'web_path' = the path to the apache web directory vicidial is in
|
||||
# 'sounds_path' = the path to the asterisk sounds directory
|
||||
# 'monitor_path' = the path to where asterisk stores the recordings
|
||||
# 'done_monitor_path' = the path to put the recordings after where done compressing them
|
||||
# 'fagi_log_min_servers' = minimum number of server threads for the FAGI
|
||||
# 'fagi_log_max_servers' = maximum number of server threads for the FAGI
|
||||
# 'fagi_log_min_spare_servers' = minimum number of spare server threads for the FAGI
|
||||
# 'fagi_log_max_spare_servers' = maximum number of spare server threads for the FAGI
|
||||
# 'fagi_log_max_requests' = maximum number of requests a thread should handle before dieing
|
||||
# 'fagi_log_checkfordead' = seconds before looking for dead threads to kill
|
||||
# 'fagi_log_checkforwait' = seconds before looking if the FAGI can kill some waitng threads
|
||||
# 'server_ip' = IP address of the server
|
||||
# 'active_keepalives' = which processes should be check to see if they are alive
|
||||
# 'db_server' = the IP or Hostname of the database server
|
||||
# 'db_database' = the database that vicidial uses
|
||||
# 'db_user' = the username that is used to connect to the database
|
||||
# 'db_pass' = the password that is used to connect to the database
|
||||
# 'db_port' = the port number to connect to the database
|
||||
# 'ftp_host' = the IP or Hostname of the ftp server to store the recordings on
|
||||
# 'ftp_user' = the username that is used to connect to the recording ftp server
|
||||
# 'ftp_pass' = the password that is used to connect to the recording ftp server
|
||||
# 'ftp_port' = the port number to connect to the recording ftp server
|
||||
# 'ftp_dir' = the directory to place the recording into on the recording ftp server
|
||||
# 'ftp_http_path' = the web address to access the recording that are on the recording ftp server
|
||||
# 'report_host' = the IP or Hostname of the ftp server to store the reports on
|
||||
# 'report_user' = the username that is used to connect to the report ftp server
|
||||
# 'report_pass' = the password that is used to connect to the report ftp server
|
||||
# 'report_port' = the port number to connect to the report ftp server
|
||||
# 'report_dir' = the directory to place the reports into on the report ftp server
|
||||
sub load_config_file {
|
||||
my $file_path = $_[0];
|
||||
|
||||
# init the hash
|
||||
my %config_hash = ();
|
||||
|
||||
$config_hash{ 'logs_path' } = "";
|
||||
$config_hash{ 'home_path' } = "";
|
||||
$config_hash{ 'agi_path' } = "";
|
||||
$config_hash{ 'web_path' } = "";
|
||||
$config_hash{ 'sounds_path' } = "";
|
||||
$config_hash{ 'monitor_path' } = "";
|
||||
$config_hash{ 'done_monitor_path' } = "";
|
||||
$config_hash{ 'fagi_log_min_servers' } = "";
|
||||
$config_hash{ 'fagi_log_max_servers' } = "";
|
||||
$config_hash{ 'fagi_log_min_spare_servers' } = "";
|
||||
$config_hash{ 'fagi_log_max_spare_servers' } = "";
|
||||
$config_hash{ 'fagi_log_max_requests' } = "";
|
||||
$config_hash{ 'fagi_log_checkfordead' } = "";
|
||||
$config_hash{ 'fastagi_log_checkforwait' } = "";
|
||||
$config_hash{ 'server_ip' } = "";
|
||||
$config_hash{ 'active_keepalives' } = "";
|
||||
$config_hash{ 'db_server' } = "";
|
||||
$config_hash{ 'db_database' } = "";
|
||||
$config_hash{ 'db_user' } = "";
|
||||
$config_hash{ 'db_pass' } = "";
|
||||
$config_hash{ 'db_port' } = "";
|
||||
$config_hash{ 'ftp_host' } = "";
|
||||
$config_hash{ 'ftp_user' } = "";
|
||||
$config_hash{ 'ftp_pass' } = "";
|
||||
$config_hash{ 'ftp_port' } = "";
|
||||
$config_hash{ 'ftp_dir' } = "";
|
||||
$config_hash{ 'ftp_http_path' } = "";
|
||||
$config_hash{ 'report_host' } = "";
|
||||
$config_hash{ 'report_user' } = "";
|
||||
$config_hash{ 'report_pass' } = "";
|
||||
$config_hash{ 'report_port' } = "";
|
||||
$config_hash{ 'report_dir' } = "";
|
||||
|
||||
|
||||
# open the config file and read it in
|
||||
open( CONFIG, "$file_path" ) || die "can't open $file_path: $!\n";
|
||||
my @conf = <CONFIG>;
|
||||
close(CONFIG);
|
||||
|
||||
# loop through the configs and set the apportiate value in the config_hash
|
||||
my $i = 0;
|
||||
foreach (@conf) {
|
||||
my $line = $conf[$i];
|
||||
$line =~ s/ |>|\n|\r|\t|\#.*|;.*//gi;
|
||||
|
||||
switch ( $line ) {
|
||||
# Paths to various directories
|
||||
case qr/^PATHlogs/ {
|
||||
$config_hash{ 'logs_path' } = $line;
|
||||
$config_hash{ 'logs_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^PATHhome/ {
|
||||
$config_hash{ 'home_path' } = $line;
|
||||
$config_hash{ 'home_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^PATHagi/ {
|
||||
$config_hash{ 'agi_path' } = $line;
|
||||
$config_hash{ 'agi_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^PATHweb/ {
|
||||
$config_hash{ 'web_path' } = $line;
|
||||
$config_hash{ 'web_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^PATHsounds/ {
|
||||
$config_hash{ 'sounds_path' } = $line;
|
||||
$config_hash{ 'sounds_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^PATHmonitor/ {
|
||||
$config_hash{ 'monitor_path' } = $line;
|
||||
$config_hash{ 'monitor_path' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^PATHDONEmonitor/ {
|
||||
$config_hash{ 'done_monitor_path' } = $line;
|
||||
$config_hash{ 'done_monitor_path' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# FAGI log server settings
|
||||
case qr/^VARfastagi_log_min_servers/ {
|
||||
$config_hash{ 'fagi_log_min_servers' } = $line;
|
||||
$config_hash{ 'fagi_log_min_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARfastagi_log_max_servers/ {
|
||||
$config_hash{ 'fagi_log_max_servers' } = $line;
|
||||
$config_hash{ 'fagi_log_max_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARfastagi_log_min_spare_servers/ {
|
||||
$config_hash{ 'fagi_log_min_spare_servers' } = $line;
|
||||
$config_hash{ 'fagi_log_min_spare_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARfastagi_log_max_spare_servers/ {
|
||||
$config_hash{ 'fagi_log_max_spare_servers' } = $line;
|
||||
$config_hash{ 'fagi_log_max_spare_servers' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARfastagi_log_max_requests/ {
|
||||
$config_hash{ 'fagi_log_max_requests' } = $line;
|
||||
$config_hash{ 'fagi_log_max_requests' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARfastagi_log_checkfordead/ {
|
||||
$config_hash{ 'fagi_log_checkfordead' } = $line;
|
||||
$config_hash{ 'fagi_log_checkfordead' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARfastagi_log_checkforwait/ {
|
||||
$config_hash{ 'fastagi_log_checkforwait' } = $line;
|
||||
$config_hash{ 'fastagi_log_checkforwait' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# general server settings
|
||||
case qr/^VARserver_ip/ {
|
||||
$config_hash{ 'server_ip' } = $line;
|
||||
$config_hash{ 'server_ip' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARactive_keepalives/ {
|
||||
$config_hash{ 'active_keepalives' } = $line;
|
||||
$config_hash{ 'active_keepalives' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# Database server connection information
|
||||
case qr/^VARDB_server/ {
|
||||
$config_hash{ 'db_server' } = $line;
|
||||
$config_hash{ 'db_server' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARDB_database/ {
|
||||
$config_hash{ 'db_database' } = $line;
|
||||
$config_hash{ 'db_database' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARDB_user/ {
|
||||
$config_hash{ 'db_user' } = $line;
|
||||
$config_hash{ 'db_user' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARDB_pass/ {
|
||||
$config_hash{ 'db_pass' } = $line;
|
||||
$config_hash{ 'db_pass' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARDB_port/ {
|
||||
$config_hash{ 'db_port' } = $line;
|
||||
$config_hash{ 'db_port' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# FTP recording archive connection information
|
||||
case qr/^VARFTP_host/ {
|
||||
$config_hash{ 'ftp_host' } = $line;
|
||||
$config_hash{ 'ftp_host' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARFTP_user/ {
|
||||
$config_hash{ 'ftp_user' } = $line;
|
||||
$config_hash{ 'ftp_user' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARFTP_pass/ {
|
||||
$config_hash{ 'ftp_pass' } = $line;
|
||||
$config_hash{ 'ftp_pass' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARFTP_port/ {
|
||||
$config_hash{ 'ftp_port' } = $line;
|
||||
$config_hash{ 'ftp_port' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARFTP_dir/ {
|
||||
$config_hash{ 'ftp_dir' } = $line;
|
||||
$config_hash{ 'ftp_dir' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARHTTP_path/ {
|
||||
$config_hash{ 'ftp_http_path' } = $line;
|
||||
$config_hash{ 'ftp_http_path' } =~ s/.*=//gi;
|
||||
}
|
||||
|
||||
# REPORT server connection information
|
||||
case qr/^VARREPORT_host/ {
|
||||
$config_hash{ 'report_host' } = $line;
|
||||
$config_hash{ 'report_host' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARREPORT_user/ {
|
||||
$config_hash{ 'report_user' } = $line;
|
||||
$config_hash{ 'report_user' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARREPORT_pass/ {
|
||||
$config_hash{ 'report_pass' } = $line;
|
||||
$config_hash{ 'report_pass' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARREPORT_port/ {
|
||||
$config_hash{ 'report_port' } = $line;
|
||||
$config_hash{ 'report_port' } =~ s/.*=//gi;
|
||||
}
|
||||
case qr/^VARREPORT_dir/ {
|
||||
$config_hash{ 'report_dir' } = $line;
|
||||
$config_hash{ 'report_dir' } =~ s/.*=//gi;
|
||||
}
|
||||
}
|
||||
$i++;
|
||||
}
|
||||
|
||||
# return the hash
|
||||
return \%config_hash;
|
||||
}
|
||||
|
||||
|
||||
# function to load the system configs from the db
|
||||
# ARG0 is an already connected database handle
|
||||
# this function returns a hash with the servers configs in it
|
||||
# the hash has the following values:
|
||||
# version = the version of astguiclient that is being used
|
||||
# install_date = the date that the orginal installation was done
|
||||
# use_utf8 = if to use UTF8 instead of latin characters
|
||||
# webroot_writable = if to place temp files in the webroot directory
|
||||
# enable_qm_logging = if to use QueueMetrics
|
||||
# qm_server_ip = QM servers ip address
|
||||
# qm_dbname = QM DB name
|
||||
# qm_login = QM DB username
|
||||
# qm_pass = QM DB password
|
||||
# qm_url = url to get to QM
|
||||
# qm_log_id = the server ID that all VICIDIAL logs will use as an id for each record in QM
|
||||
# qm_eq_prepend = field from vicidial_list to prepend to the cust. phone number in QM
|
||||
# vd_agent_disable = if to disable manager actions on agents screens
|
||||
# allow_sipsak_msgs = if to use sipsak
|
||||
# admin_home_url = url to go to if you click the HOME link on the top of the admin page
|
||||
# agent_xfer_weblog = log to a text logfile on the webserver every time call is xfered to agent
|
||||
sub load_sys_config_db {
|
||||
my $dbh = $_[0];
|
||||
|
||||
# init the hash
|
||||
my %system_hash = ();
|
||||
|
||||
# fetch data from db
|
||||
my $stmt =
|
||||
"SELECT version, install_date, use_non_latin, webroot_writable, enable_queuemetrics_logging, queuemetrics_server_ip, queuemetrics_dbname, queuemetrics_login, queuemetrics_pass, queuemetrics_url, queuemetrics_log_id, queuemetrics_eq_prepend, vicidial_agent_disable, allow_sipsak_messages, admin_home_url, enable_agc_xfer_log FROM system_settings LIMIT 1;";
|
||||
my $sth = $dbh->prepare($stmt) or die "preparing: ", $dbh->errstr;
|
||||
$sth->execute or die "executing: $stmt ", $dbh->errstr;
|
||||
my @ary = $sth->fetchrow_array;
|
||||
$sth->finish();
|
||||
|
||||
# assign the hash values
|
||||
$system_hash{ 'version' } = $ary[0]; # version db field
|
||||
$system_hash{ 'install_date' } = $ary[1]; # install_date db field
|
||||
$system_hash{ 'use_utf8' } = $ary[2]; # use_non_latin db field
|
||||
$system_hash{ 'webroot_writable' } = $ary[3]; # webroot_writable db field
|
||||
$system_hash{ 'enable_qm_log' } = $ary[4]; # enable_queuemetrics_logging db field
|
||||
$system_hash{ 'qm_server_ip' } = $ary[5]; # queuemetrics_server_ip db field
|
||||
$system_hash{ 'qm_dbname' } = $ary[6]; # queuemetrics_dbname db field
|
||||
$system_hash{ 'qm_login' } = $ary[7]; # queuemetrics_login db field
|
||||
$system_hash{ 'qm_pass' } = $ary[8]; # queuemetrics_pass db field
|
||||
$system_hash{ 'qm_url' } = $ary[9]; # queuemetrics_url db field
|
||||
$system_hash{ 'qm_log_id' } = $ary[10]; # queuemetrics_log_id db field
|
||||
$system_hash{ 'qm_eq_prepend' } = $ary[11]; # queuemetrics_eq_prepend db field
|
||||
$system_hash{ 'vd_agent_disable' } = $ary[12]; # vicidial_agent_disable db field
|
||||
$system_hash{ 'allow_sipsak_msgs' } = $ary[13]; # allow_sipsak_messages db field
|
||||
$system_hash{ 'admin_home_url' } = $ary[14]; # admin_home_url db field
|
||||
$system_hash{ 'agent_xfer_weblog' } = $ary[15]; # enable_agc_xfer_log db field
|
||||
|
||||
# run through the hash and set any non-defined keys to ""
|
||||
for my $sys_key ( keys %system_hash ) {
|
||||
if ( !defined( $system_hash{ $sys_key } ) ) {
|
||||
$system_hash{ $sys_key } = "";
|
||||
}
|
||||
}
|
||||
|
||||
# return the hash
|
||||
return \%system_hash;
|
||||
}
|
||||
|
||||
|
||||
# function to load a servers configs from the db
|
||||
# ARG0 is the ip of the server to load configs for
|
||||
# ARG1 is an already connected database handle
|
||||
# this function returns a reference to a hash with the servers configs in it
|
||||
# the hash has the following values:
|
||||
# server_id = the id for the server in the DB
|
||||
# server_desc = the description of the server
|
||||
# server_ip = the IP address of the server
|
||||
# active = if the server is active or not
|
||||
# ast_version = the version of asterisk used on the server
|
||||
# max_vd_trunks = the maximum number of trunks vicidial can use on this server
|
||||
# ast_mgr_host = the telnet host to connect to this servers Asterisk Manager interface
|
||||
# localhost = what this server thinks localhost should be (usually 127.0.0.1)
|
||||
# ast_mgr_port = the telnet port to connect to this servers Asterisk Manager interface
|
||||
# ast_mgr_user = the username for the general connection to the manager interface
|
||||
# ast_mgr_pass = the secret used to connect to the manager inferface for all of the usernames
|
||||
# ast_mgr_update_user = the username to run updates from on the manager interface
|
||||
# ast_mgr_listen_user = the username to listen on the manager interface
|
||||
# ast_mgr_send_user = the username to send actions on the manager interface
|
||||
# local_gmt = the gmt offset for this server
|
||||
# vm_dump_exten = the extension to send voicemail to on this server
|
||||
# dft_xfer_exten = default extension to send calls to for VICIDIAL auto dialing
|
||||
# ext_context = the context where to find the vicidial extension
|
||||
# sys_perf_log = if vicidial should do performance logging for this server
|
||||
# vd_server_logs = if vicidial should do normal logging for this server
|
||||
# agi_output = what style of logging should be done for this server
|
||||
# vd_balance_active = if vicidial should do balanced dialing with this server
|
||||
# vd_balance_free_trunks = the number of trunks balanced dialing must keep free
|
||||
sub load_server_config_db {
|
||||
my $server_ip = $_[0];
|
||||
my $dbh = $_[1];
|
||||
|
||||
# init the hash
|
||||
my %server_hash = ();
|
||||
|
||||
# fetch data from the DB
|
||||
my $stmt = "SELECT server_id, server_description, server_ip, active, asterisk_version, max_vicidial_trunks, telnet_host, telnet_port, ASTmgrUSERNAME, ASTmgrSECRET, ASTmgrUSERNAMEupdate, ASTmgrUSERNAMElisten, ASTmgrUSERNAMEsend, local_gmt, voicemail_dump_exten, answer_transfer_agent, ext_context, sys_perf_log, vd_server_logs, agi_output, vicidial_balance_active, balance_trunks_offlimits FROM servers WHERE server_ip = '$server_ip' LIMIT 1;";
|
||||
|
||||
my $sth = $dbh->prepare($stmt) or die "preparing: ", $dbh->errstr;
|
||||
$sth->execute or die "executing: $stmt ", $dbh->errstr;
|
||||
my @ary = $sth->fetchrow_array;
|
||||
$sth->finish();
|
||||
|
||||
# assign the hash values
|
||||
$server_hash{ 'server_id' } = "$ary[0]"; # server_id db field
|
||||
$server_hash{ 'server_desc' } = "$ary[1]"; # server_description db field
|
||||
$server_hash{ 'server_ip' } = "$ary[2]"; # server_ip db field
|
||||
$server_hash{ 'active' } = "$ary[3]"; # active db field
|
||||
$server_hash{ 'ast_version' } = "$ary[4]"; # asterisk_version db field
|
||||
$server_hash{ 'max_vd_trunks' } = "$ary[5]"; # max_vicidial_trunks db field
|
||||
$server_hash{ 'ast_mgr_host' } = "$ary[6]"; # telnet_host db field
|
||||
$server_hash{ 'ast_mgr_port' } = "$ary[7]"; # telnet_port db field
|
||||
$server_hash{ 'ast_mgr_user' } = "$ary[8]"; # ASTmgrUSERNAME db field
|
||||
$server_hash{ 'ast_mgr_pass' } = "$ary[9]"; # ASTmgrSECRET db field
|
||||
$server_hash{ 'ast_mgr_update_user' } = "$ary[10]"; # ASTmgrUSERNAMEupdate db field
|
||||
$server_hash{ 'ast_mgr_listen_user' } = "$ary[11]"; # ASTmgrUSERNAMElisten db field
|
||||
$server_hash{ 'ast_mgr_send_user' } = "$ary[12]"; # ASTmgrUSERNAMEsend db field
|
||||
$server_hash{ 'local_gmt' } = "$ary[13]"; # local_gmt db field
|
||||
$server_hash{ 'vm_dump_exten' } = "$ary[14]"; # voicemail_dump_exten db field
|
||||
$server_hash{ 'dft_xfer_exten' } = "$ary[15]"; # answer_transfer_agent db field
|
||||
$server_hash{ 'ext_context' } = "$ary[16]"; # ext_context db field
|
||||
$server_hash{ 'sys_perf_log' } = "$ary[17]"; # sys_perf_log db field
|
||||
$server_hash{ 'vd_server_logs' } = "$ary[18]"; # vd_server_logs db field
|
||||
$server_hash{ 'agi_output' } = "$ary[19]"; # agi_output db field
|
||||
$server_hash{ 'vd_balance_active' } = "$ary[20]"; # vicidial_balance_active db field
|
||||
$server_hash{ 'vd_balance_free_trunks' } = "$ary[21]"; # balance_trunks_offlimits db field
|
||||
|
||||
# run through the hash and set any non-defined keys to ""
|
||||
for my $serv_key ( keys %server_hash ) {
|
||||
if ( !defined( $server_hash{ $serv_key } ) ) {
|
||||
$server_hash{ $serv_key } = "";
|
||||
}
|
||||
}
|
||||
|
||||
#return the hash
|
||||
return \%server_hash;
|
||||
}
|
||||
|
||||
|
||||
# function to load all servers configs from the db
|
||||
# ARG0 is an already connected database handle
|
||||
# this function returns a reference to a hash of hashes with the servers configs in them
|
||||
# the first level hash is referneced by the servers IP address
|
||||
# the second level hash has the following values:
|
||||
# server_id = the id for the server in the DB
|
||||
# server_desc = the description of the server
|
||||
# server_ip = the IP address of the server
|
||||
# active = if the server is active or not
|
||||
# ast_version = the version of asterisk used on the server
|
||||
# max_vd_trunks = the maximum number of trunks vicidial can use on this server
|
||||
# ast_mgr_host = the telnet host to connect to this servers Asterisk Manager interface
|
||||
# localhost = what this server thinks localhost should be (usually 127.0.0.1)
|
||||
# ast_mgr_port = the telnet port to connect to this servers Asterisk Manager interface
|
||||
# ast_mgr_user = the username for the general connection to the manager interface
|
||||
# ast_mgr_pass = the secret used to connect to the manager inferface for all of the usernames
|
||||
# ast_mgr_update_user = the username to run updates from on the manager interface
|
||||
# ast_mgr_listen_user = the username to listen on the manager interface
|
||||
# ast_mgr_send_user = the username to send actions on the manager interface
|
||||
# local_gmt = the gmt offset for this server
|
||||
# vm_dump_exten = the extension to send voicemail to on this server
|
||||
# dft_xfer_exten = default extension to send calls to for VICIDIAL auto dialing
|
||||
# ext_context = the context where to find the vicidial extension
|
||||
# sys_perf_log = if vicidial should do performance logging for this server
|
||||
# vd_server_logs = if vicidial should do normal logging for this server
|
||||
# agi_output = what style of logging should be done for this server
|
||||
# vd_balance_active = if vicidial should do balanced dialing with this server
|
||||
# vd_balance_free_trunks = the number of trunks balanced dialing must keep free
|
||||
sub load_all_servers_config_db {
|
||||
my $dbh = $_[0];
|
||||
|
||||
# init the hash
|
||||
my %all_servers_hash = ();
|
||||
|
||||
# fetch data from the DB
|
||||
my $stmt =
|
||||
"SELECT server_id, server_description, server_ip, active, asterisk_version, max_vicidial_trunks, telnet_host, telnet_port, ASTmgrUSERNAME, ASTmgrSECRET, ASTmgrUSERNAMEupdate, ASTmgrUSERNAMElisten, ASTmgrUSERNAMEsend, local_gmt, voicemail_dump_exten, answer_transfer_agent, ext_context, sys_perf_log, vd_server_logs, agi_output, vicidial_balance_active, balance_trunks_offlimits FROM servers;";
|
||||
my $sth = $dbh->prepare($stmt) or die "preparing: ", $dbh->errstr;
|
||||
$sth->execute or die "executing: $stmt ", $dbh->errstr;
|
||||
|
||||
# loop through each of the servers
|
||||
my $sthrows = $sth->rows;
|
||||
my $rec_count = 0;
|
||||
while ( $sthrows > $rec_count ) {
|
||||
my @ary = $sth->fetchrow_array;
|
||||
|
||||
# get the ip address of the server for refernecing
|
||||
my $server_ip = "$ary[2]";
|
||||
|
||||
# assign the hash values
|
||||
$all_servers_hash{ $server_ip }{ 'server_id' } = "$ary[0]"; # server_id db field
|
||||
$all_servers_hash{ $server_ip }{ 'server_desc' } = "$ary[1]"; # server_description db field
|
||||
$all_servers_hash{ $server_ip }{ 'server_ip' } = "$ary[2]"; # server_ip db field
|
||||
$all_servers_hash{ $server_ip }{ 'active' } = "$ary[3]"; # active db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_version' } = "$ary[4]"; # asterisk_version db field
|
||||
$all_servers_hash{ $server_ip }{ 'max_vd_trunks' } = "$ary[5]"; # max_vicidial_trunks db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_mgr_host' } = "$ary[6]"; # telnet_host db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_mgr_port' } = "$ary[7]"; # telnet_port db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_mgr_user' } = "$ary[8]"; # ASTmgrUSERNAME db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_mgr_pass' } = "$ary[9]"; # ASTmgrSECRET db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_mgr_update_user' } = "$ary[10]"; # ASTmgrUSERNAMEupdate db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_mgr_listen_user' } = "$ary[11]"; # ASTmgrUSERNAMElisten db field
|
||||
$all_servers_hash{ $server_ip }{ 'ast_mgr_send_user' } = "$ary[12]"; # ASTmgrUSERNAMEsend db field
|
||||
$all_servers_hash{ $server_ip }{ 'local_gmt' } = "$ary[13]"; # local_gmt db field
|
||||
$all_servers_hash{ $server_ip }{ 'vm_dump_exten' } = "$ary[14]"; # voicemail_dump_exten db field
|
||||
$all_servers_hash{ $server_ip }{ 'dft_xfer_exten' } = "$ary[15]"; # answer_transfer_agent db field
|
||||
$all_servers_hash{ $server_ip }{ 'ext_context' } = "$ary[16]"; # ext_context db field
|
||||
$all_servers_hash{ $server_ip }{ 'sys_perf_log' } = "$ary[17]"; # sys_perf_log db field
|
||||
$all_servers_hash{ $server_ip }{ 'vd_server_logs' } = "$ary[18]"; # vd_server_logs db field
|
||||
$all_servers_hash{ $server_ip }{ 'agi_output' } = "$ary[19]"; # agi_output db field
|
||||
$all_servers_hash{ $server_ip }{ 'vd_balance_active' } = "$ary[20]"; # vicidial_balance_active db field
|
||||
$all_servers_hash{ $server_ip }{ 'vd_balance_free_trunks' } = "$ary[21]"; # balance_trunks_offlimits db field
|
||||
|
||||
$rec_count++;
|
||||
}
|
||||
|
||||
my $all_servers_hash_ref = \%all_servers_hash;
|
||||
|
||||
# run through the hash and set any non-defined keys to ""
|
||||
for my $serv_ip_key ( keys %$all_servers_hash_ref ) {
|
||||
for my $serv_key ( keys %{$all_servers_hash_ref->{ $serv_ip_key }} ) {
|
||||
if ( !defined( $all_servers_hash{ $serv_ip_key }{ $serv_key } ) ) {
|
||||
$all_servers_hash{ $serv_ip_key }{ $serv_key } = "";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
$sth->finish();
|
||||
|
||||
# return the hash of hashes
|
||||
return \%all_servers_hash;
|
||||
}
|
||||
|
||||
1;
|
||||
@@ -0,0 +1,216 @@
|
||||
#!/usr/bin/perl
|
||||
|
||||
|
||||
# vicilib-testcode.pl version 2.0.5
|
||||
#
|
||||
# This script is designed to test the vicidial.pm library.
|
||||
# It gets it's settings from the local /etc/astguiclient.conf file.
|
||||
# and connects the the database specified there in.
|
||||
#
|
||||
# This script should be updated anytime anything new is added to the
|
||||
# vicidial.pm library and should throughly test each functon
|
||||
#
|
||||
# Copyright (C) 2008 VICIDIAL-GROUP <info@vicidial-group.com> LICENSE: AGPLv2
|
||||
#
|
||||
# CHANGELOG:
|
||||
# 80324-1435 - First fully successful run
|
||||
|
||||
|
||||
use strict;
|
||||
use warnings;
|
||||
|
||||
use vicidial;
|
||||
use DBI;
|
||||
|
||||
# Test if get_date_hash_current is working
|
||||
print "Test if get_date_hash_current is working\n";
|
||||
print "printing the current time\n";
|
||||
my $cur_date_hash_ref = get_date_hash_current();
|
||||
my %cur_date_hash = %$cur_date_hash_ref;
|
||||
|
||||
print "cur_date_hash{ 'sec' } = $cur_date_hash{ 'sec' }\n";
|
||||
print "cur_date_hash{ 'min' } = $cur_date_hash{ 'min' }\n";
|
||||
print "cur_date_hash{ 'hour' } = $cur_date_hash{ 'hour' }\n";
|
||||
print "cur_date_hash{ 'mday' } = $cur_date_hash{ 'mday' }\n";
|
||||
print "cur_date_hash{ 'month' } = $cur_date_hash{ 'month' }\n";
|
||||
print "cur_date_hash{ 'year' } = $cur_date_hash{ 'year' }\n";
|
||||
print "cur_date_hash{ 'wday' } = $cur_date_hash{ 'wday' }\n";
|
||||
print "cur_date_hash{ 'yday' } = $cur_date_hash{ 'yday' }\n";
|
||||
print "cur_date_hash{ 'isdst' } = $cur_date_hash{ 'isdst' }\n";
|
||||
print "cur_date_hash{ 'Fhour' } = $cur_date_hash{ 'Fhour' }\n\n";
|
||||
|
||||
|
||||
|
||||
# Test if get_date_hash_value is working
|
||||
print "Test if get_date_hash_value is working\n";
|
||||
print "printing the time at the epoch\n";
|
||||
my $epoch_date_hash_ref = get_date_hash_value(0);
|
||||
my %epoch_date_hash = %$epoch_date_hash_ref;
|
||||
|
||||
print "epoch_date_hash{ 'sec' } = $epoch_date_hash{ 'sec' }\n";
|
||||
print "epoch_date_hash{ 'min' } = $epoch_date_hash{ 'min' }\n";
|
||||
print "epoch_date_hash{ 'hour' } = $epoch_date_hash{ 'hour' }\n";
|
||||
print "epoch_date_hash{ 'mday' } = $epoch_date_hash{ 'mday' }\n";
|
||||
print "epoch_date_hash{ 'month' } = $epoch_date_hash{ 'month' }\n";
|
||||
print "epoch_date_hash{ 'year' } = $epoch_date_hash{ 'year' }\n";
|
||||
print "epoch_date_hash{ 'wday' } = $epoch_date_hash{ 'wday' }\n";
|
||||
print "epoch_date_hash{ 'yday' } = $epoch_date_hash{ 'yday' }\n";
|
||||
print "epoch_date_hash{ 'isdst' } = $epoch_date_hash{ 'isdst' }\n";
|
||||
print "epoch_date_hash{ 'Fhour' } = $epoch_date_hash{ 'Fhour' }\n\n";
|
||||
|
||||
|
||||
|
||||
# Test if get_now_date is working
|
||||
print "Test if get_now_date is working\n";
|
||||
print "printing the current time as a now_date string\n";
|
||||
|
||||
my $now_date_str_ref = get_now_date( \%cur_date_hash );
|
||||
my $now_date_str = $$now_date_str_ref;
|
||||
|
||||
print "$now_date_str\n\n";
|
||||
|
||||
|
||||
# Test if agi_log is working
|
||||
agi_output(3, $now_date_str, $0, "test agi_log", "./agi_log_test", "Test if agi_log is working");
|
||||
|
||||
|
||||
# Test if load_config_file is working
|
||||
print "Test if load_config_file is working\n";
|
||||
print "printing the config_hash loaded from /etc/astguiclient.conf\n";
|
||||
|
||||
my $file_path = "/etc/astguiclient.conf";
|
||||
|
||||
my $config_hash_ref = load_config_file( $file_path );
|
||||
my %config_hash = %$config_hash_ref;
|
||||
|
||||
print "config_hash{ 'logs_path' } = $config_hash{ 'logs_path' }\n";
|
||||
print "config_hash{ 'home_path' } = $config_hash{ 'home_path' }\n";
|
||||
print "config_hash{ 'agi_path' } = $config_hash{ 'agi_path' }\n";
|
||||
print "config_hash{ 'web_path' } = $config_hash{ 'web_path' }\n";
|
||||
print "config_hash{ 'sounds_path' } = $config_hash{ 'sounds_path' }\n";
|
||||
print "config_hash{ 'monitor_path' } = $config_hash{ 'monitor_path' }\n";
|
||||
print "config_hash{ 'done_monitor_path' } = $config_hash{ 'done_monitor_path' }\n";
|
||||
print "config_hash{ 'fagi_log_min_servers' } = $config_hash{ 'fagi_log_min_servers' }\n";
|
||||
print "config_hash{ 'fagi_log_max_servers' } = $config_hash{ 'fagi_log_max_servers' }\n";
|
||||
print "config_hash{ 'fagi_log_min_spare_servers' } = $config_hash{ 'fagi_log_min_spare_servers' }\n";
|
||||
print "config_hash{ 'fagi_log_max_spare_servers' } = $config_hash{ 'fagi_log_max_spare_servers' }\n";
|
||||
print "config_hash{ 'fagi_log_max_requests' } = $config_hash{ 'fagi_log_max_requests' }\n";
|
||||
print "config_hash{ 'fagi_log_checkfordead' } = $config_hash{ 'fagi_log_checkfordead' }\n";
|
||||
print "config_hash{ 'fastagi_log_checkforwait' } = $config_hash{ 'fastagi_log_checkforwait' }\n";
|
||||
print "config_hash{ 'server_ip' } = $config_hash{ 'server_ip' }\n";
|
||||
print "config_hash{ 'active_keepalives' } = $config_hash{ 'active_keepalives' }\n";
|
||||
print "config_hash{ 'db_server' } = $config_hash{ 'db_server' }\n";
|
||||
print "config_hash{ 'db_database' } = $config_hash{ 'db_database' }\n";
|
||||
print "config_hash{ 'db_user' } = $config_hash{ 'db_user' }\n";
|
||||
print "config_hash{ 'db_pass' } = $config_hash{ 'db_pass' }\n";
|
||||
print "config_hash{ 'db_port' } = $config_hash{ 'db_port' }\n";
|
||||
print "config_hash{ 'ftp_host' } = $config_hash{ 'ftp_host' }\n";
|
||||
print "config_hash{ 'ftp_user' } = $config_hash{ 'ftp_user' }\n";
|
||||
print "config_hash{ 'ftp_pass' } = $config_hash{ 'ftp_pass' }\n";
|
||||
print "config_hash{ 'ftp_port' } = $config_hash{ 'ftp_port' }\n";
|
||||
print "config_hash{ 'ftp_dir' } = $config_hash{ 'ftp_dir' }\n";
|
||||
print "config_hash{ 'ftp_http_path' } = $config_hash{ 'report_host' }\n";
|
||||
print "config_hash{ 'report_host' } = $config_hash{ 'report_host' }\n";
|
||||
print "config_hash{ 'report_user' } = $config_hash{ 'report_user' }\n";
|
||||
print "config_hash{ 'report_pass' } = $config_hash{ 'report_pass' }\n";
|
||||
print "config_hash{ 'report_port' } = $config_hash{ 'report_port' }\n";
|
||||
print "config_hash{ 'report_dir' } = $config_hash{ 'report_dir' }\n\n";
|
||||
|
||||
# get a dbconnection for the rest of these routines
|
||||
my $dbh = DBI->connect(
|
||||
"DBI:mysql:$config_hash{ 'db_database' }:$config_hash{ 'db_server' }:$config_hash{ 'db_port' }",
|
||||
"$config_hash{ 'db_user' }",
|
||||
"$config_hash{ 'db_pass' }"
|
||||
) or die "Couldn't connect to database: " . DBI->errstr;
|
||||
|
||||
|
||||
# Test if load_sys_config_db is working
|
||||
print "Test if load_sys_config_db is working\n";
|
||||
|
||||
my $system_hash_ref = load_sys_config_db( $dbh );
|
||||
my %system_hash = %$system_hash_ref;
|
||||
|
||||
print "system_hash{ 'version' } = $system_hash{ 'version' }\n";
|
||||
print "system_hash{ 'install_date' } = $system_hash{ 'install_date' }\n";
|
||||
print "system_hash{ 'use_utf8' } = $system_hash{ 'use_utf8' }\n";
|
||||
print "system_hash{ 'webroot_writable' } = $system_hash{ 'webroot_writable' }\n";
|
||||
print "system_hash{ 'enable_qm_log' } = $system_hash{ 'enable_qm_log' }\n";
|
||||
print "system_hash{ 'qm_server_ip' } = $system_hash{ 'qm_server_ip' }\n";
|
||||
print "system_hash{ 'qm_dbname' } = $system_hash{ 'qm_dbname' }\n";
|
||||
print "system_hash{ 'qm_login' } = $system_hash{ 'qm_login' }\n";
|
||||
print "system_hash{ 'qm_pass' } = $system_hash{ 'qm_pass' }\n";
|
||||
print "system_hash{ 'qm_url' } = $system_hash{ 'qm_url' }\n";
|
||||
print "system_hash{ 'qm_log_id' } = $system_hash{ 'qm_log_id' }\n";
|
||||
print "system_hash{ 'qm_eq_prepend' } = $system_hash{ 'qm_eq_prepend' }\n";
|
||||
print "system_hash{ 'vd_agent_disable' } = $system_hash{ 'vd_agent_disable' }\n";
|
||||
print "system_hash{ 'allow_sipsak_msgs' } = $system_hash{ 'allow_sipsak_msgs' }\n";
|
||||
print "system_hash{ 'admin_home_url' } = $system_hash{ 'admin_home_url' }\n";
|
||||
print "system_hash{ 'agent_xfer_weblog' } = $system_hash{ 'agent_xfer_weblog' }\n\n";
|
||||
|
||||
|
||||
|
||||
# Test if load_server_config_db is working
|
||||
print "Test if load_server_config_db is working\n";
|
||||
|
||||
my $server_hash_ref = load_server_config_db( $config_hash{ 'server_ip' } , $dbh );
|
||||
my %server_hash = %$server_hash_ref;
|
||||
|
||||
print "server_hash{ 'server_id' } = $server_hash{ 'server_id' }\n";
|
||||
print "server_hash{ 'server_desc' } = $server_hash{ 'server_desc' }\n";
|
||||
print "server_hash{ 'server_ip' } = $server_hash{ 'server_ip' }\n";
|
||||
print "server_hash{ 'active' } = $server_hash{ 'active' }\n";
|
||||
print "server_hash{ 'ast_version' } = $server_hash{ 'ast_version' }\n";
|
||||
print "server_hash{ 'max_vd_trunks' } = $server_hash{ 'max_vd_trunks' }\n";
|
||||
print "server_hash{ 'ast_mgr_host' } = $server_hash{ 'ast_mgr_host' }\n";
|
||||
print "server_hash{ 'ast_mgr_port' } = $server_hash{ 'ast_mgr_port' }\n";
|
||||
print "server_hash{ 'ast_mgr_user' } = $server_hash{ 'ast_mgr_user' }\n";
|
||||
print "server_hash{ 'ast_mgr_pass' } = $server_hash{ 'ast_mgr_pass' }\n";
|
||||
print "server_hash{ 'ast_mgr_update_user' } = $server_hash{ 'ast_mgr_update_user' }\n";
|
||||
print "server_hash{ 'ast_mgr_listen_user' } = $server_hash{ 'ast_mgr_listen_user' }\n";
|
||||
print "server_hash{ 'ast_mgr_send_user' } = $server_hash{ 'ast_mgr_send_user' }\n";
|
||||
print "server_hash{ 'local_gmt' } = $server_hash{ 'local_gmt' }\n";
|
||||
print "server_hash{ 'vm_dump_exten' } = $server_hash{ 'vm_dump_exten' }\n";
|
||||
print "server_hash{ 'dft_xfer_exten' } = $server_hash{ 'dft_xfer_exten' }\n";
|
||||
print "server_hash{ 'ext_context' } = $server_hash{ 'ext_context' }\n";
|
||||
print "server_hash{ 'sys_perf_log' } = $server_hash{ 'sys_perf_log' }\n";
|
||||
print "server_hash{ 'vd_server_logs' } = $server_hash{ 'vd_server_logs' }\n";
|
||||
print "server_hash{ 'agi_output' } = $server_hash{ 'agi_output' }\n";
|
||||
print "server_hash{ 'vd_balance_active' } = $server_hash{ 'vd_balance_active' }\n";
|
||||
print "server_hash{ 'vd_balance_free_trunks' } = $server_hash{ 'vd_balance_free_trunks' }\n\n";
|
||||
|
||||
|
||||
print "Test if load_all_servers_config_db is working\n";
|
||||
|
||||
my $all_servers_hash_ref = load_all_servers_config_db( $dbh );
|
||||
my %all_servers_hash = %$all_servers_hash_ref;
|
||||
|
||||
my $hash_size = %all_servers_hash;
|
||||
|
||||
for my $server_ip ( keys %all_servers_hash ) {
|
||||
# assign the hash values
|
||||
print "all_servers_hash{ $server_ip }{ 'server_id' } = $all_servers_hash{ $server_ip }{ 'server_id' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'server_desc' } = $all_servers_hash{ $server_ip }{ 'server_desc' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'server_ip' } = $all_servers_hash{ $server_ip }{ 'server_ip' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'active' } = $all_servers_hash{ $server_ip }{ 'active' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_version' } = $all_servers_hash{ $server_ip }{ 'ast_version' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'max_vd_trunks' } = $all_servers_hash{ $server_ip }{ 'max_vd_trunks' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_mgr_host' } = $all_servers_hash{ $server_ip }{ 'ast_mgr_host' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_mgr_port' } = $all_servers_hash{ $server_ip }{ 'ast_mgr_port' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_mgr_user' } = $all_servers_hash{ $server_ip }{ 'ast_mgr_user' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_mgr_pass' } = $all_servers_hash{ $server_ip }{ 'ast_mgr_pass' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_mgr_update_user' } = $all_servers_hash{ $server_ip }{ 'ast_mgr_update_user' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_mgr_listen_user' } = $all_servers_hash{ $server_ip }{ 'ast_mgr_listen_user' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ast_mgr_send_user' } = $all_servers_hash{ $server_ip }{ 'ast_mgr_send_user' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'local_gmt' } = $all_servers_hash{ $server_ip }{ 'local_gmt' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'vm_dump_exten' } = $all_servers_hash{ $server_ip }{ 'vm_dump_exten' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'dft_xfer_exten' } = $all_servers_hash{ $server_ip }{ 'dft_xfer_exten' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'ext_context' } = $all_servers_hash{ $server_ip }{ 'ext_context' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'sys_perf_log' } = $all_servers_hash{ $server_ip }{ 'sys_perf_log' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'vd_server_logs' } = $all_servers_hash{ $server_ip }{ 'vd_server_logs' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'agi_output' } = $all_servers_hash{ $server_ip }{ 'agi_output' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'vd_balance_active' } = $all_servers_hash{ $server_ip }{ 'vd_balance_active' }\n";
|
||||
print "all_servers_hash{ $server_ip }{ 'vd_balance_free_trunks' } = $all_servers_hash{ $server_ip }{ 'vd_balance_free_trunks' }\n\n";
|
||||
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user