some POD update, code cleanup, ...

5 files changed, 30 insertions, 13 deletions

diff --git a/lib/presque.pm b/lib/presque.pm
index a6dffd4..50a0178 100644
--- a/lib/presque.pm
+++ b/lib/presque.pm
@@ -30,7 +30,8 @@ sub h {
 sub app {
     my ($class, %args) = @_;
     my $self = $class->new(
-        [   '/q/(.*)'       => h('presque::RestQueueHandler'),
+        [   '/qb/(.*)' => h('presque::RestQueueBatchHandler'),
+            '/q/(.*)'  => h('presque::RestQueueHandler'),
             '/j/(.*)'       => h('presque::JobQueueHandler'),
             '/w/(.*)'       => h('presque::WorkerHandler'),
             '/status/(.*)'  => h('presque::StatusHandler'),
diff --git a/lib/presque/ControlHandler.pm b/lib/presque/ControlHandler.pm
index ccfc663..7feadc8 100644
--- a/lib/presque/ControlHandler.pm
+++ b/lib/presque/ControlHandler.pm
@@ -4,12 +4,11 @@ use JSON;
 use Moose;
 extends 'Tatsumaki::Handler';
 
-with (
-  'presque::Role::QueueName',
+with
+  'presque::Role::Queue::Names',
   'presque::Role::Error',
   'presque::Role::Response',
-  'presque::Role::RequireQueue' => {methods => [qw/get post/]},
-);
+  'presque::Role::Queue::WithQueueName' => {methods => [qw/get post/]},;
 
 __PACKAGE__->asynchronous(1);
 
@@ -81,7 +80,7 @@ presque::ControlHandler
 
 =head1 DESCRIPTION
 
-By default, when a queue is created, the status is set to 'open'. When a queue is set to 'stop', no job will be fetched from the queue.
+By default, when a queue is created, the status is set to 'open'. When a queue is set to 'stop', no job will be fetched from the queue, but it's still possible to add new jobs.
 
 =head1 METHODS
 
@@ -91,7 +90,7 @@ By default, when a queue is created, the status is set to 'open'. When a queue i
 
 =item path
 
-/control/queuename
+/control/:queuename
 
 =item request
 
@@ -111,7 +110,7 @@ content : {"status":"0","queue":"foo"}
 
 =item path
 
-/control/queuename
+/control/:queuename
 
 =item request
 
diff --git a/lib/presque/StatusHandler.pm b/lib/presque/StatusHandler.pm
index ee0abce..778aeb4 100644
--- a/lib/presque/StatusHandler.pm
+++ b/lib/presque/StatusHandler.pm
@@ -1,14 +1,15 @@
 package presque::StatusHandler;
 
+use JSON;
 use Moose;
 extends 'Tatsumaki::Handler';
 with
-  qw/presque::Role::QueueName presque::Role::Error presque::Role::Response/;
+  'presque::Role::Queue::Names',
+  'presque::Role::Error',
+  'presque::Role::Response';
 
 __PACKAGE__->asynchronous(1);
 
-use JSON;
-
 sub get {
     my ($self, $queue_name) = @_;
 
diff --git a/lib/presque/StreamHandler.pm b/lib/presque/StreamHandler.pm
new file mode 100644
index 0000000..fe88b76
--- /dev/null
+++ b/lib/presque/StreamHandler.pm
@@ -0,0 +1,14 @@
+package presque::StreamHandler;
+
+use JSON;
+use Moose;
+extends 'Tatsumaki::Handler';
+with qw/presque::Role::QueueName presque::Role::Response/;
+
+__PACKAGE__->asynchronous(1);
+
+sub get {
+    my ($self, $queue_name) = @_;
+}
+
+1;
diff --git a/lib/presque/WorkerHandler.pm b/lib/presque/WorkerHandler.pm
index 0421729..4399ddf 100644
--- a/lib/presque/WorkerHandler.pm
+++ b/lib/presque/WorkerHandler.pm
@@ -3,8 +3,10 @@ package presque::WorkerHandler;
 use JSON;
 use Moose;
 extends 'Tatsumaki::Handler';
-with('presque::Role::Error', 'presque::Role::Response',
-    'presque::Role::RequireQueue' => {methods => [qw/delete post/]});
+with
+    'presque::Role::Error',
+    'presque::Role::Response',
+    'presque::Role::Queue::WithQueueName' => {methods => [qw/delete post/]};
 
 __PACKAGE__->asynchronous(1);