diff --git a/indexer-core/pom.xml b/indexer-core/pom.xml index 7a4e8e9213d2cfafdd3de581a0d01ba39bae11dc..91dbfc2c82037cc87de9349a2a0ecee3404230f8 100644 --- a/indexer-core/pom.xml +++ b/indexer-core/pom.xml @@ -16,7 +16,7 @@ <properties> <commons-beanutils.version>1.9.4</commons-beanutils.version> - <osdu.oscorecommon.version>0.13.0-rc4</osdu.oscorecommon.version> + <osdu.oscorecommon.version>0.13.0-SNAPSHOT-REMOVE-ELASTIC</osdu.oscorecommon.version> </properties> <dependencies> diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/CronServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/CronServiceImpl.java index b6a61d47c0f41ec13cc9cbf3635a859d49baf4bb..1ec074481b13495868ca5c16608b213d7a8ccdfd 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/CronServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/CronServiceImpl.java @@ -1,5 +1,3 @@ - - // Copyright 2017-2019, Schlumberger // // Licensed under the Apache License, Version 2.0 (the "License"); @@ -22,7 +20,6 @@ import org.opengroup.osdu.core.common.model.http.AppException; import org.opengroup.osdu.core.common.model.search.IndexInfo; import org.opengroup.osdu.core.common.logging.JaxRsDpsLog; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.config.IndexerConfigurationProperties; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.springframework.beans.factory.annotation.Value; diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingService.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IMappingService.java similarity index 87% rename from indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingService.java rename to indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IMappingService.java index efbda282b271ebef8814a293c4751b4ecc81953e..689e7a654ae9fcbb6acc0fa659a51f804151ad03 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingService.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IMappingService.java @@ -15,14 +15,17 @@ package org.opengroup.osdu.indexer.service; import org.elasticsearch.client.RestHighLevelClient; -import org.opengroup.osdu.core.common.search.IMappingService; import org.opengroup.osdu.core.common.model.indexer.IndexSchema; import java.io.IOException; import java.util.Map; import java.util.Set; -public interface IndexerMappingService extends IMappingService { +public interface IMappingService { + + String getIndexMapping(RestHighLevelClient client, String index) throws Exception; + + String getIndexSchema(String index) throws Exception; String createMapping(RestHighLevelClient client, IndexSchema schema, String index, boolean merge) throws IOException; diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImpl.java index 1a02c456ded766a73da95636ed4e7ae8e6718768..23027e20654fcaae75e8aafd58cf51972565c4e7 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImpl.java @@ -30,7 +30,6 @@ import org.opengroup.osdu.core.common.model.http.DpsHeaders; import org.opengroup.osdu.core.common.model.tenant.TenantInfo; import org.opengroup.osdu.core.common.model.http.AppException; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.core.common.search.Preconditions; import org.opengroup.osdu.indexer.logging.AuditLogger; import org.opengroup.osdu.core.common.model.indexer.IElasticSettingService; @@ -55,7 +54,7 @@ public class IndexCopyServiceImpl implements IndexCopyService { @Inject private IElasticSettingService elasticSettingService; @Inject - private IndexerMappingService mappingService; + private IMappingService mappingService; @Inject private DpsHeaders headersInfo; @Inject diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexSchemaServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexSchemaServiceImpl.java index 009247ba48e40da753c5c10a38b8a3d265e325e9..7787fba463d36e76566575bc9e949bbb3ea92727 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexSchemaServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexSchemaServiceImpl.java @@ -30,7 +30,6 @@ import org.opengroup.osdu.core.common.model.search.RecordMetaAttribute; import org.opengroup.osdu.core.common.model.storage.Schema; import org.opengroup.osdu.core.common.model.storage.SchemaItem; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache; import org.opengroup.osdu.indexer.schema.converter.exeption.SchemaProcessingException; import org.opengroup.osdu.indexer.util.ElasticClientHandler; @@ -61,7 +60,7 @@ public class IndexSchemaServiceImpl implements IndexSchemaService { @Inject private ElasticIndexNameResolver elasticIndexNameResolver; @Inject - private IndexerMappingService mappingService; + private IMappingService mappingService; @Inject private IndicesService indicesService; @Inject diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceImpl.java index 1bfda7e9797a8ed1105d9006d2784432d9139a07..329ebd3245eef95724ac38a84c3cd15de49a89bc 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceImpl.java @@ -36,7 +36,6 @@ import org.opengroup.osdu.core.common.logging.JaxRsDpsLog; import org.opengroup.osdu.core.common.model.http.AppException; import org.opengroup.osdu.core.common.model.indexer.IndexSchema; import org.opengroup.osdu.core.common.provider.interfaces.IIndexCache; -import org.opengroup.osdu.core.common.search.IMappingService; import org.opengroup.osdu.core.common.search.Preconditions; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.opengroup.osdu.indexer.util.TypeMapper; @@ -49,7 +48,7 @@ import java.lang.reflect.Type; import java.util.*; @Service -public class IndexerMappingServiceImpl extends MappingServiceImpl implements IndexerMappingService { +public class IndexerMappingServiceImpl extends MappingServiceImpl implements IMappingService { @Inject private JaxRsDpsLog log; diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java index 36d0bcdcf6b4a4fb3af176a6b742a1035e6cd1f5..e5ffb3b7aedf3474537977cb1d313dd506e9482d 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java @@ -41,7 +41,6 @@ import org.opengroup.osdu.core.common.model.search.RecordChangedMessages; import org.opengroup.osdu.core.common.model.search.RecordMetaAttribute; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.logging.AuditLogger; import org.opengroup.osdu.indexer.provider.interfaces.IPublisher; import org.opengroup.osdu.indexer.util.ElasticClientHandler; @@ -81,7 +80,7 @@ public class IndexerServiceImpl implements IndexerService { @Inject private IndicesService indicesService; @Inject - private IndexerMappingService mappingService; + private IMappingService mappingService; @Inject private IPublisher progressPublisher; @Inject diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesService.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesService.java new file mode 100644 index 0000000000000000000000000000000000000000..c09ff3e5744cb5ad52016499abdb8e55aff0b271 --- /dev/null +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesService.java @@ -0,0 +1,39 @@ +// Copyright 2017-2019, Schlumberger +// +// 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 org.opengroup.osdu.indexer.service; + +import org.elasticsearch.ElasticsearchException; +import org.elasticsearch.ElasticsearchStatusException; +import org.elasticsearch.client.RestHighLevelClient; +import org.elasticsearch.common.settings.Settings; +import org.opengroup.osdu.core.common.model.http.AppException; +import org.opengroup.osdu.core.common.model.search.IndexInfo; + +import java.io.IOException; +import java.util.List; +import java.util.Map; + +public interface IndicesService { + + boolean createIndex(RestHighLevelClient client, String index, Settings settings, String type, Map<String, Object> mapping) throws ElasticsearchStatusException, IOException; + + boolean isIndexExist(RestHighLevelClient client, String index) throws IOException; + + boolean deleteIndex(RestHighLevelClient client, String index) throws ElasticsearchException, IOException, AppException; + + boolean deleteIndex(String index) throws ElasticsearchException, IOException, AppException; + + List<IndexInfo> getIndexInfo(RestHighLevelClient client, String indexPattern) throws IOException; +} diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java index bd3a90009edc62e105323b2586678083cc094267..50f58e9d9c38bc0ccd4e155904b868d8ae5d3cb9 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java @@ -37,7 +37,6 @@ import org.elasticsearch.common.xcontent.XContentType; import org.elasticsearch.rest.RestStatus; import org.opengroup.osdu.core.common.model.http.AppException; import org.opengroup.osdu.core.common.logging.JaxRsDpsLog; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.core.common.provider.interfaces.IIndexCache; import org.opengroup.osdu.core.common.model.search.IndexInfo; import org.opengroup.osdu.indexer.util.ElasticClientHandler; diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/MappingServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/MappingServiceImpl.java index 005e8c28a7844d4f14ef3ce8d41f1d60af111106..566de1d5bc7aff30d3c166bf69fa529834e48403 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/MappingServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/MappingServiceImpl.java @@ -24,8 +24,6 @@ import org.elasticsearch.client.indices.GetMappingsResponse; import org.elasticsearch.common.unit.TimeValue; import org.opengroup.osdu.core.common.model.http.AppException; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IMappingService; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.core.common.search.Preconditions; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.springframework.beans.factory.annotation.Autowired; @@ -39,7 +37,7 @@ import java.util.Objects; @Service @RequestScope -public class MappingServiceImpl implements IMappingService { +public abstract class MappingServiceImpl implements IMappingService { @Autowired private IndicesService indicesService; diff --git a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceTest.java b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceTest.java index a7dca6b6897f5900a9fd6200146a7afc52774ec0..b52abb7c8598bb3a7e8ed3a1c064cf8c445ee1b1 100644 --- a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceTest.java +++ b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceTest.java @@ -28,7 +28,6 @@ import org.opengroup.osdu.core.common.logging.JaxRsDpsLog; import org.opengroup.osdu.core.common.model.indexer.IndexSchema; import org.opengroup.osdu.core.common.model.search.RecordMetaAttribute; import org.opengroup.osdu.core.common.provider.interfaces.IIndexCache; -import org.opengroup.osdu.core.common.search.IMappingService; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.opengroup.osdu.indexer.util.TypeMapper; import org.powermock.api.mockito.PowerMockito; diff --git a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerSchemaServiceTest.java b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerSchemaServiceTest.java index 705f8e98ad4e733377abc03948fbe0fb22227c5c..8b1a7e0a28b1524b8056986bfc664efc67c22a2d 100644 --- a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerSchemaServiceTest.java +++ b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerSchemaServiceTest.java @@ -28,7 +28,6 @@ import org.opengroup.osdu.core.common.model.http.RequestStatus; import org.opengroup.osdu.core.common.model.indexer.IndexSchema; import org.opengroup.osdu.core.common.model.indexer.OperationType; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache; import org.opengroup.osdu.indexer.schema.converter.exeption.SchemaProcessingException; import org.opengroup.osdu.indexer.util.ElasticClientHandler; @@ -75,7 +74,7 @@ public class IndexerSchemaServiceTest { @Mock private ElasticIndexNameResolver elasticIndexNameResolver; @Mock - private IndexerMappingService mappingService; + private IMappingService mappingService; @Mock private IndicesService indicesService; @Mock diff --git a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerServiceImplTest.java b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerServiceImplTest.java index c3c3d3a7a09e86a35c96fe224397aabf60ccfcf1..026ff32cb2e04a3da21b765baefc282d056915bf 100644 --- a/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerServiceImplTest.java +++ b/indexer-core/src/test/java/org/opengroup/osdu/indexer/service/IndexerServiceImplTest.java @@ -13,7 +13,6 @@ import org.mockito.InjectMocks; import org.mockito.Mock; import org.opengroup.osdu.core.common.model.indexer.RecordInfo; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.springframework.test.context.junit4.SpringRunner; diff --git a/pom.xml b/pom.xml index 7e269cedec18e5a7b8ccf95d5be9fbbfdb0ab456..0aebab06f0d9971743da2f6bb89ee4721a873437 100644 --- a/pom.xml +++ b/pom.xml @@ -19,7 +19,7 @@ <java.version>1.8</java.version> <springfox-version>2.7.0</springfox-version> <spring-cloud.version>Greenwich.SR2</spring-cloud.version> - <os-core-common.version>0.13.0-rc4</os-core-common.version> + <os-core-common.version>0.13.0-SNAPSHOT-REMOVE-ELASTIC</os-core-common.version> <snakeyaml.version>1.26</snakeyaml.version> <hibernate-validator.version>6.1.5.Final</hibernate-validator.version> <jackson.version>2.11.4</jackson.version> diff --git a/provider/indexer-azure/pom.xml b/provider/indexer-azure/pom.xml index a90cd035b1033dca96a2ff9b82cc8be5a85ccf2e..047fc8de16ba0560b4b0271bd87b86d0729ca3d0 100644 --- a/provider/indexer-azure/pom.xml +++ b/provider/indexer-azure/pom.xml @@ -42,7 +42,7 @@ <indexer-core.version>0.13.0-SNAPSHOT</indexer-core.version> <spring-security-jwt.version>1.1.1.RELEASE</spring-security-jwt.version> <osdu.corelibazure.version>0.13.0-rc6</osdu.corelibazure.version> - <osdu.oscorecommon.version>0.13.0-rc4</osdu.oscorecommon.version> + <osdu.oscorecommon.version>0.13.0-SNAPSHOT-REMOVE-ELASTIC</osdu.oscorecommon.version> <reactor-netty.version>0.9.12.RELEASE</reactor-netty.version> <java-jwt.version>3.8.1</java-jwt.version> <powermock.version>2.0.2</powermock.version> diff --git a/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/CronServiceImplTest.java b/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/CronServiceImplTest.java index 2ec6cfdf20306468e69d78d70450c9def671bfe2..4e14ed7038f7073a798c5c89a7addfd50c20ea81 100644 --- a/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/CronServiceImplTest.java +++ b/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/CronServiceImplTest.java @@ -28,7 +28,7 @@ import org.opengroup.osdu.indexer.config.IndexerConfigurationProperties; import org.opengroup.osdu.indexer.service.CronServiceImpl; import org.opengroup.osdu.core.common.model.search.IndexInfo; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; -import org.opengroup.osdu.core.common.search.IndicesService; +import org.opengroup.osdu.indexer.service.IndicesService; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.powermock.core.classloader.annotations.PrepareForTest; import org.springframework.test.context.junit4.SpringRunner; diff --git a/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/IndexCopyServiceImplTest.java b/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/IndexCopyServiceImplTest.java index e03a77601ca1297aa4cf73cd6022da094ef5c6e2..6fa376a3f6d5a14fe151f2c881202809c220f700 100644 --- a/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/IndexCopyServiceImplTest.java +++ b/provider/indexer-azure/src/test/java/org/opengroup/osdu/indexer/azure/service/IndexCopyServiceImplTest.java @@ -32,13 +32,13 @@ import org.mockito.InjectMocks; import org.mockito.Mock; import org.opengroup.osdu.core.common.model.http.DpsHeaders; import org.opengroup.osdu.indexer.logging.AuditLogger; +import org.opengroup.osdu.indexer.service.IMappingService; import org.opengroup.osdu.indexer.service.IndexCopyServiceImpl; -import org.opengroup.osdu.indexer.service.IndexerMappingService; import org.opengroup.osdu.core.common.model.search.ClusterSettings; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; import org.opengroup.osdu.core.common.model.indexer.IElasticSettingService; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.core.common.model.http.AppException; +import org.opengroup.osdu.indexer.service.IndicesService; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; import org.powermock.core.classloader.annotations.PrepareForTest; @@ -74,7 +74,7 @@ public class IndexCopyServiceImplTest { @Mock private IndicesService indicesService; @Mock - private IndexerMappingService mappingService; + private IMappingService mappingService; @Mock private ElasticClientHandler elasticClientHandler; @Mock diff --git a/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java b/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java index f839c8d2f25e550df8ee3e631a1c96c6b826ff66..1038c1f9376f8a0a877700394633e0340c2e2018 100644 --- a/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java +++ b/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java @@ -25,7 +25,6 @@ import org.opengroup.osdu.core.common.model.http.DpsHeaders; import org.opengroup.osdu.core.common.model.search.IndexInfo; import org.opengroup.osdu.core.common.logging.JaxRsDpsLog; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.config.IndexerConfigurationProperties; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.powermock.core.classloader.annotations.PrepareForTest; diff --git a/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java b/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java index c689c04d3c4fa8d0a4f4c40ead41db09a25df4b7..7b26ad8a3a283adb917ffc00c41dd27d58f40b1a 100644 --- a/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java +++ b/provider/indexer-gcp/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java @@ -37,7 +37,6 @@ import org.opengroup.osdu.core.common.model.http.AppException; import org.opengroup.osdu.indexer.logging.AuditLogger; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; import org.opengroup.osdu.core.common.model.indexer.IElasticSettingService; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; import org.powermock.core.classloader.annotations.PrepareForTest; @@ -73,7 +72,7 @@ public class IndexCopyServiceImplTest { @Mock private IndicesService indicesService; @Mock - private IndexerMappingService mappingService; + private IMappingService mappingService; @Mock private ElasticClientHandler elasticClientHandler; @Mock diff --git a/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/CronServiceImplTest.java b/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/CronServiceImplTest.java index 02ee673a2d681c10861453dbafa828374232fc57..56fa2033b16112284ff0817a21606484a0397a1c 100644 --- a/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/CronServiceImplTest.java +++ b/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/CronServiceImplTest.java @@ -17,7 +17,7 @@ import org.opengroup.osdu.indexer.config.IndexerConfigurationProperties; import org.opengroup.osdu.indexer.service.CronServiceImpl; import org.opengroup.osdu.core.common.model.search.IndexInfo; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; -import org.opengroup.osdu.core.common.search.IndicesService; +import org.opengroup.osdu.indexer.service.IndicesService; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.powermock.core.classloader.annotations.PrepareForTest; import org.springframework.test.context.junit4.SpringRunner; diff --git a/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/IndexCopyServiceImplTest.java b/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/IndexCopyServiceImplTest.java index bfa8e4103cbca3d54955201fe1a633e36d65ee91..a12e905f8d6602f52701806e51c58cffecf66688 100644 --- a/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/IndexCopyServiceImplTest.java +++ b/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/IndexCopyServiceImplTest.java @@ -21,13 +21,13 @@ import org.mockito.InjectMocks; import org.mockito.Mock; import org.opengroup.osdu.core.common.model.http.DpsHeaders; import org.opengroup.osdu.indexer.logging.AuditLogger; +import org.opengroup.osdu.indexer.service.IMappingService; import org.opengroup.osdu.indexer.service.IndexCopyServiceImpl; -import org.opengroup.osdu.indexer.service.IndexerMappingService; import org.opengroup.osdu.core.common.model.search.ClusterSettings; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; import org.opengroup.osdu.core.common.model.indexer.IElasticSettingService; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.core.common.model.http.AppException; +import org.opengroup.osdu.indexer.service.IndicesService; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; import org.powermock.core.classloader.annotations.PrepareForTest; @@ -63,7 +63,7 @@ public class IndexCopyServiceImplTest { @Mock private IndicesService indicesService; @Mock - private IndexerMappingService mappingService; + private IMappingService mappingService; @Mock private ElasticClientHandler elasticClientHandler; @Mock diff --git a/provider/indexer-reference/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java b/provider/indexer-reference/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java index 5fc2d11920d2e2b39bf43a2fcde771f21fa90517..81da502c69dc5dc20160417bd1ff1085f823b139 100644 --- a/provider/indexer-reference/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java +++ b/provider/indexer-reference/src/main/java/org/opengroup/osdu/indexer/service/IndexerServiceImpl.java @@ -60,7 +60,6 @@ import org.opengroup.osdu.core.common.model.search.RecordChangedMessages; import org.opengroup.osdu.core.common.model.search.RecordMetaAttribute; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.logging.AuditLogger; import org.opengroup.osdu.indexer.provider.interfaces.IPublisher; import org.opengroup.osdu.indexer.util.ElasticClientHandler; @@ -91,7 +90,7 @@ public class IndexerServiceImpl implements IndexerService { @Inject private IndicesService indicesService; @Inject - private IndexerMappingService mappingService; + private IMappingService mappingService; @Inject private IPublisher progressPublisher; @Inject diff --git a/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java b/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java index e1c53edb8ab313727f54a905a3494a74cb3f6961..cadcb0bf01f4e8516756d2cc2e070b71071178f8 100644 --- a/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java +++ b/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/CronServiceImplTest.java @@ -36,7 +36,6 @@ import org.opengroup.osdu.core.common.logging.JaxRsDpsLog; import org.opengroup.osdu.core.common.model.http.DpsHeaders; import org.opengroup.osdu.core.common.model.search.IndexInfo; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.config.IndexerConfigurationProperties; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.powermock.core.classloader.annotations.PrepareForTest; diff --git a/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java b/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java index 6a438da28b492752abe329f329c0cbd85ec09977..db855559e8c02acc780da73f5436a4081b8e03b2 100644 --- a/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java +++ b/provider/indexer-reference/src/test/java/org/opengroup/osdu/indexer/service/IndexCopyServiceImplTest.java @@ -48,7 +48,6 @@ import org.opengroup.osdu.core.common.model.indexer.IElasticSettingService; import org.opengroup.osdu.core.common.model.search.ClusterSettings; import org.opengroup.osdu.core.common.provider.interfaces.IRequestInfo; import org.opengroup.osdu.core.common.search.ElasticIndexNameResolver; -import org.opengroup.osdu.core.common.search.IndicesService; import org.opengroup.osdu.indexer.logging.AuditLogger; import org.opengroup.osdu.indexer.util.ElasticClientHandler; import org.powermock.core.classloader.annotations.PrepareForTest; @@ -76,7 +75,7 @@ public class IndexCopyServiceImplTest { @Mock private IndicesService indicesService; @Mock - private IndexerMappingService mappingService; + private IMappingService mappingService; @Mock private ElasticClientHandler elasticClientHandler; @Mock