File Coverage

blib/lib/Qless/BaseJob.pm

Criterion	Covered	Total	%
statement	12	43	27.9
branch	0	4	0.0
condition			n/a
subroutine	4	16	25.0
pod	0	12	0.0
total	16	75	21.3

package Qless::BaseJob;
use strict; use warnings;
use Qless::Utils qw(fix_empty_array);
use Time::HiRes qw();

sub new {
	my $class = shift;

	my ($client, $args) = @_;

	$class = ref $class if ref $class;
	my $self = bless {}, $class;

	$self->{'client'} = $client;

	$self->{'_loaded'} = {};
	foreach my $key (qw(data jid priority)) {
		$self->{$key} = $args->{ $key };
	}

	$self->{'klass'}      = $args->{'klass'};
	$self->{'queue_name'} = $args->{'queue'};
	$self->{'tags'}       = fix_empty_array($args->{'tags'});

	$self;
}


sub priority {
	my $self = shift;

	if ($#_ == 0) {
		$self->{'client'}->_priority([], $self->{'jid'}, $_[0]);
		$self->{'priority'} = $_[0];
	}

	return $self->{'priority'};
}

sub queue {
	my ($self) = @_;
	return $self->{'queue'} = $self->{'client'}->queues($self->{'queue_name'});
}

sub client { $_[0]->{'client'} }
sub queue_name { $_[0]->{'queue_name'} }
sub klass { $_[0]->{'klass'} }
sub data { $_[0]->{'data'} }
sub jid { $_[0]->{'jid'} }
sub tags { $_[0]->{'tags'} }

sub cancel {
	my ($self) = @_;
	$self->{'client'}->_cancel([], $self->{'jid'});
}

sub tag {
	my ($self, @tags) = @_;
	$self->{'client'}->_tag([], 'add', $self->{'jid'}, Time::HiRes::time, @tags);
}

sub untag {
	my ($self, @tags) = @_;
	$self->{'client'}->_tag([], 'remove', $self->{'jid'}, Time::HiRes::time, @tags);
}

1;