Add a way to "sync" transitions only, by a query

Author: marko-bekhta

src/main/java/org/hibernate/infra/replicate/jira/service/jira/JiraService.java

@@ -10,10 +10,12 @@
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.BooleanSupplier;
+import java.util.function.Consumer;
 
 import org.hibernate.infra.replicate.jira.JiraConfig;
 import org.hibernate.infra.replicate.jira.service.jira.client.JiraRestClient;
 import org.hibernate.infra.replicate.jira.service.jira.client.JiraRestClientBuilder;
+import org.hibernate.infra.replicate.jira.service.jira.handler.JiraIssueTransitionOnlyEventHandler;
 import org.hibernate.infra.replicate.jira.service.jira.model.hook.JiraWebHookEvent;
 import org.hibernate.infra.replicate.jira.service.jira.model.hook.JiraWebHookIssue;
 import org.hibernate.infra.replicate.jira.service.jira.model.hook.JiraWebHookIssueLink;
@@ -154,6 +156,25 @@ public void registerManagementRoutes(@Observes ManagementInterface mi) {
 			triggerSyncEvent(context.sourceJiraClient().getIssue(issue), context);
 			rc.end();
 		});
+		mi.router().get("/sync/issues/transition/re-sync/:project").blockingHandler(rc -> {
+			// TODO: we can remove this one once we figure out why POST management does not
+			// work correctly...
+			String project = rc.pathParam("project");
+			String query = rc.queryParam("query").getFirst();
+
+			HandlerProjectContext context = contextPerProject.get(project);
+
+			if (context == null) {
+				throw new IllegalArgumentException("Unknown project '%s'".formatted(project));
+			}
+
+			context.submitTask(() -> {
+				syncByQuery(query, context, jiraIssue -> {
+					context.submitTask(new JiraIssueTransitionOnlyEventHandler(reportingConfig, context, jiraIssue));
+				});
+			});
+			rc.end();
+		});
 		mi.router().post("/sync/issues/list").consumes(MediaType.APPLICATION_JSON).blockingHandler(rc -> {
 			// sync issues based on a list of issue-keys supplied in the JSON body:
 			JsonObject request = rc.body().asJsonObject();
@@ -272,12 +293,16 @@ public void finishProcessingAndShutdown() {
 	}
 
 	private void syncByQuery(String query, HandlerProjectContext context) {
+		syncByQuery(query, context, jiraIssue -> triggerSyncEvent(jiraIssue, context));
+	}
+
+	private void syncByQuery(String query, HandlerProjectContext context, Consumer<JiraIssue> action) {
 		JiraIssues issues = null;
 		int start = 0;
 		int max = 100;
 		do {
 			issues = context.sourceJiraClient().find(query, start, max);
-			issues.issues.forEach(jiraIssue -> triggerSyncEvent(jiraIssue, context));
+			issues.issues.forEach(action);
 
 			start += max;
 		} while (!issues.issues.isEmpty());

src/main/java/org/hibernate/infra/replicate/jira/service/jira/handler/JiraIssueTransitionOnlyEventHandler.java

@@ -0,0 +1,52 @@
+package org.hibernate.infra.replicate.jira.service.jira.handler;
+
+import java.util.Optional;
+
+import org.hibernate.infra.replicate.jira.service.jira.HandlerProjectContext;
+import org.hibernate.infra.replicate.jira.service.jira.client.JiraRestException;
+import org.hibernate.infra.replicate.jira.service.jira.model.rest.JiraIssue;
+import org.hibernate.infra.replicate.jira.service.jira.model.rest.JiraTransition;
+import org.hibernate.infra.replicate.jira.service.reporting.ReportingConfig;
+
+public class JiraIssueTransitionOnlyEventHandler extends JiraEventHandler {
+
+	private final JiraIssue sourceIssue;
+
+	public JiraIssueTransitionOnlyEventHandler(ReportingConfig reportingConfig, HandlerProjectContext context,
+			JiraIssue issue) {
+		super(reportingConfig, context, issue.id);
+		this.sourceIssue = issue;
+	}
+
+	@Override
+	protected void doRun() {
+		// NOTE: we do not look up the source issue as we've already queried for it
+		// before creating this handler:
+		String destinationKey = toDestinationKey(sourceIssue.key);
+		// We don't really need one, but doing so means that we will create the
+		// placeholder for it if the issue wasn't already present in the destination
+		// Jira instance
+		context.createNextPlaceholderBatch(destinationKey);
+
+		try {
+			// issue status can be updated only through transition:
+			prepareTransition(sourceIssue).ifPresent(
+					jiraTransition -> context.destinationJiraClient().transition(destinationKey, jiraTransition));
+		} catch (JiraRestException e) {
+			failureCollector
+					.critical("Unable to update destination issue %s: %s".formatted(destinationKey, e.getMessage()), e);
+		}
+	}
+
+	@Override
+	public String toString() {
+		return "JiraIssueTransitionOnlyEventHandler[" + "objectId=" + objectId + ", project=" + context.projectName()
+				+ ']';
+	}
+
+	private Optional<JiraTransition> prepareTransition(JiraIssue sourceIssue) {
+		return statusToTransition(sourceIssue.fields.status.id).map(
+				tr -> new JiraTransition(tr, "Upstream issue status updated to: " + sourceIssue.fields.status.name));
+	}
+
+}