add POD; fix queue size when null

3 files changed, 30 insertions, 6 deletions

diff --git a/lib/presque/JobQueueHandler.pm b/lib/presque/JobQueueHandler.pm
index 6bc9f8f..62ad8da 100644
--- a/lib/presque/JobQueueHandler.pm
+++ b/lib/presque/JobQueueHandler.pm
@@ -22,6 +22,7 @@ sub get {
         $key,
         sub {
             my $size = shift;
+            warn "ici avec size!\n";
             $self->application->redis->mget(
                 $processed,
                 $failed,
@@ -29,9 +30,9 @@ sub get {
                     my $res = shift;
                     $self->entity(
                         {   queue_name    => $queue_name,
-                            job_count     => $size,
-                            job_processed => $res->[0],
-                            job_failed    => $res->[1],
+                            job_count     => $size || 0,
+                            job_processed => $res->[0] || 0,
+                            job_failed    => $res->[1] || 0,
                         }
                     );
                 }
diff --git a/lib/presque/RestQueueBatchHandler.pm b/lib/presque/RestQueueBatchHandler.pm
index adbfe06..30008b8 100644
--- a/lib/presque/RestQueueBatchHandler.pm
+++ b/lib/presque/RestQueueBatchHandler.pm
@@ -148,3 +148,25 @@ sub _create_job {
 }
 
 1;
+__END__
+
+=head1 NAME
+
+presque::RestQueueBatchHandler
+
+=head1 SYNOPSIS
+
+    # insert a list of jobs
+    curl -H 'Content-Type: application/json' -X POST "http://localhost:5000/qb/foo" -d '{jobs:["key":"value"], ["key2":"value2"]}'
+
+    # fetch some jobs
+    curl http://localhost:5000/qb/foo
+
+=head1 DESCRIPTION
+
+=head1 METHODS
+
+=head2 get
+
+=head2 post
+
diff --git a/lib/presque/WorkerHandler.pm b/lib/presque/WorkerHandler.pm
index 4399ddf..dcb6acf 100644
--- a/lib/presque/WorkerHandler.pm
+++ b/lib/presque/WorkerHandler.pm
@@ -71,9 +71,10 @@ sub _get_stats_for_worker {
         'failed:' . $worker_id,
         sub {
             my $res  = shift;
-            my $desc = JSON::decode_json(shift @$res);
-            $desc->{processed} = shift @$res;
-            $desc->{failed}    = shift @$res;
+            my $desc = {};
+            $desc = JSON::decode_json(shift @$res) if $res->[0];
+            $desc->{processed} = $res->[1] || 0;
+            $desc->{failed}    = $res->[2] || 0;
             $self->entity($desc);
         }
     );