Skip to content

Commit

Permalink
merge with release and changes post merge
Browse files Browse the repository at this point in the history
  • Loading branch information
sondermanish committed Jan 2, 2025
1 parent 3959aab commit de5c867
Showing 1 changed file with 15 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2157,7 +2157,11 @@ private Mono<String> syncDefaultBranchNameFromRemote(
GitHandlingService gitHandlingService = gitHandlingServiceResolver.getGitHandlingService(gitType);

return gitRedisUtils
.acquireGitLock(metadata.getDefaultArtifactId(), GitConstants.GitCommandConstants.SYNC_BRANCH, TRUE)
.acquireGitLock(
jsonTransformationDTO.getArtifactType(),
metadata.getDefaultArtifactId(),
GitConstants.GitCommandConstants.SYNC_BRANCH,
TRUE)
.then(gitHandlingService
.getDefaultBranchFromRepository(jsonTransformationDTO, metadata)
.flatMap(defaultBranchNameInRemote -> {
Expand All @@ -2180,7 +2184,8 @@ private Mono<String> syncDefaultBranchNameFromRemote(
.thenReturn(defaultBranchNameInRemote);
})
.flatMap(branchName -> gitRedisUtils
.releaseFileLock(metadata.getDefaultArtifactId(), TRUE)
.releaseFileLock(
jsonTransformationDTO.getArtifactType(), metadata.getDefaultArtifactId(), TRUE)
.thenReturn(branchName)));
}

Expand Down Expand Up @@ -2325,6 +2330,7 @@ private Mono<List<GitBranchDTO>> getBranchListWithDefaultBranchName(
boolean pruneBranches,
GitType gitType) {

ArtifactType artifactType = baseArtifact.getArtifactType();
GitArtifactMetadata baseGitData = baseArtifact.getGitArtifactMetadata();
GitHandlingService gitHandlingService = gitHandlingServiceResolver.getGitHandlingService(gitType);

Expand All @@ -2337,7 +2343,11 @@ private Mono<List<GitBranchDTO>> getBranchListWithDefaultBranchName(
jsonTransformationDTO.setArtifactType(baseArtifact.getArtifactType());

return gitRedisUtils
.acquireGitLock(baseGitData.getDefaultArtifactId(), GitConstants.GitCommandConstants.LIST_BRANCH, TRUE)
.acquireGitLock(
artifactType,
baseGitData.getDefaultArtifactId(),
GitConstants.GitCommandConstants.LIST_BRANCH,
TRUE)
.flatMap(ignoredLock -> {
Mono<List<String>> listBranchesMono =
Mono.defer(() -> gitHandlingService.listReferences(jsonTransformationDTO, false));
Expand All @@ -2351,12 +2361,12 @@ private Mono<List<GitBranchDTO>> getBranchListWithDefaultBranchName(
})
.onErrorResume(error -> {
return gitRedisUtils
.releaseFileLock(baseGitData.getDefaultArtifactId(), TRUE)
.releaseFileLock(artifactType, baseGitData.getDefaultArtifactId(), TRUE)
.then(Mono.error(error));
})
.flatMap(branches -> {
return gitRedisUtils
.releaseFileLock(baseGitData.getDefaultArtifactId(), TRUE)
.releaseFileLock(artifactType, baseGitData.getDefaultArtifactId(), TRUE)
.thenReturn(branches.stream()
.map(branchName -> {
GitBranchDTO gitBranchDTO = new GitBranchDTO();
Expand Down

0 comments on commit de5c867

Please sign in to comment.