package TheSchwartz::Moosified::JobHandle;

use TheSchwartz::Moosified::Job;
use Moose;

has 'jobid'  => ( is => 'rw', isa => 'Int' );
has 'client' => ( is => 'rw', isa => 'Object' );
has 'dbh'    => ( is => 'rw', isa => 'Object' );

sub job {
    my $handle = shift;
    
    my $dbh = $handle->dbh;
    my $table_job = $handle->client->prefix . 'job';
    my $sql = qq~SELECT * FROM $table_job WHERE jobid = ?~;
    my $sth = $dbh->prepare_cached($sql);
    $sth->execute($handle->jobid);
    my $row = $sth->fetchrow_hashref;
    $sth->finish;
    if ($row) {
        my $job = TheSchwartz::Moosified::Job->new( $row );
        $job->handle($handle);
        return $job;
    }
}

sub is_pending {
    my $handle = shift;
    return $handle->job ? 1 : 0;
}

sub exit_status {
    my $handle = shift;
    
    my $dbh = $handle->dbh;
    my $table_exitstatus = $handle->client->prefix . 'exitstatus';
    my $sql = qq~SELECT status FROM $table_exitstatus WHERE jobid = ?~;
    my $sth = $dbh->prepare($sql);
    $sth->execute($handle->jobid);
    my ($status) = $sth->fetchrow_array;
    return $status;
}

sub failure_log {
    my $handle = shift;
    
    my $dbh = $handle->dbh;
    my $table_error = $handle->client->prefix . 'error';
    my $sql = qq~SELECT message FROM $table_error WHERE jobid = ?~;
    my $sth = $dbh->prepare($sql);
    $sth->execute($handle->jobid);
    
    my @failures;
    while (my ($message) = $sth->fetchrow_array) {
        push @failures, $message;
    }
    return @failures;
}

sub failures {
    my $handle = shift;
    return scalar $handle->failure_log;
}

no Moose;
1;
__END__