002ac9ef63
The catalyst-action-rest branch from shlevy/hydra was an exploration of
using Catalyst::Action::REST to create a JSON API for hydra. This commit
merges in the best bits from that experiment, with the goal that further
API endpoints can be added incrementally.
In addition to migrating more endpoints, there is potential for
improvement in what's already been done:
* The web interface can be updated to use the same non-GET endpoints as
the JSON interface (using x-tunneled-method) instead of having a
separate endpoint
* The web rendering should use the $c->stash->{resource} data structure
where applicable rather than putting the same data in two places in
the stash
* Which columns to render for each endpoint is a completely debatable
question
* Hydra::Component::ToJSON should turn has_many relations that have
strings as their primary keys into objects instead of arrays
Fixes NixOS/hydra#98
Signed-off-by: Shea Levy <shea@shealevy.com>
64 lines
3.3 KiB
Perl
64 lines
3.3 KiB
Perl
use LWP::UserAgent;
|
|
use JSON;
|
|
use Test::Simple tests => 15;
|
|
|
|
my $ua = LWP::UserAgent->new;
|
|
$ua->cookie_jar({});
|
|
|
|
sub request_json {
|
|
my ($opts) = @_;
|
|
my $req = HTTP::Request->new;
|
|
$req->method($opts->{method} or "GET");
|
|
$req->uri("http://localhost:3000$opts->{uri}");
|
|
$req->header(Accept => "application/json");
|
|
$req->content(encode_json($opts->{data})) if defined $opts->{data};
|
|
my $res = $ua->request($req);
|
|
print $res->as_string();
|
|
return $res;
|
|
}
|
|
|
|
my $result = request_json({ uri => "/login", method => "POST", data => { username => "root", password => "foobar" } });
|
|
|
|
my $user = decode_json($result->content());
|
|
|
|
ok($user->{username} eq "root", "The root user is named root");
|
|
ok($user->{userroles}->[0]->{role} eq "admin", "The root user is an admin");
|
|
|
|
$user = decode_json(request_json({ uri => "/current-user" })->content());
|
|
ok($user->{username} eq "root", "The current user is named root");
|
|
ok($user->{userroles}->[0]->{role} eq "admin", "The current user is an admin");
|
|
|
|
ok(request_json({ uri => '/project/sample' })->code() == 404, "Non-existent projects don't exist");
|
|
|
|
$result = request_json({ uri => '/project/sample', method => 'PUT', data => { displayname => "Sample", enabled => "1", } });
|
|
ok($result->code() == 201, "PUTting a new project creates it");
|
|
|
|
my $project = decode_json(request_json({ uri => '/project/sample' })->content());
|
|
|
|
ok((not @{$project->{jobsets}}), "A new project has no jobsets");
|
|
|
|
$result = request_json({ uri => '/jobset/sample/default', method => 'PUT', data => { nixexprpath => "default.nix", nixexprinput => "src", inputs => { src => { type => "path", values => "/run/jobset" } }, enabled => "1", checkinterval => "3600"} });
|
|
ok($result->code() == 201, "PUTting a new jobset creates it");
|
|
|
|
my $jobset = decode_json(request_json({ uri => '/jobset/sample/default' })->content());
|
|
|
|
ok($jobset->{jobsetinputs}->[0]->{name} eq "src", "The new jobset has an 'src' input");
|
|
ok($jobset->{jobsetinputs}->[0]->{jobsetinputalts}->[0]->{value} eq "/run/jobset", "The 'src' input is in /run/jobset");
|
|
|
|
system("LOGNAME=root NIX_STORE_DIR=/run/nix/store NIX_LOG_DIR=/run/nix/var/log/nix NIX_STATE_DIR=/run/nix/var/nix HYDRA_DATA=/var/lib/hydra HYDRA_DBI='dbi:Pg:dbname=hydra;user=root;' hydra-evaluator sample default");
|
|
$result = request_json({ uri => '/jobset/sample/default/evals' });
|
|
ok($result->code() == 200, "Can get evals of a jobset");
|
|
my $evals = decode_json($result->content())->{evals};
|
|
my $eval = $evals->[0];
|
|
ok($eval->{hasnewbuilds} == 1, "The first eval of a jobset has new builds");
|
|
|
|
# Ugh, cached for 30s
|
|
sleep 30;
|
|
system("echo >> /run/jobset/default.nix; LOGNAME=root NIX_STORE_DIR=/run/nix/store NIX_LOG_DIR=/run/nix/var/log/nix NIX_STATE_DIR=/run/nix/var/nix HYDRA_DATA=/var/lib/hydra HYDRA_DBI='dbi:Pg:dbname=hydra;user=root;' hydra-evaluator sample default");
|
|
my $evals = decode_json(request_json({ uri => '/jobset/sample/default/evals' })->content())->{evals};
|
|
ok($evals->[0]->{jobsetevalinputs}->[0]->{revision} != $evals->[1]->{jobsetevalinputs}->[0]->{revision}, "Changing a jobset source changes its revision");
|
|
|
|
my $build = decode_json(request_json({ uri => "/build/" . $evals->[0]->{jobsetevalmembers}->[0]->{build} })->content());
|
|
ok($build->{job} eq "job", "The build's job name is job");
|
|
ok($build->{finished} == 0, "The build isn't finished yet");
|