Add an optional limit to init-sync

Author: marko-bekhta

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

@@ -138,6 +138,9 @@ public void createNextPlaceholderBatch(Long upToKeyNumber) {
 				JiraIssueBulkResponse response = destinationJiraClient.create(bulk);
 				response.issues.stream().mapToLong(i -> JiraIssue.keyToLong(i.key)).max()
 						.ifPresent(currentIssueKeyNumber::set);
+				Log.infof(
+						"Created more sync placeholders for %s; Current latest Jira key number is %s while required key is %s",
+						projectName, currentIssueKeyNumber.get(), upToKeyNumber);
 			} while (currentIssueKeyNumber.get() < upToKeyNumber);
 		} finally {
 			lock.unlock();

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

@@ -7,7 +7,9 @@
 import java.util.Objects;
 import java.util.Optional;
 import java.util.Set;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
+import java.util.function.BooleanSupplier;
 
 import org.hibernate.infra.replicate.jira.JiraConfig;
 import org.hibernate.infra.replicate.jira.service.jira.client.JiraRestClient;
@@ -109,6 +111,10 @@ public void registerManagementRoutes(@Observes ManagementInterface mi) {
 			// TODO: we can remove this one once we figure out why POST management does not
 			// work correctly...
 			String project = rc.pathParam("project");
+			List<String> maxToSyncList = rc.queryParam("maxToSync");
+			AtomicInteger maxToSync = maxToSyncList.isEmpty()
+					? null
+					: new AtomicInteger(Integer.parseInt(maxToSyncList.get(0)) + 1);
 
 			HandlerProjectContext context = contextPerProject.get(project);
 
@@ -117,14 +123,14 @@ public void registerManagementRoutes(@Observes ManagementInterface mi) {
 			}
 
 			AtomicLong largestSyncedJiraIssueKeyNumber = new AtomicLong(context.getLargestSyncedJiraIssueKeyNumber());
-
+			BooleanSupplier continueSyncing = maxToSync == null ? () -> true : () -> maxToSync.decrementAndGet() > 0;
 			String identity = "Init Sync for project %s".formatted(project);
 			scheduler.newJob(identity).setConcurrentExecution(Scheduled.ConcurrentExecution.SKIP)
 					// every 10 seconds:
 					.setCron("0/10 * * * * ?").setTask(executionContext -> {
 						Optional<JiraIssue> issueToSync = context
 								.getNextIssueToSync(largestSyncedJiraIssueKeyNumber.get());
-						if (issueToSync.isEmpty()) {
+						if (issueToSync.isEmpty() || !continueSyncing.getAsBoolean()) {
 							scheduler.unscheduleJob(identity);
 						} else {
 							triggerSyncEvent(issueToSync.get(), context);

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

@@ -16,6 +16,7 @@
 import org.hibernate.infra.replicate.jira.service.reporting.FailureCollector;
 import org.hibernate.infra.replicate.jira.service.reporting.ReportingConfig;
 
+import io.quarkus.logging.Log;
 import jakarta.ws.rs.core.UriBuilder;
 
 public abstract class JiraEventHandler implements Runnable {
@@ -158,6 +159,8 @@ public final void run() {
 			Thread.currentThread().interrupt();
 		} finally {
 			failureCollector.close();
+			Log.infof("Pending events in %s to process: %s", context.projectGroupName(),
+					context.pendingEventsInCurrentContext());
 		}
 	}
 

src/main/java/org/hibernate/infra/replicate/jira/service/reporting/LoggingFailureCollector.java

@@ -16,7 +16,7 @@ public void warning(String details) {
 
 	@Override
 	public void warning(String details, Exception exception) {
-		Log.warn(details, exception);
+		Log.warnf(exception, details);
 	}
 
 	@Override
@@ -26,7 +26,7 @@ public void critical(String details) {
 
 	@Override
 	public void critical(String details, Exception exception) {
-		Log.error(details, exception);
+		Log.errorf(exception, details);
 	}
 
 	@Override