Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[JENKINS-40765] add pipeline support (#22)
* [JENKINS-40765] add pipeline support * fix after code review * remove guice * allow to schedule release when build is in queue rewrite SafeParametersAction in order to use parent's parameters field that allows to benefit on correct execution of ParametersAction#shouldSchedule method * acquire the lock only when needed * fix after code review
- Loading branch information
1 parent
a06e566
commit 1f9b17f
Showing
12 changed files
with
673 additions
and
33 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
28 changes: 28 additions & 0 deletions
28
src/main/java/hudson/plugins/release/pipeline/ReleaseQueueListener.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,28 @@ | ||
| package hudson.plugins.release.pipeline; | ||
|
|
||
| import org.kohsuke.accmod.Restricted; | ||
| import org.kohsuke.accmod.restrictions.NoExternalUse; | ||
|
|
||
| import hudson.AbortException; | ||
| import hudson.Extension; | ||
| import hudson.model.Queue; | ||
| import hudson.model.queue.QueueListener; | ||
|
|
||
| /** | ||
| * copied from org.jenkinsci.plugins.workflow.support.steps.build.BuildQueueListener | ||
| * @since 2.7 | ||
| */ | ||
| @Extension | ||
| @Restricted(NoExternalUse.class) | ||
| public class ReleaseQueueListener extends QueueListener { | ||
| @Override | ||
| public void onLeft(Queue.LeftItem li) { | ||
| if(li.isCancelled()){ | ||
| for (ReleaseTriggerAction.Trigger trigger : ReleaseTriggerAction.triggersFor(li)) { | ||
| trigger.context.onFailure(new AbortException("Pipeline Release plugin: build of " + li.task.getFullDisplayName() + " was cancelled")); | ||
| } | ||
| } | ||
| } | ||
|
|
||
|
|
||
| } |
160 changes: 160 additions & 0 deletions
160
src/main/java/hudson/plugins/release/pipeline/ReleaseStep.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,160 @@ | ||
| package hudson.plugins.release.pipeline; | ||
|
|
||
| import java.util.ArrayList; | ||
| import java.util.List; | ||
| import java.util.Set; | ||
| import java.util.logging.Logger; | ||
|
|
||
| import javax.annotation.Nonnull; | ||
|
|
||
| import org.jenkinsci.plugins.workflow.steps.Step; | ||
| import org.jenkinsci.plugins.workflow.steps.StepContext; | ||
| import org.jenkinsci.plugins.workflow.steps.StepDescriptor; | ||
| import org.jenkinsci.plugins.workflow.steps.StepExecution; | ||
| import org.jenkinsci.plugins.workflow.util.StaplerReferer; | ||
| import org.kohsuke.accmod.Restricted; | ||
| import org.kohsuke.accmod.restrictions.DoNotUse; | ||
| import org.kohsuke.stapler.AncestorInPath; | ||
| import org.kohsuke.stapler.DataBoundConstructor; | ||
| import org.kohsuke.stapler.DataBoundSetter; | ||
| import org.kohsuke.stapler.QueryParameter; | ||
| import org.kohsuke.stapler.StaplerRequest; | ||
|
|
||
| import com.google.common.collect.ImmutableSet; | ||
|
|
||
| import hudson.Extension; | ||
| import hudson.model.AutoCompletionCandidates; | ||
| import hudson.model.BuildableItem; | ||
| import hudson.model.BuildableItemWithBuildWrappers; | ||
| import hudson.model.ItemGroup; | ||
| import hudson.model.Job; | ||
| import hudson.model.ParameterDefinition; | ||
| import hudson.model.ParameterValue; | ||
| import hudson.model.Run; | ||
| import hudson.model.TaskListener; | ||
| import hudson.plugins.release.ReleaseWrapper; | ||
| import jenkins.model.Jenkins; | ||
| import jenkins.model.ParameterizedJobMixIn; | ||
| import net.sf.json.JSONArray; | ||
| import net.sf.json.JSONObject; | ||
|
|
||
| /** | ||
| * Pipeline step implementation for Release plugin. | ||
| * | ||
| * @author Alexey Merezhin | ||
| * @since 2.7 | ||
| */ | ||
| public class ReleaseStep extends Step { | ||
| private static final Logger LOGGER = Logger.getLogger(ReleaseStep.class.getName()); | ||
|
|
||
| private String job; | ||
| @Nonnull | ||
| private List<ParameterValue> parameters; | ||
|
|
||
| @DataBoundConstructor | ||
| public ReleaseStep(String job) { | ||
| this.job = job; | ||
| parameters = new ArrayList<>(); | ||
| } | ||
|
|
||
| public String getJob() { | ||
| return job; | ||
| } | ||
|
|
||
| public void setJob(String job) { | ||
| this.job = job; | ||
| } | ||
|
|
||
| public List<ParameterValue> getParameters() { | ||
| return parameters; | ||
| } | ||
|
|
||
| @DataBoundSetter | ||
| public void setParameters(List<ParameterValue> parameters) { | ||
| if (parameters == null) { | ||
| this.parameters = new ArrayList<>(); | ||
| } else { | ||
| this.parameters = parameters; | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public StepExecution start(StepContext stepContext) throws Exception { | ||
| return new ReleaseStepExecution(stepContext, this); | ||
| } | ||
|
|
||
| @Extension | ||
| public static class DescriptorImpl extends StepDescriptor { | ||
|
|
||
| @Override | ||
| public String getFunctionName() { | ||
| return "release"; | ||
| } | ||
|
|
||
| @Override | ||
| public String getDisplayName() { | ||
| return Messages.ReleaseStep_DisplayName(); | ||
| } | ||
|
|
||
| @Override | ||
| public Set<Class<?>> getRequiredContext() { | ||
| return ImmutableSet.of(Run.class, TaskListener.class); | ||
| } | ||
|
|
||
| @Override | ||
| public Step newInstance(StaplerRequest req, JSONObject formData) throws FormException { | ||
| ReleaseStep step = (ReleaseStep) super.newInstance(req, formData); | ||
| // Cf. ParametersDefinitionProperty._doBuild: | ||
| Object parameter = formData.get("parameter"); | ||
| JSONArray params = parameter != null ? JSONArray.fromObject(parameter) : null; | ||
| if (params != null) { | ||
| Jenkins jenkins = Jenkins.getInstance(); | ||
| Job<?,?> context = StaplerReferer.findItemFromRequest(Job.class); | ||
| Job<?,?> job = jenkins != null ? jenkins.getItem(step.getJob(), context, Job.class) : null; | ||
|
|
||
| BuildableItem project = Jenkins.getActiveInstance() | ||
| .getItem(step.getJob(), context, BuildableItem.class); | ||
|
|
||
| if (project == null) { | ||
| throw new IllegalArgumentException("Can't find project " + step.getJob()); | ||
| } else if (project instanceof BuildableItemWithBuildWrappers) { | ||
| ReleaseWrapper wrapper = ((BuildableItemWithBuildWrappers) project).getBuildWrappersList() | ||
| .get(ReleaseWrapper.class); | ||
| if (wrapper == null) { | ||
| throw new FormException("Job doesn't have release plugin configuration", "job"); | ||
| } | ||
| List<ParameterDefinition> parameterDefinitions = wrapper.getParameterDefinitions(); | ||
| if (parameterDefinitions != null) { | ||
| List<ParameterValue> values = new ArrayList<>(); | ||
| for (Object o : params) { | ||
| if (o instanceof JSONObject) { | ||
| JSONObject jo = (JSONObject) o; | ||
| String name = jo.getString("name"); | ||
| for (ParameterDefinition pd : parameterDefinitions) { | ||
| if (name.equals(pd.getName())) { | ||
| ParameterValue parameterValue = pd.createValue(req, jo); | ||
| values.add(parameterValue); | ||
| } | ||
| } | ||
| } | ||
| } | ||
| step.setParameters(values); | ||
| } | ||
| } else { | ||
| throw new FormException("Wrong job type: " + project.getClass().getName(), "job"); | ||
| } | ||
| } | ||
| return step; | ||
| } | ||
|
|
||
| public AutoCompletionCandidates doAutoCompleteJob(@AncestorInPath ItemGroup<?> context, @QueryParameter String value) { | ||
| return AutoCompletionCandidates.ofJobNames(ParameterizedJobMixIn.ParameterizedJob.class, value, context); | ||
| } | ||
|
|
||
| @Restricted(DoNotUse.class) // for use from config.jelly / parameters.groovy | ||
| public String getContext() { | ||
| Job<?,?> job = StaplerReferer.findItemFromRequest(Job.class); | ||
| return job != null ? job.getFullName() : null; | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.