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))
  )
  );
+
  }
  }