TW-79075 For feature branch builds only publish status for participating commits, commits coming from default branches will be skipped

Author: idlsoft

commit-status-publisher-server/src/main/java/jetbrains/buildServer/commitPublisher/CommitStatusPublisherListener.java

@@ -619,15 +619,16 @@ private Collection<BuildRevision> getQueuedBuildRevisionForVote(@NotNull BuildTy
     if (buildPromotion.isFailedToCollectChanges()) return Collections.emptyList();
 
     if (!((BuildPromotionEx)buildPromotion).isChangeCollectingNeeded(false)) {
-      return getBuildRevisionForVote(publisher, buildPromotion.getRevisions());
+      return getBuildRevisionForVote(publisher, buildPromotion.getRevisions(), buildPromotion.getBranch());
     }
     LOG.debug("No revision is found for build " + buildPromotion.getBuildTypeExternalId() + ". Queue-related status won't be published");
     return Collections.emptyList();
   }
 
   @NotNull
   private List<BuildRevision> getBuildRevisionForVote(@NotNull CommitStatusPublisher publisher,
-                                                      @NotNull Collection<BuildRevision> revisionsToCheck) {
+                                                      @NotNull Collection<BuildRevision> revisionsToCheck,
+                                                      @Nullable Branch buildBranch) {
     if (revisionsToCheck.isEmpty()) return Collections.emptyList();
 
     String vcsRootId = publisher.getVcsRootId();
@@ -638,6 +639,30 @@ private List<BuildRevision> getBuildRevisionForVote(@NotNull CommitStatusPublish
           revisions.add(revision);
         }
       }
+      // TW-79075
+      if (buildBranch != null && !buildBranch.isDefaultBranch()) {
+        Set<String> selectedBranchNames = new HashSet<>();
+        selectedBranchNames.add(buildBranch.getName());
+        selectedBranchNames.add("refs/heads/" + buildBranch.getName());  // git prepends this to the branch name
+        List<BuildRevision> revisionsForBranch = new ArrayList<>();
+        for(BuildRevision revision: revisions) {
+          String vcsBranch = revision.getRepositoryVersion().getVcsBranch();
+          if (vcsBranch != null && selectedBranchNames.contains(vcsBranch)) {
+            revisionsForBranch.add(revision);
+          }
+        }
+        if (!revisionsForBranch.isEmpty()) {
+          LOG.info("Selective publishing for buildBranch=" + buildBranch + ", selected "
+            + revisionsForBranch.stream().map(r -> r.getRoot().getName() + '@' + r.getRepositoryVersion().getVcsBranch()).collect(Collectors.joining(", ", "[", "]"))
+            + " out of " + revisions.stream().map(r -> r.getRoot().getName() + '@' + r.getRepositoryVersion().getVcsBranch()).collect(Collectors.joining(", ", "[", "]"))
+          );
+          revisions = revisionsForBranch;
+        } else {
+          LOG.warn("Attempted selective publishing, but did not find revisions for buildBranch=" + buildBranch + " among "
+            + revisions.stream().map(r -> r.getRoot().getName() + '@' + r.getRepositoryVersion().getVcsBranch()).collect(Collectors.joining(", ", "[", "]"))
+            + ", will publish all");
+        }
+      }
       return revisions;
     }
 
@@ -785,7 +810,7 @@ public void publish(Event event, BuildRevision revision, CommitStatusPublisher p
         @Override
         public Collection<BuildRevision> getRevisions(BuildType buildType, CommitStatusPublisher publisher) {
           if (buildPromotion.isFailedToCollectChanges()) return Collections.emptyList();
-          return getBuildRevisionForVote(publisher, build.getRevisions());
+          return getBuildRevisionForVote(publisher, build.getRevisions(), build.getBranch());
         }
       };