diff --git a/core/app/datasource/src/main/java/io/openk9/datasource/pipeline/NotificationSender.java b/core/app/datasource/src/main/java/io/openk9/datasource/pipeline/NotificationSender.java index 7408ace8a..d5a8a2f14 100644 --- a/core/app/datasource/src/main/java/io/openk9/datasource/pipeline/NotificationSender.java +++ b/core/app/datasource/src/main/java/io/openk9/datasource/pipeline/NotificationSender.java @@ -63,7 +63,7 @@ private Behavior onStart() { tenantName, scheduleId ); - VertxUtil.runOnContext(() -> service.getDiff(tenantName, scheduleId), list -> { + VertxUtil.runOnContext(() -> service.getDeletedContentIds(tenantName, scheduleId), list -> { Long datasourceId = scheduler.getDatasource().getId(); DataIndex newDataIndex = scheduler.getNewDataIndex(); diff --git a/core/app/datasource/src/main/java/io/openk9/datasource/service/SchedulerService.java b/core/app/datasource/src/main/java/io/openk9/datasource/service/SchedulerService.java index edc95a3cd..354403e19 100644 --- a/core/app/datasource/src/main/java/io/openk9/datasource/service/SchedulerService.java +++ b/core/app/datasource/src/main/java/io/openk9/datasource/service/SchedulerService.java @@ -69,7 +69,7 @@ public Uni getNewDataIndex(Scheduler scheduler) { return em.withStatelessTransaction(s -> Mutiny2.fetch(s, scheduler.getNewDataIndex())); } - public Uni> getDiff(String tenant, String schedulerId) { + public Uni> getDeletedContentIds(String tenant, String schedulerId) { return em.withStatelessTransaction(tenant, s -> s.createQuery( "select s " + "from Scheduler s " + @@ -81,11 +81,11 @@ public Uni> getDiff(String tenant, String schedulerId) { .flatMap(this::indexesDiff); } - public Uni> getDiff(String schedulerId) { - return getDiff(null, schedulerId); + public Uni> getDeletedContentIds(String schedulerId) { + return getDeletedContentIds(null, schedulerId); } - public Uni> getDiff(long id) { + public Uni> getDeletedContentIds(long id) { return em.withStatelessTransaction(s -> s.createQuery( "select s " + "from Scheduler s " + diff --git a/core/app/datasource/src/main/java/io/openk9/datasource/web/SchedulerResource.java b/core/app/datasource/src/main/java/io/openk9/datasource/web/SchedulerResource.java index 781346f6c..6deb88c5a 100644 --- a/core/app/datasource/src/main/java/io/openk9/datasource/web/SchedulerResource.java +++ b/core/app/datasource/src/main/java/io/openk9/datasource/web/SchedulerResource.java @@ -16,10 +16,10 @@ @RolesAllowed("k9-admin") public class SchedulerResource { - @Path("/{schedulerId}/getDiff") + @Path("/{schedulerId}/getDeletedContentIds") @GET public Uni> getDeletedContentIds(@PathParam("schedulerId") long schedulerId) { - return schedulerService.getDiff(schedulerId); + return schedulerService.getDeletedContentIds(schedulerId); } @Inject