Skip to content

Commit

Permalink
update data sync scheduler
Browse files Browse the repository at this point in the history
  • Loading branch information
egekocabas committed Feb 8, 2025
1 parent be4fffd commit 46b2d42
Showing 1 changed file with 11 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
import de.tum.cit.aet.helios.gitrepo.GitRepository;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import lombok.RequiredArgsConstructor;
import lombok.extern.log4j.Log4j2;
Expand Down Expand Up @@ -48,15 +49,19 @@ public void syncDataCron() {

public void syncData() {
Stream<String> envRepoNames = Arrays.stream(repositoriesToMonitor);
log.info("Repositories from environment: {}", Arrays.toString(repositoriesToMonitor));

Stream<String> dbRepoNames = gitRepositoryRepository.findAll().stream()
.map(GitRepository::getNameWithOwner);
List<String> dbRepoList = gitRepositoryRepository.findAll().stream()
.map(GitRepository::getNameWithOwner)
.collect(Collectors.toList());
log.info("Repositories from database: {}", dbRepoList);

List<String> uniqueRepoNames = Stream.concat(envRepoNames, dbRepoNames)
.distinct()
.toList();
List<String> uniqueRepoNames =
Stream.concat(Arrays.stream(repositoriesToMonitor), dbRepoList.stream())
.distinct()
.toList();

log.info("Found {} unique repositories to sync.", uniqueRepoNames.size());
log.info("Found {} unique repositories to sync: {}", uniqueRepoNames.size(), uniqueRepoNames);

uniqueRepoNames.forEach(repoName -> {
try {
Expand Down

0 comments on commit 46b2d42

Please sign in to comment.