1 files changed, 77 insertions, 0 deletions
diff --git a/lib/Devscripts/Salsa/last_ci_status.pm b/lib/Devscripts/Salsa/last_ci_status.pm
new file mode 100644
index 0000000..2292c30
--- /dev/null
+++ b/lib/Devscripts/Salsa/last_ci_status.pm
@@ -0,0 +1,77 @@
+package Devscripts::Salsa::last_ci_status;
+
+use strict;
+use Devscripts::Output;
+use Moo::Role;
+
+with "Devscripts::Salsa::Repo";
+
+use constant OK      => 'success';
+use constant SKIPPED => 'skipped';
+use constant FAILED  => 'failed';
+
+sub last_ci_status {
+    my ($self, @repos) = @_;
+    unless (@repos or $self->config->all or $self->config->all_archived) {
+        ds_warn "Usage $0 ci_status <--all|--all-archived|names>";
+        return 1;
+    }
+    if (@repos and $self->config->all) {
+        ds_warn "--all with a project name makes no sense";
+        return 1;
+    }
+    if (@repos and $self->config->all_archived) {
+        ds_warn "--all-archived with a project name makes no sense";
+        return 1;
+    }
+    # If --all is asked, launch all projects
+    @repos = map { $_->[1] } $self->get_repo(0, @repos) unless (@repos);
+    my $ret = 0;
+    foreach my $repo (@repos) {
+        my $id        = $self->project2id($repo) or return 1;
+        my $pipelines = $self->api->pipelines($id);
+        unless ($pipelines and @$pipelines) {
+            ds_warn "No pipelines for $repo";
+            $ret++;
+            unless ($self->config->no_fail) {
+                ds_verbose "Use --no-fail to continue";
+                return 1;
+            }
+        } else {
+            my $status = $pipelines->[0]->{status};
+            if ($status eq OK) {
+                print "Last result for $repo: $status\n";
+            } else {
+                print STDERR "Last result for $repo: $status\n";
+                my $jobs
+                  = $self->api->pipeline_jobs($id, $pipelines->[0]->{id});
+                my %jres;
+                foreach my $job (sort { $a->{id} <=> $b->{id} } @$jobs) {
+                    next if $job->{status} eq SKIPPED;
+                    push @{ $jres{ $job->{status} } }, $job->{name};
+                }
+                if ($jres{ OK() }) {
+                    print STDERR '    success: '
+                      . join(', ', @{ $jres{ OK() } }) . "\n";
+                    delete $jres{ OK() };
+                }
+                foreach my $k (sort keys %jres) {
+                    print STDERR '    '
+                      . uc($k) . ': '
+                      . join(', ', @{ $jres{$k} }) . "\n";
+                }
+                print STDERR "\n  See: " . $pipelines->[0]->{web_url} . "\n\n";
+                if ($status eq FAILED) {
+                    $ret++;
+                    unless ($self->config->no_fail) {
+                        ds_verbose "Use --no-fail to continue";
+                        return 1;
+                    }
+                }
+            }
+        }
+    }
+    return $ret;
+}
+
+1;