#!/usr/bin/perl
#/* ========================================
# * ███╗   ███╗██████╗ ██╗ █████╗ ██╗
# * ████╗ ████║██╔══██╗██║██╔══██╗██║
# * ██╔████╔██║██║  ██║██║███████║██║
# * ██║╚██╔╝██║██║  ██║██║██╔══██║██║
# * ██║ ╚═╝ ██║██████╔╝██║██║  ██║███████╗
# * ╚═╝     ╚═╝╚═════╝ ╚═╝╚═╝  ╚═╝╚══════╝
# * ========================================
# * mDial - Omni-Channel Contact Centre Suite.
# * Initially Written by Martin McCarthy.
# * Contributions welcome.
# * Active: 2020 - 2023.
# *
# * This software is licensed under AGPLv2.
# * You can find more information here;
# * https://www.gnu.org/licenses/agpl-3.0.en.html
# * A copy of the license is also shipped with this build.
# *
# * Important note: this software is provided to you free of charge.
# * If you paid for this software, you were ripped off.
# *
# * This project is a fork of the awesome FOSS project, ViCiDial.
# * ViCiDial is copyrighted by Matt Florell and the ViCiDial Group
# * under the AGPLv2 license.
# *
# * You can find out more about ViCiDial;
# * Web: https://www.vicidial.com/
# * Email: Matt Florell <vicidial@gmail.com>
# * IRC: Libera.Chat - ##vicidial
# *
# * Bug reports, feature requests and patches welcome!
# * ======================================== */
$|++;
use strict;
use DBI;
use Getopt::Long;
use Time::HiRes ( 'gettimeofday', 'usleep', 'sleep' )
  ;    # necessary to have perl sleep command of less than one second
my $run_check = 1;    # concurrency check
my $servConf;
my %conf;
$conf{PATHconf} =
  '/etc/astguiclient.conf';   # default path to astguiclient configuration file:
my $COUNTER_OUTPUT = 1;    # set to 1 to display the counter as the script runs
my ( $CLOhelp, $sendonlyone, $TEST, $DB, $DBX, $SYSLOG );

if ( scalar @ARGV ) {
    GetOptions(
        'help!'          => \$CLOhelp,
        'sendonlyone!'   => \$sendonlyone,
        'counteroutput!' => \$COUNTER_OUTPUT,
        't!'             => \$TEST,    #Fucntionality doesn't actually exist.
        'debug!'         => \$DB,
        'debugX!'        => \$DBX
    );
    $DB = 1 if ($DBX);
    if ($DB) {
        print "----- DEBUGGING -----\n";
        print "----- EXTRA-VERBOSE DEBUGGING -----\n" if ($DBX);
        print "COUNTER_OUTPUT:     $COUNTER_OUTPUT\n";
        print "sendonlyone:        $sendonlyone\n" if ($sendonlyone);
        print "TEST:               $TEST\n"        if ($TEST);
    }
    if ($CLOhelp) {
        print "\nAST_manager_send.pl\n";
        print "allowed run time options:\n";
        print "  [--help] = This help screen.\n";
        print "  [--sendonlyone] = Send only one command\n";
        print "  [--nocounteroutput] = Do not display counter as script runs\n";
        print "  [-t] = Test Mode\n";
        print "  [--debug] or [-v] = Verbose debug messages\n";
        print "  [--debugX] or [-vv] = Extra-verbose debug messages\n\n";
        exit 0;
    }
}
open( CONF, $conf{PATHconf} )
  || die "can't open " . $conf{PATHconf} . ": " . $! . "\n";
while ( my $line = <CONF> ) {
    $line =~ s/ |>|\n|\r|\t|\#.*|;.*//gi;
    foreach my $key (
        qw( PATHhome PATHlogs PATHagi PATHweb PATHsounds PATHmontior
        VARserver_ip VARDB_server VARDB_database VARDB_user VARDB_pass VARDB_port)
      )
    {
        if ( $line =~ /^$key/ ) {
            $conf{$key} = $line;
            $conf{$key} =~ s/.*=//gi;
        }
    }
}
$conf{VARDB_port} = '3306' unless ( $conf{VARDB_port} );
my $dbhA = DBI->connect(
    "DBI:mysql:"
      . $conf{VARDB_database} . ":"
      . $conf{VARDB_server} . ":"
      . $conf{VARDB_port},
    $conf{VARDB_user},
    $conf{VARDB_pass}
) or die "Couldn't connect to database: " . DBI->errstr;
$servConf = getServerConfig( $dbhA, $conf{VARserver_ip} );
$SYSLOG   = 1 if ( $servConf->{vd_server_logs} =~ /Y/ );
my $event_string = 'LOGGED INTO MYSQL SERVER ON 1 CONNECTION|';
eventLogger( $conf{PATHlogs}, 'process', $event_string );
if ( $run_check > 0 ) {
    my $grepout = `/bin/ps ax | grep $0 | grep -v grep | grep -v '/bin/sh'`;
    my $grepnum = 0;
    $grepnum++ while ( $grepout =~ m/\n/g );
    if ( $grepnum > 2 ) {
        if ($DB) {
            print "I am not alone! Another $0 is running! Exiting...\n";
        }
        my $event_string = "I am not alone! Another $0 is running! Exiting...";
        eventLogger( $conf{PATHlogs}, 'process', $event_string );
        exit;
    }
}
my $processed_actions = 0;
my $one_day_interval  = 182;    # 2 day loops for 12 months
while ( $one_day_interval > 0 ) {
    my $endless_loop = 1728000;    # 2 days at .10 seconds per loop
    my $affected_rows;
    my $NEW_actions;
    while ( $endless_loop > 0 ) {
        my $stmtA =
            "SELECT count(*) from vicidial_manager where server_ip = '"
          . $conf{VARserver_ip}
          . "' and status = 'NEW';";
        my $sthA = $dbhA->prepare($stmtA) or die "preparing: ", $dbhA->errstr;
        $sthA->execute or die "executing: $stmtA ",             $dbhA->errstr;
        my $NEW_actions = ( $sthA->fetchrow_array )[0];
        $sthA->finish();
        my $stmtA =
            "SELECT count(*) from vicidial_manager where server_ip = '"
          . $conf{VARserver_ip}
          . "' and status = 'QUEUE';";
        my $sthA = $dbhA->prepare($stmtA) or die "preparing: ", $dbhA->errstr;
        $sthA->execute or die "executing: $stmtA ",             $dbhA->errstr;
        my $QUEUE_actions = ( $sthA->fetchrow_array )[0];
        print STDERR $NEW_actions
          . " NEW and "
          . $QUEUE_actions
          . " QUEUE Actions to send on server "
          . $conf{VARserver_ip}
          . "    $endless_loop\n"
          if ($DB);
        $sthA->finish();
        $affected_rows = 0;

        if ( $NEW_actions > 0 ) {
            my $stmtA =
                "UPDATE vicidial_manager set status='QUEUE' where server_ip = '"
              . $conf{VARserver_ip}
              . "' and status = 'NEW' order by man_id limit 1;";
            $affected_rows = $dbhA->do($stmtA);
            print STDERR "rows updated to QUEUE: |$affected_rows|\n" if ($DB);
        }
        else {
            if ( $QUEUE_actions > 0 ) {
                $affected_rows = $QUEUE_actions;
                my $event_string =
                    nowDate()
                  . "No NEW actions, but "
                  . $QUEUE_actions
                  . " QUEUE actions in vicidial_manager|"
                  . $affected_rows;
                eventLogger( $conf{PATHlogs}, 'process', $event_string );
            }
        }
        if ($affected_rows) {
            my $stmtA =
"SELECT man_id,uniqueid,entry_date,status,response,server_ip,channel,action,callerid,cmd_line_b,cmd_line_c,cmd_line_d,cmd_line_e,cmd_line_f,cmd_line_g,cmd_line_h,cmd_line_i,cmd_line_j,cmd_line_k FROM vicidial_manager where server_ip = '"
              . $conf{VARserver_ip}
              . "' and status = 'QUEUE' order by man_id limit 1";
            eventLogger( $conf{'PATHlogs'}, 'process',
                "SQL_QUERY|" . $stmtA . "|" );
            my $sthA = $dbhA->prepare($stmtA)
              or die "preparing: ", $dbhA->errstr;
            $sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
            while ( my $vdm = $sthA->fetchrow_hashref ) {
                print STDERR $vdm->{man_id} . "|"
                  . $vdm->{uniqueid} . "|"
                  . $vdm->{channel} . "|"
                  . $vdm->{action} . "|"
                  . $vdm->{callerid} . "\n"
                  if ($DB);
                my $event_string =
                    nowDate() . "|"
                  . $vdm->{entry_date} . "|"
                  . $vdm->{man_id} . "|"
                  . $vdm->{uniqueid} . "|"
                  . $vdm->{channel} . "|"
                  . $vdm->{action} . "|"
                  . $vdm->{callerid};
                eventLogger( $conf{PATHlogs}, 'process', $event_string );
                my $originate_command = "Action: " . $vdm->{action} . "\n";
                $originate_command .= $vdm->{cmd_line_b} . "\n"
                  if ( $vdm->{cmd_line_b} );
                $originate_command .= $vdm->{cmd_line_c} . "\n"
                  if ( $vdm->{cmd_line_c} );
                $originate_command .= $vdm->{cmd_line_d} . "\n"
                  if ( $vdm->{cmd_line_d} );
                $originate_command .= $vdm->{cmd_line_e} . "\n"
                  if ( $vdm->{cmd_line_e} );
                $originate_command .= $vdm->{cmd_line_f} . "\n"
                  if ( $vdm->{cmd_line_f} );
                $originate_command .= $vdm->{cmd_line_g} . "\n"
                  if ( $vdm->{cmd_line_g} );
                $originate_command .= $vdm->{cmd_line_h} . "\n"
                  if ( $vdm->{cmd_line_h} );
                $originate_command .= $vdm->{cmd_line_i} . "\n"
                  if ( $vdm->{cmd_line_i} );
                $originate_command .= $vdm->{cmd_line_j} . "\n"
                  if ( $vdm->{cmd_line_j} );
                $originate_command .= $vdm->{cmd_line_k} . "\n"
                  if ( $vdm->{cmd_line_k} );
                $originate_command .= "\n";
                my $SENDNOW = 1;

                if ( ( $originate_command =~ /Action: Hangup|Action: Redirect/ )
                    && ( $originate_command !~ /Exten: 8309\n|Exten: 8310\n/ ) )
                {
                    $SENDNOW = 0;
                    print STDERR "\n|checking for dead call before executing|"
                      . $vdm->{callerid} . "|"
                      . $vdm->{uniqueid} . "|\n"
                      if ($DB);
                    my $stmtB =
"SELECT count(*) FROM vicidial_manager where server_ip = '"
                      . $conf{VARserver_ip}
                      . "' and callerid='"
                      . $vdm->{callerid}
                      . "' and status = 'DEAD'";
                    my $sthB = $dbhA->prepare($stmtB)
                      or die "preparing: ", $dbhA->errstr;
                    $sthB->execute or die "executing: $stmtA ", $dbhA->errstr;
                    my $dead_count = ( $sthB->fetchrow_array )[0];
                    $sthB->finish();
                    if ($dead_count) {
                        print STDERR "\n|not sending command line is dead|"
                          . $vdm->{callerid} . "|"
                          . $vdm->{uniqueid} . "|\n"
                          if ($DB);
                    }
                    else {
                        $SENDNOW = 1;
                    }
                }
                my $event_string =
                    "----BEGIN NEW COMMAND----\nCallerID: "
                  . $vdm->{callerid}
                  . "\n$originate_command----END NEW COMMAND----\n";
                eventLogger( $conf{'PATHlogs'}, 'process', $event_string );
                if ($SENDNOW) {
                    my $cPATHlogs = $conf{PATHlogs};
                    $cPATHlogs =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_b} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_c} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_d} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_e} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_f} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_g} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_h} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_i} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_j} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    $vdm->{cmd_line_k} =~
                      s/([^A-Za-z0-9])/sprintf("%%%02X", ord($1))/seg;
                    my $launch = $conf{PATHhome} . "/AST_send_action_child.pl";
                    $launch .= " --SYSLOG" if ($SYSLOG);
                    $launch .= " --PATHlogs=" . $cPATHlogs;
                    $launch .= " --telnet_host=" . $servConf->{telnet_host};
                    $launch .= " --telnet_port=" . $servConf->{telnet_port};
                    $launch .=
                      " --ASTmgrUSERNAME=" . $servConf->{ASTmgrUSERNAME};
                    $launch .= " --ASTmgrSECRET=" . $servConf->{ASTmgrSECRET};
                    $launch .= " --ASTmgrUSERNAMEsend="
                      . $servConf->{ASTmgrUSERNAMEsend};
                    $launch .= " --man_id=" . $vdm->{man_id};
                    $launch .= " --action=" . $vdm->{action};
                    $launch .= " --cmd_line_b=" . $vdm->{cmd_line_b}
                      if ( $vdm->{cmd_line_b} );
                    $launch .= " --cmd_line_c=" . $vdm->{cmd_line_c}
                      if ( $vdm->{cmd_line_c} );
                    $launch .= " --cmd_line_d=" . $vdm->{cmd_line_d}
                      if ( $vdm->{cmd_line_d} );
                    $launch .= " --cmd_line_e=" . $vdm->{cmd_line_e}
                      if ( $vdm->{cmd_line_e} );
                    $launch .= " --cmd_line_f=" . $vdm->{cmd_line_f}
                      if ( $vdm->{cmd_line_f} );
                    $launch .= " --cmd_line_g=" . $vdm->{cmd_line_g}
                      if ( $vdm->{cmd_line_g} );
                    $launch .= " --cmd_line_h=" . $vdm->{cmd_line_h}
                      if ( $vdm->{cmd_line_h} );
                    $launch .= " --cmd_line_i=" . $vdm->{cmd_line_i}
                      if ( $vdm->{cmd_line_i} );
                    $launch .= " --cmd_line_j=" . $vdm->{cmd_line_j}
                      if ( $vdm->{cmd_line_j} );
                    $launch .= " --cmd_line_k=" . $vdm->{cmd_line_k}
                      if ( $vdm->{cmd_line_k} );
                    eventLogger( $conf{'PATHlogs'}, 'launch',
                            $launch . "  "
                          . $vdm->{callerid} . " "
                          . $vdm->{uniqueid} . " "
                          . $vdm->{channel} );
                    $launch .=
                      " >> " . $conf{PATHlogs} . "/action_send." . logDate()
                      if ($SYSLOG);
                    system( $launch . ' &' );
                    my $stmtA =
                      "UPDATE vicidial_manager set status='SENT' where man_id='"
                      . $vdm->{man_id} . "'";
                    print STDERR "\n|$stmtA|\n" if ($DB);
                    $affected_rows = $dbhA->do($stmtA);
                    $event_string  = "SQL_QUERY|$stmtA|";
                    eventLogger( $conf{'PATHlogs'}, 'process', $event_string );
                }
                else {
                    $stmtA =
                      "UPDATE vicidial_manager set status='DEAD' where man_id='"
                      . $vdm->{man_id}
                      . "' and cmd_line_d!='Exten: 8309' and cmd_line_d!='Exten: 8310';";
                    print STDERR "\n|$stmtA|\n" if ($DB);
                    $affected_rows = $dbhA->do($stmtA);
                    $event_string  = "COMMAND NOT SENT, SQL_QUERY|$stmtA|";
                    eventLogger( $conf{'PATHlogs'}, 'process', $event_string );
                }
                $processed_actions++;
            }
            $sthA->finish();
        }
        if ($affected_rows) {
            usleep( 1 * 10 * 1000 );
        }
        else {
            usleep( 1 * 100 * 1000 );
        }
        $endless_loop--;
        print STDERR "loop counter: |$endless_loop|\r"
          if ( $COUNTER_OUTPUT or $DB );
        if ( -e $conf{PATHhome} . "/sendmgr.kill" or $sendonlyone ) {
            unlink( $conf{PATHhome} . "/sendmgr.kill" );
            $endless_loop     = 0;
            $one_day_interval = 0;
            print "\nPROCESS KILLED MANUALLY... EXITING\n\n";
        }
        my $running_listen = 0;
        if ( $endless_loop =~ /0$/ ) {
            $servConf = getServerConfig( $dbhA, $conf{VARserver_ip} );
            print nowDate()
              . " checking to see if listener is dead |$sendonlyone|$running_listen|$endless_loop|$processed_actions|\n"
              if ( $COUNTER_OUTPUT or $DB );
            $processed_actions = 0;
            my @psoutput = `/bin/ps -o "%p %a" --no-headers -A`;
            foreach my $line (@psoutput) {
                chomp($line);
                print "|$line|     \n" if ($DBX);
                my @psline = split( /\/usr\/bin\/perl /, $line );
                if ( $psline[1] =~ /AST_manager_li/ ) {
                    $running_listen++;
                    print "SEND RUNNING: |$psline[1]|\n" if ($DB);
                }
            }
            unless ($running_listen) {
                $sendonlyone++;
                print
"LISTENER DEAD STOPPING PROGRAM... ATTEMPTING TO START keepalive SCRIPT\n"
                  if ( $COUNTER_OUTPUT or $DB );
                $event_string =
'LISTENER DEAD STOPPING PROGRAM... ATTEMPTING TO START keepalive SCRIPT|';
                eventLogger( $conf{'PATHlogs'}, 'process', $event_string );
            }
        }
    }
    print
"DONE... Exiting... Goodbye... See you later... Not really, initiating next loop...$one_day_interval left\n"
      if ( $COUNTER_OUTPUT or $DB );
    $one_day_interval--;
}
$event_string = 'CLOSING DB CONNECTION|';
eventLogger( $conf{'PATHlogs'}, 'process', $event_string );
$dbhA->disconnect();
print
  "DONE... Exiting... Goodbye... See you later... Really I mean it this time\n"
  if ( $COUNTER_OUTPUT or $DB );
exit 0;

sub getServerConfig {
    my ( $dbhA, $serverip ) = @_;
    my $stmtA =
"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,recording_web_link,alt_server_ip,active_asterisk_server,generate_vicidial_conf,rebuild_conf_files,outbound_calls_per_second,sysload,channels_total,cpu_idle_percent,disk_usage,sounds_update,vicidial_recording_limit,carrier_logging_active,vicidial_balance_rank,rebuild_music_on_hold,active_agent_login_server,conf_secret FROM servers where server_ip = '"
      . $serverip . "';";
    my $sthA = $dbhA->prepare($stmtA) or die "preparing: " . $dbhA->errstr;
    $sthA->execute or die "executing: $stmtA " . $dbhA->errstr;
    my $servConf = $sthA->fetchrow_hashref;
    $SYSLOG = 1 if ( $servConf->{vd_server_logs} =~ /Y/ );
    $sthA->finish();
    return $servConf;
}

sub eventLogger {
    my ( $path, $type, $string ) = @_;
    open( LOG, ">>" . $path . "/action_" . $type . "." . logDate() )
      || die "Can't open "
      . $path
      . "/action_"
      . $type . "."
      . logDate() . ": "
      . $! . "\n";
    print LOG nowDate() . "|" . $string . "|\n";
    close(LOG);
}

sub getTime {
    my ($tms) = @_;
    $tms = time unless ($tms);
    my ( $sec, $min, $hour, $mday, $mon, $year, $wday, $yday, $isdst ) =
      localtime($tms);
    $year += 1900;
    $mon++;
    $mon  = "0" . $mon  if ( $mon < 10 );
    $mday = "0" . $mday if ( $mday < 10 );
    $min  = "0" . $min  if ( $min < 10 );
    $sec  = "0" . $sec  if ( $sec < 10 );
    return ( $sec, $min, $hour, $mday, $mon, $year );
}

sub nowDate {
    my ($tms) = @_;
    my ( $sec, $min, $hour, $mday, $mon, $year ) = getTime($tms);
    return $year . '-' . $mon . '-' . $mday . ' ' . $hour . ':' . $min . ':'
      . $sec;
}

sub logDate {
    my ($tms) = @_;
    my ( $sec, $min, $hour, $mday, $mon, $year ) = getTime($tms);
    return $year . '-' . $mon . '-' . $mday;
}