feat: add pipeline versioning support

conf/reflect-config.json

@@ -1469,12 +1469,6 @@
   "allDeclaredMethods":true,
   "methods":[{"name":"<init>","parameterTypes":[] }]
 },
-{
-  "name":"io.seqera.tower.cli.commands.pipelines.LabelsCmd",
-  "allDeclaredFields":true,
-  "queryAllDeclaredMethods":true,
-  "methods":[{"name":"<init>","parameterTypes":[] }]
-},
 {
   "name":"io.seqera.tower.cli.commands.pipelines.LaunchOptions",
   "allDeclaredFields":true,
@@ -1511,6 +1505,48 @@
   "allDeclaredMethods":true,
   "methods":[{"name":"<init>","parameterTypes":[] }]
 },
+{
+  "name":"io.seqera.tower.cli.commands.pipelines.labels.LabelsCmd",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
+{
+  "name":"io.seqera.tower.cli.commands.pipelines.versions.ListCmd",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
+{
+  "name":"io.seqera.tower.cli.commands.pipelines.versions.UpdateCmd",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
+{
+  "name":"io.seqera.tower.cli.commands.pipelines.versions.UpdateCmd$UpdateOptions",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
+{
+  "name":"io.seqera.tower.cli.commands.pipelines.versions.VersionRefOptions",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
+{
+  "name":"io.seqera.tower.cli.commands.pipelines.versions.VersionRefOptions$VersionRef",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
+{
+  "name":"io.seqera.tower.cli.commands.pipelines.versions.VersionsCmd",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
 {
   "name":"io.seqera.tower.cli.commands.pipelineschemas.AbstractPipelineSchemasCmd",
   "allDeclaredFields":true,
@@ -2187,12 +2223,30 @@
   "allDeclaredMethods":true,
   "allDeclaredConstructors":true
 },
+{
+  "name":"io.seqera.tower.cli.responses.pipelines.PipelinesUpdated",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "queryAllDeclaredConstructors":true
+},
 {
   "name":"io.seqera.tower.cli.responses.pipelines.PipelinesView",
   "allDeclaredFields":true,
   "queryAllDeclaredMethods":true,
   "queryAllDeclaredConstructors":true
 },
+{
+  "name":"io.seqera.tower.cli.responses.pipelines.versions.ListPipelineVersionsCmdResponse",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "queryAllDeclaredConstructors":true
+},
+{
+  "name":"io.seqera.tower.cli.responses.pipelines.versions.ManagePipelineVersionCmdResponse",
+  "allDeclaredFields":true,
+  "queryAllDeclaredMethods":true,
+  "queryAllDeclaredConstructors":true
+},
 {
   "name":"io.seqera.tower.cli.responses.pipelineschemas.PipelineSchemasAdded",
   "allDeclaredFields":true,
@@ -4027,6 +4081,7 @@
 },
 {
   "name":"io.seqera.tower.model.ListPipelineVersionsResponse",
+  "allDeclaredFields":true,
   "queryAllDeclaredMethods":true,
   "queryAllDeclaredConstructors":true,
   "methods":[{"name":"<init>","parameterTypes":[] }, {"name":"addVersionsItem","parameterTypes":["io.seqera.tower.model.PipelineDbDto"] }, {"name":"equals","parameterTypes":["java.lang.Object"] }, {"name":"getTotalSize","parameterTypes":[] }, {"name":"getVersions","parameterTypes":[] }, {"name":"hashCode","parameterTypes":[] }, {"name":"setTotalSize","parameterTypes":["java.lang.Long"] }, {"name":"setVersions","parameterTypes":["java.util.List"] }, {"name":"toIndentedString","parameterTypes":["java.lang.Object"] }, {"name":"toString","parameterTypes":[] }, {"name":"totalSize","parameterTypes":["java.lang.Long"] }, {"name":"versions","parameterTypes":["java.util.List"] }]
@@ -4352,6 +4407,7 @@
 },
 {
   "name":"io.seqera.tower.model.PipelineVersionManageRequest",
+  "allDeclaredFields":true,
   "queryAllDeclaredMethods":true,
   "queryAllDeclaredConstructors":true,
   "methods":[{"name":"<init>","parameterTypes":[] }, {"name":"equals","parameterTypes":["java.lang.Object"] }, {"name":"getIsDefault","parameterTypes":[] }, {"name":"getName","parameterTypes":[] }, {"name":"hashCode","parameterTypes":[] }, {"name":"isDefault","parameterTypes":["java.lang.Boolean"] }, {"name":"name","parameterTypes":["java.lang.String"] }, {"name":"setIsDefault","parameterTypes":["java.lang.Boolean"] }, {"name":"setName","parameterTypes":["java.lang.String"] }, {"name":"toIndentedString","parameterTypes":["java.lang.Object"] }, {"name":"toString","parameterTypes":[] }]

conf/resource-config.json

@@ -82,10 +82,10 @@
     "locales":["und"]
   }, {
     "name":"org.glassfish.jersey.client.internal.localization",
-    "locales":["und"]
+    "locales":["", "und"]
   }, {
     "name":"org.glassfish.jersey.internal.localization",
-    "locales":["und"]
+    "locales":["", "und"]
   }, {
     "name":"org.glassfish.jersey.media.multipart.internal.localization"
   }]

src/main/java/io/seqera/tower/cli/commands/AbstractApiCmd.java

@@ -30,6 +30,7 @@
 import io.seqera.tower.api.OrgsApi;
 import io.seqera.tower.api.PipelineSchemasApi;
 import io.seqera.tower.api.PipelineSecretsApi;
+import io.seqera.tower.api.PipelineVersionsApi;
 import io.seqera.tower.api.PipelinesApi;
 import io.seqera.tower.api.PlatformsApi;
 import io.seqera.tower.api.ServiceInfoApi;
@@ -43,6 +44,7 @@
 import io.seqera.tower.cli.Tower;
 import io.seqera.tower.cli.commands.labels.Label;
 import io.seqera.tower.cli.commands.labels.LabelsFinder;
+import io.seqera.tower.cli.commands.pipelines.versions.VersionRefOptions;
 import io.seqera.tower.cli.exceptions.ComputeEnvNotFoundException;
 import io.seqera.tower.cli.exceptions.InvalidWorkspaceParameterException;
 import io.seqera.tower.cli.exceptions.MissingTowerAccessTokenException;
@@ -59,10 +61,12 @@
 import io.seqera.tower.model.Credentials;
 import io.seqera.tower.model.DataStudioQueryAttribute;
 import io.seqera.tower.model.ListComputeEnvsResponseEntry;
+import io.seqera.tower.model.ListPipelineVersionsResponse;
 import io.seqera.tower.model.ListWorkspacesAndOrgResponse;
 import io.seqera.tower.model.OrgAndWorkspaceDto;
 import io.seqera.tower.model.PipelineDbDto;
 import io.seqera.tower.model.PipelineQueryAttribute;
+import io.seqera.tower.model.PipelineVersionFullInfoDto;
 import io.seqera.tower.model.UserResponseDto;
 import io.seqera.tower.model.WorkflowQueryAttribute;
 import org.glassfish.jersey.CommonProperties;
@@ -82,6 +86,7 @@
 import java.util.Map;
 import java.util.Objects;
 import java.util.Properties;
+import java.util.function.Predicate;
 import java.util.logging.Logger;
 import java.util.stream.Collectors;
 
@@ -115,6 +120,7 @@ public abstract class AbstractApiCmd extends AbstractCmd {
     private PipelinesApi pipelinesApi;
     private PipelineSchemasApi pipelineSchemasApi;
     private PipelineSecretsApi pipelineSecretsApi;
+    private PipelineVersionsApi pipelineVersionsApi;
     private PlatformsApi platformsApi;
     private ServiceInfoApi serviceInfoApi;
     private StudiosApi studiosApi;
@@ -234,6 +240,10 @@ protected PipelinesApi pipelinesApi() throws ApiException {
         return pipelinesApi == null ? new PipelinesApi(apiClient()) : pipelinesApi;
     }
 
+    protected PipelineVersionsApi pipelineVersionsApi() throws ApiException {
+        return pipelineVersionsApi == null ? new PipelineVersionsApi(apiClient()) : pipelineVersionsApi;
+    }
+
     protected PlatformsApi platformsApi() throws ApiException {
         return platformsApi == null ? new PlatformsApi(apiClient()) : platformsApi;
     }
@@ -579,6 +589,39 @@ protected String workspaceRef(Long workspaceId) throws ApiException {
         return buildWorkspaceRef(orgName(workspaceId), workspaceName(workspaceId));
     }
 
+    protected PipelineVersionFullInfoDto findPipelineVersionByRef(Long pipelineId, Long wspId, VersionRefOptions.VersionRef ref) throws ApiException {
+        String search = ref.versionName;
+        Boolean isPublished = ref.versionName != null ? true : null;
+        Predicate<PipelineVersionFullInfoDto> matcher = ref.versionId != null
+                ? v -> ref.versionId.equals(v.getId())
+                : v -> ref.versionName.equals(v.getName());
+
+        ListPipelineVersionsResponse response = pipelineVersionsApi()
+                .listPipelineVersions(pipelineId, wspId, null, null, search, isPublished);
+
+        if (response.getVersions() == null) {
+            throw new TowerException("No versions available for the pipeline, check if Pipeline versioning feature is enabled for the workspace");
+        }
+
+        return response.getVersions().stream()
+                .map(PipelineDbDto::getVersion)
+                .filter(Objects::nonNull)
+                .filter(matcher)
+                .findFirst()
+                .orElse(null);
+    }
+
+    protected String resolvePipelineVersionId(Long pipelineId, Long wspId, VersionRefOptions.VersionRef versionRef) throws ApiException {
+        if (versionRef == null) return null;
+        if (versionRef.versionId != null) return versionRef.versionId;
+
+        PipelineVersionFullInfoDto version = findPipelineVersionByRef(pipelineId, wspId, versionRef);
+        if (version == null) {
+            throw new TowerException(String.format("Pipeline version '%s' not found", versionRef.versionName));
+        }
+        return version.getId();
+    }
+
     protected Long sourceWorkspaceId(Long currentWorkspace, PipelineDbDto pipeline) {
         if (pipeline == null)
             return null;

src/main/java/io/seqera/tower/cli/commands/LaunchCmd.java

@@ -20,6 +20,7 @@
 import io.seqera.tower.cli.commands.enums.OutputType;
 import io.seqera.tower.cli.commands.global.WorkspaceOptionalOptions;
 import io.seqera.tower.cli.commands.labels.Label;
+import io.seqera.tower.cli.commands.pipelines.versions.VersionRefOptions;
 import io.seqera.tower.cli.exceptions.InvalidResponseException;
 import io.seqera.tower.cli.responses.Response;
 import io.seqera.tower.cli.responses.runs.RunSubmited;
@@ -82,6 +83,10 @@ public class LaunchCmd extends AbstractRootCmd {
     @Option(names = {"--commit-id"}, description = "Specific Git commit hash to pin the pipeline execution to.")
     String commitId;
 
+    // Explicit "0..1" for clarity — contrasts with the required "1" in VersionRefOptions. @Mixin won't work here as it would lose mutual exclusivity.
+    @ArgGroup(multiplicity = "0..1")
+    VersionRefOptions.VersionRef versionRef;
+
     @Option(names = {"--wait"}, description = "Wait until workflow reaches specified status: ${COMPLETION-CANDIDATES}")
     public WorkflowStatus wait;
 
@@ -177,8 +182,9 @@ protected Response runTowerPipeline(Long wspId) throws ApiException, IOException
         }
 
         Long sourceWorkspaceId = sourceWorkspaceId(wspId, pipe);
+        String versionId = resolvePipelineVersionId(pipe.getPipelineId(), wspId, versionRef);
 
-        LaunchDbDto launch = pipelinesApi().describePipelineLaunch(pipe.getPipelineId(), wspId, sourceWorkspaceId, null).getLaunch();
+        LaunchDbDto launch = pipelinesApi().describePipelineLaunch(pipe.getPipelineId(), wspId, sourceWorkspaceId, versionId).getLaunch();
 
         WorkflowLaunchRequest launchRequest = createLaunchRequest(launch);
         if (computeEnv != null) {

src/main/java/io/seqera/tower/cli/commands/PipelinesCmd.java

@@ -20,10 +20,11 @@
 import io.seqera.tower.cli.commands.pipelines.DeleteCmd;
 import io.seqera.tower.cli.commands.pipelines.ExportCmd;
 import io.seqera.tower.cli.commands.pipelines.ImportCmd;
-import io.seqera.tower.cli.commands.pipelines.LabelsCmd;
+import io.seqera.tower.cli.commands.pipelines.labels.LabelsCmd;
 import io.seqera.tower.cli.commands.pipelines.ListCmd;
 import io.seqera.tower.cli.commands.pipelines.UpdateCmd;
 import io.seqera.tower.cli.commands.pipelines.ViewCmd;
+import io.seqera.tower.cli.commands.pipelines.versions.VersionsCmd;
 import picocli.CommandLine.Command;
 
 
@@ -39,6 +40,7 @@
                 ExportCmd.class,
                 ImportCmd.class,
                 LabelsCmd.class,
+                VersionsCmd.class
         }
 )
 public class PipelinesCmd extends AbstractRootCmd {

src/main/java/io/seqera/tower/cli/commands/pipelines/AddCmd.java

@@ -19,12 +19,16 @@
 import io.seqera.tower.ApiException;
 import io.seqera.tower.cli.commands.global.WorkspaceOptionalOptions;
 import io.seqera.tower.cli.commands.labels.LabelsOptionalOptions;
+import io.seqera.tower.cli.commands.pipelines.labels.PipelinesLabelsManager;
+import io.seqera.tower.cli.exceptions.TowerException;
 import io.seqera.tower.cli.responses.Response;
 import io.seqera.tower.cli.responses.pipelines.PipelinesAdded;
 import io.seqera.tower.cli.utils.FilesHelper;
+import io.seqera.tower.cli.utils.ResponseHelper;
 import io.seqera.tower.model.ComputeEnvResponseDto;
 import io.seqera.tower.model.CreatePipelineRequest;
 import io.seqera.tower.model.CreatePipelineResponse;
+import io.seqera.tower.model.CreatePipelineVersionRequest;
 import io.seqera.tower.model.Visibility;
 import io.seqera.tower.model.WorkflowLaunchRequest;
 import picocli.CommandLine;
@@ -55,6 +59,9 @@ public class AddCmd extends AbstractPipelinesCmd {
     @Parameters(index = "0", paramLabel = "PIPELINE_URL", description = "Nextflow pipeline URL", arity = "1")
     public String pipeline;
 
+    @Option(names = {"--version-name"}, description = "Initial pipeline version name.")
+    public String versionName;
+
     @Mixin
     public LabelsOptionalOptions labels;
 
@@ -77,7 +84,7 @@ protected Response exec() throws ApiException, IOException {
         // Retrieve the provided computeEnv or use the primary if not provided
         ComputeEnvResponseDto ce = opts.computeEnv != null ? computeEnvByRef(wspId, opts.computeEnv) : null;
 
-        // By default use primary compute environment at private workspaces
+        // By default, use primary compute environment at private workspaces
         if (ce == null && visibility == Visibility.PRIVATE) {
             ce = primaryComputeEnv(wspId);
             if (ce == null) {
@@ -90,36 +97,46 @@ protected Response exec() throws ApiException, IOException {
         String preRunScriptValue = opts.preRunScript == null && ce != null ? ce.getConfig().getPreRunScript() : FilesHelper.readString(opts.preRunScript);
         String postRunScriptValue = opts.postRunScript == null && ce != null ? ce.getConfig().getPostRunScript() : FilesHelper.readString(opts.postRunScript);
 
-        CreatePipelineResponse response = pipelinesApi().createPipeline(
-                new CreatePipelineRequest()
-                        .name(name)
-                        .description(description)
-                        .launch(new WorkflowLaunchRequest()
-                                .computeEnvId(ce != null ? ce.getId() : null)
-                                .pipeline(pipeline)
-                                .revision(opts.revision)
-                                .commitId(opts.commitId)
-                                .workDir(workDirValue)
-                                .configProfiles(opts.profile)
-                                .paramsText(FilesHelper.readString(opts.paramsFile))
-
-                                // Advanced options
-                                .configText(FilesHelper.readString(opts.config))
-                                .preRunScript(preRunScriptValue)
-                                .postRunScript(postRunScriptValue)
-                                .pullLatest(opts.pullLatest)
-                                .stubRun(opts.stubRun)
-                                .mainScript(opts.mainScript)
-                                .entryName(opts.entryName)
-                                .schemaName(opts.schemaName)
-                                .pipelineSchemaId(pipelineSchemaId)
-                                .userSecrets(removeEmptyValues(opts.userSecrets))
-                                .workspaceSecrets(removeEmptyValues(opts.workspaceSecrets))
-                        )
-                , wspId
-        );
-
-        attachLabels(wspId,response.getPipeline().getPipelineId());
+        CreatePipelineResponse response;
+        try {
+            response = pipelinesApi().createPipeline(
+                    new CreatePipelineRequest()
+                            .name(name)
+                            .description(description)
+                            .version(versionName != null ? new CreatePipelineVersionRequest().name(versionName) : null)
+                            .launch(new WorkflowLaunchRequest()
+                                    .computeEnvId(ce != null ? ce.getId() : null)
+                                    .pipeline(pipeline)
+                                    .revision(opts.revision)
+                                    .commitId(opts.commitId)
+                                    .workDir(workDirValue)
+                                    .configProfiles(opts.profile)
+                                    .paramsText(FilesHelper.readString(opts.paramsFile))
+
+                                    // Advanced options
+                                    .configText(FilesHelper.readString(opts.config))
+                                    .preRunScript(preRunScriptValue)
+                                    .postRunScript(postRunScriptValue)
+                                    .pullLatest(opts.pullLatest)
+                                    .stubRun(opts.stubRun)
+                                    .mainScript(opts.mainScript)
+                                    .entryName(opts.entryName)
+                                    .schemaName(opts.schemaName)
+                                    .pipelineSchemaId(pipelineSchemaId)
+                                    .userSecrets(removeEmptyValues(opts.userSecrets))
+                                    .workspaceSecrets(removeEmptyValues(opts.workspaceSecrets))
+                            )
+                    , wspId
+            );
+        } catch (ApiException e) {
+            throw new TowerException(String.format("Unable to add pipeline '%s': %s", name, ResponseHelper.decodeMessage(e)));
+        }
+
+        try {
+            attachLabels(wspId, response.getPipeline().getPipelineId());
+        } catch (ApiException e) {
+            throw new TowerException(String.format("Pipeline '%s' was created but failed to add labels: %s", name, ResponseHelper.decodeMessage(e)));
+        }
 
         return new PipelinesAdded(workspaceRef(wspId), response.getPipeline().getName());
     }