File Coverage

blib/lib/AnyEvent/Beanstalk/Job.pm

Criterion	Covered	Total	%
statement	9	65	13.8
branch	0	20	0.0
condition	0	24	0.0
subroutine	3	14	21.4
pod	10	11	90.9
total	22	134	16.4

package AnyEvent::Beanstalk::Job;
{
  $AnyEvent::Beanstalk::Job::VERSION = '1.123530';
}

use strict;
use warnings;

use base qw(Class::Accessor::Fast);

__PACKAGE__->mk_accessors(qw(id client buried reserved data error));

sub new {
  my $proto = shift;
  bless {@_}, ref($proto) || $proto;
}

sub stats {
  my $self = shift;
  my ($stats, $err) = $self->client->stats($self->id)->recv;
  return $self->{_stats} = $stats if $stats;
  $self->error($err || 'unknown');
  return undef;
}

sub delete {
  my $self = shift;
  my ($ok, $err) = $self->client->delete($self->id)->recv;
  if ($ok) {
    $self->reserved(0);
    $self->buried(0);
    return 1;
  }
  $self->error($err || 'unknown');
  return undef;
}

sub touch {
  my $self = shift;
  my ($ok, $err) = $self->client->touch($self->id)->recv;
  return 1 if $ok;
  $self->error($err || 'unknown');
  return undef;
}

sub peek {
  my $self = shift;
  my ($job, $err) = $self->client->peek($self->id)->recv;
  if ($job) {
    $self->data($job->data);
    return 1;
  }
  $self->error($err || 'unknown');
  return undef;
}

sub release {
  my $self = shift;
  my $opt  = shift;
  my ($ok, $err) = $self->client->release($self->id, $opt)->recv;
  $self->reserved(0);
  return 1 if $ok;
  $self->error($err || 'unknown');
  return undef;
}

sub bury {
  my $self = shift;
  my $opt  = shift;
  my ($ok, $err) = $self->client->bury($self->id, $opt)->recv;
  if ($ok) {
    $self->reserved(0);
    $self->buried(1);
    return 1;
  }
  $self->error($err || 'unknown');
  return undef;
}

sub decode {
  my $self = shift;
  my $data = $self->data;
  return unless defined($data);
  $self->client->decoder->($data);
}

sub tube {
  my $self = shift;

  my $stats = $self->{_stats} || $self->stats
    or return undef;

  $stats->tube;
}

sub ttr {
  my $self = shift;

  my $stats = $self->{_stats} || $self->stats
    or return undef;

  $stats->ttr;
}

sub priority {
  my $self = shift;

  my $stats = $self->{_stats} || $self->stats
    or return undef;

  $stats->pri;
}

1;

__END__