feat: add task to wait until all the artifacts are available on MC (#360)

* feat: add task to wait until all the artifacts in the current release are available on MC

* chore: permit test run with empty include/exclude tags

Author: ndr-brt

plugins/edc-build/src/main/java/org/eclipse/edc/plugins/edcbuild/EdcBuildPlugin.java

@@ -36,6 +36,7 @@
 import static org.eclipse.edc.plugins.edcbuild.conventions.Conventions.signing;
 import static org.eclipse.edc.plugins.edcbuild.conventions.Conventions.swagger;
 import static org.eclipse.edc.plugins.edcbuild.conventions.Conventions.tests;
+import static org.eclipse.edc.plugins.edcbuild.conventions.Conventions.waitForPublishedArtifacts;
 
 /**
  * Adds (opinionated) conventions (=configuration) for various plugins.
@@ -77,7 +78,8 @@ public void apply(Project target) {
                     tests(),
                     jar(),
                     swagger(),
-                    printClasspath()
+                    printClasspath(),
+                    waitForPublishedArtifacts()
             ).forEach(c -> c.apply(project));
         });
 

plugins/edc-build/src/main/java/org/eclipse/edc/plugins/edcbuild/conventions/Conventions.java

@@ -82,4 +82,8 @@ public static EdcConvention mavenPublication() {
     public static EdcConvention printClasspath() {
         return new PrintClasspathConvention();
     }
+
+    public static EdcConvention waitForPublishedArtifacts() {
+        return new WaitForPublishedArtifactsConvention();
+    }
 }

plugins/edc-build/src/main/java/org/eclipse/edc/plugins/edcbuild/conventions/TestConvention.java

@@ -19,8 +19,6 @@
 import org.gradle.api.tasks.testing.logging.TestExceptionFormat;
 import org.jetbrains.annotations.NotNull;
 
-import static java.util.Optional.ofNullable;
-
 /**
  * Configures the use of JUnit, the tagging mechanism and also configures the test logging
  */
@@ -60,9 +58,11 @@ private static void determineJunitPlatform(Test testTask) {
 
     @NotNull
     private static String[] getTags(String tagsSeparatedByComma) {
-        return ofNullable(tagsSeparatedByComma)
-                .map(prop -> prop.split(","))
-                .orElse(new String[0]);
+        if (tagsSeparatedByComma == null || tagsSeparatedByComma.isBlank()) {
+            return new String[0];
+        }
+
+        return tagsSeparatedByComma.split(",");
     }
 
     @Override

plugins/edc-build/src/main/java/org/eclipse/edc/plugins/edcbuild/conventions/WaitForPublishedArtifactsConvention.java

@@ -0,0 +1,25 @@
+/*
+ *  Copyright (c) 2025 Think-it GmbH
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Think-it GmbH - initial API and implementation
+ *
+ */
+
+package org.eclipse.edc.plugins.edcbuild.conventions;
+
+import org.eclipse.edc.plugins.edcbuild.tasks.WaitForPublishedArtifacts;
+import org.gradle.api.Project;
+
+public class WaitForPublishedArtifactsConvention implements EdcConvention {
+    @Override
+    public void apply(Project target) {
+        target.getTasks().register("waitForPublishedArtifacts", WaitForPublishedArtifacts.class);
+    }
+}

plugins/edc-build/src/main/java/org/eclipse/edc/plugins/edcbuild/tasks/WaitForPublishedArtifacts.java

@@ -0,0 +1,77 @@
+/*
+ *  Copyright (c) 2025 Think-it GmbH
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Think-it GmbH - initial API and implementation
+ *
+ */
+
+package org.eclipse.edc.plugins.edcbuild.tasks;
+
+import org.gradle.api.DefaultTask;
+import org.gradle.api.artifacts.dsl.RepositoryHandler;
+import org.gradle.api.publish.PublishingExtension;
+import org.gradle.api.publish.maven.MavenPublication;
+import org.gradle.api.tasks.TaskAction;
+
+import java.net.URL;
+import java.time.LocalDateTime;
+
+import static java.lang.Thread.sleep;
+import static org.eclipse.edc.plugins.edcbuild.conventions.ConventionFunctions.requireExtension;
+
+/**
+ * Task for root project that looks up for published artifacts, waiting if they are not available.
+ * After a certain timeout the task fails
+ */
+public class WaitForPublishedArtifacts extends DefaultTask {
+
+    private static final int TASK_TIMEOUT_MINUTES = 60;
+    private static final int RETRY_WAIT_SECONDS = 30;
+
+    @TaskAction
+    public void waitForPublishedArtifacts() {
+        requireExtension(getProject(), PublishingExtension.class)
+                .getPublications().stream()
+                .map(MavenPublication.class::cast)
+                .forEach(this::lookUpForPublication);
+    }
+
+    private void lookUpForPublication(MavenPublication publication) {
+        if (publication.getVersion().endsWith("-SNAPSHOT")) {
+            throw new IllegalStateException("This task can only be executed on proper releases, not on snapshots");
+        }
+        var artifact = publication.getName() + " " + publication.getGroupId() + ":" + publication.getArtifactId() + ":" + publication.getVersion();
+        var repo = RepositoryHandler.MAVEN_CENTRAL_URL;
+
+        var timeout = LocalDateTime.now().plusMinutes(TASK_TIMEOUT_MINUTES);
+        var found = false;
+        while (!found && timeout.isAfter(LocalDateTime.now())) {
+            try {
+                var url = repo + publication.getGroupId().replace('.', '/') +
+                        "/" + publication.getArtifactId() + "/" + publication.getVersion() +
+                        "/" + publication.getArtifactId() + "-" + publication.getVersion() +
+                        ".pom";
+                new URL(url).openStream().close();
+                found = true;
+            } catch (Throwable e) {
+                getLogger().warn("Artifact {} is NOT available on maven central, will try again in {} seconds", artifact, RETRY_WAIT_SECONDS);
+                try {
+                    sleep(RETRY_WAIT_SECONDS * 1000);
+                } catch (InterruptedException ex) {
+                    throw new RuntimeException(ex);
+                }
+            }
+        }
+
+        if (!found) {
+            throw new IllegalStateException("Artifact %s has not been found maven central after %s minutes".formatted(artifact, TASK_TIMEOUT_MINUTES));
+        }
+    }
+}