use 5.010;
use strict;
use lib '/home/lacuna/server/lib';
use Lacuna::DB;
use Lacuna;
use Lacuna::Util qw(randint format_date);
use Getopt::Long;
use App::Daemon qw(daemonize );
use Data::Dumper;
use Try::Tiny;
use Log::Log4perl qw(:levels);

# --------------------------------------------------------------------
# command line arguments:
#
my $daemonize   = 1;    # run the script as a daemon
my $loop        = 1;    # loop continuously waiting for jobs
my $initialize  = 1;    # (re)initialize the queue from the database
our $quiet      = 1;    # don't output any text

GetOptions(
    'daemonize!'    => \$daemonize,
    'loop!'         => \$loop,
    'quiet!'        => \$quiet,
    'initialize!'   => \$initialize,
);

$App::Daemon::loglevel = $quiet ? $WARN : $DEBUG;
$App::Daemon::logfile  = '/home/lacuna/server/log/scheduler/schedule_ship_arrival.log';

chdir '/home/lacuna/server/bin';

my $pid_file        = '/home/lacuna/server/bin/schedule_ship_arrival.pid';

my $start = time;

# kill any existing processes
#
if (-f $pid_file) {
    open(PIDFILE, $pid_file);
    my $PID = <PIDFILE>;
    chomp $PID;
    if (grep /$PID/, `ps -p $PID`) {
        close (PIDFILE);
        out("Killing previous job, PID=$PID");
        kill 9, $PID;
        sleep 5;
    }
}

if ($initialize) {
    # (re)initialize all the jobs on the queues, replacing any 
    # existing jobs
    out('Reinitializing all jobs');
    out('Deleting existing jobs');
    my $schedule_rs = Lacuna->db->resultset('Schedule')->search({
        parent_table    => 'Ships',
        task            => 'arrive',
    });
    while (my $schedule = $schedule_rs->next) {
        # note. deleting the DB entry also deletes the entry on beanstalk
        $schedule->delete;
    }

    out('Adding ship arrivals');
    my $ship_rs = Lacuna->db->resultset('Ships')->search({
        task => 'Travelling',
    });
    while (my $ship = $ship_rs->next) {
        # add to queue
        my $schedule = Lacuna->db->resultset('Schedule')->create({
            delivery        => $ship->date_available,
            queue           => 'arrive_queue',
            parent_table    => 'Ships',
            parent_id       => $ship->id,
            task            => 'arrive',
        });
    }
}

# --------------------------------------------------------------------
# Daemonize

if ($daemonize) {
    daemonize();
    out('Running as a daemon');
}
else {
    out('Running in the foreground');
}

my $config = Lacuna->config;

my $queue = Lacuna::Queue->new({
    max_timeouts    => $config->get('beanstalk/max_timeouts'),
    max_reserves    => $config->get('beanstalk/max_reserves'),
    server          => $config->get('beanstalk/server'),
    ttr             => $config->get('beanstalk/ttr'),
    debug           => $config->get('beanstalk/debug'),
});

out("queue = $queue");

# --------------------------------------------------------------------
# Main processing loop

out('Started');
# Timeout after an hour
eval {
    
    LOOP: do {
        my $job     = $queue->consume('arrive_queue');
        my $args    = $job->args;
        $job->delete, next unless ref $args eq 'HASH';
        my $task    = $args->{task};
        my $task_args = $args->{args};
    
        out('job received ['.$job->id.']');

        my $payload = $job->payload;

        try {
            # process the job
            out("Process class=$payload task=$task");
            $payload->$task($task_args);
            out("Processing done. Delete job ".$job->id);
            $job->delete;
        }
        catch {
            # bury the job, it failed
            out("Job ".$job->id." failed: $_");
            $job->bury;
        };
    } while ($loop);
};
if ($@) {
    die unless $@ eq "alarm\n"; # propagate unexpected errors
    # timed out
}

my $finish = time;
out('Finished');
out(int(($finish - $start)/60)." minutes have elapsed");
exit 0;

###############
## SUBROUTINES
###############

sub out {
    my ($message) = @_;
    my $logger = Log::Log4perl->get_logger;
    # STDERR is what actually lands in the log: under compose bin/run_scheduler.sh
    # tees it to log/scheduler/, and App::Daemon captures it to $logfile when
    # daemonized. Log4perl is never ->init'd here, so $logger->info is a no-op.
    print STDERR $message."\n";
    $logger->info($message);
}