diff --git a/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/persistence/ElasticSettingSchemaRepositoryImpl.java b/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/persistence/ElasticSettingSchemaRepositoryImpl.java index 4fb739997dfd8d4f7411d085742f8b0d1aea0bc4..063a9d7895635cafe7edf461299d111a598b730a 100644 --- a/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/persistence/ElasticSettingSchemaRepositoryImpl.java +++ b/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/persistence/ElasticSettingSchemaRepositoryImpl.java @@ -31,16 +31,16 @@ import com.cloudant.client.api.Database; public class ElasticSettingSchemaRepositoryImpl implements ISchemaRepository { private static final Logger logger = LoggerFactory.getLogger(ElasticSettingSchemaRepositoryImpl.class); - - @Value("${ibm.cloudant.url}") + + @Value("${ibm.cloudant.url}") private String url; @Value("${ibm.cloudant.apikey}") private String apiKey; @Value("${ibm.cloudant.dbname.prefix:local-dev}") private String dbNamePrefix; - + private Database db; - + @PostConstruct public void init(){ try { @@ -50,15 +50,15 @@ public class ElasticSettingSchemaRepositoryImpl implements ISchemaRepository { e.printStackTrace(); } } - - @Override + + @Override public void add(ElasticSettingSchema schema, String id) { ElasticSettingsDoc sd = new ElasticSettingsDoc(); sd.setId(id); sd.setSettingSchema(schema); db.save(sd); } - + @Override public ElasticSettingSchema get(String id) { if (db.contains(id)) { @@ -72,7 +72,7 @@ public class ElasticSettingSchemaRepositoryImpl implements ISchemaRepository { } else { logger.error(ElasticSettingsDoc.class + " with id " + id + " was not found in the database."); return null; - } + } } } 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 004f48a5540dfad74c64bc62bff11b1aea727c4a..84201df5cc09d423885819ad2a33179505afcaa5 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 @@ -44,7 +44,6 @@ 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.ibm.util.IHeadersInfo; import org.opengroup.osdu.indexer.logging.AuditLogger; import org.opengroup.osdu.indexer.service.IndexCopyServiceImpl; import org.opengroup.osdu.indexer.service.IndexerMappingService; @@ -66,8 +65,8 @@ public class IndexCopyServiceImplTest { private HttpEntity httpEntityRequest; @Mock private IRequestInfo requestInfo; - @Mock - private IHeadersInfo headersInfo; + //@Mock TODO + //private IHeadersInfo headersInfo; @Mock private RestClient restClient; @Mock @@ -105,7 +104,7 @@ public class IndexCopyServiceImplTest { httpHeaders.put(DpsHeaders.AUTHORIZATION, "testAuth"); httpHeaders.put(DpsHeaders.CORRELATION_ID, correlationId); DpsHeaders standardHeaders = DpsHeaders.createFromMap(httpHeaders); - when(headersInfo.getHeaders()).thenReturn(standardHeaders); + //when(headersInfo.getHeaders()).thenReturn(standardHeaders); when(requestInfo.getHeadersMapWithDwdAuthZ()).thenReturn(httpHeaders); when(response.getEntity()).thenReturn(httpEntity); diff --git a/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/TenantInfoServiceTest.java b/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/TenantInfoServiceTest.java index 1c7eb56fcc6d93d749ca22d611b559a0882d24b7..1999577ccb5ad78f95dd887351fe6f6be849b1b2 100644 --- a/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/TenantInfoServiceTest.java +++ b/provider/indexer-ibm/src/test/java/org/opengroup/osdu/indexer/ibm/service/TenantInfoServiceTest.java @@ -26,7 +26,6 @@ import org.opengroup.osdu.core.common.model.http.AppException; import org.opengroup.osdu.core.common.model.http.DpsHeaders; import org.opengroup.osdu.core.common.model.tenant.TenantInfo; import org.opengroup.osdu.core.common.provider.interfaces.ITenantFactory; -import org.opengroup.osdu.indexer.ibm.util.IHeadersInfo; import org.springframework.http.HttpHeaders; import org.springframework.test.context.junit4.SpringRunner; @@ -38,8 +37,8 @@ public class TenantInfoServiceTest { @Mock private ITenantFactory tenantFactory; - @Mock - private IHeadersInfo headersInfo; + //@Mock + //private IHeadersInfo headersInfo; // TODO alanbraz investigate //@InjectMocks //private TenantInfoService sut; @@ -65,9 +64,9 @@ public class TenantInfoServiceTest { when(this.info.getName()).thenReturn("tenant1"); when(tenantFactory.getTenantInfo("tenant1")).thenReturn(info); - when(this.headersInfo.getHeaders()).thenReturn(HEADERS); + //when(this.headersInfo.getHeaders()).thenReturn(HEADERS); - when(this.headersInfo.getPartitionId()).thenReturn("tenant1"); + //when(this.headersInfo.getPartitionId()).thenReturn("tenant1"); //when(this.sut.getTenantInfo()).thenReturn(info); @@ -85,4 +84,4 @@ public class TenantInfoServiceTest { //assertNotNull(this.sut.getTenantInfo()); } -} \ No newline at end of file +}