Feature: Add option for single triggered job

README.md

@@ -78,11 +78,13 @@ in the __Jenkins Global Configurations__:
 
 1. you can override the default webhook endpoint "/bitbucket-hook/" consumed by the plugin
 
-2. you can disable the build status notifications propagation.
+2. you can configure a single job to be triggered exclusively. That overrides the default behavior of having a dedicated endpoint (+ some internal matching logic) for ALL pipelines to be triggered via this plugin. In case of a non-existing job a WARNING will be logged at global jenkins log. You can omit this feature by simply leaving this field blank.
 
-3. you can choose what build key to use for build status propagation
+3. you can disable the build status notifications propagation.
 
-4. you can set global credentials used by the plugin for the state notification
+4. you can choose what build key to use for build status propagation
+
+5. you can set global credentials used by the plugin for the state notification
 
 ![example global config jenkins bb ppr 1](docs/img/global-config.png)
 

docs/index.md

@@ -78,11 +78,13 @@ in the __Jenkins Global Configurations__:
 
 1. you can override the default webhook endpoint "/bitbucket-hook/" consumed by the plugin
 
-2. you can disable the build status notifications propagation.
+2. you can configure a single job to be triggered exclusively. That overrides the default behavior of having a dedicated endpoint (+ some internal matching logic) for ALL pipelines to be triggered via this plugin. In case of a non-existing job a WARNING will be logged at global jenkins log. You can omit this feature by simply leaving this field blank.
 
-3. you can choose what build key to use for build status propagation
+3. you can disable the build status notifications propagation.
 
-4. you can set global credentials used by the plugin for the state notification
+4. you can choose what build key to use for build status propagation
+
+5. you can set global credentials used by the plugin for the state notification
 
 ![example global config jenkins bb ppr 1](./img/global-config.png)
 

src/main/java/io/jenkins/plugins/bitbucketpushandpullrequest/BitBucketPPRJobProbe.java

@@ -37,6 +37,8 @@
 import java.util.logging.Logger;
 import java.util.stream.Collectors;
 import javax.annotation.Nonnull;
+
+import io.jenkins.plugins.bitbucketpushandpullrequest.config.BitBucketPPRPluginConfig;
 import org.apache.commons.lang.StringUtils;
 import org.eclipse.jgit.transport.URIish;
 import hudson.model.Job;
@@ -47,7 +49,6 @@
 import hudson.security.ACL;
 import hudson.security.ACLContext;
 import io.jenkins.plugins.bitbucketpushandpullrequest.action.BitBucketPPRAction;
-import io.jenkins.plugins.bitbucketpushandpullrequest.common.BitBucketPPRUtils;
 import io.jenkins.plugins.bitbucketpushandpullrequest.exception.TriggerNotSetException;
 import io.jenkins.plugins.bitbucketpushandpullrequest.model.BitBucketPPRHookEvent;
 import io.jenkins.plugins.bitbucketpushandpullrequest.observer.BitBucketPPRObservable;
@@ -64,6 +65,14 @@
 public class BitBucketPPRJobProbe {
   private static final Logger logger = Logger.getLogger(BitBucketPPRJobProbe.class.getName());
 
+  private static final BitBucketPPRPluginConfig globalConfig =
+          BitBucketPPRPluginConfig.getInstance();
+  private final List<SCM> scmTriggered;
+
+  public BitBucketPPRJobProbe() {
+    scmTriggered = new ArrayList<>();
+  }
+
   public void triggerMatchingJobs(BitBucketPPRHookEvent bitbucketEvent,
       BitBucketPPRAction bitbucketAction, BitBucketPPRObservable observable) {
 
@@ -85,30 +94,66 @@
         .filter(Objects::nonNull).collect(Collectors.toList());
 
     try (ACLContext ctx = ACL.as(ACL.SYSTEM)) {
-      Jenkins.get().getAllItems(Job.class).stream().forEach(job -> {
+      if (globalConfig.isSingleJobSet()) {
         try {
-          triggerScm(job, remotes, bitbucketEvent, bitbucketAction, observable);
+          Job job = (Job) Jenkins.get().getItemByFullName(globalConfig.getSingleJob());
+          if (job == null) {
+            logger.log(Level.WARNING, "Job could not be found!");
+            return;
+          }
+          triggerScmForSingleJob(job, remotes, bitbucketEvent, bitbucketAction, observable);
         } catch (TriggerNotSetException e) {
           logger.log(Level.FINE, "Trigger not set");
         }
-      });
+      }
+      if (!globalConfig.isSingleJobSet()) {
+        Jenkins.get().getAllItems(Job.class).stream().forEach(job -> {
+          try {
+            triggerScm(job, remotes, bitbucketEvent, bitbucketAction, observable);
+          } catch (TriggerNotSetException e) {
+            logger.log(Level.FINE, "Trigger not set");
+          }
+        });
+      }
     }
   }
 
+  private void triggerScmForSingleJob(@Nonnull Job<?, ?> job, List<URIish> remotes,
+                          BitBucketPPRHookEvent bitbucketEvent, BitBucketPPRAction bitbucketAction,
+                          BitBucketPPRObservable observable) throws TriggerNotSetException {
+
+    Trigger trigger = new Trigger(getBitBucketTrigger(job)
+            .orElseThrow(() -> new TriggerNotSetException(job.getFullDisplayName())), Optional.ofNullable(SCMTriggerItem.SCMTriggerItems.asSCMTriggerItem(job)));
+
+    trigger.scmTriggerItem.ifPresent(it -> it.getSCMs().stream().forEach(scmTrigger -> {
+
+      if (!scmTriggered.contains(scmTrigger)) {
+        scmTriggered.add(scmTrigger);
+
+        try {
+          trigger.bitbucketTrigger.onPost(bitbucketEvent, bitbucketAction, scmTrigger, observable);
+          return;
+
+        } catch (Throwable e) {
+          logger.log(Level.WARNING, "Error: {0}", e.getMessage());
+          e.printStackTrace();
+        }
+      }
+
+      logger.log(Level.FINE, "{0} SCM doesn't match remote repo {1} or it was already triggered.",
+              new Object[] {job.getName(), remotes});
+
+    }));
+  }
+
   private void triggerScm(@Nonnull Job<?, ?> job, List<URIish> remotes,
       BitBucketPPRHookEvent bitbucketEvent, BitBucketPPRAction bitbucketAction,
       BitBucketPPRObservable observable) throws TriggerNotSetException {
 
-    BitBucketPPRTrigger bitbucketTrigger = getBitBucketTrigger(job)
-        .orElseThrow(() -> new TriggerNotSetException(job.getFullDisplayName()));
-
-    // @todo shouldn't be an instance variable?
-    List<SCM> scmTriggered = new ArrayList<>();
+    Trigger trigger = new Trigger(getBitBucketTrigger(job)
+            .orElseThrow(() -> new TriggerNotSetException(job.getFullDisplayName())), Optional.ofNullable(SCMTriggerItem.SCMTriggerItems.asSCMTriggerItem(job)));
 
-    Optional<SCMTriggerItem> item =
-        Optional.ofNullable(SCMTriggerItem.SCMTriggerItems.asSCMTriggerItem(job));
-
-    item.ifPresent(it -> it.getSCMs().stream().forEach(scmTrigger -> {
+    trigger.scmTriggerItem.ifPresent(it -> it.getSCMs().stream().forEach(scmTrigger -> {
 
       // @todo add comments to explain what is this check for
       if (job.getParent() instanceof MultiBranchProject
@@ -124,7 +169,7 @@
         scmTriggered.add(scmTrigger);
 
         try {
-          bitbucketTrigger.onPost(bitbucketEvent, bitbucketAction, scmTrigger, observable);
+          trigger.bitbucketTrigger.onPost(bitbucketEvent, bitbucketAction, scmTrigger, observable);
           return;
 
         } catch (Throwable e) {
@@ -139,6 +184,16 @@
     }));
   }
 
+  private static class Trigger {
+    public final BitBucketPPRTrigger bitbucketTrigger;
+    public final Optional<SCMTriggerItem> scmTriggerItem;
+
+    public Trigger(BitBucketPPRTrigger bitbucketTrigger, Optional<SCMTriggerItem> item) {
+      this.bitbucketTrigger = bitbucketTrigger;
+      this.scmTriggerItem = item;
+    }
+  }
+
   private boolean mPJobShouldNotBeTriggered(Job<?, ?> job, BitBucketPPRHookEvent bitbucketEvent,
       BitBucketPPRAction bitbucketAction) {
 

src/main/java/io/jenkins/plugins/bitbucketpushandpullrequest/config/BitBucketPPRPluginConfig.java

@@ -36,6 +36,8 @@
 
   public String credentialsId;
 
+  public String singleJob;
+
   public BitBucketPPRPluginConfig() {
     logger.fine("Read bitbucket push and pull request plugin global configuration.");
     this.notifyBitBucket = true;
@@ -87,6 +89,24 @@
     this.credentialsId = credentialsId;
   }
 
+  @DataBoundSetter
+  public void setSingleJob(String singleJob) {
+    if (isEmpty(singleJob)) {
+      this.singleJob = "";
+    } else {
+      this.singleJob = singleJob.trim();
+    }
+    save();
+  }
+
+  public boolean isSingleJobSet() {
+    return !isEmpty(singleJob);
+  }
+
+  public String getSingleJob() {
+    return singleJob;
+  }
+
   @Override
   public String getDisplayName() {
     return "Bitbucket Push and Pull Request";

src/main/resources/io/jenkins/plugins/bitbucketpushandpullrequest/config/BitBucketPPRPluginConfig/config.jelly

@@ -6,6 +6,9 @@
       <f:entry title="Hook URL" field="hookUrlTitle">
         <f:textbox field="hookUrl" />
       </f:entry>
+      <f:entry title="Single job to build" field="singleJobTitle">
+        <f:textbox field="singleJob" />
+      </f:entry>
       <f:entry title="${%Send build status to BitBucket}" field="notifyBitBucket">
         <f:checkbox default="true" />
       </f:entry>