switch from cloud connectors to cfenv

admin-ch · Dec 14, 2022 · 046a9d2 · 046a9d2
1 parent ebc909e
commit 046a9d2
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 32 deletions.
diff --git a/...dcertificate-backend-transformation/ch-covidcertificate-backend-transformation-ws/pom.xml b/...dcertificate-backend-transformation/ch-covidcertificate-backend-transformation-ws/pom.xml
@@ -40,10 +40,10 @@
             <artifactId>micrometer-registry-prometheus</artifactId>
         </dependency>
         <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-cloud-connectors</artifactId>
-            <version>${spring-cloud-connectors-version}</version>
-        </dependency>
+            <groupId>io.pivotal.cfenv</groupId>
+            <artifactId>java-cfenv-boot</artifactId>
+            <version>2.4.1</version>
+          </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-validation</artifactId>

diff --git a/...ain/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/WsBaseConfig.java b/...ain/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/WsBaseConfig.java
@@ -68,9 +68,7 @@ public abstract class WsBaseConfig {
     @Value("${ws.rate-limit:10}")
     private int rateLimit;
 
-    public abstract DataSource dataSource();
-
-    public abstract Flyway flyway();
+    public abstract Flyway flyway(DataSource dataSource);
 
     public abstract BitClient bitClient(
             ClientRegistrationRepository clientRegistration, ObjectMapper objectMapper);

diff --git a/...in/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/WsCloudConfig.java b/...in/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/WsCloudConfig.java
@@ -17,9 +17,6 @@
 import javax.sql.DataSource;
 import org.flywaydb.core.Flyway;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.cloud.CloudFactory;
-import org.springframework.cloud.service.PooledServiceConnectorConfig.PoolConfig;
-import org.springframework.cloud.service.relational.DataSourceConfig;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Profile;
@@ -49,25 +46,10 @@ public class WsCloudConfig extends WsBaseConfig {
 
     @Bean
     @Override
-    public DataSource dataSource() {
-        PoolConfig poolConfig =
-                new PoolConfig(dataSourceMaximumPoolSize, dataSourceConnectionTimeout);
-        DataSourceConfig dbConfig =
-                new DataSourceConfig(
-                        poolConfig,
-                        null,
-                        null,
-                        Map.of("leakDetectionThreshold", dataSourceLeakDetectionThreshold));
-        CloudFactory factory = new CloudFactory();
-        return factory.getCloud().getSingletonServiceConnector(DataSource.class, dbConfig);
-    }
-
-    @Bean
-    @Override
-    public Flyway flyway() {
+    public Flyway flyway(DataSource dataSource) {
         Flyway flyWay =
                 Flyway.configure()
-                        .dataSource(dataSource())
+                        .dataSource(dataSource)
                         .locations("classpath:/db/migration/pgsql_cluster")
                         .load();
         flyWay.migrate();

diff --git a/...in/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/WsLocalConfig.java b/...in/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/WsLocalConfig.java
@@ -74,10 +74,10 @@ public DataSource dataSource() {
 
     @Bean
     @Override
-    public Flyway flyway() {
+    public Flyway flyway(DataSource dataSource) {
         Flyway flyWay =
                 Flyway.configure()
-                        .dataSource(dataSource())
+                        .dataSource(dataSource)
                         .locations("classpath:/db/migration/pgsql")
                         .load();
         flyWay.migrate();

diff --git a/.../test/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/TestConfig.java b/.../test/java/ch/admin/bag/covidcertificate/backend/transformation/ws/config/TestConfig.java
@@ -28,14 +28,13 @@ public class TestConfig extends WsBaseConfig {
 
     @Autowired DataSource dataSource;
 
-    @Override
     public DataSource dataSource() {
         return dataSource;
     }
 
     @Bean
     @Override
-    public Flyway flyway() {
+    public Flyway flyway(DataSource dataSource) {
         final var flyway =
                 Flyway.configure()
                         .dataSource(dataSource)

diff --git a/ch-covidcertificate-backend-transformation/pom.xml b/ch-covidcertificate-backend-transformation/pom.xml
@@ -18,7 +18,6 @@
 
         <spring-boot-version>2.7.3</spring-boot-version>
         <spring-cloud-sleuth-version>3.1.3</spring-cloud-sleuth-version>
-        <spring-cloud-connectors-version>2.2.13.RELEASE</spring-cloud-connectors-version>
         <testcontainers-version>1.17.3</testcontainers-version>
         <shedlock-version>4.41.0</shedlock-version>