CB-5574. Added new api for get manager, added flap in server configur…

server/bundles/io.cloudbeaver.model/src/io/cloudbeaver/model/WebPropertyInfo.java

@@ -1,6 +1,6 @@
 /*
  * DBeaver - Universal Database Manager
- * Copyright (C) 2010-2024 DBeaver Corp and others
+ * Copyright (C) 2010-2025 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -44,6 +44,10 @@ public class WebPropertyInfo {
     private DBPPropertySource propertySource;
     private boolean showProtected;
 
+    private Object[] validValues;
+
+    private String[] supportedConfigurationTypes = new String[0];
+
     public WebPropertyInfo(WebSession session, DBPPropertyDescriptor property, DBPPropertySource propertySource) {
         this.session = session;
         this.property = property;
@@ -154,9 +158,9 @@ public Object[] getValidValues() {
                 }
                 return validValues;
             }
-            return null;
+            return validValues;
         }
-        return null;
+        return validValues;
     }
 
     @Property
@@ -172,7 +176,7 @@ public String[] getSupportedConfigurationTypes() {
                 .map(DBPDriverConfigurationType::toString)
                 .toArray(String[]::new);
         }
-        return new String[0];
+        return supportedConfigurationTypes;
     }
 
     @Property
@@ -252,4 +256,14 @@ public List<String> getScopes() {
         }
         return null;
     }
+
+    //TODO: delete after refactoring on front-end
+    public void setValidValues(Object[] validValues) {
+        this.validValues = validValues;
+    }
+
+    //TODO: delete after refactoring on front-end
+    public void setSupportedConfigurationTypes(String[] supportedConfigurationTypes) {
+        this.supportedConfigurationTypes = supportedConfigurationTypes;
+    }
 }

server/bundles/io.cloudbeaver.model/src/io/cloudbeaver/model/app/BaseWebAppConfiguration.java

@@ -31,6 +31,7 @@ public abstract class BaseWebAppConfiguration implements ServletAppConfiguration
     protected final Map<String, Object> plugins;
     protected String defaultUserTeam = DEFAULT_APP_ANONYMOUS_TEAM_NAME;
     protected boolean resourceManagerEnabled;
+    protected boolean secretManagerEnabled;
     protected boolean showReadOnlyConnectionInfo;
     protected String[] enabledFeatures;
     protected String[] disabledBetaFeatures;
@@ -42,6 +43,7 @@ public BaseWebAppConfiguration() {
         this.enabledFeatures = null;
         this.disabledBetaFeatures = new String[0];
         this.showReadOnlyConnectionInfo = false;
+        this.secretManagerEnabled = false;
     }
 
     public BaseWebAppConfiguration(BaseWebAppConfiguration src) {
@@ -51,6 +53,7 @@ public BaseWebAppConfiguration(BaseWebAppConfiguration src) {
         this.enabledFeatures = src.enabledFeatures;
         this.disabledBetaFeatures = src.disabledBetaFeatures;
         this.showReadOnlyConnectionInfo = src.showReadOnlyConnectionInfo;
+        this.secretManagerEnabled = src.secretManagerEnabled;
     }
 
     @Override
@@ -84,6 +87,11 @@ public boolean isResourceManagerEnabled() {
         return resourceManagerEnabled;
     }
 
+    @Override
+    public boolean isSecretManagerEnabled() {
+        return secretManagerEnabled;
+    }
+
     @Override
     public boolean isFeatureEnabled(String id) {
         return ArrayUtils.contains(getEnabledFeatures(), id);

server/bundles/io.cloudbeaver.model/src/io/cloudbeaver/model/app/ServletAppConfiguration.java

@@ -38,11 +38,13 @@
 
     Map<String, Object> getPluginConfig(@NotNull String pluginId, boolean create);
 
     boolean isResourceManagerEnabled();
 
+    boolean isSecretManagerEnabled();
+
     boolean isFeaturesEnabled(String[] requiredFeatures);
 
     boolean isFeatureEnabled(String id);
 
     @NotNull
     default String[] getEnabledFeatures() {

server/bundles/io.cloudbeaver.model/src/io/cloudbeaver/model/config/CBAppConfig.java

@@ -134,6 +134,10 @@ public void setResourceManagerEnabled(boolean resourceManagerEnabled) {
         this.resourceManagerEnabled = resourceManagerEnabled;
     }
 
+    public void setSecretManagerEnabled(boolean secretManagerEnabled) {
+        this.secretManagerEnabled = secretManagerEnabled;
+    }
+
     public boolean isSupportsCustomConnections() {
         return supportsCustomConnections;
     }

server/bundles/io.cloudbeaver.model/src/io/cloudbeaver/server/CBConstants.java

@@ -46,6 +46,7 @@ public class CBConstants {
     public static final String PARAM_STATIC_CONTENT = "staticContent";
     public static final String PARAM_RESOURCE_QUOTAS = "resourceQuotas";
     public static final String PARAM_RESOURCE_MANAGER_ENABLED = "resourceManagerEnabled";
+    public static final String PARAM_SECRET_MANAGER_ENABLED = "secretManagerEnabled";
     public static final String PARAM_SHOW_READ_ONLY_CONN_INFO = "showReadOnlyConnectionInfo";
     public static final String PARAM_CONN_GRANT_ANON_ACCESS = "grantConnectionsAccessToAnonymousTeam";
     public static final String PARAM_AUTH_PROVIDERS = "authConfiguration";

server/bundles/io.cloudbeaver.server.ce/META-INF/MANIFEST.MF

@@ -15,6 +15,7 @@ Export-Package: io.cloudbeaver,
  io.cloudbeaver.model.config,
  io.cloudbeaver.server,
  io.cloudbeaver.service,
+ io.cloudbeaver.service.core,
  io.cloudbeaver.service.session
 Import-Package: org.slf4j
 Automatic-Module-Name: io.cloudbeaver.server.ce

server/bundles/io.cloudbeaver.server.ce/src/io/cloudbeaver/server/CBApplication.java

@@ -29,6 +29,8 @@
 import io.cloudbeaver.registry.WebDriverRegistry;
 import io.cloudbeaver.registry.WebServiceRegistry;
 import io.cloudbeaver.server.jetty.CBJettyServer;
+import io.cloudbeaver.service.ConnectionController;
+import io.cloudbeaver.service.ConnectionControllerCE;
 import io.cloudbeaver.service.DBWServiceInitializer;
 import io.cloudbeaver.service.DBWServiceServerConfigurator;
 import io.cloudbeaver.service.session.CBSessionManager;
@@ -772,4 +774,9 @@ public Map<String, String> getInitActions() {
     public WebServerConfig getWebServerConfig() {
         return new CBWebServerConfig(this);
     }
+
+    @Override
+    public ConnectionController getConnectionController() {
+        return new ConnectionControllerCE();
+    }
 }

server/bundles/io.cloudbeaver.server.ce/src/io/cloudbeaver/server/CBServerConfigurationController.java

@@ -436,6 +436,11 @@ protected Map<String, Object> collectConfigurationProperties(
                 appConfigProperties,
                 CBConstants.PARAM_RESOURCE_MANAGER_ENABLED,
                 appConfig.isResourceManagerEnabled());
+            copyConfigValue(
+                oldAppConfig,
+                appConfigProperties,
+                CBConstants.PARAM_SECRET_MANAGER_ENABLED,
+                appConfig.isSecretManagerEnabled());
             copyConfigValue(
                 oldAppConfig,
                 appConfigProperties,

server/bundles/io.cloudbeaver.server/schema/service.core.graphqls

@@ -130,6 +130,8 @@ type ServerConfig {
     supportsCustomConnections: Boolean!
     resourceManagerEnabled: Boolean!
 
+    secretManagerEnabled: Boolean!  @since(version: "24.3.2")
+
     publicCredentialsSaveEnabled: Boolean!
     adminCredentialsSaveEnabled: Boolean!
 

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/model/WebDatabaseDriverInfo.java

@@ -1,6 +1,6 @@
 /*
  * DBeaver - Universal Database Manager
- * Copyright (C) 2010-2024 DBeaver Corp and others
+ * Copyright (C) 2010-2025 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -42,6 +42,7 @@
 import java.util.Arrays;
 import java.util.LinkedHashMap;
 import java.util.Map;
+import java.util.stream.Stream;
 
 /**
  * Web driver configuration
@@ -258,9 +259,17 @@ public WebPropertyInfo[] getMainProperties() {
 
     @Property
     public WebPropertyInfo[] getProviderProperties() {
-        return Arrays.stream(driver.getProviderPropertyDescriptors())
+        WebPropertyInfo[] additionalWebProperty = WebAppUtils.getWebApplication().getConnectionController().getExternalInfo(webSession);
+        WebPropertyInfo[] providerProperties = Arrays.stream(driver.getProviderPropertyDescriptors())
             .map(p -> new WebPropertyInfo(webSession, p, null))
             .toArray(WebPropertyInfo[]::new);
+
+        WebPropertyInfo[] combinedProperties = Stream.concat(
+            Arrays.stream(additionalWebProperty),
+            Arrays.stream(providerProperties)
+        ).toArray(WebPropertyInfo[]::new);
+
+        return combinedProperties;
     }
 
     @Property

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/model/WebServerConfig.java

@@ -110,6 +110,11 @@ public boolean isResourceManagerEnabled() {
         return application.getAppConfiguration().isResourceManagerEnabled();
     }
 
+    @Property
+    public boolean isSecretManagerEnabled() {
+        return application.getAppConfiguration().isSecretManagerEnabled();
+    }
+
     @Property
     public String[] getEnabledFeatures() {
         return application.getAppConfiguration().getEnabledFeatures();

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/server/WebApplication.java

@@ -21,6 +21,7 @@
 import io.cloudbeaver.model.app.WebAppConfiguration;
 import io.cloudbeaver.model.app.WebServerConfiguration;
 import io.cloudbeaver.registry.WebDriverRegistry;
+import io.cloudbeaver.service.ConnectionController;
 import org.jkiss.code.NotNull;
 
 import java.net.InetAddress;
@@ -50,6 +51,8 @@
 
     String getLicenseStatus();
 
     WebServerConfig getWebServerConfig();
 
+    ConnectionController getConnectionController();
+
 }

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/ConnectionController.java

@@ -0,0 +1,78 @@
+/*
+ * DBeaver - Universal Database Manager
+ * Copyright (C) 2010-2025 DBeaver Corp and others
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.cloudbeaver.service;
+
+import io.cloudbeaver.DBWebException;
+import io.cloudbeaver.WebObjectId;
+import io.cloudbeaver.model.WebConnectionConfig;
+import io.cloudbeaver.model.WebConnectionInfo;
+import io.cloudbeaver.model.WebPropertyInfo;
+import io.cloudbeaver.model.session.WebSession;
+import org.jkiss.code.NotNull;
+import org.jkiss.code.Nullable;
+import org.jkiss.dbeaver.model.DBPDataSourceContainer;
+import org.jkiss.dbeaver.model.app.DBPDataSourceRegistry;
+import org.jkiss.dbeaver.registry.DataSourceDescriptor;
+
+
+public interface ConnectionController {
+
+    DBPDataSourceContainer createDataSourceContainer(
+        @NotNull WebSession webSession,
+        @Nullable @WebObjectId String projectId,
+        @NotNull WebConnectionConfig connectionConfig
+    ) throws DBWebException;
+
+    WebConnectionInfo createConnection(
+        @NotNull WebSession webSession,
+        @Nullable String projectId,
+        DBPDataSourceRegistry sessionRegistry,
+        DBPDataSourceContainer newDataSource
+    ) throws DBWebException;
+
+    DBPDataSourceContainer getDatasourceConnection(
+        @NotNull WebSession webSession,
+        @Nullable @WebObjectId String projectId,
+        @NotNull WebConnectionConfig connectionConfig) throws DBWebException;
+
+    WebConnectionInfo updateConnection(
+        @NotNull WebSession webSession,
+        @Nullable String projectId,
+        @NotNull WebConnectionConfig config,
+        DBPDataSourceContainer dataSource,
+        DBPDataSourceRegistry sessionRegistry
+    ) throws DBWebException;
+
+    boolean deleteConnection(
+        @NotNull WebSession webSession,
+        @Nullable @WebObjectId String projectId,
+        @NotNull String connectionId) throws DBWebException;
+
+    DataSourceDescriptor prepareTestConnection(
+        @NotNull WebSession webSession,
+        @Nullable String projectId,
+        @NotNull WebConnectionConfig connectionConfig) throws DBWebException;
+
+    WebConnectionInfo testConnection(
+        @NotNull WebSession webSession,
+        @Nullable String projectId,
+        @NotNull WebConnectionConfig connectionConfig,
+        DataSourceDescriptor dataSource
+    ) throws DBWebException;
+
+    WebPropertyInfo[] getExternalInfo(WebSession webSession);
+}