diff --git a/app/server/appsmith-server/src/main/java/com/appsmith/server/plugins/base/PluginServiceCEImpl.java b/app/server/appsmith-server/src/main/java/com/appsmith/server/plugins/base/PluginServiceCEImpl.java index e4f3727fae..bdbfe12114 100644 --- a/app/server/appsmith-server/src/main/java/com/appsmith/server/plugins/base/PluginServiceCEImpl.java +++ b/app/server/appsmith-server/src/main/java/com/appsmith/server/plugins/base/PluginServiceCEImpl.java @@ -159,8 +159,8 @@ public class PluginServiceCEImpl extends BaseService { + // used retrieveAll() as it does not need user session context + return workspaceService.retrieveAll().flatMap(workspace -> { // Only perform a DB op if plugins associated to this org have changed if (workspace.getPlugins().containsAll(newWorkspacePlugins)) { return Mono.just(workspace); diff --git a/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCE.java b/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCE.java index 071001f4d9..09a5a74916 100644 --- a/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCE.java +++ b/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCE.java @@ -43,4 +43,6 @@ public interface WorkspaceServiceCE extends CrudService { Mono archiveById(String s); Mono getDefaultEnvironmentId(String workspaceId, AclPermission aclPermission); + + Flux retrieveAll(); } diff --git a/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCEImpl.java b/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCEImpl.java index 899c7fb053..e1d4b60727 100644 --- a/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCEImpl.java +++ b/app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/WorkspaceServiceCEImpl.java @@ -618,4 +618,9 @@ public class WorkspaceServiceCEImpl extends BaseService getAll(AclPermission permission) { return repository.findAll(permission); } + + @Override + public Flux retrieveAll() { + return repository.retrieveAll(); + } }