hydra/src/lib/Hydra/Plugin/RunCommand.pm

package Hydra::Plugin::RunCommand;

use strict;
use parent 'Hydra::Plugin';
use experimental 'smartmatch';
use JSON;

sub configSectionMatches {
    my ($name, $project, $jobset, $job) = @_;

    my @elems = split ':', $name;

    die "invalid section name '$name'\n" if scalar(@elems) > 3;

    my $project2 = $elems[0] // "*";
    return 0 if $project2 ne "*" && $project ne $project2;

    my $jobset2 = $elems[1] // "*";
    return 0 if $jobset2 ne "*" && $jobset ne $jobset2;

    my $job2 = $elems[2] // "*";
    return 0 if $job2 ne "*" && $job ne $job2;

    return 1;
}

sub eventMatches {
    my ($cfg, $event) = @_;
    for my $x (split " ", ($cfg->{events} // "buildFinished")) {
        return 1 if $x eq $event;
    }
    return 0;
}

sub buildFinished {
    my ($self, $build, $dependents) = @_;
    my $event = "buildFinished";

    my $config = $self->{config}->{runcommand} // [];

    my $tmp;

    foreach my $cfg (@$config) {
        next unless eventMatches($cfg, $event);
        next unless configSectionMatches(
            $cfg->{job} // "*:*:*",
            $build->get_column('project'),
            $build->get_column('jobset'),
            $build->get_column('job'));

        my $command = $cfg->{command} // die "<runcommand> section lacks a 'command' option";

        unless (defined $tmp) {
            $tmp = File::Temp->new(SUFFIX => '.json');

            my $json = {
                event => $event,
                build => $build->id,
                finished => $build->get_column('finished'),
                timestamp => $build->get_column('timestamp'),
                project => $build->get_column('project'),
                jobset => $build->get_column('jobset'),
                job => $build->get_column('job'),
                drvPath => $build->get_column('drvpath'),
                startTime => $build->get_column('starttime'),
                stopTime => $build->get_column('stoptime'),
                buildStatus => $build->get_column('buildstatus'),
                outputs => [],
                products => [],
                metrics => [],
            };

            for my $output ($build->buildoutputs) {
                my $j = {
                    name => $output->name,
                    path => $output->path,
                };
                push @{$json->{outputs}}, $j;
            }

            for my $product ($build->buildproducts) {
                my $j = {
                    productNr => $product->productnr,
                    type => $product->type,
                    subtype => $product->subtype,
                    fileSize => $product->filesize,
                    sha1hash => $product->sha1hash,
                    sha256hash => $product->sha256hash,
                    path => $product->path,
                    name => $product->name,
                    defaultPath => $product->defaultpath,
                };
                push @{$json->{products}}, $j;
            }

            for my $metric ($build->buildmetrics) {
                my $j = {
                    name => $metric->name,
                    unit => $metric->unit,
                    value => $metric->value,
                };
                push @{$json->{metrics}}, $j;
            }

            print $tmp encode_json($json) or die;
        }

        $ENV{"HYDRA_JSON"} = $tmp->filename;

        system("$command") == 0
            or warn "notification command '$command' failed with exit status $?\n";
    }
}

1;