Feature/multibranch scan (#372) (#374)

* Added functionality for Multibranch Scan

Functionality added to trigger a Jenkins Multibranch scan when a branch is added or deleted in bitbucket.

* Added functions for data capture

Added a function to capture both the from Hash and change type items that are inside of the payload received from Bitbucket

* Added full functions for payload data

Functions added get the from hash and change type items from the Bitbucket payload

* Added constant variables

Added constant variables for the change type values along with the value of an empty hash.  These are used to determine when a branch is being added or deleted.

* Update repository URL

Updating the plugin repository to have the correct URL for a successful Maven Build

* Update Logic for Multibranch Pipeline Scan Trigger

Previously when triggering the scan it was done so for all pipelines. New logic ensures that it only occurs for the repo captured from the payload if it matches the branch source specified in the multibranch pipeline

* Adding functions to pull clone links from payload

Functiions have been added to pull http and ssh clone links from bitbucket payload

* Added functions for capturing clone links

Added Functions to pull the SSH and HTTP clone links from the Bitbucket payload

* Update BitBucketPPRJobProbe.java

Ran into null pointer issue causing issues with other triggers.  Updates made to resolve null pointer occurrence.

Co-authored-by: s78258819-svg <s78258819@gmail.com>

Author: cdelmonte-zg

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

@@ -21,11 +21,6 @@
 
 package io.jenkins.plugins.bitbucketpushandpullrequest;
 
-import static io.jenkins.plugins.bitbucketpushandpullrequest.common.BitBucketPPRConst.PULL_REQUEST_MERGED;
-import static io.jenkins.plugins.bitbucketpushandpullrequest.common.BitBucketPPRConst.PULL_REQUEST_SERVER_MERGED;
-import static io.jenkins.plugins.bitbucketpushandpullrequest.common.BitBucketPPRConst.REPOSITORY_CLOUD_PUSH;
-import static io.jenkins.plugins.bitbucketpushandpullrequest.common.BitBucketPPRConst.REPOSITORY_SERVER_PUSH;
-
 import hudson.model.Job;
 import hudson.plugins.git.GitSCM;
 import hudson.plugins.git.GitStatus;
@@ -53,6 +48,11 @@
 import jenkins.model.ParameterizedJobMixIn;
 import jenkins.triggers.SCMTriggerItem;
 import org.eclipse.jgit.transport.URIish;
+import org.jenkinsci.plugins.workflow.multibranch.WorkflowMultiBranchProject;
+import jenkins.branch.BranchSource;
+import jenkins.scm.api.SCMSource;
+
+import static io.jenkins.plugins.bitbucketpushandpullrequest.common.BitBucketPPRConst.*;
 
 /**
  *
@@ -152,6 +152,8 @@ private void triggerScm(@Nonnull Job<?, ?> job, List<URIish> remotes,
 
     jobTrigger.scmTriggerItem.ifPresent(it -> it.getSCMs().forEach(scm -> {
 
+      triggerMultibranchScan(job, bitbucketAction);
+
       // @todo add comments to explain what is this check for
       if (job.getParent() instanceof MultiBranchProject
           && mPJobShouldNotBeTriggered(job, bitbucketEvent, bitbucketAction)) {
@@ -244,4 +246,59 @@ private boolean matchGitScm(SCM scm, URIish remote) {
         .anyMatch((repo) -> repo.getURIs().stream().anyMatch((repoUrl) -> GitStatus.looselyMatches(repoUrl, remote)));
   }
 
+  private void triggerMultibranchScan(@Nonnull Job<?, ?> job,
+                                      BitBucketPPRAction bitbucketAction) {
+
+      String getLatestCommit = bitbucketAction.getLatestCommit();
+      String getLatestFromCommit = bitbucketAction.getLatestFromCommit();
+      String pipelineName = job.getParent().getFullName();
+      String getPayldChgType = bitbucketAction.getPayloadChangeType();
+
+      if ((getLatestCommit != null) && (getLatestFromCommit != null) && (pipelineName != null) && (getPayldChgType != null)) {
+        if ((getLatestFromCommit.equals(EMPTY_HASH) && PAYLOAD_CHANGE_TYPE_ADD.equals(getPayldChgType)) ||
+            (getLatestCommit.equals(EMPTY_HASH) && PAYLOAD_CHANGE_TYPE_DELETE.equals(getPayldChgType))) {
+
+            Jenkins jenkins = Jenkins.get();
+
+            WorkflowMultiBranchProject mbp = jenkins.getInstance().getItemByFullName(pipelineName, WorkflowMultiBranchProject.class);
+
+            if (mbp != null) {
+              for (BranchSource bs : mbp.getSourcesList()) {
+                SCMSource src = bs.getSource();
+                String getOPT1CloneUrl = bitbucketAction.getOPT1CloneUrl();
+                String getOPT2CloneUrl = bitbucketAction.getOPT2CloneUrl();
+
+                logger.log(Level.FINEST,
+                      "Source Type: {0}",
+                      new String[] { src.getDescriptor().getDisplayName() });
+
+                if (src instanceof jenkins.plugins.git.GitSCMSource) {
+                  jenkins.plugins.git.GitSCMSource git = (jenkins.plugins.git.GitSCMSource) src;
+                  String gitRemote = git.getRemote();
+
+                  logger.log(Level.FINEST,
+                      "Branch Source URL: {0}",
+                      new String[] { gitRemote });
+
+                  if (gitRemote.equals(getOPT1CloneUrl) || gitRemote.equals(getOPT2CloneUrl)) {
+                    logger.log(Level.FINEST,
+                          "Branch Source URL: {0}, getOPT1CloneUrl: {1}, getOPT2CloneUrl: {2}",
+                          new String[] { gitRemote, getOPT1CloneUrl, getOPT2CloneUrl });
+
+                    mbp.scheduleBuild2(0);
+
+                    logger.log(Level.INFO,
+                      "Triggered branch indexing for: {0}",
+                      new String[] { pipelineName });
+                  }
+                }
+              }
+            } else {
+                logger.log(Level.WARNING,
+                      "Multibranch job not found: {0}",
+                      new String[] { pipelineName });
+            }
+        }
+      }
+  }
 }

src/main/java/io/jenkins/plugins/bitbucketpushandpullrequest/action/BitBucketPPRAction.java

@@ -141,4 +141,12 @@ default String getLatestCommitFromRef() {
   default String getLatestCommitToRef() {
     return null;
   }
+
+  default String getLatestFromCommit() { return null; }
+
+  default String getPayloadChangeType() { return null; }
+
+  default String getOPT1CloneUrl() { return null; }
+
+  default String getOPT2CloneUrl() { return null; }
 }

src/main/java/io/jenkins/plugins/bitbucketpushandpullrequest/action/BitBucketPPRServerRepositoryAction.java

@@ -186,4 +186,34 @@ public List<String> getCommitLinks() throws MalformedURLException {
   private String getBaseUrl() {
     return baseUrl.getProtocol() + "://" + baseUrl.getHost() + ":" + baseUrl.getPort();
   }
+
+  @Override
+  public String getLatestFromCommit() {
+      for (BitBucketPPRServerChange change : payload.getServerChanges()) {
+          if(change.getRefId() != null) {
+              return change.getFromHash();
+          }
+      }
+      return null;
+  }
+
+  @Override
+  public String getPayloadChangeType() {
+      for (BitBucketPPRServerChange change : payload.getServerChanges()) {
+          if(change.getRefId() != null) {
+              return change.getType();
+          }
+      }
+      return null;
+  }
+
+  @Override
+  public String getOPT1CloneUrl() {
+    return payload.getServerRepository().getLinks().getCloneProperty().get(0).getHref();
+  }
+
+  @Override
+  public String getOPT2CloneUrl() {
+    return payload.getServerRepository().getLinks().getCloneProperty().get(1).getHref();
+  }
 }

src/main/java/io/jenkins/plugins/bitbucketpushandpullrequest/common/BitBucketPPRConst.java

@@ -61,6 +61,10 @@ public final class BitBucketPPRConst {
   public static final String APPLICATION_X_WWW_FORM_URLENCODED =
       "application/x-www-form-urlencoded";
 
+  public static final String PAYLOAD_CHANGE_TYPE_ADD = "ADD";
+  public static final String PAYLOAD_CHANGE_TYPE_DELETE = "DELETE";
+  public static final String EMPTY_HASH = "0000000000000000000000000000000000000000";
+
   private BitBucketPPRConst() {
     throw new AssertionError();
   }