From e6314a220acf626250a3edd8aebfb425f37eefa2 Mon Sep 17 00:00:00 2001 From: Ali Oezyetimoglu Date: Fri, 1 Sep 2023 15:20:49 +0200 Subject: [PATCH] RED-7175: added index name to search connection entity and adapted the code accordingly --- build.gradle.kts | 2 +- .../dev/DevTestTenantService.java | 2 +- .../entity/SearchConnectionEntity.java | 2 ++ .../tenantusermanagement/model/TenantRequest.java | 1 - .../service/TenantManagementService.java | 3 +++ .../resources/db/changelog/db.changelog-master.yaml | 2 ++ .../master/6-add-index-name-column.changelog.yaml | 11 +++++++++++ .../java/com/knecon/fforesight/tests/TenantsTest.java | 1 + .../knecon/fforesight/utils/TestTenantService.java | 2 +- 9 files changed, 22 insertions(+), 4 deletions(-) create mode 100644 src/main/resources/db/changelog/master/6-add-index-name-column.changelog.yaml diff --git a/build.gradle.kts b/build.gradle.kts index 39a106e..3706ac3 100644 --- a/build.gradle.kts +++ b/build.gradle.kts @@ -82,7 +82,7 @@ tasks.named("bootBuildImage") { dependencies { - implementation("com.knecon.fforesight:keycloak-commons:0.19.0") + implementation("com.knecon.fforesight:keycloak-commons:0.20.0") implementation("com.knecon.fforesight:swagger-commons:0.5.0") implementation("org.postgresql:postgresql:42.5.4") implementation("com.google.guava:guava:31.1-jre") diff --git a/src/main/java/com/knecon/fforesight/tenantusermanagement/dev/DevTestTenantService.java b/src/main/java/com/knecon/fforesight/tenantusermanagement/dev/DevTestTenantService.java index 05ef0fc..804e117 100644 --- a/src/main/java/com/knecon/fforesight/tenantusermanagement/dev/DevTestTenantService.java +++ b/src/main/java/com/knecon/fforesight/tenantusermanagement/dev/DevTestTenantService.java @@ -81,7 +81,7 @@ public class DevTestTenantService { .username(tenantsDBName) .password(tenantsDBPassword) .build()) - .searchConnection(SearchConnection.builder().hosts(Set.of("localhost")).port(9200).scheme("http").numberOfShards("1").numberOfReplicas("5").build()) + .searchConnection(SearchConnection.builder().hosts(Set.of("localhost")).port(9200).scheme("http").numberOfShards("1").numberOfReplicas("5").indexName("indexname").build()) .s3StorageConnection(S3StorageConnection.builder().key("minioadmin").secret("minioadmin").bucketName("redaction").endpoint("http://localhost:9000").build()) .build(); diff --git a/src/main/java/com/knecon/fforesight/tenantusermanagement/entity/SearchConnectionEntity.java b/src/main/java/com/knecon/fforesight/tenantusermanagement/entity/SearchConnectionEntity.java index 0426436..14c2fff 100644 --- a/src/main/java/com/knecon/fforesight/tenantusermanagement/entity/SearchConnectionEntity.java +++ b/src/main/java/com/knecon/fforesight/tenantusermanagement/entity/SearchConnectionEntity.java @@ -34,5 +34,7 @@ public class SearchConnectionEntity { private String numberOfShards; @Column(name = "search_number_of_replicas") private String numberOfReplicas; + @Column(name = "search_index_name") + private String indexName; } diff --git a/src/main/java/com/knecon/fforesight/tenantusermanagement/model/TenantRequest.java b/src/main/java/com/knecon/fforesight/tenantusermanagement/model/TenantRequest.java index dd5ced6..c4ee21a 100644 --- a/src/main/java/com/knecon/fforesight/tenantusermanagement/model/TenantRequest.java +++ b/src/main/java/com/knecon/fforesight/tenantusermanagement/model/TenantRequest.java @@ -10,7 +10,6 @@ import com.knecon.fforesight.tenantcommons.model.SearchConnection; import io.swagger.v3.oas.annotations.media.Schema; import jakarta.validation.constraints.NotBlank; -import jakarta.validation.constraints.NotEmpty; import jakarta.validation.constraints.Pattern; import lombok.AllArgsConstructor; import lombok.Builder; diff --git a/src/main/java/com/knecon/fforesight/tenantusermanagement/service/TenantManagementService.java b/src/main/java/com/knecon/fforesight/tenantusermanagement/service/TenantManagementService.java index 0ecb211..4ef1bab 100644 --- a/src/main/java/com/knecon/fforesight/tenantusermanagement/service/TenantManagementService.java +++ b/src/main/java/com/knecon/fforesight/tenantusermanagement/service/TenantManagementService.java @@ -113,6 +113,7 @@ public class TenantManagementService implements TenantProvider { .password(encryptionService.encrypt(tenantRequest.getSearchConnection().getPassword())) .numberOfShards(tenantRequest.getSearchConnection().getNumberOfShards()) .numberOfReplicas(tenantRequest.getSearchConnection().getNumberOfReplicas()) + .indexName(tenantRequest.getSearchConnection().getIndexName()) .build()) .build(); @@ -407,6 +408,7 @@ public class TenantManagementService implements TenantProvider { .password(encryptionService.encrypt(searchConnection.getPassword())) .numberOfShards(searchConnection.getNumberOfShards()) .numberOfReplicas(searchConnection.getNumberOfReplicas()) + .indexName(searchConnection.getIndexName()) .build()); } @@ -508,6 +510,7 @@ public class TenantManagementService implements TenantProvider { .numberOfShards(entity.getSearchConnection().getNumberOfShards()) .numberOfReplicas(entity.getSearchConnection().getNumberOfReplicas()) .password(entity.getSearchConnection().getPassword()) + .indexName(entity.getSearchConnection().getIndexName()) .build()) .build(); diff --git a/src/main/resources/db/changelog/db.changelog-master.yaml b/src/main/resources/db/changelog/db.changelog-master.yaml index 305dd4f..aee0958 100644 --- a/src/main/resources/db/changelog/db.changelog-master.yaml +++ b/src/main/resources/db/changelog/db.changelog-master.yaml @@ -7,3 +7,5 @@ databaseChangeLog: file: db/changelog/master/4-add-unique-constraint-for-tenants-table.yaml - include: file: db/changelog/master/5-add-details-column.changelog.yaml + - include: + file: db/changelog/master/6-add-index-name-column.changelog.yaml diff --git a/src/main/resources/db/changelog/master/6-add-index-name-column.changelog.yaml b/src/main/resources/db/changelog/master/6-add-index-name-column.changelog.yaml new file mode 100644 index 0000000..1c6882a --- /dev/null +++ b/src/main/resources/db/changelog/master/6-add-index-name-column.changelog.yaml @@ -0,0 +1,11 @@ +databaseChangeLog: + - changeSet: + id: add-index-name-column-to-tenant + author: ali + changes: + - addColumn: + tableName: tenant + columns: + - column: + name: search_index_name + type: TEXT \ No newline at end of file diff --git a/src/test/java/com/knecon/fforesight/tests/TenantsTest.java b/src/test/java/com/knecon/fforesight/tests/TenantsTest.java index 9c141fb..a01917f 100644 --- a/src/test/java/com/knecon/fforesight/tests/TenantsTest.java +++ b/src/test/java/com/knecon/fforesight/tests/TenantsTest.java @@ -78,6 +78,7 @@ public class TenantsTest extends AbstractTenantUserManagementIntegrationTest { .port(123) .username("updated_username") .scheme("updated_scheme") + .indexName("indexname") .build()) .databaseConnection(DatabaseConnection.builder() .database("updated_db") diff --git a/src/test/java/com/knecon/fforesight/utils/TestTenantService.java b/src/test/java/com/knecon/fforesight/utils/TestTenantService.java index a9ecbb0..2ef7930 100644 --- a/src/test/java/com/knecon/fforesight/utils/TestTenantService.java +++ b/src/test/java/com/knecon/fforesight/utils/TestTenantService.java @@ -75,7 +75,7 @@ public class TestTenantService { .username(SpringPostgreSQLTestContainer.getInstance().getUsername()) .password(SpringPostgreSQLTestContainer.getInstance().getPassword()) .build()) - .searchConnection(SearchConnection.builder().hosts(Set.of("localhost")).port(9200).scheme("http").numberOfShards("1").numberOfReplicas("5").build()); + .searchConnection(SearchConnection.builder().hosts(Set.of("localhost")).port(9200).scheme("http").numberOfShards("1").numberOfReplicas("5").indexName("indexname").build()); if (withStorage) { tenantRequest = tenantRequestBuilder.s3StorageConnection(S3StorageConnection.builder()