diff options
| -rw-r--r-- | t/10_basic.t | 119 |
1 files changed, 84 insertions, 35 deletions
diff --git a/t/10_basic.t b/t/10_basic.t index 5b12d4f..86495ec 100644 --- a/t/10_basic.t +++ b/t/10_basic.t @@ -19,57 +19,73 @@ my $app = presque->app( } ); -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"; +my $queue = "presque_test"; +my $queue_url = "http://localhost/q/$queue"; +my $queue_batch_url = "http://localhost/qb/$queue"; +my $job_url = "http://localhost/j/$queue"; +my $status_url = "http://localhost/status/$queue"; +my $worker_url = "http://localhost/w/$queue"; +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 ); + 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'; + is_deeply JSON::decode_json $res->content, + { job_processed => 0, + job_count => 0, + queue_name => $queue, + job_failed => 0, + }, + 'good job info result'; # no job in queue - $req = HTTP::Request->new( GET => $queue_url ); + $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" }, + 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' } ) ); + $req = HTTP::Request->new(POST => $queue_url); + my $job = {foo => "bar"}; + $req->content(JSON::encode_json($job)); $res = $cb->($req); ok !$res->is_success, 'content-type is not set to json'; # insert a job - $req->header( 'Content-Type' => 'application/json' ); + $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 ); + $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' } ); + is_deeply $content, + { job_count => 1, + job_failed => 0, + job_processed => 0, + queue_name => $queue, + }, + 'valid jobs info'; + + # do a basic job + $req = HTTP::Request->new(GET => $queue_url); + ok $res = $cb->($req), 'get a job'; + ok $res->is_success, 'job fetched'; + is_deeply JSON::decode_json $res->content, $job, 'job is good'; + + # insert a delayed job + $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 ); + + # no job to do now + $req = HTTP::Request->new(GET => $queue_url); $res = $cb->($req); ok !$res->is_success, 'no job'; sleep(2); @@ -77,12 +93,12 @@ test_psgi $app, sub { ok $res->is_success, 'job found'; like $res->content, qr/baz/, 'delayed job'; - # control queue - $req = HTTP::Request->new( GET => $control_url ); + # # control queue + $req = HTTP::Request->new(GET => $control_url); $res = $cb->($req); $content = JSON::decode_json $res->content; - is_deeply $content, { - status => 1, + is_deeply $content, + { status => 1, queue => 'presque_test' }, 'queue is open'; @@ -91,17 +107,50 @@ test_psgi $app, sub { $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'; + like $res->content, qr/updated/, 'queue status change'; # status of a closed queue - $req = HTTP::Request->new( GET => $control_url ); - $res = $cb->($req); + $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 ); + $req = HTTP::Request->new(GET => $queue_url); $res = $cb->($req); ok !$res->is_success, 'no job for this queue'; + + # open queue + $req = HTTP::Request->new(POST => $control_url); + $req->content(JSON::encode_json({status => 'start'})); + $res = $cb->($req); + like $res->content, qr/updated/, 'queue status change'; + + # batch inserts + $req = HTTP::Request->new(POST => $queue_batch_url); + $req->header('Content-Type' => 'application/json'); + my $jobs = [{foo => 1}, {foo => 2}, {foo => 3}, {foo => 4}]; + $req->content(JSON::encode_json({jobs => $jobs})); + ok $res = $cb->($req), 'insert a batch of jobs'; + + # batch fetch + $req = HTTP::Request->new(GET => $queue_batch_url); + $res = $cb->($req); + $content = JSON::decode_json $res->content; + my @jobs = map { JSON::decode_json $_ } @$content; + is_deeply $jobs, \@jobs, 'valid jobs'; + + # status + $req = HTTP::Request->new(GET => $status_url); + $res = $cb->($req); + is_deeply JSON::decode_json $res->content, + {queue => 'presque_test', size => 0}, 'valid status'; + + # worker stats + + # purge queue + $req = HTTP::Request->new(DELETE => $queue_url); + $res = $cb->($req); + is $res->code, 204, 'queue purge'; }; done_testing; |