Add a plugin to interact with the github status API.

[?]
Mar 12, 2016, 4:03 PM
NSRWW6LCJUUNQO4RI3MMYD4NVURBYBAG7SK3LJUY7KKC4OH7J65QC

Dependencies

  • [2] FCTX433O Add buildStarted plugin hook
  • [3] PHNLYPKB Call buildFinished when a cached build is added
  • [*] 5EQYVRWE Add a plugin mechanism

Change contents

  • replacement in src/lib/Hydra/Helper/PluginHooks.pm at line 18
    [2.1406][2.1406:1462]()
    print STDERR "$plugin->buildStarted: $@\n":
    [2.1406]
    [2.1462]
    print STDERR "$plugin->buildStarted: $@\n";
  • file addition: GithubStatus.pm (----------)
    [5.1]
    package Hydra::Plugin::GithubStatus;
    use strict;
    use parent 'Hydra::Plugin';
    use HTTP::Request;
    use JSON;
    use LWP::UserAgent;
    use Hydra::Helper::CatalystUtils;
    sub toGithubState {
    my ($buildStatus) = @_;
    if ($buildStatus == 0) {
    return "success";
    } elsif ($buildStatus == 3 || $buildStatus == 4 || $buildStatus == 8 || $buildStatus == 10 || $buildStatus == 11) {
    return "error";
    } else {
    return "failure";
    }
    }
    sub common {
    my ($self, $build, $dependents, $finished) = @_;
    my $cfg = $self->{config}->{githubstatus};
    my @config = defined $cfg ? ref $cfg eq "ARRAY" ? @$cfg : ($cfg) : ();
    my $baseurl = $self->{config}->{'base_uri'} || "http://localhost:3000";
    # Find matching configs
    foreach my $b ($build, @{$dependents}) {
    my $jobName = showJobName $b;
    my $evals = $build->jobsetevals;
    my $ua = LWP::UserAgent->new();
    my $body = encode_json(
    {
    state => $finished ? toGithubState($b->buildstatus) : "pending",
    target_url => "$baseurl/build/" . $b->id,
    description => "Hydra build #" . $b->id . " of $jobName",
    context => "continuous-integration/hydra"
    });
    foreach my $conf (@config) {
    next unless $jobName =~ /^$conf->{jobs}$/;
    my $inputs_cfg = $conf->{inputs};
    my @inputs = defined $inputs_cfg ? ref $inputs_cfg eq "ARRAY" ? @$inputs_cfg : ($inputs_cfg) : ();
    my %seen = map { $_ => {} } @inputs;
    while (my $eval = $evals->next) {
    foreach my $input (@inputs) {
    my $i = $eval->jobsetevalinputs->find({ name => $input, altnr => 0 });
    next unless defined $i;
    my $uri = $i->uri;
    my $rev = $i->revision;
    my $key = $uri . "-" . $rev;
    next if exists $seen{$input}->{$key};
    $seen{$input}->{$key} = 1;
    $uri =~ m![:/]([^/]+)/([^/]+?)(?:.git)?$!;
    my $req = HTTP::Request->new('POST', "https://api.github.com/repos/$1/$2/statuses/$rev");
    $req->header('Content-Type' => 'application/json');
    $req->header('Accept' => 'application/vnd.github.v3+json');
    $req->header('Authorization' => $conf->{authorization});
    $req->content($body);
    my $res = $ua->request($req);
    print STDERR $res->status_line, ": ", $res->decoded_content, "\n" unless $res->is_success;
    }
    }
    }
    }
    }
    sub buildStarted {
    common(@_, [], 0);
    }
    sub buildFinished {
    common(@_, 1);
    }
    1;