CPAN::Groonga

package Resque::Plugin::Delay::Dequeue;
use 5.008001;
use strict;
use warnings;

use Moose::Role;
use JSON qw/decode_json/;

around pop => sub {
    my ( $orig, $self, $queue ) = @_;
    my $payload = $self->redis->lpop($self->key( queue => $queue ));
    return unless $payload;
    $payload = decode_json($payload);

    my $job = $self->new_job({
        payload => $payload,
        queue   => $queue
    });

    if (defined $payload->{start_time}) {
        my ($epoch,) = $payload->{start_time};
        if ($epoch > time) {
            $self->push($queue, $job);
            return;
        }
    }

    return $job;
};

1;