issue #922: handles json decoding in uni

smclab · Aug 5, 2024 · 27e752a · 27e752a
1 parent e091e20
commit 27e752a
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/core/app/datasource/src/main/java/io/openk9/datasource/listener/JobScheduler.java b/core/app/datasource/src/main/java/io/openk9/datasource/listener/JobScheduler.java
@@ -408,12 +408,16 @@ private static Behavior<Command> onInvokePluginDriverInternal(
 
 		switch (pluginDriver.getType()) {
 			case HTTP: {
-				VertxUtil.runOnContext(
-					() -> httpPluginDriverClient.invoke(
+
+				VertxUtil.runOnContext(() -> Uni.createFrom().item(() ->
 							Json.decodeValue(
 								pluginDriver.getJsonConfig(),
 								HttpPluginDriverInfo.class
-							),
+							)
+						)
+						.flatMap(httpPluginDriverInfo -> httpPluginDriverClient
+								.invoke(
+									httpPluginDriverInfo,
 							HttpPluginDriverContext
 								.builder()
 								.timestamp(lastIngestionDate)
@@ -423,6 +427,7 @@ private static Behavior<Command> onInvokePluginDriverInternal(
 								.datasourceConfig(new JsonObject(datasource.getJsonConfig()).getMap())
 								.build()
 						)
+						)
 						.onItem()
 						.invoke(() -> ctx
 							.getSelf()
@@ -433,6 +438,7 @@ private static Behavior<Command> onInvokePluginDriverInternal(
 							.tell(new CancelScheduling(tenantName, scheduler))
 						)
 				);
+
 			}
 		}