start to write tests

1 files changed, 108 insertions, 0 deletions

diff --git a/t/10_basic.t b/t/10_basic.t
new file mode 100644
index 0000000..5b12d4f
--- /dev/null
+++ b/t/10_basic.t
@@ -0,0 +1,108 @@
+use strict;
+use warnings;
+
+use Test::More;
+use Plack::Test;
+
+use JSON;
+use HTTP::Request;
+use presque;
+
+$Plack::Test::Impl = 'Server';
+
+my $app = presque->app(
+    config => {
+        redis => {
+            host => '127.0.0.1',
+            port => 6379
+        }
+    }
+);
+
+my $queue       = 'presque_test';
+my $queue_url   = "http://localhost/q/$queue";
+my $job_url     = "http://localhost/j/$queue";
+my $stat_url    = "http://localhost/stats/";
+my $control_url = "http://localhost/control/$queue";
+
+test_psgi $app, sub {
+    my $cb = shift;
+
+    # get queue informations
+    my $req = HTTP::Request->new( GET => $job_url );
+    ok my $res = $cb->($req), 'get info on an empty queue';
+    is_deeply JSON::decode_json $res->content, {
+        jobs       => undef,
+        job_count  => 0,
+        queue      => $queue,
+        queue_size => 0
+      }, 'good job info result';
+
+    # no job in queue
+    $req = HTTP::Request->new( GET => $queue_url );
+    ok $res = $cb->($req), 'first request done';
+    ok !$res->is_success, 'no job for this queue';
+    is_deeply JSON::decode_json( $res->content ), { error => "no job" },
+      'error message is valid';
+
+    # fail to create a new job
+    $req = HTTP::Request->new( POST => $queue_url );
+    $req->content( JSON::encode_json( { foo => 'bar' } ) );
+    $res = $cb->($req);
+    ok !$res->is_success, 'content-type is not set to json';
+
+    # insert a job
+    $req->header( 'Content-Type' => 'application/json' );
+    $res = $cb->($req);
+    ok $res->is_success, 'new job inserted';
+
+    # info about a queue
+    $req = HTTP::Request->new( GET => $job_url );
+    $res = $cb->($req);
+    my $content = JSON::decode_json $res->content;
+    ok grep {/presque_test:1/} @{$content->{jobs}}, 'find jobs';
+
+    # delayed job
+    ok $cb->( HTTP::Request->new( GET => $queue_url ) ), 'purged jobs';
+    $req = HTTP::Request->new(
+        POST => $queue_url . '?delayed=' . ( time() + 2 ) );
+    $req->header( 'Content-Type' => 'application/json' );
+    $req->content( JSON::encode_json { foo => 'baz' } );
+    ok $res = $cb->($req), 'delayed job inserted';
+    $req = HTTP::Request->new( GET => $queue_url );
+    $res = $cb->($req);
+    ok !$res->is_success, 'no job';
+    sleep(2);
+    $res = $cb->($req);
+    ok $res->is_success, 'job found';
+    like $res->content, qr/baz/, 'delayed job';
+
+    # control queue
+    $req     = HTTP::Request->new( GET => $control_url );
+    $res     = $cb->($req);
+    $content = JSON::decode_json $res->content;
+    is_deeply $content, {
+        status => 1,
+        queue  => 'presque_test'
+      },
+      'queue is open';
+
+    # close queue
+    $req = HTTP::Request->new(POST => $control_url);
+    $req->content(JSON::encode_json({status => 'stop'}));
+    $res = $cb->($req);
+    like $res->content, qr/OK/, 'queue status change';
+
+    # status of a closed queue
+    $req     = HTTP::Request->new( GET => $control_url );
+    $res     = $cb->($req);
+    like $res->content, qr/0/, 'queue is closed';
+
+    # can't get job on a stopped queue
+    $req = HTTP::Request->new( GET => $queue_url );
+    $res = $cb->($req);
+    ok !$res->is_success, 'no job for this queue';
+};
+
+done_testing;
+