in src/main/java/com/googlesource/gerrit/plugins/its/base/workflow/FireEventOnCommits.java [58:80]
public void execute(
ItsFacade its, String itsProject, ActionRequest actionRequest, Map<String, String> properties)
throws IOException {
Optional<FireEventOnCommitsParameters> extractedParameters =
parametersExtractor.extract(actionRequest, properties);
if (!extractedParameters.isPresent()) {
return;
}
CommitCollector commitCollector = extractedParameters.get().getCommitCollector();
String projectName = extractedParameters.get().getProjectName();
Set<Map<String, String>> issuesProperties =
commitCollector.collect(properties).stream()
.map(commitId -> issueExtractor.getIssueIds(projectName, commitId))
.flatMap(Stream::of)
.map(
associations -> propertyExtractor.extractIssuesProperties(properties, associations))
.flatMap(Collection::stream)
.collect(Collectors.toSet());
issuesProperties.forEach(this::doExecute);
}