summaryrefslogtreecommitdiffstats
path: root/src/test/java
diff options
context:
space:
mode:
authorShawn Severin <shawn.severin@amdocs.com>2017-12-08 12:53:42 -0500
committerShawn Severin <shawn.severin@amdocs.com>2017-12-08 12:54:36 -0500
commite72b52437992610d38939700d38c42336cade235 (patch)
tree765c492fecd4a4de547cfc0d308086494c964fae /src/test/java
parent27da2e3395b009702c9032f9fa184f253747c8a7 (diff)
Adding back-end support for UI filters
Issue-ID: AAI-543 Change-Id: I5cec6f340ab6c531f073e10e7902a84036c961d5 Signed-off-by: Shawn Severin <shawn.severin@amdocs.com>
Diffstat (limited to 'src/test/java')
-rw-r--r--src/test/java/org/onap/aai/sparky/FilterByContainsClassName.java4
-rw-r--r--src/test/java/org/onap/aai/sparky/SparkyPojoTest.java324
-rw-r--r--src/test/java/org/onap/aai/sparky/analytics/AbstractStatisticsTest.java76
-rw-r--r--src/test/java/org/onap/aai/sparky/analytics/AveragingRingBufferTest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/analytics/HistogramSamplerTest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/analytics/HistoricalCounterTest.java88
-rw-r--r--src/test/java/org/onap/aai/sparky/config/oxm/CrossEntityReferenceTest.java36
-rw-r--r--src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderFilterTest.java70
-rw-r--r--src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderTest.java24
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/NetworkTransactionTest.java50
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryAdapterTest.java126
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryEntityStatisticsTest.java116
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryProcessingExceptionStatisticsTest.java100
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventoryConfigTest.java155
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventorySslConfigTest.java43
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/cache/InMemoryEntityCacheTest.java34
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchConfigTest.java68
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchEntityStatisticsTest.java126
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntity.java6
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntityFields.java6
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticHitsEntity.java6
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticSearchResponse.java20
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/BucketEntity.java14
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticHitsEntity.java12
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggegrationResponse.java4
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggregation.java10
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchCountResponse.java6
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/PayloadEntity.java5
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/rest/RestOperationalStatisticsTest.java358
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/rest/RestfulDataAccessorTest.java6
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/DocumentEntity.java12
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/EntityCountResponse.java10
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationEntity.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationResponseEntity.java10
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/HitEntity.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionEntityBuilder.java210
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionResponse.java4
-rw-r--r--src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchResult.java13
-rw-r--r--src/test/java/org/onap/aai/sparky/search/VnfSearchQueryBuilderTest.java78
-rw-r--r--src/test/java/org/onap/aai/sparky/search/VnfSearchServiceTest.java91
-rw-r--r--src/test/java/org/onap/aai/sparky/search/filters/FilteredSearchHelperTest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/search/filters/entity/DiscoverFiltersRequest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/security/portal/TestPortalRestAPIServiceImpl.java22
-rw-r--r--src/test/java/org/onap/aai/sparky/security/portal/TestUserManager.java36
-rw-r--r--src/test/java/org/onap/aai/sparky/synchronizer/AggregationSuggestionSynchronizerTest.java81
-rw-r--r--src/test/java/org/onap/aai/sparky/synchronizer/IndexDocumentTest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerBuilder.java26
-rw-r--r--src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerTest.java89
-rw-r--r--src/test/java/org/onap/aai/sparky/synchronizer/SyncHelperTest.java148
-rw-r--r--src/test/java/org/onap/aai/sparky/synchronizer/config/SynchronizerConfigurationTest.java299
-rw-r--r--src/test/java/org/onap/aai/sparky/synchronizer/entity/AggregationSuggestionEntityTest.java4
-rw-r--r--src/test/java/org/onap/aai/sparky/util/CaptureLoggerAppender.java52
-rw-r--r--src/test/java/org/onap/aai/sparky/util/ElasticEntitySummarizer.java7
-rw-r--r--src/test/java/org/onap/aai/sparky/util/ElasticGarbageInjector.java4
-rw-r--r--src/test/java/org/onap/aai/sparky/util/ExceptionHelper.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/util/HttpServletHelper.java16
-rw-r--r--src/test/java/org/onap/aai/sparky/util/KeystoreBuilderTest.java85
-rw-r--r--src/test/java/org/onap/aai/sparky/util/NodeUtilsTest.java41
-rw-r--r--src/test/java/org/onap/aai/sparky/util/SuggestionsPermutationsTest.java10
-rw-r--r--src/test/java/org/onap/aai/sparky/util/TreeWalkerTest.java400
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/ActiveInventoryNodeTester.java3
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/SearchAdapterTest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/SearchResponseTest.java20
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/SearchServletTest.java397
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/SearchableGroupsTest.java66
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/ViewAndInspectSearchRequestTest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/entity/EntityEntryTest.java2
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationContextTest.java146
-rw-r--r--src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationServiceTest.java133
69 files changed, 2282 insertions, 2146 deletions
diff --git a/src/test/java/org/onap/aai/sparky/FilterByContainsClassName.java b/src/test/java/org/onap/aai/sparky/FilterByContainsClassName.java
index 1f55628..bfcc1c7 100644
--- a/src/test/java/org/onap/aai/sparky/FilterByContainsClassName.java
+++ b/src/test/java/org/onap/aai/sparky/FilterByContainsClassName.java
@@ -4,7 +4,7 @@ import com.openpojo.reflection.PojoClass;
import com.openpojo.reflection.PojoClassFilter;
public class FilterByContainsClassName implements PojoClassFilter {
- //Since Pattern doesn't implement equals, relying on String for equals & hashCode instead.
+ // Since Pattern doesn't implement equals, relying on String for equals & hashCode instead.
private final String className;
public FilterByContainsClassName(String regex) {
@@ -19,4 +19,4 @@ public class FilterByContainsClassName implements PojoClassFilter {
public int hashCode() {
return className.hashCode();
}
-} \ No newline at end of file
+}
diff --git a/src/test/java/org/onap/aai/sparky/SparkyPojoTest.java b/src/test/java/org/onap/aai/sparky/SparkyPojoTest.java
index ce50718..bc56223 100644
--- a/src/test/java/org/onap/aai/sparky/SparkyPojoTest.java
+++ b/src/test/java/org/onap/aai/sparky/SparkyPojoTest.java
@@ -16,178 +16,206 @@ import com.openpojo.validation.test.impl.GetterTester;
import com.openpojo.validation.test.impl.SetterTester;
public class SparkyPojoTest {
-//The package to be tested
+ // The package to be tested
private String packageName = "org.onap.aai.sparky";
private List<PojoClass> pojoClasses;
-@Test
+ @Test
public void validateAnalytics() {
-
- String packageName = "org.onap.aai.sparky.analytics";
- List<PojoClass> analyticsPojoClasses;
-
- FilterChain filterChainByClassNameForAnalytics = new FilterChain(new FilterByContainsClassName("AveragingRingBuffer"),
- new FilterByContainsClassName("AbstractStatistics"), new FilterByContainsClassName("HistogramSampler"),
- new FilterByContainsClassName("Test"));
- analyticsPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForAnalytics);
- validateAll(analyticsPojoClasses);
-
+
+ String packageName = "org.onap.aai.sparky.analytics";
+ List<PojoClass> analyticsPojoClasses;
+
+ FilterChain filterChainByClassNameForAnalytics = new FilterChain(
+ new FilterByContainsClassName("AveragingRingBuffer"),
+ new FilterByContainsClassName("AbstractStatistics"),
+ new FilterByContainsClassName("HistogramSampler"), new FilterByContainsClassName("Test"));
+ analyticsPojoClasses =
+ PojoClassFactory.getPojoClassesRecursively(packageName, filterChainByClassNameForAnalytics);
+ validateAll(analyticsPojoClasses);
+
}
-@Test
-public void validateAAIConfig() {
-
- String packageName = "org.onap.aai.sparky.dal.aai.config";
- List<PojoClass> aaiConfigPojoClasses;
- // activeinventory config mught come back
- FilterChain filterChainByClassNameForConfig = new FilterChain(new FilterByContainsClassName("ActiveInventoryConfig"),
- new FilterByContainsClassName("Test"));
- aaiConfigPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForConfig);
- validateAll(aaiConfigPojoClasses);
-
-
-
-}
+ @Test
+ public void validateAAIConfig() {
+ String packageName = "org.onap.aai.sparky.dal.aai.config";
+ List<PojoClass> aaiConfigPojoClasses;
+ // activeinventory config mught come back
+ FilterChain filterChainByClassNameForConfig =
+ new FilterChain(new FilterByContainsClassName("ActiveInventoryConfig"),
+ new FilterByContainsClassName("Test"));
+ aaiConfigPojoClasses =
+ PojoClassFactory.getPojoClassesRecursively(packageName, filterChainByClassNameForConfig);
+ validateAll(aaiConfigPojoClasses);
-@Test
-public void validateElasticSearch(){
-
- String packageName = "org.onap.aai.sparky.dal.elasticsearch";
- List<PojoClass> elasticSearchPojoClasses;
-
- FilterChain filterChainByClassNameForElasticSearch = new FilterChain(new FilterByContainsClassName("ElasticSearchEntityStatistics"),
- new FilterByContainsClassName("Test"));
- elasticSearchPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForElasticSearch);
- validateAll(elasticSearchPojoClasses);
-
-
-}
-@Test
-public void validateElasticSearchEntity(){
-
- String packageName = "org.onap.aai.sparky.dal.elasticsearch.entity";
- List<PojoClass> elasticSearchConfigPojoClasses;
-
- //FilterChain filterChainByClassNameForElasticSearchConfig = new FilterChain(new FilterByContainsClassName("ElasticSearchEntityStatistics"),
- // new FilterByContainsClassName("Test"));
- elasticSearchConfigPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,null);
- validateAll(elasticSearchConfigPojoClasses);
-
-}
+ }
-@Test
-public void validateRest(){
-
- String packageName = "org.onap.aai.sparky.dal.rest";
- List<PojoClass> restPojoClasses;
-
- FilterChain filterChainByClassNameForRest = new FilterChain(new FilterByContainsClassName("RestfulDataAccessor"),
- new FilterByContainsClassName("Test"),new FilterByContainsClassName("RestOperationalStatistics"),
- new FilterByContainsClassName("RestClientBuilder"));
- restPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForRest);
- validateAll(restPojoClasses);
-}
+ @Test
+ public void validateElasticSearch() {
+ String packageName = "org.onap.aai.sparky.dal.elasticsearch";
+ List<PojoClass> elasticSearchPojoClasses;
-@Test
-public void validateSASEntity(){
+ FilterChain filterChainByClassNameForElasticSearch =
+ new FilterChain(new FilterByContainsClassName("ElasticSearchEntityStatistics"),
+ new FilterByContainsClassName("Test"));
+ elasticSearchPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,
+ filterChainByClassNameForElasticSearch);
+ validateAll(elasticSearchPojoClasses);
- String packageName = "org.onap.aai.sparky.dal.sas.entity";
- List<PojoClass> sasEntityPojoClasses;
-
- sasEntityPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,null);
- validateAll(sasEntityPojoClasses);
-
-}
+ }
-@Test
-public void validateSecurity(){
- String packageName = "org.onap.aai.sparky.security";
- List<PojoClass> securityPojoClasses;
-
- FilterChain filterChainByClassNameForSecurity = new FilterChain(new FilterByContainsClassName("SecurityContextFactoryImpl"),
- new FilterByContainsClassName("Test"), new FilterByContainsClassName("UserManager"),
- new FilterByContainsClassName("RolesConfig"),new FilterByContainsClassName("PortalAuthenticationConfig"));
- securityPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForSecurity);
- validateAll(securityPojoClasses);
-}
+ @Test
+ public void validateElasticSearchEntity() {
+ String packageName = "org.onap.aai.sparky.dal.elasticsearch.entity";
+ List<PojoClass> elasticSearchConfigPojoClasses;
-@Test
-public void validateSecurityPortal(){
+ // FilterChain filterChainByClassNameForElasticSearchConfig = new FilterChain(new
+ // FilterByContainsClassName("ElasticSearchEntityStatistics"),
+ // new FilterByContainsClassName("Test"));
+ elasticSearchConfigPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName, null);
+ validateAll(elasticSearchConfigPojoClasses);
- String packageName = "org.onap.aai.sparky.security.portal";
- List<PojoClass> securityPortalPojoClasses;
-
- FilterChain filterChainByClassNameForSecurityPortal = new FilterChain(new FilterByContainsClassName("Test"),
- new FilterByContainsClassName("UserManager"),new FilterByContainsClassName("RolesConfig"),
- new FilterByContainsClassName("PortalAuthenticationConfig"));
- securityPortalPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForSecurityPortal);
- validateAll(securityPortalPojoClasses);
-}
+ }
-@Test
-public void validateSynchronizer(){
-
- String packageName = "org.onap.aai.sparky.synchronizer";
- List<PojoClass> synchronizerPojoClasses;
-
- FilterChain filterChainByClassNameForSynchronizer = new FilterChain(new FilterByContainsClassName("Test"),
- new FilterByContainsClassName("AggregationSynchronizer"),new FilterByContainsClassName("SearchableEntitySynchronizer"),
- new FilterByContainsClassName("AutosuggestionSynchronizer"),new FilterByContainsClassName("CrossEntityReferenceSynchronizer"),
- new FilterByContainsClassName("SyncController"),new FilterByContainsClassName("SyncHelper"),
- new FilterByContainsClassName("TransactionRateController"),new FilterByContainsClassName("AggregationSuggestionSynchronizer"),
- new FilterByContainsClassName("AbstractEntitySynchronizer"),new FilterByContainsClassName("SynchronizerConfiguration"));
- synchronizerPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForSynchronizer);
- validateAll(synchronizerPojoClasses);
-}
+ @Test
+ public void validateRest() {
-@Test
-public void validateUtil(){
-
- String packageName = "org.onap.aai.sparky.util";
- List<PojoClass> utilPojoClasses;
-
- FilterChain filterChainByClassNameForUtil = new FilterChain(new FilterByContainsClassName("KeystoreBuilder"),
- new FilterByContainsClassName("Test"),new FilterByContainsClassName("HttpServletHelper"),new FilterByContainsClassName("NodeUtils"),
- new FilterByContainsClassName("CaptureLoggerAppender"),new FilterByContainsClassName("ElasticEntitySummarizer"),
- new FilterByContainsClassName("ElasticGarbageInjector"),new FilterByContainsClassName("SuggestionsPermutation"),
- new FilterByContainsClassName("savingTrustManager"));
- utilPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForUtil);
- validateAll(utilPojoClasses);
-}
+ String packageName = "org.onap.aai.sparky.dal.rest";
+ List<PojoClass> restPojoClasses;
-@Test
-public void validateViewAndInspect(){
-
- String packageName = "org.onap.aai.sparky.viewandinspect";
- List<PojoClass> viewAndInspectPojoClasses;
-
- FilterChain filterChainByClassNameForViewAndInspect = new FilterChain(new FilterByContainsClassName("Test"),
- new FilterByContainsClassName("PerformSelfLinkDetermination"),new FilterByContainsClassName("PerformNodeSelfLinkProcessingTask"),
- new FilterByContainsClassName("ActiveInventoryNode"),new FilterByContainsClassName("NodeProcessingTransaction"),
- new FilterByContainsClassName("VisualizationServlet"),new FilterByContainsClassName("VisualizationService"),
- new FilterByContainsClassName("VisualizationContext"));
- viewAndInspectPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,filterChainByClassNameForViewAndInspect);
- validateAll(viewAndInspectPojoClasses);
-}
+ FilterChain filterChainByClassNameForRest = new FilterChain(
+ new FilterByContainsClassName("RestfulDataAccessor"), new FilterByContainsClassName("Test"),
+ new FilterByContainsClassName("RestOperationalStatistics"),
+ new FilterByContainsClassName("RestClientBuilder"));
+ restPojoClasses =
+ PojoClassFactory.getPojoClassesRecursively(packageName, filterChainByClassNameForRest);
+ validateAll(restPojoClasses);
+ }
-public void validateAll(List<PojoClass> pojoClasses){
-
- Validator validator = ValidatorBuilder.create()
- .with(new SetterMustExistRule(),
- new GetterMustExistRule())
- .with(new SetterTester(),
- new GetterTester())
- .build();
-validator.validate(pojoClasses);
-}
-} \ No newline at end of file
+ @Test
+ public void validateSASEntity() {
+
+ String packageName = "org.onap.aai.sparky.dal.sas.entity";
+ List<PojoClass> sasEntityPojoClasses;
+
+ sasEntityPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName, null);
+ validateAll(sasEntityPojoClasses);
+
+ }
+
+
+ @Test
+ public void validateSecurity() {
+
+ String packageName = "org.onap.aai.sparky.security";
+ List<PojoClass> securityPojoClasses;
+
+ FilterChain filterChainByClassNameForSecurity =
+ new FilterChain(new FilterByContainsClassName("SecurityContextFactoryImpl"),
+ new FilterByContainsClassName("Test"), new FilterByContainsClassName("UserManager"),
+ new FilterByContainsClassName("RolesConfig"),
+ new FilterByContainsClassName("PortalAuthenticationConfig"));
+ securityPojoClasses =
+ PojoClassFactory.getPojoClassesRecursively(packageName, filterChainByClassNameForSecurity);
+ validateAll(securityPojoClasses);
+ }
+
+
+ @Test
+ public void validateSecurityPortal() {
+
+ String packageName = "org.onap.aai.sparky.security.portal";
+ List<PojoClass> securityPortalPojoClasses;
+
+ FilterChain filterChainByClassNameForSecurityPortal = new FilterChain(
+ new FilterByContainsClassName("Test"), new FilterByContainsClassName("UserManager"),
+ new FilterByContainsClassName("RolesConfig"),
+ new FilterByContainsClassName("PortalAuthenticationConfig"));
+ securityPortalPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,
+ filterChainByClassNameForSecurityPortal);
+ validateAll(securityPortalPojoClasses);
+ }
+
+
+ @Test
+ public void validateSynchronizer() {
+
+ String packageName = "org.onap.aai.sparky.synchronizer";
+ List<PojoClass> synchronizerPojoClasses;
+
+ FilterChain filterChainByClassNameForSynchronizer =
+ new FilterChain(new FilterByContainsClassName("Test"),
+ new FilterByContainsClassName("AggregationSynchronizer"),
+ new FilterByContainsClassName("SearchableEntitySynchronizer"),
+ new FilterByContainsClassName("AutosuggestionSynchronizer"),
+ new FilterByContainsClassName("CrossEntityReferenceSynchronizer"),
+ new FilterByContainsClassName("SyncController"),
+ new FilterByContainsClassName("SyncHelper"),
+ new FilterByContainsClassName("TransactionRateController"),
+ new FilterByContainsClassName("AggregationSuggestionSynchronizer"),
+ new FilterByContainsClassName("AbstractEntitySynchronizer"),
+ new FilterByContainsClassName("SynchronizerConfiguration"));
+ synchronizerPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,
+ filterChainByClassNameForSynchronizer);
+ validateAll(synchronizerPojoClasses);
+ }
+
+ @Test
+ public void validateUtil() {
+
+ String packageName = "org.onap.aai.sparky.util";
+ List<PojoClass> utilPojoClasses;
+
+ FilterChain filterChainByClassNameForUtil = new FilterChain(
+ new FilterByContainsClassName("KeystoreBuilder"), new FilterByContainsClassName("Test"),
+ new FilterByContainsClassName("HttpServletHelper"),
+ new FilterByContainsClassName("NodeUtils"),
+ new FilterByContainsClassName("CaptureLoggerAppender"),
+ new FilterByContainsClassName("ElasticEntitySummarizer"),
+ new FilterByContainsClassName("ElasticGarbageInjector"),
+ new FilterByContainsClassName("SuggestionsPermutation"),
+ new FilterByContainsClassName("savingTrustManager"));
+ utilPojoClasses =
+ PojoClassFactory.getPojoClassesRecursively(packageName, filterChainByClassNameForUtil);
+ validateAll(utilPojoClasses);
+ }
+
+ @Test
+ public void validateViewAndInspect() {
+
+ String packageName = "org.onap.aai.sparky.viewandinspect";
+ List<PojoClass> viewAndInspectPojoClasses;
+
+ FilterChain filterChainByClassNameForViewAndInspect =
+ new FilterChain(new FilterByContainsClassName("Test"),
+ new FilterByContainsClassName("PerformSelfLinkDetermination"),
+ new FilterByContainsClassName("PerformNodeSelfLinkProcessingTask"),
+ new FilterByContainsClassName("ActiveInventoryNode"),
+ new FilterByContainsClassName("NodeProcessingTransaction"),
+ new FilterByContainsClassName("VisualizationServlet"),
+ new FilterByContainsClassName("VisualizationService"),
+ new FilterByContainsClassName("VisualizationContext"));
+ viewAndInspectPojoClasses = PojoClassFactory.getPojoClassesRecursively(packageName,
+ filterChainByClassNameForViewAndInspect);
+ validateAll(viewAndInspectPojoClasses);
+ }
+
+ public void validateAll(List<PojoClass> pojoClasses) {
+
+ Validator validator =
+ ValidatorBuilder.create().with(new SetterMustExistRule(), new GetterMustExistRule())
+ .with(new SetterTester(), new GetterTester()).build();
+ validator.validate(pojoClasses);
+ }
+
+}
diff --git a/src/test/java/org/onap/aai/sparky/analytics/AbstractStatisticsTest.java b/src/test/java/org/onap/aai/sparky/analytics/AbstractStatisticsTest.java
index a420e1d..c2ab18f 100644
--- a/src/test/java/org/onap/aai/sparky/analytics/AbstractStatisticsTest.java
+++ b/src/test/java/org/onap/aai/sparky/analytics/AbstractStatisticsTest.java
@@ -5,42 +5,42 @@ import org.junit.Test;
public class AbstractStatisticsTest {
- @Test
- public void testAllMethods() {
- AbstractStatistics abs = new AbstractStatistics();
-
- int counterValue1 = abs.getCounterValue("key");
- Assert.assertEquals(-1, counterValue1);
-
- abs.addCounter("key");
- int counterValue2 = abs.getCounterValue("key");
- Assert.assertEquals(0, counterValue2);
-
- abs.pegCounter("key");
- int counterValue3 = abs.getCounterValue("key");
- Assert.assertEquals(1, counterValue3);
-
- abs.incrementCounter("key", 2);
- int counterValue4 = abs.getCounterValue("key");
- Assert.assertEquals(3, counterValue4);
-
- String histStat1 = abs.getHistogramStats("key", false, " ");
- Assert.assertNull(histStat1);
-
- abs.addHistogram("key", "hist1", 10, 1, 2);
- String histStat2 = abs.getHistogramStats("key", false, " ");
- Assert.assertEquals(" hist1,-1,0,0,0,1,10.00,0",histStat2);
-
- abs.updateHistogram("key", 3);
- String histStat3 = abs.getHistogramStats("key", false, " ");
- Assert.assertEquals(" hist1,3,3,3,1,1,10.00,1",histStat3);
-
- abs.reset();
- int counterValue5 = abs.getCounterValue("key");
- String histStat4 = abs.getHistogramStats("key", false, " ");
- Assert.assertEquals(0, counterValue5);
- Assert.assertEquals(" hist1,-1,0,0,0,1,10.00,0",histStat4);
-
-
- }
+ @Test
+ public void testAllMethods() {
+ AbstractStatistics abs = new AbstractStatistics();
+
+ int counterValue1 = abs.getCounterValue("key");
+ Assert.assertEquals(-1, counterValue1);
+
+ abs.addCounter("key");
+ int counterValue2 = abs.getCounterValue("key");
+ Assert.assertEquals(0, counterValue2);
+
+ abs.pegCounter("key");
+ int counterValue3 = abs.getCounterValue("key");
+ Assert.assertEquals(1, counterValue3);
+
+ abs.incrementCounter("key", 2);
+ int counterValue4 = abs.getCounterValue("key");
+ Assert.assertEquals(3, counterValue4);
+
+ String histStat1 = abs.getHistogramStats("key", false, " ");
+ Assert.assertNull(histStat1);
+
+ abs.addHistogram("key", "hist1", 10, 1, 2);
+ String histStat2 = abs.getHistogramStats("key", false, " ");
+ Assert.assertEquals(" hist1,-1,0,0,0,1,10.00,0", histStat2);
+
+ abs.updateHistogram("key", 3);
+ String histStat3 = abs.getHistogramStats("key", false, " ");
+ Assert.assertEquals(" hist1,3,3,3,1,1,10.00,1", histStat3);
+
+ abs.reset();
+ int counterValue5 = abs.getCounterValue("key");
+ String histStat4 = abs.getHistogramStats("key", false, " ");
+ Assert.assertEquals(0, counterValue5);
+ Assert.assertEquals(" hist1,-1,0,0,0,1,10.00,0", histStat4);
+
+
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/analytics/AveragingRingBufferTest.java b/src/test/java/org/onap/aai/sparky/analytics/AveragingRingBufferTest.java
index 4c37c08..89d32ef 100644
--- a/src/test/java/org/onap/aai/sparky/analytics/AveragingRingBufferTest.java
+++ b/src/test/java/org/onap/aai/sparky/analytics/AveragingRingBufferTest.java
@@ -38,7 +38,7 @@ import org.mockito.runners.MockitoJUnitRunner;
/**
* The Class AveragingRingBufferTest.
*/
-@RunWith(MockitoJUnitRunner.class)
+@RunWith(MockitoJUnitRunner.class)
public class AveragingRingBufferTest {
protected SecureRandom random = new SecureRandom();
diff --git a/src/test/java/org/onap/aai/sparky/analytics/HistogramSamplerTest.java b/src/test/java/org/onap/aai/sparky/analytics/HistogramSamplerTest.java
index 60a67d5..63d24a6 100644
--- a/src/test/java/org/onap/aai/sparky/analytics/HistogramSamplerTest.java
+++ b/src/test/java/org/onap/aai/sparky/analytics/HistogramSamplerTest.java
@@ -36,7 +36,7 @@ import org.mockito.runners.MockitoJUnitRunner;
/**
* The Class HistogramSamplerTest.
*/
-@RunWith(MockitoJUnitRunner.class)
+@RunWith(MockitoJUnitRunner.class)
public class HistogramSamplerTest {
protected SecureRandom random = new SecureRandom();
diff --git a/src/test/java/org/onap/aai/sparky/analytics/HistoricalCounterTest.java b/src/test/java/org/onap/aai/sparky/analytics/HistoricalCounterTest.java
index 9816fff..f8f4b99 100644
--- a/src/test/java/org/onap/aai/sparky/analytics/HistoricalCounterTest.java
+++ b/src/test/java/org/onap/aai/sparky/analytics/HistoricalCounterTest.java
@@ -5,48 +5,48 @@ import org.junit.Test;
public class HistoricalCounterTest {
-
- @Test
- public void testAllMethods() {
- HistoricalCounter hc = new HistoricalCounter(true);
-
- boolean maintainSingleValue = hc.isSingleValue();
- Assert.assertTrue(maintainSingleValue);
-
- hc.update(1.0);
- double value = hc.getValue();
- Assert.assertEquals(1.0, value, 0.1);
-
- double min = hc.getMin();
- Assert.assertEquals(-1, min, 0.1);
-
- double max = hc.getMax();
- Assert.assertEquals(0, max, 0.1);
-
- long numOfSamples = hc.getNumSamples();
- Assert.assertEquals(0, numOfSamples, 0.1);
-
- double avg = hc.getAvg();
- Assert.assertEquals(0, avg, 0.1);
-
- String stringValue = hc.toString();
- Assert.assertNotNull(stringValue);
-
- hc.reset();
-
- double valueReset = hc.getValue();
- Assert.assertEquals(0.0, valueReset, 0.1);
-
- double minReset = hc.getMin();
- Assert.assertEquals(-1, minReset, 0.1);
-
- double maxReset = hc.getMax();
- Assert.assertEquals(0, maxReset, 0.1);
-
- long numOfSamplesReset = hc.getNumSamples();
- Assert.assertEquals(0, numOfSamplesReset, 0.1);
-
- double avgReset = hc.getAvg();
- Assert.assertEquals(0, avgReset, 0.1);
- }
+
+ @Test
+ public void testAllMethods() {
+ HistoricalCounter hc = new HistoricalCounter(true);
+
+ boolean maintainSingleValue = hc.isSingleValue();
+ Assert.assertTrue(maintainSingleValue);
+
+ hc.update(1.0);
+ double value = hc.getValue();
+ Assert.assertEquals(1.0, value, 0.1);
+
+ double min = hc.getMin();
+ Assert.assertEquals(-1, min, 0.1);
+
+ double max = hc.getMax();
+ Assert.assertEquals(0, max, 0.1);
+
+ long numOfSamples = hc.getNumSamples();
+ Assert.assertEquals(0, numOfSamples, 0.1);
+
+ double avg = hc.getAvg();
+ Assert.assertEquals(0, avg, 0.1);
+
+ String stringValue = hc.toString();
+ Assert.assertNotNull(stringValue);
+
+ hc.reset();
+
+ double valueReset = hc.getValue();
+ Assert.assertEquals(0.0, valueReset, 0.1);
+
+ double minReset = hc.getMin();
+ Assert.assertEquals(-1, minReset, 0.1);
+
+ double maxReset = hc.getMax();
+ Assert.assertEquals(0, maxReset, 0.1);
+
+ long numOfSamplesReset = hc.getNumSamples();
+ Assert.assertEquals(0, numOfSamplesReset, 0.1);
+
+ double avgReset = hc.getAvg();
+ Assert.assertEquals(0, avgReset, 0.1);
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/config/oxm/CrossEntityReferenceTest.java b/src/test/java/org/onap/aai/sparky/config/oxm/CrossEntityReferenceTest.java
index 205cefd..0ef0458 100644
--- a/src/test/java/org/onap/aai/sparky/config/oxm/CrossEntityReferenceTest.java
+++ b/src/test/java/org/onap/aai/sparky/config/oxm/CrossEntityReferenceTest.java
@@ -6,22 +6,22 @@ import org.onap.aai.sparky.config.oxm.CrossEntityReference;
public class CrossEntityReferenceTest {
-
- @Test
- public void testCrossEntityReferenceAllMethods() {
- CrossEntityReference cer = new CrossEntityReference();
-
- Assert.assertNull(cer.getTargetEntityType());
-
- cer.setTargetEntityType("TET");
- Assert.assertEquals(cer.getTargetEntityType(), "TET");
-
- Assert.assertEquals(cer.getReferenceAttributes().size(), 0);
-
- cer.addReferenceAttribute("AT");
-
- Assert.assertEquals(cer.getReferenceAttributes().size(), 1);
-
- Assert.assertNotNull(cer.toString());
- }
+
+ @Test
+ public void testCrossEntityReferenceAllMethods() {
+ CrossEntityReference cer = new CrossEntityReference();
+
+ Assert.assertNull(cer.getTargetEntityType());
+
+ cer.setTargetEntityType("TET");
+ Assert.assertEquals(cer.getTargetEntityType(), "TET");
+
+ Assert.assertEquals(cer.getReferenceAttributes().size(), 0);
+
+ cer.addReferenceAttribute("AT");
+
+ Assert.assertEquals(cer.getReferenceAttributes().size(), 1);
+
+ Assert.assertNotNull(cer.toString());
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderFilterTest.java b/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderFilterTest.java
index 0c21c03..d971084 100644
--- a/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderFilterTest.java
+++ b/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderFilterTest.java
@@ -18,38 +18,40 @@ import org.onap.aai.sparky.config.oxm.OxmModelLoaderFilter;
public class OxmModelLoaderFilterTest {
- @Mock
- ServletRequest servletRequest;
-
- @Mock
- ServletResponse servletResponse;
-
- @Mock
- FilterChain filterChain;
-
- @Mock
- FilterConfig filterConfig;
-
- @InjectMocks
- OxmModelLoaderFilter oxmModelLoaderFilter;
-
- @Before
- public void init() {
- MockitoAnnotations.initMocks(this);
- }
-
- @Test
- public void testDoFilter() throws IOException, ServletException{
- Mockito.doNothing().when(filterChain).doFilter(Mockito.any(ServletRequest.class), Mockito.any(ServletResponse.class));
- oxmModelLoaderFilter.doFilter(servletRequest, servletResponse, filterChain);
- Mockito.verify(filterChain, Mockito.times(1)).doFilter(Mockito.any(ServletRequest.class), Mockito.any(ServletResponse.class));
- }
-
- /*This test is taking more than 5 secs. Commented out
- @Test
- public void testInit() throws ServletException {
- OxmModelLoaderFilter oxmFilter = new OxmModelLoaderFilter();
- oxmFilter.init(filterConfig);
- }*/
-
+ @Mock
+ ServletRequest servletRequest;
+
+ @Mock
+ ServletResponse servletResponse;
+
+ @Mock
+ FilterChain filterChain;
+
+ @Mock
+ FilterConfig filterConfig;
+
+ @InjectMocks
+ OxmModelLoaderFilter oxmModelLoaderFilter;
+
+ @Before
+ public void init() {
+ MockitoAnnotations.initMocks(this);
+ }
+
+ @Test
+ public void testDoFilter() throws IOException, ServletException {
+ Mockito.doNothing().when(filterChain).doFilter(Mockito.any(ServletRequest.class),
+ Mockito.any(ServletResponse.class));
+ oxmModelLoaderFilter.doFilter(servletRequest, servletResponse, filterChain);
+ Mockito.verify(filterChain, Mockito.times(1)).doFilter(Mockito.any(ServletRequest.class),
+ Mockito.any(ServletResponse.class));
+ }
+
+ /*
+ * This test is taking more than 5 secs. Commented out
+ *
+ * @Test public void testInit() throws ServletException { OxmModelLoaderFilter oxmFilter = new
+ * OxmModelLoaderFilter(); oxmFilter.init(filterConfig); }
+ */
+
}
diff --git a/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderTest.java b/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderTest.java
index 3ef571e..5ff9e85 100644
--- a/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderTest.java
+++ b/src/test/java/org/onap/aai/sparky/config/oxm/OxmModelLoaderTest.java
@@ -32,19 +32,19 @@ import org.mockito.Mockito;
public class OxmModelLoaderTest {
- OxmModelLoader loader;
-
- @Test
- public void testLoadModel_ShouldSucceed() throws IOException {
- String version = "v11";
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ OxmModelLoader loader;
- loader = Mockito.spy(new OxmModelLoader());
- Mockito.when(loader.loadOxmFileName(version)).thenReturn(
- System.getProperty("AJSC_HOME") + "/bundleconfig-local/oxm/aai_oxm_" + version + ".xml");
+ @Test
+ public void testLoadModel_ShouldSucceed() throws IOException {
+ String version = "v11";
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- loader.loadModel(version);
+ loader = Mockito.spy(new OxmModelLoader());
+ Mockito.when(loader.loadOxmFileName(version)).thenReturn(
+ System.getProperty("AJSC_HOME") + "/bundleconfig-local/oxm/aai_oxm_" + version + ".xml");
- assertNotEquals(null, loader.getOxmModel());
- }
+ loader.loadModel(version);
+
+ assertNotEquals(null, loader.getOxmModel());
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/NetworkTransactionTest.java b/src/test/java/org/onap/aai/sparky/dal/NetworkTransactionTest.java
index 0e3c398..f2098fb 100644
--- a/src/test/java/org/onap/aai/sparky/dal/NetworkTransactionTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/NetworkTransactionTest.java
@@ -8,29 +8,29 @@ import org.onap.aai.sparky.dal.rest.OperationResult;
public class NetworkTransactionTest {
- @Test
- public void testAllMethods() {
- NetworkTransaction ntt = new NetworkTransaction();
- ntt.setOperationType(HttpMethod.GET);
- Assert.assertEquals(HttpMethod.GET, ntt.getOperationType());
-
- ntt.setTaskAgeInMs();
- Assert.assertNotNull(ntt.getTaskAgeInMs());
-
- ntt.setOperationResult(new OperationResult());
- Assert.assertNotNull(ntt.getOperationResult());
-
- ntt.setEntityType("entity");
- Assert.assertEquals(ntt.getEntityType(), "entity");
-
- ntt.setLink("link");
- Assert.assertEquals(ntt.getLink(), "link");
-
- ntt.setDescriptor(new OxmEntityDescriptor());
- Assert.assertNotNull(ntt.getDescriptor());
-
- Assert.assertNotNull(ntt.toString());
- }
-
-
+ @Test
+ public void testAllMethods() {
+ NetworkTransaction ntt = new NetworkTransaction();
+ ntt.setOperationType(HttpMethod.GET);
+ Assert.assertEquals(HttpMethod.GET, ntt.getOperationType());
+
+ ntt.setTaskAgeInMs();
+ Assert.assertNotNull(ntt.getTaskAgeInMs());
+
+ ntt.setOperationResult(new OperationResult());
+ Assert.assertNotNull(ntt.getOperationResult());
+
+ ntt.setEntityType("entity");
+ Assert.assertEquals(ntt.getEntityType(), "entity");
+
+ ntt.setLink("link");
+ Assert.assertEquals(ntt.getLink(), "link");
+
+ ntt.setDescriptor(new OxmEntityDescriptor());
+ Assert.assertNotNull(ntt.getDescriptor());
+
+ Assert.assertNotNull(ntt.toString());
+ }
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryAdapterTest.java b/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryAdapterTest.java
index 9f18ab2..936bc72 100644
--- a/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryAdapterTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryAdapterTest.java
@@ -35,68 +35,70 @@ import org.onap.aai.sparky.dal.rest.RestClientBuilder;
import org.onap.aai.sparky.viewandinspect.config.TierSupportUiConstants;
public class ActiveInventoryAdapterTest {
-
- OxmModelLoader oxmModelLoader;
- ActiveInventoryAdapter adapter;
-
- @Before
- public void init() throws IOException, ElasticSearchOperationException {
- String version = "v11";
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/";
- oxmModelLoader = Mockito.spy(new OxmModelLoader());
- Mockito.when(oxmModelLoader.loadOxmFileName(version)).thenReturn(
+
+ OxmModelLoader oxmModelLoader;
+ ActiveInventoryAdapter adapter;
+
+ @Before
+ public void init() throws IOException, ElasticSearchOperationException {
+ String version = "v11";
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION =
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/";
+ oxmModelLoader = Mockito.spy(new OxmModelLoader());
+ Mockito.when(oxmModelLoader.loadOxmFileName(version)).thenReturn(
System.getProperty("AJSC_HOME") + "/bundleconfig-local/oxm/aai_oxm_" + version + ".xml");
-
- adapter = new ActiveInventoryAdapter(new RestClientBuilder());
- }
-
- @Test
- public void testQueryActiveInventoryWithRetries() {
-
- adapter.queryActiveInventoryWithRetries("https://localhost:9517/model/aai/webapp/index.html", "response-type-1", 1);
- }
-
- @Test(expected=NullPointerException.class)
- public void testGetSelfLinkForEntity_NullEntityType() throws Exception {
-
- adapter.getSelfLinkForEntity(null, "key", "value");
- }
-
- @Test(expected=NullPointerException.class)
- public void testGetSelfLinkForEntity_NullKeyName() throws Exception {
-
- adapter.getSelfLinkForEntity("entity", null, "value");
- }
-
- @Test(expected=NullPointerException.class)
- public void testGetSelfLinkForEntity_NullKeyValue() throws Exception {
-
- adapter.getSelfLinkForEntity("entity", "key", null);
- }
-
- @Test
- public void testGetSelfLinkForEntity_ServiceInstance() throws Exception {
-
- adapter.getSelfLinkForEntity("service-instance", "key", "value");
- }
-
- @Test
- public void testGetSelfLinkForEntity_NotServiceInstance() throws Exception {
-
- adapter.getSelfLinkForEntity("service", "key", "value");
- }
-
- @Test(expected=NullPointerException.class)
- public void testGetSelfLinkByEntityType_NullEntity() throws Exception {
-
- adapter.getSelfLinksByEntityType(null);
- }
-
- @Test(expected=NoSuchElementException.class)
- public void testGetSelfLinkByEntityType_NullEntityDescriptor() throws Exception {
-
- adapter.getSelfLinksByEntityType("entity-1");
- }
+
+ adapter = new ActiveInventoryAdapter(new RestClientBuilder());
+ }
+
+ @Test
+ public void testQueryActiveInventoryWithRetries() {
+
+ adapter.queryActiveInventoryWithRetries("https://localhost:9517/model/aai/webapp/index.html",
+ "response-type-1", 1);
+ }
+
+ @Test(expected = NullPointerException.class)
+ public void testGetSelfLinkForEntity_NullEntityType() throws Exception {
+
+ adapter.getSelfLinkForEntity(null, "key", "value");
+ }
+
+ @Test(expected = NullPointerException.class)
+ public void testGetSelfLinkForEntity_NullKeyName() throws Exception {
+
+ adapter.getSelfLinkForEntity("entity", null, "value");
+ }
+
+ @Test(expected = NullPointerException.class)
+ public void testGetSelfLinkForEntity_NullKeyValue() throws Exception {
+
+ adapter.getSelfLinkForEntity("entity", "key", null);
+ }
+
+ @Test
+ public void testGetSelfLinkForEntity_ServiceInstance() throws Exception {
+
+ adapter.getSelfLinkForEntity("service-instance", "key", "value");
+ }
+
+ @Test
+ public void testGetSelfLinkForEntity_NotServiceInstance() throws Exception {
+
+ adapter.getSelfLinkForEntity("service", "key", "value");
+ }
+
+ @Test(expected = NullPointerException.class)
+ public void testGetSelfLinkByEntityType_NullEntity() throws Exception {
+
+ adapter.getSelfLinksByEntityType(null);
+ }
+
+ @Test(expected = NoSuchElementException.class)
+ public void testGetSelfLinkByEntityType_NullEntityDescriptor() throws Exception {
+
+ adapter.getSelfLinksByEntityType("entity-1");
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryEntityStatisticsTest.java b/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryEntityStatisticsTest.java
index b1357c4..f861a68 100644
--- a/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryEntityStatisticsTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryEntityStatisticsTest.java
@@ -14,62 +14,62 @@ import org.onap.aai.sparky.dal.rest.OperationResult;
public class ActiveInventoryEntityStatisticsTest {
- OxmModelLoader oxmModelLoader;
-
- @Before
- public void init() {
- oxmModelLoader = OxmModelLoader.getInstance();
- }
-
- @Test
- public void testInitializeCountersFromOxmEntityDescriptors_NotNullDescriptors() {
- ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);
-
- Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
-
- OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
- oxmEd.setEntityName("entity-1");
- oxmEd.setGeoLatName("geoLatName-1");
-
- descriptors.put("entity-1", oxmEd);
-
- aies.initializeCountersFromOxmEntityDescriptors(descriptors);
-
- aies.reset();
-
- }
-
- @Test
- public void testInitializeCountersFromOxmEntityDescriptors_NullDescriptors() {
- ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);
-
- Map<String, OxmEntityDescriptor> descriptors = null;
-
- aies.initializeCountersFromOxmEntityDescriptors(descriptors);
-
- }
-
- @Test
- public void testUpdateCounters() {
-
- ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);
- Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
- OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
- oxmEd.setEntityName("entity-1");
- oxmEd.setGeoLatName("geoLatName-1");
- descriptors.put("entity-1", oxmEd);
- aies.initializeCountersFromOxmEntityDescriptors(descriptors);
-
- OperationResult result = new OperationResult();
- result.setResultCode(200);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
-
- aies.updateCounters(ntwTxn);
-
- String statistics = aies.getStatisticsReport();
- Assert.assertNotNull(statistics);
-
- }
+ OxmModelLoader oxmModelLoader;
+
+ @Before
+ public void init() {
+ oxmModelLoader = OxmModelLoader.getInstance();
+ }
+
+ @Test
+ public void testInitializeCountersFromOxmEntityDescriptors_NotNullDescriptors() {
+ ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);
+
+ Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
+
+ OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
+ oxmEd.setEntityName("entity-1");
+ oxmEd.setGeoLatName("geoLatName-1");
+
+ descriptors.put("entity-1", oxmEd);
+
+ aies.initializeCountersFromOxmEntityDescriptors(descriptors);
+
+ aies.reset();
+
+ }
+
+ @Test
+ public void testInitializeCountersFromOxmEntityDescriptors_NullDescriptors() {
+ ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);
+
+ Map<String, OxmEntityDescriptor> descriptors = null;
+
+ aies.initializeCountersFromOxmEntityDescriptors(descriptors);
+
+ }
+
+ @Test
+ public void testUpdateCounters() {
+
+ ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);
+ Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
+ OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
+ oxmEd.setEntityName("entity-1");
+ oxmEd.setGeoLatName("geoLatName-1");
+ descriptors.put("entity-1", oxmEd);
+ aies.initializeCountersFromOxmEntityDescriptors(descriptors);
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(200);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+
+ aies.updateCounters(ntwTxn);
+
+ String statistics = aies.getStatisticsReport();
+ Assert.assertNotNull(statistics);
+
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryProcessingExceptionStatisticsTest.java b/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryProcessingExceptionStatisticsTest.java
index 5677f4c..2b65655 100644
--- a/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryProcessingExceptionStatisticsTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/aai/ActiveInventoryProcessingExceptionStatisticsTest.java
@@ -8,53 +8,55 @@ import org.onap.aai.sparky.dal.rest.OperationResult;
public class ActiveInventoryProcessingExceptionStatisticsTest {
-
- @Test
- public void testUpdateCounters() {
- ActiveInventoryProcessingExceptionStatistics aipes = new ActiveInventoryProcessingExceptionStatistics();
-
- aipes.incrementCounter("NativeSocketConnectException", 1);
- aipes.incrementCounter("NativeSocketConnectionReset", 1);
- aipes.incrementCounter("NativeSocketConnectionRefused", 1);
- aipes.incrementCounter("JerseyClientTimoutException", 1);
- aipes.incrementCounter("UnknownException", 1);
-
- OperationResult result = new OperationResult();
- result.setResultCode(310);
- result.setResult("java.net.SocketTimeoutException: connect timed out");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- aipes.updateCounters(ntwTxn1);
-
- result.setResult("result-1");
- NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- aipes.updateCounters(ntwTxn2);
-
- result.setResult("java.net.ConnectException: Connection timed out: connect");
- NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- aipes.updateCounters(ntwTxn3);
-
- result.setResult("java.net.ConnectException: Connection refused: connect");
- NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- aipes.updateCounters(ntwTxn4);
-
- result.setResult("java.net.SocketException: Connection reset");
- NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- aipes.updateCounters(ntwTxn5);
-
- }
-
- @Test
- public void testGetStatisticsReport() {
- ActiveInventoryProcessingExceptionStatistics aipes = new ActiveInventoryProcessingExceptionStatistics();
-
- aipes.incrementCounter("NativeSocketConnectException", 1);
- aipes.incrementCounter("NativeSocketConnectionReset", 1);
- aipes.incrementCounter("NativeSocketConnectionRefused", 1);
- aipes.incrementCounter("JerseyClientTimoutException", 1);
- aipes.incrementCounter("UnknownException", 1);
-
- String statReport = aipes.getStatisticsReport();
- Assert.assertNotNull(statReport);
- }
+
+ @Test
+ public void testUpdateCounters() {
+ ActiveInventoryProcessingExceptionStatistics aipes =
+ new ActiveInventoryProcessingExceptionStatistics();
+
+ aipes.incrementCounter("NativeSocketConnectException", 1);
+ aipes.incrementCounter("NativeSocketConnectionReset", 1);
+ aipes.incrementCounter("NativeSocketConnectionRefused", 1);
+ aipes.incrementCounter("JerseyClientTimoutException", 1);
+ aipes.incrementCounter("UnknownException", 1);
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(310);
+ result.setResult("java.net.SocketTimeoutException: connect timed out");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ aipes.updateCounters(ntwTxn1);
+
+ result.setResult("result-1");
+ NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ aipes.updateCounters(ntwTxn2);
+
+ result.setResult("java.net.ConnectException: Connection timed out: connect");
+ NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ aipes.updateCounters(ntwTxn3);
+
+ result.setResult("java.net.ConnectException: Connection refused: connect");
+ NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ aipes.updateCounters(ntwTxn4);
+
+ result.setResult("java.net.SocketException: Connection reset");
+ NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ aipes.updateCounters(ntwTxn5);
+
+ }
+
+ @Test
+ public void testGetStatisticsReport() {
+ ActiveInventoryProcessingExceptionStatistics aipes =
+ new ActiveInventoryProcessingExceptionStatistics();
+
+ aipes.incrementCounter("NativeSocketConnectException", 1);
+ aipes.incrementCounter("NativeSocketConnectionReset", 1);
+ aipes.incrementCounter("NativeSocketConnectionRefused", 1);
+ aipes.incrementCounter("JerseyClientTimoutException", 1);
+ aipes.incrementCounter("UnknownException", 1);
+
+ String statReport = aipes.getStatisticsReport();
+ Assert.assertNotNull(statReport);
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventoryConfigTest.java b/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventoryConfigTest.java
index 0166550..9a590b8 100644
--- a/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventoryConfigTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventoryConfigTest.java
@@ -42,83 +42,83 @@ public class ActiveInventoryConfigTest {
assertNotNull(config);
}
-
+
private Properties getTestProperties() {
-
+
Properties props = new Properties();
-
- props.put("aai.rest.host","aai-host");
- props.put("aai.rest.port","8443");
- props.put("aai.rest.resourceBasePath","/aai/v10");
- props.put("aai.rest.connectTimeoutInMs","30000");
- props.put("aai.rest.readTimeoutInMs","60000");
- props.put("aai.rest.numRequestRetries","5");
- props.put("aai.rest.numResolverWorkers","15");
-
- props.put("aai.rest.cache.enabled","false");
- props.put("aai.rest.cache.numWorkers","10");
- props.put("aai.rest.cache.cacheFailures","false");
- props.put("aai.rest.cache.useCacheOnly","false");
- props.put("aai.rest.cache.storageFolderOverride","");
- props.put("aai.rest.cache.maxTimeToLiveInMs","-1");
-
- props.put("aai.rest.shallowEntities","cloud-region,complex,vnf-image,image");
-
- props.put("aai.ssl.truststore.filename","synchronizer.jks");
- props.put("aai.ssl.truststore.type","jks");
-
- props.put("aai.ssl.keystore.filename","aai-client-cert.p12");
- props.put("aai.ssl.keystore.pass","70c87528c88dcd9f9c2558d30e817868");
- props.put("aai.ssl.keystore.type","pkcs12");
-
- props.put("aai.ssl.enableDebug","false");
- props.put("aai.ssl.validateServerHostName","false");
- props.put("aai.ssl.validateServerCertificateChain","false");
-
- props.put("aai.rest.authenticationMode","SSL_CERT");
- props.put("aai.ssl.basicAuth.username","");
- props.put("aai.ssl.basicAuth.password","");
-
- props.put("aai.taskProcessor.maxConcurrentWorkers","5");
-
- props.put("aai.taskProcessor.transactionRateControllerEnabled","false");
- props.put("aai.taskProcessor.numSamplesPerThreadForRunningAverage","100");
- props.put("aai.taskProcessor.targetTPS","100");
-
- props.put("aai.taskProcessor.bytesHistogramLabel","[Response Size In Bytes]");
- props.put("aai.taskProcessor.bytesHistogramMaxYAxis","1000000");
- props.put("aai.taskProcessor.bytesHistogramNumBins","20");
- props.put("aai.taskProcessor.bytesHistogramNumDecimalPoints","2");
-
- props.put("aai.taskProcessor.queueLengthHistogramLabel","[Queue Item Length]");
- props.put("aai.taskProcessor.queueLengthHistogramMaxYAxis","20000");
- props.put("aai.taskProcessor.queueLengthHistogramNumBins","20");
- props.put("aai.taskProcessor.queueLengthHistogramNumDecimalPoints","2");
-
- props.put("aai.taskProcessor.taskAgeHistogramLabel","[Task Age In Ms]");
- props.put("aai.taskProcessor.taskAgeHistogramMaxYAxis","600000");
- props.put("aai.taskProcessor.taskAgeHistogramNumBins","20");
- props.put("aai.taskProcessor.taskAgeHistogramNumDecimalPoints","2");
-
- props.put("aai.taskProcessor.responseTimeHistogramLabel","[Response Time In Ms]");
- props.put("aai.taskProcessor.responseTimeHistogramMaxYAxis","10000");
- props.put("aai.taskProcessor.responseTimeHistogramNumBins","20");
- props.put("aai.taskProcessor.responseTimeHistogramNumDecimalPoints","2");
-
- props.put("aai.taskProcessor.tpsHistogramLabel","[Transactions Per Second]");
- props.put("aai.taskProcessor.tpsHistogramMaxYAxis","100");
- props.put("aai.taskProcessor.tpsHistogramNumBins","20");
- props.put("aai.taskProcessor.tpsHistogramNumDecimalPoints","2");
-
-
+
+ props.put("aai.rest.host", "aai-host");
+ props.put("aai.rest.port", "8443");
+ props.put("aai.rest.resourceBasePath", "/aai/v10");
+ props.put("aai.rest.connectTimeoutInMs", "30000");
+ props.put("aai.rest.readTimeoutInMs", "60000");
+ props.put("aai.rest.numRequestRetries", "5");
+ props.put("aai.rest.numResolverWorkers", "15");
+
+ props.put("aai.rest.cache.enabled", "false");
+ props.put("aai.rest.cache.numWorkers", "10");
+ props.put("aai.rest.cache.cacheFailures", "false");
+ props.put("aai.rest.cache.useCacheOnly", "false");
+ props.put("aai.rest.cache.storageFolderOverride", "");
+ props.put("aai.rest.cache.maxTimeToLiveInMs", "-1");
+
+ props.put("aai.rest.shallowEntities", "cloud-region,complex,vnf-image,image");
+
+ props.put("aai.ssl.truststore.filename", "synchronizer.jks");
+ props.put("aai.ssl.truststore.type", "jks");
+
+ props.put("aai.ssl.keystore.filename", "aai-client-cert.p12");
+ props.put("aai.ssl.keystore.pass", "70c87528c88dcd9f9c2558d30e817868");
+ props.put("aai.ssl.keystore.type", "pkcs12");
+
+ props.put("aai.ssl.enableDebug", "false");
+ props.put("aai.ssl.validateServerHostName", "false");
+ props.put("aai.ssl.validateServerCertificateChain", "false");
+
+ props.put("aai.rest.authenticationMode", "SSL_CERT");
+ props.put("aai.ssl.basicAuth.username", "");
+ props.put("aai.ssl.basicAuth.password", "");
+
+ props.put("aai.taskProcessor.maxConcurrentWorkers", "5");
+
+ props.put("aai.taskProcessor.transactionRateControllerEnabled", "false");
+ props.put("aai.taskProcessor.numSamplesPerThreadForRunningAverage", "100");
+ props.put("aai.taskProcessor.targetTPS", "100");
+
+ props.put("aai.taskProcessor.bytesHistogramLabel", "[Response Size In Bytes]");
+ props.put("aai.taskProcessor.bytesHistogramMaxYAxis", "1000000");
+ props.put("aai.taskProcessor.bytesHistogramNumBins", "20");
+ props.put("aai.taskProcessor.bytesHistogramNumDecimalPoints", "2");
+
+ props.put("aai.taskProcessor.queueLengthHistogramLabel", "[Queue Item Length]");
+ props.put("aai.taskProcessor.queueLengthHistogramMaxYAxis", "20000");
+ props.put("aai.taskProcessor.queueLengthHistogramNumBins", "20");
+ props.put("aai.taskProcessor.queueLengthHistogramNumDecimalPoints", "2");
+
+ props.put("aai.taskProcessor.taskAgeHistogramLabel", "[Task Age In Ms]");
+ props.put("aai.taskProcessor.taskAgeHistogramMaxYAxis", "600000");
+ props.put("aai.taskProcessor.taskAgeHistogramNumBins", "20");
+ props.put("aai.taskProcessor.taskAgeHistogramNumDecimalPoints", "2");
+
+ props.put("aai.taskProcessor.responseTimeHistogramLabel", "[Response Time In Ms]");
+ props.put("aai.taskProcessor.responseTimeHistogramMaxYAxis", "10000");
+ props.put("aai.taskProcessor.responseTimeHistogramNumBins", "20");
+ props.put("aai.taskProcessor.responseTimeHistogramNumDecimalPoints", "2");
+
+ props.put("aai.taskProcessor.tpsHistogramLabel", "[Transactions Per Second]");
+ props.put("aai.taskProcessor.tpsHistogramMaxYAxis", "100");
+ props.put("aai.taskProcessor.tpsHistogramNumBins", "20");
+ props.put("aai.taskProcessor.tpsHistogramNumDecimalPoints", "2");
+
+
return props;
-
-
+
+
}
@Test
public void validateAccessors() throws Exception {
-
+
ActiveInventoryConfig config = new ActiveInventoryConfig(getTestProperties());
ActiveInventoryRestConfig airc = config.getAaiRestConfig();
@@ -190,7 +190,7 @@ public class ActiveInventoryConfigTest {
assertEquals("https://aai-host:9191/aai/v10/business/customers/customer/1234",
config.repairSelfLink("/aai/v10/business/customers/customer/1234"));
}
-
+
@Test
public void validateResourcePathExtraction() throws Exception {
// https with API version
@@ -210,15 +210,14 @@ public class ActiveInventoryConfigTest {
.extractResourcePath("http://aai-host:9191/business/customers/customer/1234"));
// no scheme, host, or port
- assertEquals("business/customers/customer/1234", ActiveInventoryConfig
- .extractResourcePath("business/customers/customer/1234"));
+ assertEquals("business/customers/customer/1234",
+ ActiveInventoryConfig.extractResourcePath("business/customers/customer/1234"));
// no scheme, host, or port with API version
- assertEquals("/aai/v10/business/customers/customer/1234", ActiveInventoryConfig
- .extractResourcePath("/aai/v10/business/customers/customer/1234"));
+ assertEquals("/aai/v10/business/customers/customer/1234",
+ ActiveInventoryConfig.extractResourcePath("/aai/v10/business/customers/customer/1234"));
// no scheme, host, or port with API version
- assertEquals("", ActiveInventoryConfig
- .extractResourcePath(""));
+ assertEquals("", ActiveInventoryConfig.extractResourcePath(""));
}
-} \ No newline at end of file
+}
diff --git a/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventorySslConfigTest.java b/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventorySslConfigTest.java
index e02a6a7..d6bcf99 100644
--- a/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventorySslConfigTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/aai/config/ActiveInventorySslConfigTest.java
@@ -65,8 +65,11 @@ public class ActiveInventorySslConfigTest {
props.put("aai.ssl.validateServiceCertificateChain", "false");
props.put("aai.ssl.keystore.type", "pkcs12");
props.put("aai.ssl.keystore.filename", "/opt/app/applocal/etc/cert.crt");
- /*props.put("aai.ssl.keystore.pass", encryptor.decryptValue(value)EncryptedConfiguration.encryptToTriple("AES",
- Long.toString(123456789 % 10000), "aa1admin", "password"));*/
+ /*
+ * props.put("aai.ssl.keystore.pass",
+ * encryptor.decryptValue(value)EncryptedConfiguration.encryptToTriple("AES",
+ * Long.toString(123456789 % 10000), "aa1admin", "password"));
+ */
props.put("aai.ssl.truststore.type", "jks");
props.put("aai.ssl.truststore.filename", "/opt/app/applocal/etc/cert.crt");
props.put("aai.ssl.basicAuth.username", "username");
@@ -196,15 +199,15 @@ public class ActiveInventorySslConfigTest {
assertFalse(config.isValidateServerHostName());
assertFalse(config.isValidateServerCertificateChain());
- assertEquals(config.getKeystoreType(),"invalid");
+ assertEquals(config.getKeystoreType(), "invalid");
assertTrue(config.getKeystoreFilename().contains("null"));
- assertEquals(config.getKeystorePassword(),"");
+ assertEquals(config.getKeystorePassword(), "");
- assertEquals(config.getTruststoreType(),"invalid");
+ assertEquals(config.getTruststoreType(), "invalid");
assertTrue(config.getTruststoreFilename().contains("null"));
- assertEquals(config.getBasicAuthUsername(),"invalid");
- assertEquals(config.getBasicAuthPassword(),"invalid");
+ assertEquals(config.getBasicAuthUsername(), "invalid");
+ assertEquals(config.getBasicAuthPassword(), "invalid");
assertEquals(config.getBasicAuthenticationCredentials(),
generateAuthorizationHeaderValue("invalid", "invalid"));
@@ -240,30 +243,30 @@ public class ActiveInventorySslConfigTest {
config.setEncryptor(encryptorMock);
config.setValidateServerCertificateChain(true);
config.setValidateServerHostName(true);
-
+
assertEquals(System.getProperty("javax.net.debug"), "ssl");
assertTrue(config.isValidateServerHostName());
assertTrue(config.isValidateServerCertificateChain());
- assertEquals(config.getKeystoreType(),"test");
+ assertEquals(config.getKeystoreType(), "test");
assertTrue(config.getKeystoreFilename().contains("test"));
- assertEquals(config.getKeystorePassword(),"test");
+ assertEquals(config.getKeystorePassword(), "test");
- assertEquals(config.getTruststoreType(),"test");
+ assertEquals(config.getTruststoreType(), "test");
assertTrue(config.getTruststoreFilename().contains("test"));
- assertEquals(config.getBasicAuthUsername(),"test");
- assertEquals(config.getBasicAuthPassword(),"test");
+ assertEquals(config.getBasicAuthUsername(), "test");
+ assertEquals(config.getBasicAuthPassword(), "test");
assertEquals(config.getBasicAuthenticationCredentials(),
generateAuthorizationHeaderValue("test", "test"));
-
+
assertNotNull(config.getEncryptor());
-
+
assertTrue(config.toString().contains("ActiveInventorySslConfig"));
-
-
+
+
}
-
-
-
+
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/cache/InMemoryEntityCacheTest.java b/src/test/java/org/onap/aai/sparky/dal/cache/InMemoryEntityCacheTest.java
index 45481ce..2beb36b 100644
--- a/src/test/java/org/onap/aai/sparky/dal/cache/InMemoryEntityCacheTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/cache/InMemoryEntityCacheTest.java
@@ -6,21 +6,21 @@ import org.onap.aai.sparky.dal.rest.OperationResult;
public class InMemoryEntityCacheTest {
- @Test
- public void testInMemoryEntityCache_AllMethods() {
-
- InMemoryEntityCache imec = new InMemoryEntityCache();
-
- imec.put("key-1", null);
- Assert.assertNull(imec.get("entity-1", "key-1"));
- Assert.assertNull(imec.get("entity-1", null));
-
- OperationResult result = new OperationResult();
- result.setResultCode(200);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
-
- imec.put("key-1", result);
- Assert.assertNotNull(imec.get("entity-1", "key-1"));
- }
+ @Test
+ public void testInMemoryEntityCache_AllMethods() {
+
+ InMemoryEntityCache imec = new InMemoryEntityCache();
+
+ imec.put("key-1", null);
+ Assert.assertNull(imec.get("entity-1", "key-1"));
+ Assert.assertNull(imec.get("entity-1", null));
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(200);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+
+ imec.put("key-1", result);
+ Assert.assertNotNull(imec.get("entity-1", "key-1"));
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchConfigTest.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchConfigTest.java
index 5de9e2f..01a5bb0 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchConfigTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchConfigTest.java
@@ -48,30 +48,30 @@ import ch.qos.logback.classic.Level;
public class ElasticSearchConfigTest {
private static final String GOOD_MAPPINGS_FILE =
- "{" + "\"properties\": {" + "\"entityType\": {" + "\"type\": \"string\"" + "},"
- + "\"edgeTagQueryEntityFieldName\": {" + "\"type\": \"string\"," + "\"index\": \"no\""
- + "}," + "\"edgeTagQueryEntityFieldValue\": {" + "\"type\": \"string\","
- + "\"index\": \"no\"" + "}," + "\"searchTagIDs\" : {" + "\"type\" : \"string\"" + "},"
- + "\"searchTags\": {" + "\"type\": \"string\"," + "\"analyzer\": \"nGram_analyzer\","
- + "\"search_analyzer\": \"whitespace_analyzer\"}" + "}" + "}";
+ "{" + "\"properties\": {" + "\"entityType\": {" + "\"type\": \"string\"" + "},"
+ + "\"edgeTagQueryEntityFieldName\": {" + "\"type\": \"string\"," + "\"index\": \"no\""
+ + "}," + "\"edgeTagQueryEntityFieldValue\": {" + "\"type\": \"string\","
+ + "\"index\": \"no\"" + "}," + "\"searchTagIDs\" : {" + "\"type\" : \"string\"" + "},"
+ + "\"searchTags\": {" + "\"type\": \"string\"," + "\"analyzer\": \"nGram_analyzer\","
+ + "\"search_analyzer\": \"whitespace_analyzer\"}" + "}" + "}";
private static final String GOOD_SETTINGS_FILE = "{\"analysis\": {" + "\"filter\": {"
- + "\"nGram_filter\": {" + "\"type\": \"nGram\"," + "\"min_gram\": 1," + "\"max_gram\": 50,"
- + "\"token_chars\": [" + "\"letter\"," + "\"digit\"," + "\"punctuation\"," + "\"symbol\""
- + "]}}," + "\"analyzer\": {" + "\"nGram_analyzer\": {" + "\"type\": \"custom\","
- + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\"," + "\"asciifolding\","
- + "\"nGram_filter\"]}," + "\"whitespace_analyzer\": {" + "\"type\": \"custom\","
- + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\","
- + "\"asciifolding\"]}}}}";
+ + "\"nGram_filter\": {" + "\"type\": \"nGram\"," + "\"min_gram\": 1," + "\"max_gram\": 50,"
+ + "\"token_chars\": [" + "\"letter\"," + "\"digit\"," + "\"punctuation\"," + "\"symbol\""
+ + "]}}," + "\"analyzer\": {" + "\"nGram_analyzer\": {" + "\"type\": \"custom\","
+ + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\"," + "\"asciifolding\","
+ + "\"nGram_filter\"]}," + "\"whitespace_analyzer\": {" + "\"type\": \"custom\","
+ + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\","
+ + "\"asciifolding\"]}}}}";
private static final String BAD_SETTINGS_FILE = "{\"analysis\": {" + "\"filter\": {"
- + "\"nGram_filter\": {" + "\"type\": \"nGram\"," + "\"min_gram\": 1," + "\"max_gram\": 50,"
- + "\"token_chars\": [" + "\"letter\"," + "\"digit\"," + "\"punctuation\"," + "\"symbol\""
- + "]}}," + "\"analyzer\": {" + "\"nGram_analyzer\": {" + "\"type\": \"custom\","
- + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\"," + "\"asciifolding\","
- + "\"nGram_filter\"]}," + "\"whitespace_analyzer\": {" + "\"type\": \"custom\","
- + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\","
- + "\"asciifolding\"]}}";
+ + "\"nGram_filter\": {" + "\"type\": \"nGram\"," + "\"min_gram\": 1," + "\"max_gram\": 50,"
+ + "\"token_chars\": [" + "\"letter\"," + "\"digit\"," + "\"punctuation\"," + "\"symbol\""
+ + "]}}," + "\"analyzer\": {" + "\"nGram_analyzer\": {" + "\"type\": \"custom\","
+ + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\"," + "\"asciifolding\","
+ + "\"nGram_filter\"]}," + "\"whitespace_analyzer\": {" + "\"type\": \"custom\","
+ + "\"tokenizer\": \"whitespace\"," + "\"filter\": [" + "\"lowercase\","
+ + "\"asciifolding\"]}}";
ElasticSearchConfig elasticSearchConfig;
@@ -130,12 +130,12 @@ public class ElasticSearchConfigTest {
*
* @return the elastic search settings expect valid config
* @throws IOException Signals that an I/O exception has occurred.
- * @throws ElasticSearchOperationException the elastic search operation exception
- * Need to revisit this test case and change the way this class works
+ * @throws ElasticSearchOperationException the elastic search operation exception Need to revisit
+ * this test case and change the way this class works
*/
@Ignore
public void getElasticSearchSettings_expectValidConfig()
- throws IOException, ElasticSearchOperationException {
+ throws IOException, ElasticSearchOperationException {
System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
ElasticSearchConfig esConfig = new ElasticSearchConfig();
@@ -152,11 +152,11 @@ public class ElasticSearchConfigTest {
* @throws IOException Signals that an I/O exception has occurred.
* @throws ElasticSearchOperationException the elastic search operation exception
*
- * Need to revisit this test case and change the way this class works
+ * Need to revisit this test case and change the way this class works
*/
@Ignore
public void getElasticSearchSettings_expectFileNotFoundException()
- throws IOException, ElasticSearchOperationException {
+ throws IOException, ElasticSearchOperationException {
System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
ElasticSearchConfig esConfig = new ElasticSearchConfig();
@@ -174,11 +174,11 @@ public class ElasticSearchConfigTest {
* @throws IOException Signals that an I/O exception has occurred.
* @throws ElasticSearchOperationException the elastic search operation exception
*
- * Need to revisit this test case and change the way this class works
+ * Need to revisit this test case and change the way this class works
*/
@Ignore
public void getElasticSearchMappings_expectValidConfig()
- throws IOException, ElasticSearchOperationException {
+ throws IOException, ElasticSearchOperationException {
System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
ElasticSearchConfig esConfig = new ElasticSearchConfig();
@@ -197,7 +197,7 @@ public class ElasticSearchConfigTest {
*/
@Test(expected = ElasticSearchOperationException.class)
public void getElasticSearchMappings_expectFileNotFoundException()
- throws IOException, ElasticSearchOperationException {
+ throws IOException, ElasticSearchOperationException {
System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
ElasticSearchConfig esConfig = new ElasticSearchConfig();
@@ -216,7 +216,7 @@ public class ElasticSearchConfigTest {
*/
@Test
public void buildElasticSearchTableConfig_expectValidResult()
- throws ElasticSearchOperationException, IOException {
+ throws ElasticSearchOperationException, IOException {
ElasticSearchConfig spyEsConfig = Mockito.spy(new ElasticSearchConfig());
Mockito.doReturn(GOOD_MAPPINGS_FILE).when(spyEsConfig).getElasticSearchMappings();
Mockito.doReturn(GOOD_SETTINGS_FILE).when(spyEsConfig).getElasticSearchSettings();
@@ -233,7 +233,7 @@ public class ElasticSearchConfigTest {
*/
@Test(expected = ElasticSearchOperationException.class)
public void buildElasticSearchTableConfig_expectException()
- throws ElasticSearchOperationException, IOException {
+ throws ElasticSearchOperationException, IOException {
ElasticSearchConfig spyEsConfig = Mockito.spy(new ElasticSearchConfig());
Mockito.doReturn(GOOD_MAPPINGS_FILE).when(spyEsConfig).getElasticSearchMappings();
Mockito.doReturn(BAD_SETTINGS_FILE).when(spyEsConfig).getElasticSearchSettings();
@@ -246,7 +246,8 @@ public class ElasticSearchConfigTest {
public void testGetFullUrl_ThreeParams() throws Exception {
Mockito.when(elasticSearchConfig.getIpAddress()).thenReturn("http://localhost");
Mockito.when(elasticSearchConfig.getHttpPort()).thenReturn("5443");
- String fullUrl = elasticSearchConfig.getElasticFullUrl("http://localhost:5443/aai/model/index", "entity-index", "entity");
+ String fullUrl = elasticSearchConfig.getElasticFullUrl("http://localhost:5443/aai/model/index",
+ "entity-index", "entity");
Assert.assertNotNull(fullUrl);
}
@@ -260,7 +261,7 @@ public class ElasticSearchConfigTest {
}
@Test
- public void testGetBulkUrl() throws Exception {
+ public void testGetBulkUrl() throws Exception {
Mockito.when(elasticSearchConfig.getIpAddress()).thenReturn("http://localhost");
Mockito.when(elasticSearchConfig.getHttpPort()).thenReturn("5443");
String fullUrl = elasticSearchConfig.getBulkUrl();
@@ -270,7 +271,8 @@ public class ElasticSearchConfigTest {
@Test
public void testGetConfigAsString() throws IOException, ElasticSearchOperationException {
System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- String retStr = elasticSearchConfig.getConfigAsString("item-1", System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/roles.config");
+ String retStr = elasticSearchConfig.getConfigAsString("item-1",
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/roles.config");
Assert.assertNotNull(retStr);
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchEntityStatisticsTest.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchEntityStatisticsTest.java
index 6e4cf8a..92360c7 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchEntityStatisticsTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/ElasticSearchEntityStatisticsTest.java
@@ -35,67 +35,67 @@ import org.onap.aai.sparky.dal.rest.OperationResult;
public class ElasticSearchEntityStatisticsTest {
- @Test
- public void testInitializeCountersFromOxmEntityDescriptors_NotNullDescriptors() {
-
- ElasticSearchEntityStatistics eses = new ElasticSearchEntityStatistics(new OxmModelLoader());
- Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
-
- OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
- oxmEd.setEntityName("entity-1");
- oxmEd.setGeoLatName("geoLatName-1");
-
- descriptors.put("entity-1", oxmEd);
-
- eses.initializeCountersFromOxmEntityDescriptors(descriptors);
- eses.reset();
- }
-
- @Test
- public void testInitializeCountersFromOxmEntityDescriptors_NullDescriptors() {
-
- ElasticSearchEntityStatistics eses = new ElasticSearchEntityStatistics(new OxmModelLoader());
- Map<String, OxmEntityDescriptor> descriptors = null;
- eses.initializeCountersFromOxmEntityDescriptors(descriptors);
- }
-
- @Test
- public void testUpdateCounters() {
-
- ElasticSearchEntityStatistics eses = new ElasticSearchEntityStatistics(new OxmModelLoader());
- Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
-
- OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
- oxmEd.setEntityName("entity-1");
- oxmEd.setGeoLatName("geoLatName-1");
- descriptors.put("entity-1", oxmEd);
-
- eses.initializeCountersFromOxmEntityDescriptors(descriptors);
-
- OperationResult result = new OperationResult();
- result.setResultCode(200);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- eses.updateCounters(ntwTxn);
-
- result.setResultCode(201);
- NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- eses.updateCounters(ntwTxn1);
-
- result.setResultCode(202);
- NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- eses.updateCounters(ntwTxn2);
- NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- eses.updateCounters(ntwTxn3);
-
- result.setResultCode(101);
- NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- eses.updateCounters(ntwTxn4);
- NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- eses.updateCounters(ntwTxn5);
-
- String statistics = eses.getStatisticsReport();
- Assert.assertNotNull(statistics);
- }
+ @Test
+ public void testInitializeCountersFromOxmEntityDescriptors_NotNullDescriptors() {
+
+ ElasticSearchEntityStatistics eses = new ElasticSearchEntityStatistics(new OxmModelLoader());
+ Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
+
+ OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
+ oxmEd.setEntityName("entity-1");
+ oxmEd.setGeoLatName("geoLatName-1");
+
+ descriptors.put("entity-1", oxmEd);
+
+ eses.initializeCountersFromOxmEntityDescriptors(descriptors);
+ eses.reset();
+ }
+
+ @Test
+ public void testInitializeCountersFromOxmEntityDescriptors_NullDescriptors() {
+
+ ElasticSearchEntityStatistics eses = new ElasticSearchEntityStatistics(new OxmModelLoader());
+ Map<String, OxmEntityDescriptor> descriptors = null;
+ eses.initializeCountersFromOxmEntityDescriptors(descriptors);
+ }
+
+ @Test
+ public void testUpdateCounters() {
+
+ ElasticSearchEntityStatistics eses = new ElasticSearchEntityStatistics(new OxmModelLoader());
+ Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();
+
+ OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();
+ oxmEd.setEntityName("entity-1");
+ oxmEd.setGeoLatName("geoLatName-1");
+ descriptors.put("entity-1", oxmEd);
+
+ eses.initializeCountersFromOxmEntityDescriptors(descriptors);
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(200);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ eses.updateCounters(ntwTxn);
+
+ result.setResultCode(201);
+ NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ eses.updateCounters(ntwTxn1);
+
+ result.setResultCode(202);
+ NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ eses.updateCounters(ntwTxn2);
+ NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ eses.updateCounters(ntwTxn3);
+
+ result.setResultCode(101);
+ NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ eses.updateCounters(ntwTxn4);
+ NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ eses.updateCounters(ntwTxn5);
+
+ String statistics = eses.getStatisticsReport();
+ Assert.assertNotNull(statistics);
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntity.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntity.java
index dd04248..bab190c 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntity.java
@@ -38,7 +38,7 @@ public class AutoSuggestDocumentEntity {
public void setFields(AutoSuggestDocumentEntityFields fields) {
this.fields = fields;
}
-
-
-
+
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntityFields.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntityFields.java
index eafef21..7c4c2db 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntityFields.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestDocumentEntityFields.java
@@ -37,7 +37,7 @@ public class AutoSuggestDocumentEntityFields {
private List<String> input;
private PayloadEntity payload;
private int weight;
-
+
public AutoSuggestDocumentEntityFields() {
input = new ArrayList<String>();
}
@@ -73,9 +73,9 @@ public class AutoSuggestDocumentEntityFields {
public void setWeight(int weight) {
this.weight = weight;
}
-
+
public void addInput(String input) {
this.input.add(input);
}
-
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticHitsEntity.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticHitsEntity.java
index 18dfdc4..13326ab 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticHitsEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticHitsEntity.java
@@ -28,9 +28,9 @@ import java.util.ArrayList;
import java.util.List;
public class AutoSuggestElasticHitsEntity {
-
+
private List<AutoSuggestElasticHitEntity> hits;
-
+
public AutoSuggestElasticHitsEntity() {
hits = new ArrayList<AutoSuggestElasticHitEntity>();
}
@@ -42,7 +42,7 @@ public class AutoSuggestElasticHitsEntity {
public void setHits(List<AutoSuggestElasticHitEntity> hits) {
this.hits = hits;
}
-
+
public void addHit(AutoSuggestElasticHitEntity hit) {
this.hits.add(hit);
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticSearchResponse.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticSearchResponse.java
index 40c9b6d..9dc9709 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticSearchResponse.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/AutoSuggestElasticSearchResponse.java
@@ -30,19 +30,19 @@ import java.util.Map;
import com.fasterxml.jackson.annotation.JsonProperty;
public class AutoSuggestElasticSearchResponse {
-
+
private int took;
-
+
@JsonProperty("timed_out")
private boolean timedOut;
-
+
@JsonProperty("_shards")
- private Map<String,String> shards;
-
+ private Map<String, String> shards;
+
private AutoSuggestElasticHitsEntity hits;
- public AutoSuggestElasticSearchResponse(){
- this.shards = new HashMap<String,String>();
+ public AutoSuggestElasticSearchResponse() {
+ this.shards = new HashMap<String, String>();
}
public int getTook() {
@@ -68,7 +68,7 @@ public class AutoSuggestElasticSearchResponse {
public void setShards(Map<String, String> shards) {
this.shards = shards;
}
-
+
public void addShard(String name, String value) {
shards.put(name, value);
}
@@ -80,6 +80,6 @@ public class AutoSuggestElasticSearchResponse {
public void setHits(AutoSuggestElasticHitsEntity hits) {
this.hits = hits;
}
-
-
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/BucketEntity.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/BucketEntity.java
index 5a578aa..9b5d27e 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/BucketEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/BucketEntity.java
@@ -28,19 +28,19 @@ import com.fasterxml.jackson.annotation.JsonProperty;
public class BucketEntity {
private String key;
-
+
@JsonProperty("doc_count")
private int docCount;
public BucketEntity() {
-
+
}
-
+
public BucketEntity(String name, int value) {
this.key = name;
this.docCount = value;
}
-
+
public String getKey() {
return key;
}
@@ -56,6 +56,6 @@ public class BucketEntity {
public void setDocCount(int docCount) {
this.docCount = docCount;
}
-
-
-}
+
+
+}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticHitsEntity.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticHitsEntity.java
index 4158903..dcd5b98 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticHitsEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticHitsEntity.java
@@ -30,17 +30,17 @@ import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
public class ElasticHitsEntity {
-
+
private int total;
@JsonProperty("max_score")
private int maxScore;
-
+
private List<ElasticHit> hits;
-
+
public ElasticHitsEntity() {
this.hits = new ArrayList<ElasticHit>();
}
-
+
public void addHit(ElasticHit hit) {
this.hits.add(hit);
}
@@ -68,7 +68,7 @@ public class ElasticHitsEntity {
public void setHits(List<ElasticHit> hits) {
this.hits = hits;
}
-
-
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggegrationResponse.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggegrationResponse.java
index 6dd2d11..4306f6b 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggegrationResponse.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggegrationResponse.java
@@ -45,7 +45,7 @@ public class ElasticSearchAggegrationResponse {
public ElasticSearchAggegrationResponse() {
this.shards = new HashMap<String, String>();
- this.aggregations = new HashMap<String,ElasticSearchAggregation>();
+ this.aggregations = new HashMap<String, ElasticSearchAggregation>();
}
@@ -89,7 +89,7 @@ public class ElasticSearchAggegrationResponse {
}
public void addShard(String key, String value) {
- this.shards.put(key,value);
+ this.shards.put(key, value);
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggregation.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggregation.java
index 7bcd318..44794cd 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggregation.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchAggregation.java
@@ -30,15 +30,15 @@ import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;
public class ElasticSearchAggregation {
-
+
@JsonProperty("doc_count_error_upper_bound")
private int docCountErrorUpperBound;
-
+
@JsonProperty("sum_other_doc_count")
private int sumOtherDocCount;
-
+
private List<BucketEntity> buckets;
-
+
public ElasticSearchAggregation() {
buckets = new ArrayList<BucketEntity>();
}
@@ -66,7 +66,7 @@ public class ElasticSearchAggregation {
public void setBuckets(List<BucketEntity> buckets) {
this.buckets = buckets;
}
-
+
public void addBucket(BucketEntity bucket) {
buckets.add(bucket);
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchCountResponse.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchCountResponse.java
index 5aec440..e02e353 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchCountResponse.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/ElasticSearchCountResponse.java
@@ -33,9 +33,9 @@ public class ElasticSearchCountResponse {
private Map<String, String> shards;
public ElasticSearchCountResponse() {
- this.shards = new HashMap<String,String>();
+ this.shards = new HashMap<String, String>();
}
-
+
public int getCount() {
return count;
}
@@ -51,7 +51,7 @@ public class ElasticSearchCountResponse {
public void setShards(Map<String, String> shards) {
this.shards = shards;
}
-
+
public void addShard(String key, String value) {
this.shards.put(key, value);
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/PayloadEntity.java b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/PayloadEntity.java
index 5f5e333..da84dd7 100644
--- a/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/PayloadEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/elasticsearch/entity/PayloadEntity.java
@@ -26,7 +26,6 @@ package org.onap.aai.sparky.dal.elasticsearch.entity;
public class PayloadEntity {
- public PayloadEntity() {
- }
-
+ public PayloadEntity() {}
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/rest/RestOperationalStatisticsTest.java b/src/test/java/org/onap/aai/sparky/dal/rest/RestOperationalStatisticsTest.java
index 415cbe7..2e0c90e 100644
--- a/src/test/java/org/onap/aai/sparky/dal/rest/RestOperationalStatisticsTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/rest/RestOperationalStatisticsTest.java
@@ -28,183 +28,183 @@ import org.onap.aai.sparky.dal.NetworkTransaction;
public class RestOperationalStatisticsTest {
- @Test
- public void testUpdateCounters_Get() {
- RestOperationalStatistics ros = new RestOperationalStatistics();
-
- OperationResult result = new OperationResult();
- result.setResultCode(101);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- ros.updateCounters(ntwTxn1);
-
- result.setResultCode(201);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- ros.updateCounters(ntwTxn2);
-
- result.setResultCode(301);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- ros.updateCounters(ntwTxn3);
-
- result.setResultCode(401);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- ros.updateCounters(ntwTxn4);
-
- result.setResultCode(501);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- ros.updateCounters(ntwTxn5);
-
- result.setResultCode(601);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- ros.updateCounters(ntwTxn6);
-
- String statistics = ros.getStatisticsReport();
- Assert.assertNotNull(statistics);
- }
-
- @Test
- public void testUpdateCounters_Put() {
- RestOperationalStatistics ros = new RestOperationalStatistics();
-
- OperationResult result = new OperationResult();
- result.setResultCode(101);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- ros.updateCounters(ntwTxn1);
-
- result.setResultCode(201);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- ros.updateCounters(ntwTxn2);
-
- result.setResultCode(301);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- ros.updateCounters(ntwTxn3);
-
- result.setResultCode(401);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- ros.updateCounters(ntwTxn4);
-
- result.setResultCode(501);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- ros.updateCounters(ntwTxn5);
-
- result.setResultCode(601);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
- ros.updateCounters(ntwTxn6);
-
- String statistics = ros.getStatisticsReport();
- Assert.assertNotNull(statistics);
- }
-
- @Test
- public void testUpdateCounters_Post() {
- RestOperationalStatistics ros = new RestOperationalStatistics();
-
- OperationResult result = new OperationResult();
- result.setResultCode(101);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
- ros.updateCounters(ntwTxn1);
-
- result.setResultCode(201);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
- ros.updateCounters(ntwTxn2);
-
- result.setResultCode(301);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
- ros.updateCounters(ntwTxn3);
-
- result.setResultCode(401);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
- ros.updateCounters(ntwTxn4);
-
- result.setResultCode(501);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
- ros.updateCounters(ntwTxn5);
-
- result.setResultCode(601);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
- ros.updateCounters(ntwTxn6);
-
- String statistics = ros.getStatisticsReport();
- Assert.assertNotNull(statistics);
- }
-
- @Test
- public void testUpdateCounters_Delete() {
- RestOperationalStatistics ros = new RestOperationalStatistics();
-
- OperationResult result = new OperationResult();
- result.setResultCode(101);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- ros.updateCounters(ntwTxn1);
-
- result.setResultCode(201);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- ros.updateCounters(ntwTxn2);
-
- result.setResultCode(301);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- ros.updateCounters(ntwTxn3);
-
- result.setResultCode(401);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- ros.updateCounters(ntwTxn4);
-
- result.setResultCode(501);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- ros.updateCounters(ntwTxn5);
-
- result.setResultCode(601);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
- ros.updateCounters(ntwTxn6);
-
- String statistics = ros.getStatisticsReport();
- Assert.assertNotNull(statistics);
- }
+ @Test
+ public void testUpdateCounters_Get() {
+ RestOperationalStatistics ros = new RestOperationalStatistics();
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(101);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ ros.updateCounters(ntwTxn1);
+
+ result.setResultCode(201);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ ros.updateCounters(ntwTxn2);
+
+ result.setResultCode(301);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ ros.updateCounters(ntwTxn3);
+
+ result.setResultCode(401);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ ros.updateCounters(ntwTxn4);
+
+ result.setResultCode(501);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ ros.updateCounters(ntwTxn5);
+
+ result.setResultCode(601);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ ros.updateCounters(ntwTxn6);
+
+ String statistics = ros.getStatisticsReport();
+ Assert.assertNotNull(statistics);
+ }
+
+ @Test
+ public void testUpdateCounters_Put() {
+ RestOperationalStatistics ros = new RestOperationalStatistics();
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(101);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ ros.updateCounters(ntwTxn1);
+
+ result.setResultCode(201);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ ros.updateCounters(ntwTxn2);
+
+ result.setResultCode(301);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ ros.updateCounters(ntwTxn3);
+
+ result.setResultCode(401);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ ros.updateCounters(ntwTxn4);
+
+ result.setResultCode(501);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ ros.updateCounters(ntwTxn5);
+
+ result.setResultCode(601);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.PUT, "entity-1", result);
+ ros.updateCounters(ntwTxn6);
+
+ String statistics = ros.getStatisticsReport();
+ Assert.assertNotNull(statistics);
+ }
+
+ @Test
+ public void testUpdateCounters_Post() {
+ RestOperationalStatistics ros = new RestOperationalStatistics();
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(101);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
+ ros.updateCounters(ntwTxn1);
+
+ result.setResultCode(201);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
+ ros.updateCounters(ntwTxn2);
+
+ result.setResultCode(301);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
+ ros.updateCounters(ntwTxn3);
+
+ result.setResultCode(401);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
+ ros.updateCounters(ntwTxn4);
+
+ result.setResultCode(501);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
+ ros.updateCounters(ntwTxn5);
+
+ result.setResultCode(601);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.POST, "entity-1", result);
+ ros.updateCounters(ntwTxn6);
+
+ String statistics = ros.getStatisticsReport();
+ Assert.assertNotNull(statistics);
+ }
+
+ @Test
+ public void testUpdateCounters_Delete() {
+ RestOperationalStatistics ros = new RestOperationalStatistics();
+
+ OperationResult result = new OperationResult();
+ result.setResultCode(101);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ ros.updateCounters(ntwTxn1);
+
+ result.setResultCode(201);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ ros.updateCounters(ntwTxn2);
+
+ result.setResultCode(301);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ ros.updateCounters(ntwTxn3);
+
+ result.setResultCode(401);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ ros.updateCounters(ntwTxn4);
+
+ result.setResultCode(501);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ ros.updateCounters(ntwTxn5);
+
+ result.setResultCode(601);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn6 = new NetworkTransaction(HttpMethod.DELETE, "entity-1", result);
+ ros.updateCounters(ntwTxn6);
+
+ String statistics = ros.getStatisticsReport();
+ Assert.assertNotNull(statistics);
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/rest/RestfulDataAccessorTest.java b/src/test/java/org/onap/aai/sparky/dal/rest/RestfulDataAccessorTest.java
index fe6fa56..fabc32b 100644
--- a/src/test/java/org/onap/aai/sparky/dal/rest/RestfulDataAccessorTest.java
+++ b/src/test/java/org/onap/aai/sparky/dal/rest/RestfulDataAccessorTest.java
@@ -46,7 +46,7 @@ import com.sun.jersey.api.client.WebResource.Builder;
/**
* The Class RestfulDataAccessorTest.
*/
-@RunWith(MockitoJUnitRunner.class)
+@RunWith(MockitoJUnitRunner.class)
public class RestfulDataAccessorTest {
private RestClientBuilder clientBuilderMock;
@@ -54,7 +54,7 @@ public class RestfulDataAccessorTest {
private ClientResponse mockClientResponse;
private WebResource mockWebResource;
private Builder mockBuilder;
-
+
/**
* Inits the.
@@ -63,7 +63,7 @@ public class RestfulDataAccessorTest {
*/
@Before
public void init() throws Exception {
-
+
/*
* common collaborator mocking setup
*/
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/DocumentEntity.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/DocumentEntity.java
index 4d85bd6..3aaef43 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/DocumentEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/DocumentEntity.java
@@ -30,14 +30,14 @@ import java.util.Map;
public class DocumentEntity {
private String etag;
private String url;
- private Map<String,String> content;
+ private Map<String, String> content;
public DocumentEntity() {
- content = new HashMap<String,String>();
+ content = new HashMap<String, String>();
}
-
-
- public String getEtag() {
+
+
+ public String getEtag() {
return etag;
}
@@ -60,7 +60,7 @@ public class DocumentEntity {
public void setContent(Map<String, String> content) {
this.content = content;
}
-
+
public void addContent(String key, String value) {
content.put(key, value);
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/EntityCountResponse.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/EntityCountResponse.java
index d6e9971..fe69f81 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/EntityCountResponse.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/EntityCountResponse.java
@@ -28,12 +28,12 @@ import java.util.HashMap;
import java.util.Map;
public class EntityCountResponse {
-
- private Map<String,String> shards;
+
+ private Map<String, String> shards;
private int count;
-
+
public EntityCountResponse() {
- this.shards = new HashMap<String,String>();
+ this.shards = new HashMap<String, String>();
}
public Map<String, String> getShards() {
@@ -51,5 +51,5 @@ public class EntityCountResponse {
public void setCount(int count) {
this.count = count;
}
-
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationEntity.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationEntity.java
index 0f1609b..9418cf5 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationEntity.java
@@ -32,7 +32,7 @@ import org.onap.aai.sparky.dal.elasticsearch.entity.BucketEntity;
public class GroupByAggregationEntity {
private int totalChartHits;
List<BucketEntity> buckets;
-
+
public GroupByAggregationEntity() {
this.buckets = new ArrayList<BucketEntity>();
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationResponseEntity.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationResponseEntity.java
index 0af4600..3f8cb69 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationResponseEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/GroupByAggregationResponseEntity.java
@@ -30,9 +30,9 @@ public class GroupByAggregationResponseEntity {
@JsonProperty("groupby_aggregation")
private GroupByAggregationEntity aggEntity;
-
+
public GroupByAggregationResponseEntity() {
-
+
}
public GroupByAggregationEntity getAggEntity() {
@@ -42,7 +42,7 @@ public class GroupByAggregationResponseEntity {
public void setAggEntity(GroupByAggregationEntity aggEntity) {
this.aggEntity = aggEntity;
}
-
-
-
+
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/HitEntity.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/HitEntity.java
index 755e903..2340c0d 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/HitEntity.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/HitEntity.java
@@ -30,7 +30,7 @@ public class HitEntity {
private DocumentEntity document;
public String getScore() {
- return score;
+ return score;
}
public void setScore(String score) {
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionEntityBuilder.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionEntityBuilder.java
index e815e0b..08bf76c 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionEntityBuilder.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionEntityBuilder.java
@@ -30,9 +30,9 @@ import java.util.Map;
public class SearchAbstractionEntityBuilder {
-
+
public static HitEntity getHitSample1() {
-
+
HitEntity hitEntity = new HitEntity();
DocumentEntity doc = new DocumentEntity();
@@ -40,20 +40,23 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("17.073963");
doc.addContent("entityPrimaryKeyValue", "example-vnf-id-val-4394");
- doc.addContent("entityType", "vpe");
- doc.addContent("searchTags", "example-vnf-id-val-4394;example-vnf-name-val-4394;example-vnf-name2-val-4394");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/vpes/vpe/example-vnf-id-val-4394");
- doc.addContent("searchTagIDs", "0;1;2");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:20:48.072-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/e317a35256717f10e88d1b2c995efcdddfc911bf350c73e37e8afca6dfb11553");
+ doc.addContent("entityType", "vpe");
+ doc.addContent("searchTags",
+ "example-vnf-id-val-4394;example-vnf-name-val-4394;example-vnf-name2-val-4394");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/vpes/vpe/example-vnf-id-val-4394");
+ doc.addContent("searchTagIDs", "0;1;2");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:20:48.072-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/e317a35256717f10e88d1b2c995efcdddfc911bf350c73e37e8afca6dfb11553");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample2() {
HitEntity hitEntity = new HitEntity();
@@ -63,20 +66,22 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("17.073963");
doc.addContent("entityPrimaryKeyValue", "vpe-vnf-id-team4-11");
- doc.addContent("entityType", "vpe");
- doc.addContent("searchTags", "vpe-vnf-id-team4-11;example-vnf-name-val-9512;example-vnf-name2-val-9512");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/vpes/vpe/vpe-vnf-id-team4-11");
- doc.addContent("searchTagIDs", "0;1;2");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:20:48.175-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/80f6d1a252e047e50e0adbeb90ad30876bb5b63cf70c9dd53f3fe46aeb50c74b");
+ doc.addContent("entityType", "vpe");
+ doc.addContent("searchTags",
+ "vpe-vnf-id-team4-11;example-vnf-name-val-9512;example-vnf-name2-val-9512");
+ doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/vpes/vpe/vpe-vnf-id-team4-11");
+ doc.addContent("searchTagIDs", "0;1;2");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:20:48.175-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/80f6d1a252e047e50e0adbeb90ad30876bb5b63cf70c9dd53f3fe46aeb50c74b");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample3() {
HitEntity hitEntity = new HitEntity();
@@ -86,20 +91,23 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("17.030035");
doc.addContent("entityPrimaryKeyValue", "example-vnf-id-val-6176");
- doc.addContent("entityType", "generic-vnf");
- doc.addContent("searchTags", "example-vnf-id-val-6176;example-vnf-name-val-6176;example-vnf-name2-val-6176");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/example-vnf-id-val-6176");
- doc.addContent("searchTagIDs", "0;1;2");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:29:39.889-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/8dfd1136f943296508fee11efcda35a0719aa490aa60e9abffecce0b220d8c94");
+ doc.addContent("entityType", "generic-vnf");
+ doc.addContent("searchTags",
+ "example-vnf-id-val-6176;example-vnf-name-val-6176;example-vnf-name2-val-6176");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/example-vnf-id-val-6176");
+ doc.addContent("searchTagIDs", "0;1;2");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:29:39.889-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/8dfd1136f943296508fee11efcda35a0719aa490aa60e9abffecce0b220d8c94");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample4() {
HitEntity hitEntity = new HitEntity();
@@ -109,20 +117,23 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("17.01174");
doc.addContent("entityPrimaryKeyValue", "vnf-id-team4-11");
- doc.addContent("entityType", "newvce");
- doc.addContent("searchTags", "vnf-id-team4-11;example-vnf-name-val-5313;example-vnf-name2-val-5313");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/newvces/newvce/vnf-id-team4-11");
- doc.addContent("searchTagIDs", "0;1;2");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:21:08.142-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/83dcab92d75b20eb94578039c8cec5e7b6b4717791e3c367d8af5069ce76dc90");
+ doc.addContent("entityType", "newvce");
+ doc.addContent("searchTags",
+ "vnf-id-team4-11;example-vnf-name-val-5313;example-vnf-name2-val-5313");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/newvces/newvce/vnf-id-team4-11");
+ doc.addContent("searchTagIDs", "0;1;2");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:21:08.142-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/83dcab92d75b20eb94578039c8cec5e7b6b4717791e3c367d8af5069ce76dc90");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample5() {
HitEntity hitEntity = new HitEntity();
@@ -132,20 +143,23 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("17.01174");
doc.addContent("entityPrimaryKeyValue", "example-vnf-id2-val-9501");
- doc.addContent("entityType", "newvce");
- doc.addContent("searchTags", "example-vnf-id2-val-9501;example-vnf-name-val-9501;example-vnf-name2-val-9501");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/newvces/newvce/example-vnf-id2-val-9501");
- doc.addContent("searchTagIDs", "0;1;2");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:21:23.323-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/461816ba8aa94d01f2c978999b843dbaf10e0509db58d1945d6f5999d6db8f5e");
+ doc.addContent("entityType", "newvce");
+ doc.addContent("searchTags",
+ "example-vnf-id2-val-9501;example-vnf-name-val-9501;example-vnf-name2-val-9501");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/newvces/newvce/example-vnf-id2-val-9501");
+ doc.addContent("searchTagIDs", "0;1;2");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:21:23.323-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/461816ba8aa94d01f2c978999b843dbaf10e0509db58d1945d6f5999d6db8f5e");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample6() {
HitEntity hitEntity = new HitEntity();
@@ -155,20 +169,22 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("17.01174");
doc.addContent("entityPrimaryKeyValue", "vnf-id-dm-auto-10");
- doc.addContent("entityType", "vce");
- doc.addContent("searchTags", "vpe-id-dm-auto-10;vnf-id-dm-auto-10;vnf-name-dm-auto-10;vnf-name2-dm-auto-10");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/vces/vce/vnf-id-dm-auto-10");
- doc.addContent("searchTagIDs", "0;1;2;3");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:24:57.209-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/1ead4512e65ee0eafb24e0156cc1abdf97368f08dfe065f02580aa09661bbcd8");
+ doc.addContent("entityType", "vce");
+ doc.addContent("searchTags",
+ "vpe-id-dm-auto-10;vnf-id-dm-auto-10;vnf-name-dm-auto-10;vnf-name2-dm-auto-10");
+ doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/vces/vce/vnf-id-dm-auto-10");
+ doc.addContent("searchTagIDs", "0;1;2;3");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:24:57.209-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/1ead4512e65ee0eafb24e0156cc1abdf97368f08dfe065f02580aa09661bbcd8");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample7() {
HitEntity hitEntity = new HitEntity();
@@ -178,20 +194,22 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("13.940832");
doc.addContent("entityPrimaryKeyValue", "e3e59c5b-ad48-44d0-b3e4-80eacdcee4c7");
- doc.addContent("entityType", "generic-vnf");
- doc.addContent("searchTags", "e3e59c5b-ad48-44d0-b3e4-80eacdcee4c7;VNF_Test_vNF_modules_01");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/e3e59c5b-ad48-44d0-b3e4-80eacdcee4c7");
- doc.addContent("searchTagIDs", "0;1");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:26:34.603-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/1462582e8fd7786f72f26548e4247b72ab6cd101cca0bbb68a60dd3ad16500d0");
+ doc.addContent("entityType", "generic-vnf");
+ doc.addContent("searchTags", "e3e59c5b-ad48-44d0-b3e4-80eacdcee4c7;VNF_Test_vNF_modules_01");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/e3e59c5b-ad48-44d0-b3e4-80eacdcee4c7");
+ doc.addContent("searchTagIDs", "0;1");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:26:34.603-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/1462582e8fd7786f72f26548e4247b72ab6cd101cca0bbb68a60dd3ad16500d0");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample8() {
HitEntity hitEntity = new HitEntity();
@@ -201,20 +219,22 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("13.940832");
doc.addContent("entityPrimaryKeyValue", "fusion-jitsi-vnf-001");
- doc.addContent("entityType", "generic-vnf");
- doc.addContent("searchTags", "fusion-jitsi-vnf-001;fusion-jitsi-vnf");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/fusion-jitsi-vnf-001");
- doc.addContent("searchTagIDs", "0;1");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:28:14.293-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/b79ddfec9a00184445174c91e7490a0d407f351983bba4ae53bfec0584f73ee3");
+ doc.addContent("entityType", "generic-vnf");
+ doc.addContent("searchTags", "fusion-jitsi-vnf-001;fusion-jitsi-vnf");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/fusion-jitsi-vnf-001");
+ doc.addContent("searchTagIDs", "0;1");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:28:14.293-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/b79ddfec9a00184445174c91e7490a0d407f351983bba4ae53bfec0584f73ee3");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample9() {
HitEntity hitEntity = new HitEntity();
@@ -224,20 +244,22 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("13.940832");
doc.addContent("entityPrimaryKeyValue", "vnfm0003v");
- doc.addContent("entityType", "generic-vnf");
- doc.addContent("searchTags", "vnfm0003v;vnfm0003v");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/vnfm0003v");
- doc.addContent("searchTagIDs", "0;1");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:29:39.594-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/52ae232ea5506d6de8ef35c4f46a1ceafe35f3717ff578b83531bc7615870b12");
+ doc.addContent("entityType", "generic-vnf");
+ doc.addContent("searchTags", "vnfm0003v;vnfm0003v");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/vnfm0003v");
+ doc.addContent("searchTagIDs", "0;1");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:29:39.594-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/52ae232ea5506d6de8ef35c4f46a1ceafe35f3717ff578b83531bc7615870b12");
doc.setEtag("1");
return hitEntity;
}
-
+
public static HitEntity getHitSample10() {
HitEntity hitEntity = new HitEntity();
@@ -247,33 +269,35 @@ public class SearchAbstractionEntityBuilder {
hitEntity.setScore("13.928098");
doc.addContent("entityPrimaryKeyValue", "amist456vnf");
- doc.addContent("entityType", "generic-vnf");
- doc.addContent("searchTags", "amist456vnf;amist456vnf");
- doc.addContent("link", "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/amist456vnf");
- doc.addContent("searchTagIDs", "0;1");
- doc.addContent("lastmodTimestamp", "2017-04-18T17:28:28.163-0400");
-
- doc.setUrl("services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/3424afea5963696380a0fdc78ee5320cf5fa9bc0459f1f9376db208d31196434");
+ doc.addContent("entityType", "generic-vnf");
+ doc.addContent("searchTags", "amist456vnf;amist456vnf");
+ doc.addContent("link",
+ "https://aai-hostname:8443/aai/v9/network/generic-vnfs/generic-vnf/amist456vnf");
+ doc.addContent("searchTagIDs", "0;1");
+ doc.addContent("lastmodTimestamp", "2017-04-18T17:28:28.163-0400");
+
+ doc.setUrl(
+ "services/search-data-service/v1/search/indexes/entitysearchindex-localhost-ist-apr18/documents/3424afea5963696380a0fdc78ee5320cf5fa9bc0459f1f9376db208d31196434");
doc.setEtag("1");
return hitEntity;
}
-
-
-
+
+
+
public static SearchAbstractionResponse getSuccessfulEntitySearchResponse() {
-
+
SearchAbstractionResponse sasResponse = new SearchAbstractionResponse();
-
+
SearchResult searchResult = new SearchResult();
sasResponse.setSearchResult(searchResult);
-
+
searchResult.setTotalHits(3257);
-
+
List<HitEntity> hits = new ArrayList<HitEntity>();
-
+
hits.add(getHitSample1());
hits.add(getHitSample2());
hits.add(getHitSample3());
@@ -284,12 +308,12 @@ public class SearchAbstractionEntityBuilder {
hits.add(getHitSample8());
hits.add(getHitSample9());
hits.add(getHitSample10());
-
+
searchResult.setHits(hits);
-
+
return sasResponse;
-
+
}
-
+
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionResponse.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionResponse.java
index d3d4a4c..547b61e 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionResponse.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchAbstractionResponse.java
@@ -25,13 +25,13 @@
package org.onap.aai.sparky.dal.sas.entity;
public class SearchAbstractionResponse {
-
+
private SearchResult searchResult;
public SearchResult getSearchResult() {
return searchResult;
}
-
+
public void setSearchResult(SearchResult searchResult) {
this.searchResult = searchResult;
}
diff --git a/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchResult.java b/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchResult.java
index e484fa6..255413d 100644
--- a/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchResult.java
+++ b/src/test/java/org/onap/aai/sparky/dal/sas/entity/SearchResult.java
@@ -30,20 +30,23 @@ public class SearchResult {
private int totalHits;
private List<HitEntity> hits;
-
- public int getTotalHits() {
+
+ public int getTotalHits() {
return totalHits;
}
+
public void setTotalHits(int totalHits) {
this.totalHits = totalHits;
}
+
public List<HitEntity> getHits() {
return hits;
}
+
public void setHits(List<HitEntity> hits) {
this.hits = hits;
}
-
-
-
+
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/search/VnfSearchQueryBuilderTest.java b/src/test/java/org/onap/aai/sparky/search/VnfSearchQueryBuilderTest.java
index 19a0a3a..99b20c1 100644
--- a/src/test/java/org/onap/aai/sparky/search/VnfSearchQueryBuilderTest.java
+++ b/src/test/java/org/onap/aai/sparky/search/VnfSearchQueryBuilderTest.java
@@ -34,42 +34,44 @@ import org.onap.aai.sparky.search.VnfSearchQueryBuilder;
public class VnfSearchQueryBuilderTest {
- @Test
- public void testCreateSuggestionsQuery() {
- String maxResults = "maxResults-1";
- String queryStr = "queryStr-1";
- JsonObject object = VnfSearchQueryBuilder.createSuggestionsQuery(maxResults, queryStr);
- Assert.assertNotNull(object);
- }
-
- @Test
- public void testSortCriteria() {
- JsonArray array = VnfSearchQueryBuilder.getSortCriteria("field-1", "sortOrder-1");
- Assert.assertNotNull(array);
- }
-
- @Test
- public void testCreateEntityCountsQuery_SingleAttribute() {
- Map<String, String> attributes = new HashMap<>();
- attributes.put("key-1", "value-1");
- JsonObject object = VnfSearchQueryBuilder.createEntityCountsQuery(attributes);
- Assert.assertNotNull(object);
- }
-
- @Test
- public void testCreateSummaryByEntityTypeQuery_Single() {
- Map<String, String> attributes = new HashMap<>();
- attributes.put("key-1", "value-1");
- JsonObject object = VnfSearchQueryBuilder.createSummaryByEntityTypeQuery(attributes, "groupkey-1");
- Assert.assertNotNull(object);
- }
-
- @Test
- public void testCreateSummaryByEntityTypeQuery_Multiple() {
- Map<String, String> attributes = new HashMap<>();
- attributes.put("key-1", "value-1");
- attributes.put("key-2", "value-2");
- JsonObject object = VnfSearchQueryBuilder.createSummaryByEntityTypeQuery(attributes, "groupkey-1");
- Assert.assertNotNull(object);
- }
+ @Test
+ public void testCreateSuggestionsQuery() {
+ String maxResults = "maxResults-1";
+ String queryStr = "queryStr-1";
+ JsonObject object = VnfSearchQueryBuilder.createSuggestionsQuery(maxResults, queryStr);
+ Assert.assertNotNull(object);
+ }
+
+ @Test
+ public void testSortCriteria() {
+ JsonArray array = VnfSearchQueryBuilder.getSortCriteria("field-1", "sortOrder-1");
+ Assert.assertNotNull(array);
+ }
+
+ @Test
+ public void testCreateEntityCountsQuery_SingleAttribute() {
+ Map<String, String> attributes = new HashMap<>();
+ attributes.put("key-1", "value-1");
+ JsonObject object = VnfSearchQueryBuilder.createEntityCountsQuery(attributes);
+ Assert.assertNotNull(object);
+ }
+
+ @Test
+ public void testCreateSummaryByEntityTypeQuery_Single() {
+ Map<String, String> attributes = new HashMap<>();
+ attributes.put("key-1", "value-1");
+ JsonObject object =
+ VnfSearchQueryBuilder.createSummaryByEntityTypeQuery(attributes, "groupkey-1");
+ Assert.assertNotNull(object);
+ }
+
+ @Test
+ public void testCreateSummaryByEntityTypeQuery_Multiple() {
+ Map<String, String> attributes = new HashMap<>();
+ attributes.put("key-1", "value-1");
+ attributes.put("key-2", "value-2");
+ JsonObject object =
+ VnfSearchQueryBuilder.createSummaryByEntityTypeQuery(attributes, "groupkey-1");
+ Assert.assertNotNull(object);
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/search/VnfSearchServiceTest.java b/src/test/java/org/onap/aai/sparky/search/VnfSearchServiceTest.java
index 8c4d59d..ed77e25 100644
--- a/src/test/java/org/onap/aai/sparky/search/VnfSearchServiceTest.java
+++ b/src/test/java/org/onap/aai/sparky/search/VnfSearchServiceTest.java
@@ -41,49 +41,54 @@ import org.onap.aai.sparky.viewandinspect.entity.QuerySearchEntity;
public class VnfSearchServiceTest {
- VnfSearchService searchService;
-
- @Before
- public void init() throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException, IOException {
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/";
- ElasticSearchConfig.setConfig(null);
- setFinalStatic();
- searchService = new VnfSearchService();
- }
- @Test
- public void testSetZeroCountResponse() throws IOException {
- HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
- Mockito.doNothing().when(response).setStatus(1);
- Mockito.doNothing().when(response).setContentType(Mockito.anyString());
- PrintWriter writer = Mockito.mock(PrintWriter.class);
- Mockito.doNothing().when(writer).println(Mockito.anyString());
- Mockito.doNothing().when(writer).close();
- Mockito.when(response.getWriter()).thenReturn(writer);
- searchService.setZeroCountResponse(response);
- }
-
- @Test
- public void testSetEmptyAggResponse() throws IOException {
- HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
- Mockito.doNothing().when(response).setStatus(1);
- Mockito.doNothing().when(response).setContentType(Mockito.anyString());
- PrintWriter writer = Mockito.mock(PrintWriter.class);
- Mockito.doNothing().when(writer).println(Mockito.anyString());
- Mockito.doNothing().when(writer).close();
- Mockito.when(response.getWriter()).thenReturn(writer);
- searchService.setEmptyAggResponse(response);
- }
-
-
- static void setFinalStatic() throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException {
- Field configField = ElasticSearchConfig.class.getDeclaredField("CONFIG_FILE");
- configField.setAccessible(true);
+ VnfSearchService searchService;
- Field modifiersField = Field.class.getDeclaredField( "modifiers" );
- modifiersField.setAccessible( true );
- modifiersField.setInt( configField, configField.getModifiers() & ~Modifier.FINAL );
+ @Before
+ public void init() throws NoSuchFieldException, SecurityException, IllegalArgumentException,
+ IllegalAccessException, IOException {
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION =
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/";
+ ElasticSearchConfig.setConfig(null);
+ setFinalStatic();
+ searchService = new VnfSearchService();
+ }
- configField.set(null, System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/elasticsearch.properties");
- }
+ @Test
+ public void testSetZeroCountResponse() throws IOException {
+ HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
+ Mockito.doNothing().when(response).setStatus(1);
+ Mockito.doNothing().when(response).setContentType(Mockito.anyString());
+ PrintWriter writer = Mockito.mock(PrintWriter.class);
+ Mockito.doNothing().when(writer).println(Mockito.anyString());
+ Mockito.doNothing().when(writer).close();
+ Mockito.when(response.getWriter()).thenReturn(writer);
+ searchService.setZeroCountResponse(response);
+ }
+
+ @Test
+ public void testSetEmptyAggResponse() throws IOException {
+ HttpServletResponse response = Mockito.mock(HttpServletResponse.class);
+ Mockito.doNothing().when(response).setStatus(1);
+ Mockito.doNothing().when(response).setContentType(Mockito.anyString());
+ PrintWriter writer = Mockito.mock(PrintWriter.class);
+ Mockito.doNothing().when(writer).println(Mockito.anyString());
+ Mockito.doNothing().when(writer).close();
+ Mockito.when(response.getWriter()).thenReturn(writer);
+ searchService.setEmptyAggResponse(response);
+ }
+
+
+ static void setFinalStatic() throws NoSuchFieldException, SecurityException,
+ IllegalArgumentException, IllegalAccessException {
+ Field configField = ElasticSearchConfig.class.getDeclaredField("CONFIG_FILE");
+ configField.setAccessible(true);
+
+ Field modifiersField = Field.class.getDeclaredField("modifiers");
+ modifiersField.setAccessible(true);
+ modifiersField.setInt(configField, configField.getModifiers() & ~Modifier.FINAL);
+
+ configField.set(null,
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/elasticsearch.properties");
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/search/filters/FilteredSearchHelperTest.java b/src/test/java/org/onap/aai/sparky/search/filters/FilteredSearchHelperTest.java
index aa37d42..062aa04 100644
--- a/src/test/java/org/onap/aai/sparky/search/filters/FilteredSearchHelperTest.java
+++ b/src/test/java/org/onap/aai/sparky/search/filters/FilteredSearchHelperTest.java
@@ -47,7 +47,7 @@ public class FilteredSearchHelperTest {
config.setViewsConfig(config.readUiViewsConfig());
System.out.println("SETTING UIFILTERSCONFIG");
config.setFiltersConfig(config.readUiFiltersConfig());
-
+
filteredSearchHelper = new FilteredSearchHelper(config);
}
diff --git a/src/test/java/org/onap/aai/sparky/search/filters/entity/DiscoverFiltersRequest.java b/src/test/java/org/onap/aai/sparky/search/filters/entity/DiscoverFiltersRequest.java
index 336e3b1..f836821 100644
--- a/src/test/java/org/onap/aai/sparky/search/filters/entity/DiscoverFiltersRequest.java
+++ b/src/test/java/org/onap/aai/sparky/search/filters/entity/DiscoverFiltersRequest.java
@@ -36,5 +36,5 @@ public class DiscoverFiltersRequest {
public void setViewName(String viewName) {
this.viewName = viewName;
}
-
+
}
diff --git a/src/test/java/org/onap/aai/sparky/security/portal/TestPortalRestAPIServiceImpl.java b/src/test/java/org/onap/aai/sparky/security/portal/TestPortalRestAPIServiceImpl.java
index 815199f..a84748b 100644
--- a/src/test/java/org/onap/aai/sparky/security/portal/TestPortalRestAPIServiceImpl.java
+++ b/src/test/java/org/onap/aai/sparky/security/portal/TestPortalRestAPIServiceImpl.java
@@ -63,9 +63,9 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
import org.powermock.modules.junit4.PowerMockRunner;
import org.powermock.reflect.Whitebox;
-@PowerMockIgnore({ "javax.crypto.*" })
+@PowerMockIgnore({"javax.crypto.*"})
@RunWith(PowerMockRunner.class)
-@PrepareForTest({ PortalAuthenticationConfig.class, RolesConfig.class })
+@PrepareForTest({PortalAuthenticationConfig.class, RolesConfig.class})
public class TestPortalRestAPIServiceImpl {
private static File testUsersFile;
@@ -75,13 +75,19 @@ public class TestPortalRestAPIServiceImpl {
enum TestData {
// @formatter:off
- TEST_USERS ("src/test/resources/portal/test-users.config"),
- PORTAL_AUTHENTICATION_PROPERTIES ("src/test/resources/portal/portal-authentication.properties"),
- ROLES_CONFIG_FILE ("src/test/resources/portal/roles.config");
+ TEST_USERS("src/test/resources/portal/test-users.config"), PORTAL_AUTHENTICATION_PROPERTIES(
+ "src/test/resources/portal/portal-authentication.properties"), ROLES_CONFIG_FILE(
+ "src/test/resources/portal/roles.config");
private String filename;
- TestData(String filename) {this.filename = filename;}
- public String getFilename() {return this.filename;}
+
+ TestData(String filename) {
+ this.filename = filename;
+ }
+
+ public String getFilename() {
+ return this.filename;
+ }
// @formatter:on
}
@@ -268,4 +274,4 @@ public class TestPortalRestAPIServiceImpl {
assertThat(userWithNoRoles.getRoles(), empty());
}
-} \ No newline at end of file
+}
diff --git a/src/test/java/org/onap/aai/sparky/security/portal/TestUserManager.java b/src/test/java/org/onap/aai/sparky/security/portal/TestUserManager.java
index 16669fd..2bc06ef 100644
--- a/src/test/java/org/onap/aai/sparky/security/portal/TestUserManager.java
+++ b/src/test/java/org/onap/aai/sparky/security/portal/TestUserManager.java
@@ -54,7 +54,7 @@ import org.powermock.modules.junit4.PowerMockRunner;
import com.google.gson.Gson;
@RunWith(PowerMockRunner.class)
-//@PrepareForTest(RolesConfig.class)
+// @PrepareForTest(RolesConfig.class)
public class TestUserManager {
private static final String LOGINID_3 = "3";
@@ -68,14 +68,20 @@ public class TestUserManager {
enum TestData {
// @formatter:off
- NO_FILE ("src/test/resources/portal/no-users.config"),
- CONCURRENT_USERS ("src/test/resources/portal/concurrent-users.config"),
- CONCURRENT_EDIT_USERS ("src/test/resources/portal/concurrent-edit-users.config");
-// ROLES_CONFIG_FILE ("src/test/resources/portal/roles.config");
+ NO_FILE("src/test/resources/portal/no-users.config"), CONCURRENT_USERS(
+ "src/test/resources/portal/concurrent-users.config"), CONCURRENT_EDIT_USERS(
+ "src/test/resources/portal/concurrent-edit-users.config");
+ // ROLES_CONFIG_FILE ("src/test/resources/portal/roles.config");
private String filename;
- TestData(String filename) {this.filename = filename;}
- public String getFilename() {return this.filename;}
+
+ TestData(String filename) {
+ this.filename = filename;
+ }
+
+ public String getFilename() {
+ return this.filename;
+ }
// @formatter:on
}
@@ -103,8 +109,8 @@ public class TestUserManager {
List<EcompUser> users = Arrays.asList(user1, user2);
Files.write(concurrentEditUsers.toPath(), GSON.toJson(users).getBytes());
-// Whitebox.setInternalState(RolesConfig.class, "ROLES_CONFIG_FILE",
-// TestData.ROLES_CONFIG_FILE.getFilename());
+ // Whitebox.setInternalState(RolesConfig.class, "ROLES_CONFIG_FILE",
+ // TestData.ROLES_CONFIG_FILE.getFilename());
}
@After
@@ -127,8 +133,8 @@ public class TestUserManager {
return pushTask(concurrentUsers, String.valueOf(NodeUtils.getRandomTxnId()));
};
- List<Callable<EcompUser>> callables = Arrays.asList(pushTask, pushTask, pushTask, pushTask,
- pushTask);
+ List<Callable<EcompUser>> callables =
+ Arrays.asList(pushTask, pushTask, pushTask, pushTask, pushTask);
ExecutorService executor = Executors.newWorkStealingPool();
executor.invokeAll(callables).stream().map(future -> {
@@ -165,9 +171,9 @@ public class TestUserManager {
return editTask(LOGINID_3, "Amy");
};
- List<Callable<EcompUser>> callables = Arrays.asList(pushTaskRandomId, pushTaskRandomId,
- pushTaskId3, editTaskId1, pushTaskRandomId, pushTaskRandomId, editTaskId3, editTaskId2,
- pushTaskRandomId);
+ List<Callable<EcompUser>> callables =
+ Arrays.asList(pushTaskRandomId, pushTaskRandomId, pushTaskId3, editTaskId1,
+ pushTaskRandomId, pushTaskRandomId, editTaskId3, editTaskId2, pushTaskRandomId);
ExecutorService executor = Executors.newWorkStealingPool();
List<EcompUser> userTasks = executor.invokeAll(callables).stream().map(future -> {
@@ -203,4 +209,4 @@ public class TestUserManager {
userManager.editUser(loginId, user);
return user;
}
-} \ No newline at end of file
+}
diff --git a/src/test/java/org/onap/aai/sparky/synchronizer/AggregationSuggestionSynchronizerTest.java b/src/test/java/org/onap/aai/sparky/synchronizer/AggregationSuggestionSynchronizerTest.java
index e590af6..b903851 100644
--- a/src/test/java/org/onap/aai/sparky/synchronizer/AggregationSuggestionSynchronizerTest.java
+++ b/src/test/java/org/onap/aai/sparky/synchronizer/AggregationSuggestionSynchronizerTest.java
@@ -40,47 +40,52 @@ import org.onap.aai.sparky.viewandinspect.config.TierSupportUiConstants;
public class AggregationSuggestionSynchronizerTest {
- @Before
- public void init() throws IOException {
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/";
- // TierSupportUiConstants.CONFIG_OXM_LOCATION = System.getProperty("AJSC_HOME")+"/bundleconfig-local/oxm/";
- }
-
- @Test
- public void testDoSync() throws Exception {
- ElasticSearchConfig.setConfig(null);
- setFinalStatic();
- AggregationSuggestionSynchronizer ass = new AggregationSuggestionSynchronizer("entity-search-index");
- Assert.assertNotNull(ass);
- OperationState state = ass.doSync();
- Assert.assertEquals(OperationState.OK, state);
+ @Before
+ public void init() throws IOException {
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION =
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/";
+ // TierSupportUiConstants.CONFIG_OXM_LOCATION =
+ // System.getProperty("AJSC_HOME")+"/bundleconfig-local/oxm/";
+ }
- OperationResult result = new OperationResult();
- result.setResultCode(200);
- result.setResult("result-1");
- result.setNumRequestRetries(1);
- NetworkTransaction ntwTxn = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
- ass.updateElasticSearchCounters(ntwTxn);
+ @Test
+ public void testDoSync() throws Exception {
+ ElasticSearchConfig.setConfig(null);
+ setFinalStatic();
+ AggregationSuggestionSynchronizer ass =
+ new AggregationSuggestionSynchronizer("entity-search-index");
+ Assert.assertNotNull(ass);
+ OperationState state = ass.doSync();
+ Assert.assertEquals(OperationState.OK, state);
- SynchronizerState syncState = ass.getState();
- Assert.assertEquals(SynchronizerState.IDLE, syncState);
-
- String statReport = ass.getStatReport(true);
- Assert.assertNotNull(statReport);
- Assert.assertTrue(statReport.contains("Aggregation Suggestion Synchronizer"));
-
- ass.shutdown();
- }
+ OperationResult result = new OperationResult();
+ result.setResultCode(200);
+ result.setResult("result-1");
+ result.setNumRequestRetries(1);
+ NetworkTransaction ntwTxn = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
+ ass.updateElasticSearchCounters(ntwTxn);
- static void setFinalStatic() throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException {
- Field configField = ElasticSearchConfig.class.getDeclaredField("CONFIG_FILE");
- configField.setAccessible(true);
+ SynchronizerState syncState = ass.getState();
+ Assert.assertEquals(SynchronizerState.IDLE, syncState);
- Field modifiersField = Field.class.getDeclaredField( "modifiers" );
- modifiersField.setAccessible( true );
- modifiersField.setInt( configField, configField.getModifiers() & ~Modifier.FINAL );
+ String statReport = ass.getStatReport(true);
+ Assert.assertNotNull(statReport);
+ Assert.assertTrue(statReport.contains("Aggregation Suggestion Synchronizer"));
- configField.set(null, System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/elasticsearch.properties");
- }
+ ass.shutdown();
+ }
+
+ static void setFinalStatic() throws NoSuchFieldException, SecurityException,
+ IllegalArgumentException, IllegalAccessException {
+ Field configField = ElasticSearchConfig.class.getDeclaredField("CONFIG_FILE");
+ configField.setAccessible(true);
+
+ Field modifiersField = Field.class.getDeclaredField("modifiers");
+ modifiersField.setAccessible(true);
+ modifiersField.setInt(configField, configField.getModifiers() & ~Modifier.FINAL);
+
+ configField.set(null,
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/elasticsearch.properties");
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/synchronizer/IndexDocumentTest.java b/src/test/java/org/onap/aai/sparky/synchronizer/IndexDocumentTest.java
index 822e927..1e14d38 100644
--- a/src/test/java/org/onap/aai/sparky/synchronizer/IndexDocumentTest.java
+++ b/src/test/java/org/onap/aai/sparky/synchronizer/IndexDocumentTest.java
@@ -42,7 +42,7 @@ import ch.qos.logback.classic.Level;
/**
* The Class IndexDocumentTest.
*/
-@RunWith(MockitoJUnitRunner.class)
+@RunWith(MockitoJUnitRunner.class)
public class IndexDocumentTest {
private LogValidator logValidator;
diff --git a/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerBuilder.java b/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerBuilder.java
index e97da4f..907ff23 100644
--- a/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerBuilder.java
+++ b/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerBuilder.java
@@ -130,7 +130,7 @@ public class SyncControllerBuilder {
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
IndexIntegrityValidator entityCounterHistoryValidator =
@@ -211,7 +211,7 @@ public class SyncControllerBuilder {
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
IndexIntegrityValidator entitySearchIndexValidator =
new IndexIntegrityValidator(nonCachingRestProvider, esConfig.getIndexName(),
@@ -266,7 +266,7 @@ public class SyncControllerBuilder {
*/
public void doSearchableEntitysync() {
try {
-
+
ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new RestClientBuilder());
@@ -286,10 +286,10 @@ public class SyncControllerBuilder {
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
//////
-
+
SyncController syncController = new SyncController("searchtableEntityTestController");
SearchableEntitySynchronizer ses =
@@ -340,7 +340,7 @@ public class SyncControllerBuilder {
*/
public void doCrossEntityReferenceSync() {
try {
-
+
ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new RestClientBuilder());
@@ -360,12 +360,12 @@ public class SyncControllerBuilder {
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
SyncController syncController = new SyncController("crossEntityRefSyncController");
- CrossEntityReferenceSynchronizer cers =
- new CrossEntityReferenceSynchronizer("entitysearchindex-localhost", ActiveInventoryConfig.getConfig());
+ CrossEntityReferenceSynchronizer cers = new CrossEntityReferenceSynchronizer(
+ "entitysearchindex-localhost", ActiveInventoryConfig.getConfig());
cers.setAaiDataProvider(aaiAdapter);
cers.setEsDataProvider(esAdapter);
syncController.registerEntitySynchronizer(cers);
@@ -413,7 +413,7 @@ public class SyncControllerBuilder {
*/
public void doSuggestionEntitySync() {
try {
-
+
ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new RestClientBuilder());
@@ -433,8 +433,8 @@ public class SyncControllerBuilder {
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
-
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
+
SyncController syncController = new SyncController("suggestionEntityTestController");
AutosuggestionSynchronizer ses =
@@ -456,7 +456,7 @@ public class SyncControllerBuilder {
System.out.println("Error: failed to sync with message = " + exc.getMessage());
}
}
-
+
/*
* Do no op sync.
*/
diff --git a/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerTest.java b/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerTest.java
index c7464d3..bc268df 100644
--- a/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerTest.java
+++ b/src/test/java/org/onap/aai/sparky/synchronizer/SyncControllerTest.java
@@ -29,53 +29,58 @@ import org.onap.aai.sparky.synchronizer.SyncController.SyncActions;
public class SyncControllerTest {
- SyncController controller;
+ SyncController controller;
- @Before
- public void init() throws Exception {
- controller = new SyncController("name-1");
- }
- @Test
- public void testPerformAction_PreSync() {
- controller.performAction(SyncActions.SYNCHRONIZE);
- controller.shutdown();
- }
+ @Before
+ public void init() throws Exception {
+ controller = new SyncController("name-1");
+ }
- @Test
- public void testRegisterIndexCleaner_NullIndexName() {
- IndexCleaner cleaner = new ElasticSearchIndexCleaner(null, null, "index_type-1", "host-1", "port-1", 1, 1);
- controller.registerIndexCleaner(cleaner);
- }
+ @Test
+ public void testPerformAction_PreSync() {
+ controller.performAction(SyncActions.SYNCHRONIZE);
+ controller.shutdown();
+ }
- @Test
- public void testRegisterIndexCleaner_NotNullIndexName() {
- IndexCleaner cleaner = new ElasticSearchIndexCleaner(null, "index-1", "index_type-1", "host-1", "port-1", 1, 1);
- controller.registerIndexCleaner(cleaner);
- }
+ @Test
+ public void testRegisterIndexCleaner_NullIndexName() {
+ IndexCleaner cleaner =
+ new ElasticSearchIndexCleaner(null, null, "index_type-1", "host-1", "port-1", 1, 1);
+ controller.registerIndexCleaner(cleaner);
+ }
- @Test
- public void testRegisterIndexValidator_NullIndexValidator() {
- IndexValidator validator = new IndexIntegrityValidator(null, null, "index_type-1", "host-1", "port-1", "json-1");
- controller.registerIndexValidator(validator);
- }
+ @Test
+ public void testRegisterIndexCleaner_NotNullIndexName() {
+ IndexCleaner cleaner =
+ new ElasticSearchIndexCleaner(null, "index-1", "index_type-1", "host-1", "port-1", 1, 1);
+ controller.registerIndexCleaner(cleaner);
+ }
- @Test
- public void testRegisterIndexValidator_NotNullIndexValidator() {
- IndexValidator validator = new IndexIntegrityValidator(null, "index-1", "index_type-1", "host-1", "port-1", "json-1");
- controller.registerIndexValidator(validator);
- }
+ @Test
+ public void testRegisterIndexValidator_NullIndexValidator() {
+ IndexValidator validator =
+ new IndexIntegrityValidator(null, null, "index_type-1", "host-1", "port-1", "json-1");
+ controller.registerIndexValidator(validator);
+ }
- @Test
- public void testRegisterEntitySynchronizer_NullEntitySynchronizer() throws Exception {
- IndexSynchronizer synchroniser = Mockito.mock(SearchableEntitySynchronizer.class);
- Mockito.when(synchroniser.getIndexName()).thenReturn(null);
- controller.registerEntitySynchronizer(synchroniser);
- }
+ @Test
+ public void testRegisterIndexValidator_NotNullIndexValidator() {
+ IndexValidator validator =
+ new IndexIntegrityValidator(null, "index-1", "index_type-1", "host-1", "port-1", "json-1");
+ controller.registerIndexValidator(validator);
+ }
- @Test
- public void testRegisterEntitySynchronizer_NotNullEntitySynchronizer() throws Exception {
- IndexSynchronizer synchroniser = Mockito.mock(SearchableEntitySynchronizer.class);
- Mockito.when(synchroniser.getIndexName()).thenReturn("entity-1");
- controller.registerEntitySynchronizer(synchroniser);
- }
+ @Test
+ public void testRegisterEntitySynchronizer_NullEntitySynchronizer() throws Exception {
+ IndexSynchronizer synchroniser = Mockito.mock(SearchableEntitySynchronizer.class);
+ Mockito.when(synchroniser.getIndexName()).thenReturn(null);
+ controller.registerEntitySynchronizer(synchroniser);
+ }
+
+ @Test
+ public void testRegisterEntitySynchronizer_NotNullEntitySynchronizer() throws Exception {
+ IndexSynchronizer synchroniser = Mockito.mock(SearchableEntitySynchronizer.class);
+ Mockito.when(synchroniser.getIndexName()).thenReturn("entity-1");
+ controller.registerEntitySynchronizer(synchroniser);
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/synchronizer/SyncHelperTest.java b/src/test/java/org/onap/aai/sparky/synchronizer/SyncHelperTest.java
index 5a2584f..46e6350 100644
--- a/src/test/java/org/onap/aai/sparky/synchronizer/SyncHelperTest.java
+++ b/src/test/java/org/onap/aai/sparky/synchronizer/SyncHelperTest.java
@@ -45,74 +45,82 @@ import org.onap.aai.sparky.viewandinspect.config.TierSupportUiConstants;
@RunWith(MockitoJUnitRunner.class)
public class SyncHelperTest {
- private SyncHelper syncHelper;
-
- @BeforeClass
- public static void initBeforeClass() throws IOException, NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException {
- String configHomePath =
- (new File(".").getCanonicalPath() + "/src/test/resources/appconfig/").replace('\\', '/');
- TierSupportUiConstants.AJSC_HOME = configHomePath;
- TierSupportUiConstants.CONFIG_HOME = configHomePath;
- TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = configHomePath;
- ElasticSearchConfig.setConfig(null);
- SynchronizerConfiguration.setInstance(null);
- setFinalStatic();
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/";
- }
-
-
- @Test
- public void testGetOxmModelLoader() throws Exception {
- syncHelper = new SyncHelper(new OxmModelLoader());
- OxmModelLoader oxmLoader = new OxmModelLoader();
- syncHelper.setOxmModelLoader(oxmLoader);
- assertEquals(oxmLoader, syncHelper.getOxmModelLoader());
- }
-
- @Test
- public void testGetFirstSyncTime(){
- SyncHelper syncHelper = new SyncHelper(new OxmModelLoader());
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
- TimeZone tz = TimeZone.getTimeZone("05:00:00 GMT+00:00");
- Calendar calendar = Calendar.getInstance(tz);
- sdf.setTimeZone(tz);
-
- calendar.set(Calendar.HOUR_OF_DAY, 1);
- calendar.set(Calendar.MINUTE, 1);
- calendar.set(Calendar.SECOND, 1);
-
- long timeCurrent = calendar.getTimeInMillis();
- int taskFrequencyInDay = 2;
-
- assertEquals(calendar.getTimeInMillis(), syncHelper.getFirstSyncTime(calendar, timeCurrent, taskFrequencyInDay));
- taskFrequencyInDay = 0;
- assertEquals(SynchronizerConstants.DELAY_NO_PERIODIC_SYNC_IN_MS, syncHelper.getFirstSyncTime(calendar, timeCurrent, taskFrequencyInDay));
- timeCurrent = timeCurrent + 100;
- taskFrequencyInDay = 2;
- Calendar expCalendar = calendar;
- expCalendar.add(Calendar.DAY_OF_MONTH, taskFrequencyInDay);
- //assertEquals(expCalendar.getTimeInMillis(), syncHelper.getFirstSyncTime(calendar, calendar.getTimeInMillis() + 100, taskFrequencyInDay));
-
- }
-
- static void setFinalStatic() throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException {
- Field configField = ElasticSearchConfig.class.getDeclaredField("CONFIG_FILE");
- configField.setAccessible(true);
-
- Field modifiersField = Field.class.getDeclaredField( "modifiers" );
- modifiersField.setAccessible( true );
- modifiersField.setInt( configField, configField.getModifiers() & ~Modifier.FINAL );
-
- configField.set(null, System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/elasticsearch.properties");
-
- Field syncField = SynchronizerConfiguration.class.getDeclaredField("CONFIG_FILE");
- syncField.setAccessible(true);
-
- Field syncModifiersField = Field.class.getDeclaredField( "modifiers" );
- syncModifiersField.setAccessible( true );
- syncModifiersField.setInt( syncField, syncField.getModifiers() & ~Modifier.FINAL );
-
- syncField.set(null, System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/synchronizer.properties");
- }
+ private SyncHelper syncHelper;
+
+ @BeforeClass
+ public static void initBeforeClass() throws IOException, NoSuchFieldException, SecurityException,
+ IllegalArgumentException, IllegalAccessException {
+ String configHomePath =
+ (new File(".").getCanonicalPath() + "/src/test/resources/appconfig/").replace('\\', '/');
+ TierSupportUiConstants.AJSC_HOME = configHomePath;
+ TierSupportUiConstants.CONFIG_HOME = configHomePath;
+ TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = configHomePath;
+ ElasticSearchConfig.setConfig(null);
+ SynchronizerConfiguration.setInstance(null);
+ setFinalStatic();
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION =
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/";
+ }
+
+
+ @Test
+ public void testGetOxmModelLoader() throws Exception {
+ syncHelper = new SyncHelper(new OxmModelLoader());
+ OxmModelLoader oxmLoader = new OxmModelLoader();
+ syncHelper.setOxmModelLoader(oxmLoader);
+ assertEquals(oxmLoader, syncHelper.getOxmModelLoader());
+ }
+
+ @Test
+ public void testGetFirstSyncTime() {
+ SyncHelper syncHelper = new SyncHelper(new OxmModelLoader());
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
+ TimeZone tz = TimeZone.getTimeZone("05:00:00 GMT+00:00");
+ Calendar calendar = Calendar.getInstance(tz);
+ sdf.setTimeZone(tz);
+
+ calendar.set(Calendar.HOUR_OF_DAY, 1);
+ calendar.set(Calendar.MINUTE, 1);
+ calendar.set(Calendar.SECOND, 1);
+
+ long timeCurrent = calendar.getTimeInMillis();
+ int taskFrequencyInDay = 2;
+
+ assertEquals(calendar.getTimeInMillis(),
+ syncHelper.getFirstSyncTime(calendar, timeCurrent, taskFrequencyInDay));
+ taskFrequencyInDay = 0;
+ assertEquals(SynchronizerConstants.DELAY_NO_PERIODIC_SYNC_IN_MS,
+ syncHelper.getFirstSyncTime(calendar, timeCurrent, taskFrequencyInDay));
+ timeCurrent = timeCurrent + 100;
+ taskFrequencyInDay = 2;
+ Calendar expCalendar = calendar;
+ expCalendar.add(Calendar.DAY_OF_MONTH, taskFrequencyInDay);
+ // assertEquals(expCalendar.getTimeInMillis(), syncHelper.getFirstSyncTime(calendar,
+ // calendar.getTimeInMillis() + 100, taskFrequencyInDay));
+
+ }
+
+ static void setFinalStatic() throws NoSuchFieldException, SecurityException,
+ IllegalArgumentException, IllegalAccessException {
+ Field configField = ElasticSearchConfig.class.getDeclaredField("CONFIG_FILE");
+ configField.setAccessible(true);
+
+ Field modifiersField = Field.class.getDeclaredField("modifiers");
+ modifiersField.setAccessible(true);
+ modifiersField.setInt(configField, configField.getModifiers() & ~Modifier.FINAL);
+
+ configField.set(null,
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/elasticsearch.properties");
+
+ Field syncField = SynchronizerConfiguration.class.getDeclaredField("CONFIG_FILE");
+ syncField.setAccessible(true);
+
+ Field syncModifiersField = Field.class.getDeclaredField("modifiers");
+ syncModifiersField.setAccessible(true);
+ syncModifiersField.setInt(syncField, syncField.getModifiers() & ~Modifier.FINAL);
+
+ syncField.set(null,
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/synchronizer.properties");
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/synchronizer/config/SynchronizerConfigurationTest.java b/src/test/java/org/onap/aai/sparky/synchronizer/config/SynchronizerConfigurationTest.java
index b61eebd..228b048 100644
--- a/src/test/java/org/onap/aai/sparky/synchronizer/config/SynchronizerConfigurationTest.java
+++ b/src/test/java/org/onap/aai/sparky/synchronizer/config/SynchronizerConfigurationTest.java
@@ -14,11 +14,11 @@ import org.junit.Test;
public class SynchronizerConfigurationTest {
private SynchronizerConfiguration config;
-
+
private Properties generateTestProperties() {
-
+
Properties props = new Properties();
-
+
props.put("synchronizer.syncTask.initialDelayInMs", "60000");
props.put("synchronizer.syncTask.taskFrequencyInDay", "2");
props.put("synchronizer.syncTask.startTimestamp", "05:00:00 UTC+00:00");
@@ -35,21 +35,21 @@ public class SynchronizerConfigurationTest {
props.put("synchronizer.suppressResourceNotFoundErrors", "true");
props.put("synchronizer.applyNodesOnlyModifier", "false");
props.put("synchronizer.autosuggestSynchronizationEnabled", "true");
-
+
return props;
}
-
-
+
+
@Before
public void init() throws Exception {
-
+
config = new SynchronizerConfiguration(generateTestProperties());
}
@Test
public void validateAccessors() {
-
+
assertEquals(60000, config.getSyncTaskInitialDelayInMs());
assertEquals(2, config.getSyncTaskFrequencyInDay());
assertEquals("05:00:00 UTC+00:00", config.getSyncTaskStartTime());
@@ -57,7 +57,7 @@ public class SynchronizerConfigurationTest {
assertEquals(0, config.getSyncTaskStartTimeMin());
assertEquals(0, config.getSyncTaskStartTimeSec());
assertEquals(true, config.isAutosuggestSynchronizationEnabled());
- assertEquals(false, config.isConfigDisabledForInitialSync() );
+ assertEquals(false, config.isConfigDisabledForInitialSync());
assertEquals(true, config.isConfigOkForPeriodicSync());
assertEquals(true, config.isConfigOkForStartupSync());
assertEquals(false, config.isDisplayVerboseQueueManagerStats());
@@ -72,177 +72,176 @@ public class SynchronizerConfigurationTest {
assertEquals(1000, config.getResolverQueueMonitorFrequencyInMs());
assertEquals(3600000, config.getIndexIntegrityValidatorFrequencyInMs());
assertTrue(config.toString().startsWith("SynchronizerConfiguration"));
-
-
+
+
config.setSyncTaskInitialDelayInMs(1234);
assertEquals(1234, config.getSyncTaskInitialDelayInMs());
-
+
config.setSyncTaskFrequencyInDay(5);
assertEquals(5, config.getSyncTaskFrequencyInDay());
config.setSyncTaskStartTime("06:10:22 UTC+00:00");
assertEquals("06:10:22 UTC+00:00", config.getSyncTaskStartTime());
-
+
config.setSyncTaskStartTimeHr(6);
assertEquals(6, config.getSyncTaskStartTimeHr());
-
+
config.setSyncTaskStartTimeMin(10);
assertEquals(10, config.getSyncTaskStartTimeMin());
config.setSyncTaskStartTimeSec(22);
assertEquals(22, config.getSyncTaskStartTimeSec());
-
+
config.setAutosuggestSynchronizationEnabled(false);
assertEquals(false, config.isAutosuggestSynchronizationEnabled());
-
+
config.setDisplayVerboseQueueManagerStats(true);
assertEquals(true, config.isDisplayVerboseQueueManagerStats());
-
-
+
+
config.setIndexIntegrityValidatorEnabled(true);
assertEquals(true, config.isIndexIntegrityValidatorEnabled());
-
+
config.setNodesOnlyModifierEnabled(true);
assertEquals(true, config.isNodesOnlyModifierEnabled());
config.setResourceNotFoundErrorsSupressed(false);
assertEquals(false, config.isResourceNotFoundErrorsSupressed());
-
+
config.setNumScrollContextItemsToRetrievePerRequest(1234);
assertEquals(1234, config.getNumScrollContextItemsToRetrievePerRequest());
-
+
config.setScrollContextTimeToLiveInMinutes(11);
assertEquals(11, config.getScrollContextTimeToLiveInMinutes());
-
-
+
+
config.setSyncTaskStartTimeTimeZone("EST");
assertEquals("EST", config.getSyncTaskStartTimeTimeZone());
-
+
config.setSyncTaskFrequencyInMs(1221);
assertEquals(1221, config.getSyncTaskFrequencyInMs());
-
+
config.setResolverProgressLogFrequencyInMs(1111);
assertEquals(1111, config.getResolverProgressLogFrequencyInMs());
-
+
config.setResolverQueueMonitorFrequencyInMs(1111);
assertEquals(1111, config.getResolverQueueMonitorFrequencyInMs());
-
+
config.setIndexIntegrityValidatorFrequencyInMs(5555);
assertEquals(5555, config.getIndexIntegrityValidatorFrequencyInMs());
-
+
config.setConfigOkForPeriodicSync(false);
assertEquals(false, config.isConfigOkForPeriodicSync());
-
+
config.setConfigOkForStartupSync(false);
assertEquals(false, config.isConfigOkForStartupSync());
-
+
}
-
+
@Test
public void validateFirstSyncTimeCalculation_taskFrequencyZeroDays() {
-
- Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+
+ Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// set year, month, day, hour, minute, second
- syncThresholdTime.set(2017,2,1,0,0,0); // 00:00 on 1-Feb-2017
-
-
- Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+ syncThresholdTime.set(2017, 2, 1, 0, 0, 0); // 00:00 on 1-Feb-2017
+
+
+ Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// set year, month, day, hour, minute, second
- timeNow.set(2017,2,1,0,0,0); // 00:00 on 1-Feb-2017
+ timeNow.set(2017, 2, 1, 0, 0, 0); // 00:00 on 1-Feb-2017
+
+ assertEquals(0, config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 0));
- assertEquals( 0, config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 0));
-
}
-
+
@Test
public void validateFirstSyncTimeCalculation_timeNowLessThanSyncTimeBoundary() {
-
- Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+
+ Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// 06:00 on 1-Feb-2017
- syncThresholdTime.set(2017,2,1,6,0,0);
-
- Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+ syncThresholdTime.set(2017, 2, 1, 6, 0, 0);
+
+ Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// set year, month, day, hour, minute, second
- timeNow.set(2017,2,1,0,0,0); // 00:00 on 1-Feb-2017
-
+ timeNow.set(2017, 2, 1, 0, 0, 0); // 00:00 on 1-Feb-2017
+
// First sync time is the 06:00 am threshold time
- assertEquals( syncThresholdTime.getTimeInMillis(), config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 1*86400));
-
+ assertEquals(syncThresholdTime.getTimeInMillis(),
+ config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 1 * 86400));
+
}
-
+
@Test
public void validateFirstSyncTimeCalculation_timeNowEqualsSyncTimeBoundary() {
-
- Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+
+ Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// 06:00 on 1-Feb-2017
- syncThresholdTime.set(2017,2,1,6,0,0);
-
- Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+ syncThresholdTime.set(2017, 2, 1, 6, 0, 0);
+
+ Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// set year, month, day, hour, minute, second
- timeNow.set(2017,2,1,6,0,0); // 00:00 on 1-Feb-2017
-
+ timeNow.set(2017, 2, 1, 6, 0, 0); // 00:00 on 1-Feb-2017
+
// First sync time is the 06:00 am threshold time
- //assertEquals( (syncThresholdTime.getTimeInMillis()/1000), (config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 1*86400)/1000));
-
+ // assertEquals( (syncThresholdTime.getTimeInMillis()/1000),
+ // (config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 1*86400)/1000));
+
}
-
+
@Test
public void validateFirstSyncTimeCalculation_timeNowGreaterThanSyncTimeBoundary() {
-
- Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+
+ Calendar syncThresholdTime = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// 06:00 on 1-Feb-2017
- syncThresholdTime.set(2017,2,1,6,0,0);
-
- Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"),Locale.CANADA);
+ syncThresholdTime.set(2017, 2, 1, 6, 0, 0);
+
+ Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"), Locale.CANADA);
// set year, month, day, hour, minute, second
- timeNow.set(2017,2,1,8,0,0); // 00:00 on 1-Feb-2017
-
+ timeNow.set(2017, 2, 1, 8, 0, 0); // 00:00 on 1-Feb-2017
+
// First sync time is 1 full sync period past the sync threshold time
- assertEquals( 86400000 + syncThresholdTime.getTimeInMillis(), config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 1*86400));
-
+ assertEquals(86400000 + syncThresholdTime.getTimeInMillis(),
+ config.getNextSyncTime(syncThresholdTime, timeNow.getTimeInMillis(), 1 * 86400));
+
}
-
-/* @Test
- public void validateDefaultPeriodicInitialSyncDelay_dailySync_timeNowAtMidnight() {
-
- config.setSyncTaskStartTimeTimeZone("EST");
- config.setSyncTaskStartTimeHr(6);
- config.setSyncTaskStartTimeMin(0);
- config.setSyncTaskStartTimeSec(0);
- config.setSyncTaskFrequencyInDay(1);
- config.setSyncTaskInitialDelayInMs(60000);
-
- Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
- // set year, month, day, hour, minute, second
- timeNow.set(Calendar.AM_PM, Calendar.AM);
- timeNow.set(Calendar.HOUR, 0);
- timeNow.set(Calendar.MINUTE, 0);
- timeNow.set(Calendar.SECOND, 0);
-
- // First sync time is 6 hours from midnight
- assertEquals( 6*3600*1000, config.getDefaultInitialSyncDelayInMs(timeNow));
-
- }*/
-
+ /*
+ * @Test public void validateDefaultPeriodicInitialSyncDelay_dailySync_timeNowAtMidnight() {
+ *
+ * config.setSyncTaskStartTimeTimeZone("EST"); config.setSyncTaskStartTimeHr(6);
+ * config.setSyncTaskStartTimeMin(0); config.setSyncTaskStartTimeSec(0);
+ * config.setSyncTaskFrequencyInDay(1); config.setSyncTaskInitialDelayInMs(60000);
+ *
+ * Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
+ *
+ * // set year, month, day, hour, minute, second timeNow.set(Calendar.AM_PM, Calendar.AM);
+ * timeNow.set(Calendar.HOUR, 0); timeNow.set(Calendar.MINUTE, 0); timeNow.set(Calendar.SECOND,
+ * 0);
+ *
+ * // First sync time is 6 hours from midnight assertEquals( 6*3600*1000,
+ * config.getDefaultInitialSyncDelayInMs(timeNow));
+ *
+ * }
+ */
+
@Test
public void validateDefaultPeriodicInitialSyncDelay_dailySync_timeNowAt4AM() {
-
+
config.setSyncTaskStartTimeTimeZone("EST");
config.setSyncTaskStartTimeHr(6);
config.setSyncTaskStartTimeMin(0);
config.setSyncTaskStartTimeSec(0);
config.setSyncTaskFrequencyInDay(1);
config.setSyncTaskInitialDelayInMs(60000);
-
+
Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
// set year, month, day, hour, minute, second
@@ -250,22 +249,22 @@ public class SynchronizerConfigurationTest {
timeNow.set(Calendar.HOUR, 4);
timeNow.set(Calendar.MINUTE, 0);
timeNow.set(Calendar.SECOND, 0);
-
+
// round time to minutes to avoid millisecond alignment variance
assertEquals(2 * 3600, (config.getDefaultInitialSyncDelayInMs(timeNow)) / 1000);
}
-
+
@Test
public void validateDefaultPeriodicInitialSyncDelay_dailySync_timeNowAt6AM() {
-
+
config.setSyncTaskStartTimeTimeZone("EST");
config.setSyncTaskStartTimeHr(6);
config.setSyncTaskStartTimeMin(0);
config.setSyncTaskStartTimeSec(0);
config.setSyncTaskFrequencyInDay(1);
config.setSyncTaskInitialDelayInMs(60000);
-
+
Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
// set year, month, day, hour, minute, second
@@ -273,22 +272,22 @@ public class SynchronizerConfigurationTest {
timeNow.set(Calendar.HOUR, 6);
timeNow.set(Calendar.MINUTE, 0);
timeNow.set(Calendar.SECOND, 0);
-
- // First sync time is now with 60 seconds from now
- assertEquals( 60000, config.getDefaultInitialSyncDelayInMs(timeNow));
-
+
+ // First sync time is now with 60 seconds from now
+ assertEquals(60000, config.getDefaultInitialSyncDelayInMs(timeNow));
+
}
-
+
@Test
public void validateDefaultPeriodicInitialSyncDelay_dailySync_timeNowAt10PM() {
-
+
config.setSyncTaskStartTimeTimeZone("EST");
config.setSyncTaskStartTimeHr(6);
config.setSyncTaskStartTimeMin(0);
config.setSyncTaskStartTimeSec(0);
config.setSyncTaskFrequencyInDay(1);
config.setSyncTaskInitialDelayInMs(60000);
-
+
Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
// set year, month, day, hour, minute, second
@@ -296,46 +295,42 @@ public class SynchronizerConfigurationTest {
timeNow.set(Calendar.HOUR, 10);
timeNow.set(Calendar.MINUTE, 0);
timeNow.set(Calendar.SECOND, 0);
-
- // First sync time is now 1 sync period delayed. The time delay before
+
+ // First sync time is now 1 sync period delayed. The time delay before
// the initial sync should now be 8 hours, assuming 10PM is the current time.
- assertEquals( 8*3600, (config.getDefaultInitialSyncDelayInMs(timeNow)/1000));
-
+ assertEquals(8 * 3600, (config.getDefaultInitialSyncDelayInMs(timeNow) / 1000));
+
}
-
-/* @Test
- public void validateDefaultPeriodicInitialSyncDelay_weeklySync_timeNowAtMidnight() {
-
- config.setSyncTaskStartTimeTimeZone("EST");
- config.setSyncTaskStartTimeHr(6);
- config.setSyncTaskStartTimeMin(0);
- config.setSyncTaskStartTimeSec(0);
- config.setSyncTaskFrequencyInDay(7);
- config.setSyncTaskInitialDelayInMs(60000);
-
- Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
- // set year, month, day, hour, minute, second
- timeNow.set(Calendar.AM_PM, Calendar.AM);
- timeNow.set(Calendar.HOUR, 0);
- timeNow.set(Calendar.MINUTE, 0);
- timeNow.set(Calendar.SECOND, 0);
-
- // First sync time is 6 hours from midnight
- assertTrue(6*3600*1000 >= config.getDefaultInitialSyncDelayInMs(timeNow));
-
- }*/
-
+ /*
+ * @Test public void validateDefaultPeriodicInitialSyncDelay_weeklySync_timeNowAtMidnight() {
+ *
+ * config.setSyncTaskStartTimeTimeZone("EST"); config.setSyncTaskStartTimeHr(6);
+ * config.setSyncTaskStartTimeMin(0); config.setSyncTaskStartTimeSec(0);
+ * config.setSyncTaskFrequencyInDay(7); config.setSyncTaskInitialDelayInMs(60000);
+ *
+ * Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
+ *
+ * // set year, month, day, hour, minute, second timeNow.set(Calendar.AM_PM, Calendar.AM);
+ * timeNow.set(Calendar.HOUR, 0); timeNow.set(Calendar.MINUTE, 0); timeNow.set(Calendar.SECOND,
+ * 0);
+ *
+ * // First sync time is 6 hours from midnight assertTrue(6*3600*1000 >=
+ * config.getDefaultInitialSyncDelayInMs(timeNow));
+ *
+ * }
+ */
+
@Test
public void validateDefaultPeriodicInitialSyncDelay_weeklySync_timeNowAt4AM() {
-
+
config.setSyncTaskStartTimeTimeZone("EST");
config.setSyncTaskStartTimeHr(6);
config.setSyncTaskStartTimeMin(0);
config.setSyncTaskStartTimeSec(0);
config.setSyncTaskFrequencyInDay(7);
config.setSyncTaskInitialDelayInMs(60000);
-
+
Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
// set year, month, day, hour, minute, second
@@ -343,22 +338,22 @@ public class SynchronizerConfigurationTest {
timeNow.set(Calendar.HOUR, 4);
timeNow.set(Calendar.MINUTE, 0);
timeNow.set(Calendar.SECOND, 0);
-
+
// round time to minutes to avoid millisecond alignment variance
assertEquals(2 * 3600, (config.getDefaultInitialSyncDelayInMs(timeNow)) / 1000);
}
-
+
@Test
public void validateDefaultPeriodicInitialSyncDelay_weeklySync_timeNowAt6AM() {
-
+
config.setSyncTaskStartTimeTimeZone("EST");
config.setSyncTaskStartTimeHr(6);
config.setSyncTaskStartTimeMin(0);
config.setSyncTaskStartTimeSec(0);
config.setSyncTaskFrequencyInDay(7);
config.setSyncTaskInitialDelayInMs(60000);
-
+
Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
// set year, month, day, hour, minute, second
@@ -366,22 +361,22 @@ public class SynchronizerConfigurationTest {
timeNow.set(Calendar.HOUR, 6);
timeNow.set(Calendar.MINUTE, 0);
timeNow.set(Calendar.SECOND, 0);
-
- // First sync time is now with 60 seconds from now
- assertEquals( 60000, config.getDefaultInitialSyncDelayInMs(timeNow));
-
+
+ // First sync time is now with 60 seconds from now
+ assertEquals(60000, config.getDefaultInitialSyncDelayInMs(timeNow));
+
}
-
+
@Test
public void validateDefaultPeriodicInitialSyncDelay_weeklySync_timeNowAt10PM() {
-
+
config.setSyncTaskStartTimeTimeZone("EST");
config.setSyncTaskStartTimeHr(6);
config.setSyncTaskStartTimeMin(0);
config.setSyncTaskStartTimeSec(0);
config.setSyncTaskFrequencyInDay(7);
config.setSyncTaskInitialDelayInMs(60000);
-
+
Calendar timeNow = Calendar.getInstance(TimeZone.getTimeZone("EST"));
// set year, month, day, hour, minute, second
@@ -389,12 +384,12 @@ public class SynchronizerConfigurationTest {
timeNow.set(Calendar.HOUR, 10);
timeNow.set(Calendar.MINUTE, 0);
timeNow.set(Calendar.SECOND, 0);
-
- // First sync time is now 1 sync period delayed. The time delay before
+
+ // First sync time is now 1 sync period delayed. The time delay before
// the initial sync should now be 8 hours + 24*6 days, assuming 10PM is the current time.
- assertEquals( (8+(6*24))*3600, (config.getDefaultInitialSyncDelayInMs(timeNow)/1000));
-
+ assertEquals((8 + (6 * 24)) * 3600, (config.getDefaultInitialSyncDelayInMs(timeNow) / 1000));
+
}
-
-
+
+
}
diff --git a/src/test/java/org/onap/aai/sparky/synchronizer/entity/AggregationSuggestionEntityTest.java b/src/test/java/org/onap/aai/sparky/synchronizer/entity/AggregationSuggestionEntityTest.java
index 5b945cf..5aab75d 100644
--- a/src/test/java/org/onap/aai/sparky/synchronizer/entity/AggregationSuggestionEntityTest.java
+++ b/src/test/java/org/onap/aai/sparky/synchronizer/entity/AggregationSuggestionEntityTest.java
@@ -63,7 +63,7 @@ public class AggregationSuggestionEntityTest {
String expectedFilterListPayload = getResourceFileContents(
"sync/entity/AggregationSuggestionEntity_getIndexDocumentJson_expected.json");
- assertTrue(
- aggregationSuggestionEntity.getIndexDocumentJson().contains(expectedFilterListPayload.trim()));
+ assertTrue(aggregationSuggestionEntity.getIndexDocumentJson()
+ .contains(expectedFilterListPayload.trim()));
}
}
diff --git a/src/test/java/org/onap/aai/sparky/util/CaptureLoggerAppender.java b/src/test/java/org/onap/aai/sparky/util/CaptureLoggerAppender.java
index 31b425a..3a36f7d 100644
--- a/src/test/java/org/onap/aai/sparky/util/CaptureLoggerAppender.java
+++ b/src/test/java/org/onap/aai/sparky/util/CaptureLoggerAppender.java
@@ -90,13 +90,17 @@ public class CaptureLoggerAppender implements Appender {
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.LifeCycle#start()
*/
@Override
public void start() {}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.LifeCycle#stop()
*/
@Override
@@ -123,7 +127,9 @@ public class CaptureLoggerAppender implements Appender {
return null;
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.ContextAware#addStatus(ch.qos.logback.core.status.Status)
*/
@Override
@@ -132,7 +138,9 @@ public class CaptureLoggerAppender implements Appender {
System.out.println("addStatus");
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.ContextAware#addInfo(java.lang.String)
*/
@Override
@@ -141,7 +149,9 @@ public class CaptureLoggerAppender implements Appender {
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.ContextAware#addInfo(java.lang.String, java.lang.Throwable)
*/
@Override
@@ -150,7 +160,9 @@ public class CaptureLoggerAppender implements Appender {
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.ContextAware#addWarn(java.lang.String)
*/
@Override
@@ -159,7 +171,9 @@ public class CaptureLoggerAppender implements Appender {
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.ContextAware#addWarn(java.lang.String, java.lang.Throwable)
*/
@Override
@@ -168,7 +182,9 @@ public class CaptureLoggerAppender implements Appender {
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.ContextAware#addError(java.lang.String)
*/
@Override
@@ -177,7 +193,9 @@ public class CaptureLoggerAppender implements Appender {
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.ContextAware#addError(java.lang.String, java.lang.Throwable)
*/
@Override
@@ -186,7 +204,9 @@ public class CaptureLoggerAppender implements Appender {
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.FilterAttachable#addFilter(ch.qos.logback.core.filter.Filter)
*/
@Override
@@ -195,7 +215,9 @@ public class CaptureLoggerAppender implements Appender {
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.FilterAttachable#clearAllFilters()
*/
@Override
@@ -210,7 +232,9 @@ public class CaptureLoggerAppender implements Appender {
return null;
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.spi.FilterAttachable#getFilterChainDecision(java.lang.Object)
*/
@Override
@@ -226,7 +250,9 @@ public class CaptureLoggerAppender implements Appender {
return "MOCK";
}
- /* (non-Javadoc)
+ /*
+ * (non-Javadoc)
+ *
* @see ch.qos.logback.core.Appender#doAppend(java.lang.Object)
*/
@Override
diff --git a/src/test/java/org/onap/aai/sparky/util/ElasticEntitySummarizer.java b/src/test/java/org/onap/aai/sparky/util/ElasticEntitySummarizer.java
index 7538c1b..5f98e0b 100644
--- a/src/test/java/org/onap/aai/sparky/util/ElasticEntitySummarizer.java
+++ b/src/test/java/org/onap/aai/sparky/util/ElasticEntitySummarizer.java
@@ -44,6 +44,7 @@ import org.onap.aai.sparky.synchronizer.config.TaskProcessorConfig;
public class ElasticEntitySummarizer {
private RestDataProvider syncAdapter;
+
/**
* @return the syncAdapter
*/
@@ -185,10 +186,8 @@ public class ElasticEntitySummarizer {
System.out.println(String.format("\n%-30s %-12d", "Total", totalEntities));
} catch (Exception exc) {
- System.out.println(
- "An error occurred while attempting to collect pre-sync elastic"
- + " search document ids with an error cause = "
- + exc.getLocalizedMessage());
+ System.out.println("An error occurred while attempting to collect pre-sync elastic"
+ + " search document ids with an error cause = " + exc.getLocalizedMessage());
}
diff --git a/src/test/java/org/onap/aai/sparky/util/ElasticGarbageInjector.java b/src/test/java/org/onap/aai/sparky/util/ElasticGarbageInjector.java
index 5e47942..92ccd28 100644
--- a/src/test/java/org/onap/aai/sparky/util/ElasticGarbageInjector.java
+++ b/src/test/java/org/onap/aai/sparky/util/ElasticGarbageInjector.java
@@ -47,8 +47,8 @@ public class ElasticGarbageInjector {
private enum ActiveInventoryEntities {
COMPLEX("complex"), CUSTOMER("customer"), GENERIC_VNF("generic-vnf"), NEWVCE("newvce"), PSERVER(
- "pserver"), SERVICE_INSTANCE("service-instance"), VCE("vce"), VPE("vpe"), VSERVER(
- "vserver");
+ "pserver"), SERVICE_INSTANCE(
+ "service-instance"), VCE("vce"), VPE("vpe"), VSERVER("vserver");
private final String entityName;
diff --git a/src/test/java/org/onap/aai/sparky/util/ExceptionHelper.java b/src/test/java/org/onap/aai/sparky/util/ExceptionHelper.java
index 6acb1bf..3b56a6e 100644
--- a/src/test/java/org/onap/aai/sparky/util/ExceptionHelper.java
+++ b/src/test/java/org/onap/aai/sparky/util/ExceptionHelper.java
@@ -29,7 +29,7 @@ package org.onap.aai.sparky.util;
* The Class ExceptionHelper.
*/
public class ExceptionHelper {
-
+
/**
* Extract stack trace elements.
*
diff --git a/src/test/java/org/onap/aai/sparky/util/HttpServletHelper.java b/src/test/java/org/onap/aai/sparky/util/HttpServletHelper.java
index de90f85..d06a1c1 100644
--- a/src/test/java/org/onap/aai/sparky/util/HttpServletHelper.java
+++ b/src/test/java/org/onap/aai/sparky/util/HttpServletHelper.java
@@ -64,8 +64,8 @@ public class HttpServletHelper {
try {
Mockito.when(request.getContentType()).thenReturn(mimeType);
-
-
+
+
final ByteArrayInputStream bais =
new ByteArrayInputStream(payloadContent.getBytes(StandardCharsets.UTF_8));
@@ -94,8 +94,9 @@ public class HttpServletHelper {
};
Mockito.when(request.getInputStream()).thenReturn(servletInputStream);
- Mockito.when(request.getReader()).thenReturn(new BufferedReader(new StringReader(payloadContent)));
-
+ Mockito.when(request.getReader())
+ .thenReturn(new BufferedReader(new StringReader(payloadContent)));
+
} catch (IOException ioe) {
fail(ExceptionHelper.extractStackTraceElements(5, ioe));
}
@@ -150,11 +151,12 @@ public class HttpServletHelper {
for (String key : paramNameValueMap.keySet()) {
Mockito.when(req.getParameter(key)).thenReturn(paramNameValueMap.get(key));
}
-
+
}
}
-
- public static void assignRequestHeader(HttpServletRequest req, String headerName, String headerValue) {
+
+ public static void assignRequestHeader(HttpServletRequest req, String headerName,
+ String headerValue) {
Mockito.when(req.getHeader(headerName)).thenReturn(headerValue);
}
diff --git a/src/test/java/org/onap/aai/sparky/util/KeystoreBuilderTest.java b/src/test/java/org/onap/aai/sparky/util/KeystoreBuilderTest.java
index aadaff9..b719381 100644
--- a/src/test/java/org/onap/aai/sparky/util/KeystoreBuilderTest.java
+++ b/src/test/java/org/onap/aai/sparky/util/KeystoreBuilderTest.java
@@ -49,52 +49,57 @@ import org.mockito.Mockito;
public class KeystoreBuilderTest {
- @Rule
- public TemporaryFolder folder = new TemporaryFolder();
+ @Rule
+ public TemporaryFolder folder = new TemporaryFolder();
- KeystoreBuilder ksb;
- org.onap.aai.sparky.util.test.KeystoreBuilder ksb1;
+ KeystoreBuilder ksb;
+ org.onap.aai.sparky.util.test.KeystoreBuilder ksb1;
- @Before
- public void setUp() throws IOException, NoSuchAlgorithmException {
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ @Before
+ public void setUp() throws IOException, NoSuchAlgorithmException {
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- folder.newFile("file1.xml");
- folder.newFile("file2.xml");
+ folder.newFile("file1.xml");
+ folder.newFile("file2.xml");
- String endPointList = "https://localhost:9517;https://localhost:8443";
- ksb = new KeystoreBuilder(endPointList);
- ksb1 = new org.onap.aai.sparky.util.test.KeystoreBuilder(endPointList);
- }
+ String endPointList = "https://localhost:9517;https://localhost:8443";
+ ksb = new KeystoreBuilder(endPointList);
+ ksb1 = new org.onap.aai.sparky.util.test.KeystoreBuilder(endPointList);
+ }
- @Test(expected=IOException.class)
- public void testUpdateKeyStore() throws KeyManagementException, KeyStoreException, CertificateException, IOException, NoSuchAlgorithmException {
- ksb.updateKeystore(folder.getRoot().getAbsolutePath(), "password-1");
- ksb1.updateKeystore(folder.getRoot().getAbsolutePath(), "password-1");
- }
+ @Test(expected = IOException.class)
+ public void testUpdateKeyStore() throws KeyManagementException, KeyStoreException,
+ CertificateException, IOException, NoSuchAlgorithmException {
+ ksb.updateKeystore(folder.getRoot().getAbsolutePath(), "password-1");
+ ksb1.updateKeystore(folder.getRoot().getAbsolutePath(), "password-1");
+ }
- @Test(expected=InvocationTargetException.class)
- public void testCertificateChainMethods() throws NoSuchMethodException, SecurityException,
- IllegalAccessException, IllegalArgumentException, InvocationTargetException, UnknownHostException, IOException {
- SSLSocketFactory factory = Mockito.mock(SSLSocketFactory.class);
- SSLSocket socket = Mockito.mock(SSLSocket.class);
- Mockito.when(factory.createSocket("localhost",9517)).thenReturn(socket);
- Method method = KeystoreBuilder.class.getDeclaredMethod("getCertificateChainForRemoteEndpoint", String.class, int.class);
- method.setAccessible(true);
- X509Certificate[] certChain = (X509Certificate[])method.invoke(ksb, "localhost",9517);
- Assert.assertNotNull(certChain);
- }
+ @Test(expected = InvocationTargetException.class)
+ public void testCertificateChainMethods()
+ throws NoSuchMethodException, SecurityException, IllegalAccessException,
+ IllegalArgumentException, InvocationTargetException, UnknownHostException, IOException {
+ SSLSocketFactory factory = Mockito.mock(SSLSocketFactory.class);
+ SSLSocket socket = Mockito.mock(SSLSocket.class);
+ Mockito.when(factory.createSocket("localhost", 9517)).thenReturn(socket);
+ Method method = KeystoreBuilder.class.getDeclaredMethod("getCertificateChainForRemoteEndpoint",
+ String.class, int.class);
+ method.setAccessible(true);
+ X509Certificate[] certChain = (X509Certificate[]) method.invoke(ksb, "localhost", 9517);
+ Assert.assertNotNull(certChain);
+ }
- @Test(expected=InvocationTargetException.class)
- public void testCertificateChainMethods1() throws NoSuchMethodException, SecurityException,
- IllegalAccessException, IllegalArgumentException, InvocationTargetException, UnknownHostException, IOException {
- SSLSocketFactory factory = Mockito.mock(SSLSocketFactory.class);
- SSLSocket socket = Mockito.mock(SSLSocket.class);
- Mockito.when(factory.createSocket("localhost",9517)).thenReturn(socket);
- Method method = org.onap.aai.sparky.util.test.KeystoreBuilder.class.getDeclaredMethod("getCertificateChainForRemoteEndpoint", String.class, int.class);
- method.setAccessible(true);
- X509Certificate[] certChain = (X509Certificate[])method.invoke(ksb1, "localhost",9517);
- Assert.assertNotNull(certChain);
- }
+ @Test(expected = InvocationTargetException.class)
+ public void testCertificateChainMethods1()
+ throws NoSuchMethodException, SecurityException, IllegalAccessException,
+ IllegalArgumentException, InvocationTargetException, UnknownHostException, IOException {
+ SSLSocketFactory factory = Mockito.mock(SSLSocketFactory.class);
+ SSLSocket socket = Mockito.mock(SSLSocket.class);
+ Mockito.when(factory.createSocket("localhost", 9517)).thenReturn(socket);
+ Method method = org.onap.aai.sparky.util.test.KeystoreBuilder.class
+ .getDeclaredMethod("getCertificateChainForRemoteEndpoint", String.class, int.class);
+ method.setAccessible(true);
+ X509Certificate[] certChain = (X509Certificate[]) method.invoke(ksb1, "localhost", 9517);
+ Assert.assertNotNull(certChain);
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/util/NodeUtilsTest.java b/src/test/java/org/onap/aai/sparky/util/NodeUtilsTest.java
index 9329d9a..b2c19df 100644
--- a/src/test/java/org/onap/aai/sparky/util/NodeUtilsTest.java
+++ b/src/test/java/org/onap/aai/sparky/util/NodeUtilsTest.java
@@ -448,7 +448,7 @@ public class NodeUtilsTest {
String result = NodeUtils.concatArray(numberList);
assertEquals("1 2 3", result);
}
-
+
/**
* Test format timestamp expect valid result.
*/
@@ -470,37 +470,46 @@ public class NodeUtilsTest {
assertEquals(validTimeStamp, result);
}
-
+
/**
* Test isNumeric expect true
*/
@Test
- public void test_isNumeric_expectFalse(){
- String invalidNumber="number";
- assertFalse(NodeUtils.isNumeric(invalidNumber));
+ public void test_isNumeric_expectFalse() {
+ String invalidNumber = "number";
+ assertFalse(NodeUtils.isNumeric(invalidNumber));
}
-
+
/**
* Test isNumeric expect true
*/
@Test
- public void test_isNumeric_expectTrue(){
- String validNumber="123";
- assertTrue(NodeUtils.isNumeric(validNumber));
+ public void test_isNumeric_expectTrue() {
+ String validNumber = "123";
+ assertTrue(NodeUtils.isNumeric(validNumber));
}
+
/**
* test calculate edit attributes urls
*/
@Test
public void validateCalculateEditAttributeLogic() {
-
- assertEquals(NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/v7/pservers/pserver/12345"),"pservers/pserver/12345");
- assertEquals(NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/v1/pservers/pserver/12345"),"pservers/pserver/12345");
- assertEquals(NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/v21/pservers/pserver/12345"),"pservers/pserver/12345");
- assertEquals(NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/v211/pservers/pserver/12345"),"pservers/pserver/12345");
- assertEquals(NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/v5252/pservers/pserver/12345"),"pservers/pserver/12345");
+
+ assertEquals(
+ NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/v7/pservers/pserver/12345"),
+ "pservers/pserver/12345");
+ assertEquals(
+ NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/v1/pservers/pserver/12345"),
+ "pservers/pserver/12345");
+ assertEquals(NodeUtils.calculateEditAttributeUri(
+ "https://localhost:9000/aai/v21/pservers/pserver/12345"), "pservers/pserver/12345");
+ assertEquals(NodeUtils.calculateEditAttributeUri(
+ "https://localhost:9000/aai/v211/pservers/pserver/12345"), "pservers/pserver/12345");
+ assertEquals(NodeUtils.calculateEditAttributeUri(
+ "https://localhost:9000/aai/v5252/pservers/pserver/12345"), "pservers/pserver/12345");
assertNull(NodeUtils.calculateEditAttributeUri(null));
- assertNull(NodeUtils.calculateEditAttributeUri("https://localhost:9000/aai/noVersionTag/pservers/pserver/12345"));
+ assertNull(NodeUtils.calculateEditAttributeUri(
+ "https://localhost:9000/aai/noVersionTag/pservers/pserver/12345"));
}
diff --git a/src/test/java/org/onap/aai/sparky/util/SuggestionsPermutationsTest.java b/src/test/java/org/onap/aai/sparky/util/SuggestionsPermutationsTest.java
index 2d277bd..53905d4 100644
--- a/src/test/java/org/onap/aai/sparky/util/SuggestionsPermutationsTest.java
+++ b/src/test/java/org/onap/aai/sparky/util/SuggestionsPermutationsTest.java
@@ -14,13 +14,13 @@ public class SuggestionsPermutationsTest {
@Test
public void isValidSuggestionPermutation_successPath() {
-
+
List<String> x = new ArrayList<>(Arrays.asList("A", "B", "C", "D"));
SuggestionsPermutation suggPermutation = new SuggestionsPermutation();
-
+
ArrayList<ArrayList<String>> uniqueLists = suggPermutation.getSuggestionsPermutation(x);
-
- assertTrue(uniqueLists.get(0).toString().equals("[A]"));
+
+ assertTrue(uniqueLists.get(0).toString().equals("[A]"));
assertTrue(uniqueLists.get(1).toString().equals("[A, B, C, D]"));
assertTrue(uniqueLists.get(2).toString().equals("[A, C, D]"));
assertTrue(uniqueLists.get(3).toString().equals("[A, D]"));
@@ -31,6 +31,6 @@ public class SuggestionsPermutationsTest {
assertTrue(uniqueLists.get(8).toString().equals("[C, D]"));
assertTrue(uniqueLists.get(9).toString().equals("[D]"));
assertTrue(uniqueLists.size() == 10);
-
+
}
}
diff --git a/src/test/java/org/onap/aai/sparky/util/TreeWalkerTest.java b/src/test/java/org/onap/aai/sparky/util/TreeWalkerTest.java
index 36b11ed..198a0eb 100644
--- a/src/test/java/org/onap/aai/sparky/util/TreeWalkerTest.java
+++ b/src/test/java/org/onap/aai/sparky/util/TreeWalkerTest.java
@@ -57,8 +57,7 @@ public class TreeWalkerTest {
* @throws Exception the exception
*/
@Before
- public void init() throws Exception {
- }
+ public void init() throws Exception {}
/**
* Validate json node conversion null input.
@@ -184,8 +183,7 @@ public class TreeWalkerTest {
public void validateWalkTreeOneParentNodeWithObjectArray() {
try {
- String jsonStr =
- "{\"Employee\":[{\"id\":\"101\",\"name\":\"Pushkar\",\"salary\":\"5000\"},"
+ String jsonStr = "{\"Employee\":[{\"id\":\"101\",\"name\":\"Pushkar\",\"salary\":\"5000\"},"
+ "{\"id\":\"102\",\"name\":\"Rahul\",\"salary\":\"4000\"},"
+ "{\"id\":\"103\",\"name\":\"tanveer\",\"salary\":\"56678\"}]}";
TreeWalker walker = new TreeWalker();
@@ -230,68 +228,68 @@ public class TreeWalkerTest {
try {
String jsonStr =
"{ \"generalNodeClass\": { \"class\": \"aai-entity-node general-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } }, {"
- + " \"type\": \"circle\", \"class\": \"inner\", "
- + " \"svgAttributes\": { \"r\": \"10\" "
- + "} }, { \"type\": \"text\", "
- + "\"class\": \"id-type-label\", \"displayKey\": \"itemType\", "
- + " \"shapeAttributes\": { \"offset\": { "
- + " \"x\": \"0\", \"y\": \"30\" } "
- + " } }, { \"type\": \"text\", "
- + " \"class\": \"id-value-label\", \"displayKey\":"
- + " \"itemNameValue\", \"shapeAttributes\": { "
- + " \"offset\": { \"x\": \"0\", "
- + " \"y\": \"40\" } } } ] "
- + " }, \"searchedNodeClass\": { \"class\": \"aai-entity-node search-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": { "
- + " \"r\": \"20\" } }, { "
- + " \"type\": \"circle\", \"class\": \"inner\", "
- + " \"svgAttributes\": { \"r\": \"10\" }"
- + " }, { \"type\": \"text\", "
- + "\"class\": \"id-type-label\", \"displayKey\": \"itemType\", "
- + " \"shapeAttributes\": { \"offset\": { "
- + " \"x\": \"0\", \"y\": \"30\" }"
- + " } }, { \"type\": \"text\", "
- + " \"class\": \"id-value-label\", "
- + "\"displayKey\": \"itemNameValue\", \"shapeAttributes\": {"
- + " \"offset\": { \"x\": \"0\","
- + " \"y\": \"40\" } }"
- + " } ] }, \"selectedSearchedNodeClass\": { "
- + "\"class\": \"aai-entity-node selected-search-node\", \"visualElements\": ["
- + " { \"type\": \"circle\", "
- + "\"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } }, {"
- + " \"type\": \"circle\", \"class\": \"inner\","
- + " \"svgAttributes\": { \"r\": \"10\" "
- + " } }, { \"type\": \"text\", "
- + " \"class\": \"id-type-label\", \"displayKey\": \"itemType\","
- + " \"shapeAttributes\": { \"offset\": {"
- + " \"x\": \"0\", \"y\": \"30\""
- + " } } }, { "
- + " \"type\": \"text\", \"class\": \"id-value-label\", "
- + " \"displayKey\": \"itemNameValue\", \"shapeAttributes\": {"
- + " \"offset\": { \"x\": \"0\", "
- + " \"y\": \"40\" } } } ]"
- + " }, \"selectedNodeClass\": { \"class\":"
- + " \"aai-entity-node selected-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } }, {"
- + " \"type\": \"circle\", \"class\": \"inner\","
- + " \"svgAttributes\": { \"r\": \"10\" "
- + " } }, { \"type\": \"text\", "
- + " \"class\": \"id-type-label\", \"displayKey\": \"itemType\","
- + " \"shapeAttributes\": { \"offset\": "
- + "{ "
- + " \"x\": \"0\", \"y\": \"30\" } "
- + " } }, { \"type\": \"text\","
- + " \"class\": \"id-value-label\", \"displayKey\":"
- + " \"itemNameValue\", \"shapeAttributes\": { "
- + "\"offset\": { \"x\": \"0\", "
- + "\"y\": \"40\" } } } ] }}";
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } }, {"
+ + " \"type\": \"circle\", \"class\": \"inner\", "
+ + " \"svgAttributes\": { \"r\": \"10\" "
+ + "} }, { \"type\": \"text\", "
+ + "\"class\": \"id-type-label\", \"displayKey\": \"itemType\", "
+ + " \"shapeAttributes\": { \"offset\": { "
+ + " \"x\": \"0\", \"y\": \"30\" } "
+ + " } }, { \"type\": \"text\", "
+ + " \"class\": \"id-value-label\", \"displayKey\":"
+ + " \"itemNameValue\", \"shapeAttributes\": { "
+ + " \"offset\": { \"x\": \"0\", "
+ + " \"y\": \"40\" } } } ] "
+ + " }, \"searchedNodeClass\": { \"class\": \"aai-entity-node search-node\","
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": { "
+ + " \"r\": \"20\" } }, { "
+ + " \"type\": \"circle\", \"class\": \"inner\", "
+ + " \"svgAttributes\": { \"r\": \"10\" }"
+ + " }, { \"type\": \"text\", "
+ + "\"class\": \"id-type-label\", \"displayKey\": \"itemType\", "
+ + " \"shapeAttributes\": { \"offset\": { "
+ + " \"x\": \"0\", \"y\": \"30\" }"
+ + " } }, { \"type\": \"text\", "
+ + " \"class\": \"id-value-label\", "
+ + "\"displayKey\": \"itemNameValue\", \"shapeAttributes\": {"
+ + " \"offset\": { \"x\": \"0\","
+ + " \"y\": \"40\" } }"
+ + " } ] }, \"selectedSearchedNodeClass\": { "
+ + "\"class\": \"aai-entity-node selected-search-node\", \"visualElements\": ["
+ + " { \"type\": \"circle\", "
+ + "\"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } }, {"
+ + " \"type\": \"circle\", \"class\": \"inner\","
+ + " \"svgAttributes\": { \"r\": \"10\" "
+ + " } }, { \"type\": \"text\", "
+ + " \"class\": \"id-type-label\", \"displayKey\": \"itemType\","
+ + " \"shapeAttributes\": { \"offset\": {"
+ + " \"x\": \"0\", \"y\": \"30\""
+ + " } } }, { "
+ + " \"type\": \"text\", \"class\": \"id-value-label\", "
+ + " \"displayKey\": \"itemNameValue\", \"shapeAttributes\": {"
+ + " \"offset\": { \"x\": \"0\", "
+ + " \"y\": \"40\" } } } ]"
+ + " }, \"selectedNodeClass\": { \"class\":"
+ + " \"aai-entity-node selected-node\","
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } }, {"
+ + " \"type\": \"circle\", \"class\": \"inner\","
+ + " \"svgAttributes\": { \"r\": \"10\" "
+ + " } }, { \"type\": \"text\", "
+ + " \"class\": \"id-type-label\", \"displayKey\": \"itemType\","
+ + " \"shapeAttributes\": { \"offset\": "
+ + "{ "
+ + " \"x\": \"0\", \"y\": \"30\" } "
+ + " } }, { \"type\": \"text\","
+ + " \"class\": \"id-value-label\", \"displayKey\":"
+ + " \"itemNameValue\", \"shapeAttributes\": { "
+ + "\"offset\": { \"x\": \"0\", "
+ + "\"y\": \"40\" } } } ] }}";
TreeWalker walker = new TreeWalker();
List<String> paths = new ArrayList<String>();
walker.walkTree(paths, walker.convertJsonToNode(jsonStr));
@@ -400,143 +398,143 @@ public class TreeWalkerTest {
try {
String n1Str =
"{ \"generalNodeClass\": { \"class\": \"aai-entity-node general-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } }, {"
- + " \"type\": \"circle\", \"class\": \"inner\","
- + " \"svgAttributes\": { \"r\": \"10\""
- + " } }, { \"type\": \"text\","
- + " \"class\": \"id-type-label\", \"displayKey\":"
- + " \"itemType\", \"shapeAttributes\": { \"offset\":"
- + " { \"x\": \"0\", \"y\": \"30\""
- + " } } }, {"
- + " \"type\": \"text\", \"class\": \"id-value-label\","
- + " \"displayKey\": \"itemNameValue\","
- + " \"shapeAttributes\": { \"offset\":"
- + " { \"x\": \"0\", \"y\": \"40\""
- + " } } } ] },"
- + " \"searchedNodeClass\": { \"class\": \"aai-entity-node search-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } }, {"
- + " \"type\": \"circle\", \"class\": \"inner\","
- + " \"svgAttributes\": { \"r\": \"10\""
- + " } }, { \"type\": \"text\","
- + " \"class\": \"id-type-label\", \"displayKey\":"
- + " \"itemType\", \"shapeAttributes\": { \"offset\": {"
- + " \"x\": \"0\", \"y\": \"30\""
- + " } } }, {"
- + " \"type\": \"text\", \"class\": \"id-value-label\","
- + " \"displayKey\": \"itemNameValue\","
- + " \"shapeAttributes\": { \"offset\": {"
- + " \"x\": \"0\", \"y\": \"40\""
- + " } } } ] },"
- + " \"selectedSearchedNodeClass\": { \"class\":"
- + " \"aai-entity-node selected-search-node\", \"visualElements\": ["
- + " { \"type\": \"circle\", \"class\":"
- + " \"outer\", \"svgAttributes\": { \"r\": \"20\""
- + " } }, { \"type\": \"circle\","
- + " \"class\": \"inner\", \"svgAttributes\": {"
- + " \"r\": \"10\" } }, {"
- + " \"type\": \"text\", \"class\": \"id-type-label\","
- + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
- + " \"offset\": { \"x\": \"0\","
- + " \"y\": \"30\" } }"
- + " }, { \"type\": \"text\","
- + " \"class\": \"id-value-label\","
- + " \"displayKey\": \"itemNameValue\","
- + " \"shapeAttributes\": { \"offset\": {"
- + " \"x\": \"0\", \"y\": \"40\""
- + " } } } ] },"
- + " \"selectedNodeClass\": { \"class\": \"aai-entity-node selected-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } }, {"
- + " \"type\": \"circle\", \"class\": \"inner\","
- + " \"svgAttributes\": { \"r\": \"10\""
- + " } }, { \"type\": \"text\","
- + " \"class\": \"id-type-label\", \"displayKey\":"
- + " \"itemType\", \"shapeAttributes\": {"
- + " \"offset\": { \"x\": \"0\","
- + " \"y\": \"30\" }"
- + " } }, { \"type\": \"text\","
- + " \"class\": \"id-value-label\", \"displayKey\":"
- + " \"itemNameValue\", \"shapeAttributes\": {"
- + " \"offset\": { \"x\": \"0\","
- + " \"y\": \"40\" } }"
- + " } ] }}";
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } }, {"
+ + " \"type\": \"circle\", \"class\": \"inner\","
+ + " \"svgAttributes\": { \"r\": \"10\""
+ + " } }, { \"type\": \"text\","
+ + " \"class\": \"id-type-label\", \"displayKey\":"
+ + " \"itemType\", \"shapeAttributes\": { \"offset\":"
+ + " { \"x\": \"0\", \"y\": \"30\""
+ + " } } }, {"
+ + " \"type\": \"text\", \"class\": \"id-value-label\","
+ + " \"displayKey\": \"itemNameValue\","
+ + " \"shapeAttributes\": { \"offset\":"
+ + " { \"x\": \"0\", \"y\": \"40\""
+ + " } } } ] },"
+ + " \"searchedNodeClass\": { \"class\": \"aai-entity-node search-node\","
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } }, {"
+ + " \"type\": \"circle\", \"class\": \"inner\","
+ + " \"svgAttributes\": { \"r\": \"10\""
+ + " } }, { \"type\": \"text\","
+ + " \"class\": \"id-type-label\", \"displayKey\":"
+ + " \"itemType\", \"shapeAttributes\": { \"offset\": {"
+ + " \"x\": \"0\", \"y\": \"30\""
+ + " } } }, {"
+ + " \"type\": \"text\", \"class\": \"id-value-label\","
+ + " \"displayKey\": \"itemNameValue\","
+ + " \"shapeAttributes\": { \"offset\": {"
+ + " \"x\": \"0\", \"y\": \"40\""
+ + " } } } ] },"
+ + " \"selectedSearchedNodeClass\": { \"class\":"
+ + " \"aai-entity-node selected-search-node\", \"visualElements\": ["
+ + " { \"type\": \"circle\", \"class\":"
+ + " \"outer\", \"svgAttributes\": { \"r\": \"20\""
+ + " } }, { \"type\": \"circle\","
+ + " \"class\": \"inner\", \"svgAttributes\": {"
+ + " \"r\": \"10\" } }, {"
+ + " \"type\": \"text\", \"class\": \"id-type-label\","
+ + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
+ + " \"offset\": { \"x\": \"0\","
+ + " \"y\": \"30\" } }"
+ + " }, { \"type\": \"text\","
+ + " \"class\": \"id-value-label\","
+ + " \"displayKey\": \"itemNameValue\","
+ + " \"shapeAttributes\": { \"offset\": {"
+ + " \"x\": \"0\", \"y\": \"40\""
+ + " } } } ] },"
+ + " \"selectedNodeClass\": { \"class\": \"aai-entity-node selected-node\","
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } }, {"
+ + " \"type\": \"circle\", \"class\": \"inner\","
+ + " \"svgAttributes\": { \"r\": \"10\""
+ + " } }, { \"type\": \"text\","
+ + " \"class\": \"id-type-label\", \"displayKey\":"
+ + " \"itemType\", \"shapeAttributes\": {"
+ + " \"offset\": { \"x\": \"0\","
+ + " \"y\": \"30\" }"
+ + " } }, { \"type\": \"text\","
+ + " \"class\": \"id-value-label\", \"displayKey\":"
+ + " \"itemNameValue\", \"shapeAttributes\": {"
+ + " \"offset\": { \"x\": \"0\","
+ + " \"y\": \"40\" } }"
+ + " } ] }}";
String n2Str =
"{ \"searchedNodeClass\": { \"class\": \"aai-entity-node search-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } },"
- + " { \"type\": \"circle\","
- + " \"class\": \"inner\", \"svgAttributes\": {"
- + " \"r\": \"10\" } }, {"
- + " \"type\": \"text\", \"class\": \"id-type-label\","
- + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
- + " \"offset\": { \"y\": \"30\","
- + " \"x\": \"0\" } }"
- + " }, { \"type\": \"text\","
- + " \"class\": \"id-value-label\","
- + " \"displayKey\": \"itemNameValue\","
- + " \"shapeAttributes\": { \"offset\": {"
- + " \"y\": \"40\", \"x\": \"0\""
- + " } } } ] },"
- + " \"selectedSearchedNodeClass\": { \"class\":"
- + " \"aai-entity-node selected-search-node\", \"visualElements\": ["
- + " { \"type\": \"circle\", \"class\":"
- + " \"outer\", \"svgAttributes\": { \"r\": \"20\""
- + " } }, { \"type\": \"circle\","
- + " \"class\": \"inner\", \"svgAttributes\": {"
- + " \"r\": \"10\" } }, {"
- + " \"type\": \"text\", \"class\": \"id-type-label\","
- + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
- + " \"offset\": { \"y\": \"30\","
- + " \"x\": \"0\" } }"
- + " }, { \"type\": \"text\","
- + " \"class\": \"id-value-label\","
- + " \"displayKey\": \"itemNameValue\","
- + " \"shapeAttributes\": { \"offset\": {"
- + " \"y\": \"40\", \"x\": \"0\""
- + " } } } ] },"
- + " \"selectedNodeClass\": { \"class\": \"aai-entity-node selected-node\","
- + " \"visualElements\": [ { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } }, {"
- + " \"type\": \"circle\", \"class\": \"inner\","
- + " \"svgAttributes\": { \"r\": \"10\""
- + " } }, { \"type\": \"text\","
- + " \"class\": \"id-type-label\","
- + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
- + " \"offset\": { \"y\": \"30\","
- + " \"x\": \"0\" } }"
- + " }, { \"type\": \"text\","
- + " \"class\": \"id-value-label\","
- + " \"displayKey\": \"itemNameValue\","
- + " \"shapeAttributes\": { \"offset\": {"
- + " \"y\": \"40\", \"x\": \"0\""
- + " } } } ] },"
- + " \"generalNodeClass\": { \"class\":"
- + " \"aai-entity-node general-node\", \"visualElements\": ["
- + " { \"type\": \"circle\","
- + " \"class\": \"outer\", \"svgAttributes\": {"
- + " \"r\": \"20\" } },"
- + " { \"type\": \"circle\","
- + " \"class\": \"inner\", \"svgAttributes\": {"
- + " \"r\": \"10\" } },"
- + " { \"type\": \"text\","
- + " \"class\": \"id-type-label\", \"displayKey\":"
- + " \"itemType\", \"shapeAttributes\": {"
- + " \"offset\": { \"y\": \"30\","
- + " \"x\": \"0\" }"
- + " } }, {"
- + " \"type\": \"text\","
- + " \"class\": \"id-value-label\", \"displayKey\":"
- + " \"itemNameValue\", \"shapeAttributes\": {"
- + " \"offset\": { \"y\": \"40\","
- + " \"x\": \"0\" }"
- + " } } ] }}";
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } },"
+ + " { \"type\": \"circle\","
+ + " \"class\": \"inner\", \"svgAttributes\": {"
+ + " \"r\": \"10\" } }, {"
+ + " \"type\": \"text\", \"class\": \"id-type-label\","
+ + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
+ + " \"offset\": { \"y\": \"30\","
+ + " \"x\": \"0\" } }"
+ + " }, { \"type\": \"text\","
+ + " \"class\": \"id-value-label\","
+ + " \"displayKey\": \"itemNameValue\","
+ + " \"shapeAttributes\": { \"offset\": {"
+ + " \"y\": \"40\", \"x\": \"0\""
+ + " } } } ] },"
+ + " \"selectedSearchedNodeClass\": { \"class\":"
+ + " \"aai-entity-node selected-search-node\", \"visualElements\": ["
+ + " { \"type\": \"circle\", \"class\":"
+ + " \"outer\", \"svgAttributes\": { \"r\": \"20\""
+ + " } }, { \"type\": \"circle\","
+ + " \"class\": \"inner\", \"svgAttributes\": {"
+ + " \"r\": \"10\" } }, {"
+ + " \"type\": \"text\", \"class\": \"id-type-label\","
+ + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
+ + " \"offset\": { \"y\": \"30\","
+ + " \"x\": \"0\" } }"
+ + " }, { \"type\": \"text\","
+ + " \"class\": \"id-value-label\","
+ + " \"displayKey\": \"itemNameValue\","
+ + " \"shapeAttributes\": { \"offset\": {"
+ + " \"y\": \"40\", \"x\": \"0\""
+ + " } } } ] },"
+ + " \"selectedNodeClass\": { \"class\": \"aai-entity-node selected-node\","
+ + " \"visualElements\": [ { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } }, {"
+ + " \"type\": \"circle\", \"class\": \"inner\","
+ + " \"svgAttributes\": { \"r\": \"10\""
+ + " } }, { \"type\": \"text\","
+ + " \"class\": \"id-type-label\","
+ + " \"displayKey\": \"itemType\", \"shapeAttributes\": {"
+ + " \"offset\": { \"y\": \"30\","
+ + " \"x\": \"0\" } }"
+ + " }, { \"type\": \"text\","
+ + " \"class\": \"id-value-label\","
+ + " \"displayKey\": \"itemNameValue\","
+ + " \"shapeAttributes\": { \"offset\": {"
+ + " \"y\": \"40\", \"x\": \"0\""
+ + " } } } ] },"
+ + " \"generalNodeClass\": { \"class\":"
+ + " \"aai-entity-node general-node\", \"visualElements\": ["
+ + " { \"type\": \"circle\","
+ + " \"class\": \"outer\", \"svgAttributes\": {"
+ + " \"r\": \"20\" } },"
+ + " { \"type\": \"circle\","
+ + " \"class\": \"inner\", \"svgAttributes\": {"
+ + " \"r\": \"10\" } },"
+ + " { \"type\": \"text\","
+ + " \"class\": \"id-type-label\", \"displayKey\":"
+ + " \"itemType\", \"shapeAttributes\": {"
+ + " \"offset\": { \"y\": \"30\","
+ + " \"x\": \"0\" }"
+ + " } }, {"
+ + " \"type\": \"text\","
+ + " \"class\": \"id-value-label\", \"displayKey\":"
+ + " \"itemNameValue\", \"shapeAttributes\": {"
+ + " \"offset\": { \"y\": \"40\","
+ + " \"x\": \"0\" }"
+ + " } } ] }}";
TreeWalker walker = new TreeWalker();
List<String> n1Paths = new ArrayList<String>();
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/ActiveInventoryNodeTester.java b/src/test/java/org/onap/aai/sparky/viewandinspect/ActiveInventoryNodeTester.java
index 9dd23b5..df6bc2c 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/ActiveInventoryNodeTester.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/ActiveInventoryNodeTester.java
@@ -87,8 +87,7 @@ public class ActiveInventoryNodeTester {
return nodeA;
}
- private String selfLinkFormat =
- "https://aai-hostname:9292/aai/v7/network/generic-vnfs/%s/%s";
+ private String selfLinkFormat = "https://aai-hostname:9292/aai/v7/network/generic-vnfs/%s/%s";
/**
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchAdapterTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchAdapterTest.java
index bbee87c..1baf2e4 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchAdapterTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchAdapterTest.java
@@ -56,7 +56,7 @@ public class SearchAdapterTest {
private WebResource mockWebResource;
private Builder mockBuilder;
-
+
/**
* Inits the.
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchResponseTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchResponseTest.java
index cae9290..3b2158b 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchResponseTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchResponseTest.java
@@ -57,19 +57,19 @@ public class SearchResponseTest {
SearchResponse response = new SearchResponse();
- //response.setNumReturned(1);
+ // response.setNumReturned(1);
response.setProcessingTimeInMs(512);
- //response.setTotalFound(50);
+ // response.setTotalFound(50);
List<EntityEntry> entities = new ArrayList<EntityEntry>();
- //response.setEntities(entities);
+ // response.setEntities(entities);
EntityEntry e1 = new EntityEntry();
e1.setEntityPrimaryKeyValue("e1");
e1.setEntityType("e1");
e1.setSearchTags("e1");
- //response.addEntityEntry(e1);
+ // response.addEntityEntry(e1);
EntityEntry e2 = new EntityEntry();
@@ -77,15 +77,15 @@ public class SearchResponseTest {
e2.setEntityType("e2");
e2.setSearchTags("e2");
- //response.addEntityEntry(e2);
+ // response.addEntityEntry(e2);
- //assertEquals(1, response.getNumReturned());
- //assertEquals(512, response.getProcessingTimeInMs());
- //assertEquals(50, response.getTotalFound());
+ // assertEquals(1, response.getNumReturned());
+ // assertEquals(512, response.getProcessingTimeInMs());
+ // assertEquals(50, response.getTotalFound());
- //List<EntityEntry> responseEntities = response.getEntities();
+ // List<EntityEntry> responseEntities = response.getEntities();
- //assertEquals(2, responseEntities.size());
+ // assertEquals(2, responseEntities.size());
}
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchServletTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchServletTest.java
index 198bbb3..6d682f4 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchServletTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchServletTest.java
@@ -97,7 +97,7 @@ public class SearchServletTest {
private static final String VNF_ROUTE = "vnf";
private static final String VIEW_INSPECT_ROUTE = "viewInspect";
-
+
private HttpServletRequest commonRequest = null;
private HttpServletResponse commonResponse = null;
private PrintWriter printWriter = null;
@@ -111,7 +111,7 @@ public class SearchServletTest {
private Map<String, OxmEntityDescriptor> descriptors = null;
private SuggestionConfig suggestionConfig = null;
private SearchServiceConfig esConfig = null;
-
+
/**
* Inits the.
*
@@ -128,21 +128,21 @@ public class SearchServletTest {
// permit serialization of objects with no members
mapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
-
+
rand = new SecureRandom();
- loader = Mockito.mock(OxmModelLoader.class);
+ loader = Mockito.mock(OxmModelLoader.class);
descriptors = new HashMap<String, OxmEntityDescriptor>();
esConfig = new SearchServiceConfig();
suggestionConfig = SuggestionConfig.getConfig();
-
+
// Use SearchServiceWrapper and VnfSearchService for suggestionConfig
Map<String, String> svcs = new HashMap<String, String>();
svcs.put("autosuggestIndexname", "SearchServiceWrapper");
svcs.put("indexName", "VnfSearchService");
suggestionConfig.setSearchIndexToSearchService(svcs);
-
+
esConfig.setIndexName("esi-localhost");
esConfig.setType("default");
@@ -150,7 +150,7 @@ public class SearchServletTest {
vnfSearchService = Mockito.mock(VnfSearchService.class);
initializeEntityDescriptors();
-
+
searchWrapper = new SearchServiceWrapper();
searchWrapper.setSasConfig(esConfig);
searchWrapper.setSearch(searchAdapter);
@@ -161,9 +161,9 @@ public class SearchServletTest {
@Test
public void validateAccessors() {
- assertNotNull("Vnf Search Service should not be null", searchWrapper.getVnfSearch());
+ assertNotNull("Vnf Search Service should not be null", searchWrapper.getVnfSearch());
}
-
+
@Test
public void validateInitializer() {
@@ -173,7 +173,7 @@ public class SearchServletTest {
assertNotNull("SearchAdapter should not be null", searchWrapper.getSearch());
assertNotNull("Suggestion Config should not be null", searchWrapper.getSuggestionConfig());
assertNotNull("VnfSearchService should not be null", searchWrapper.getVnfSearch());
-
+
searchWrapper.setOxmModelLoader(null);
searchWrapper.setSasConfig(null);
searchWrapper.setSearch(null);
@@ -191,34 +191,34 @@ public class SearchServletTest {
}
}
-
+
/**
- * Test doGet() and doPost() for a non-existent end-point. A test objective would be
- * to either return a 404 Not Found.
+ * Test doGet() and doPost() for a non-existent end-point. A test objective would be to either
+ * return a 404 Not Found.
*/
@Test
public void validateMdcContextLoggingVariablesWhenExplicitlySet() {
-
+
final String transactionId = "1234";
final String serviceName = "AAI_UI";
final String partnerName = "SparkyApp";
-
+
HttpServletHelper.assignRequestHeader(commonRequest, "X-TransactionId", transactionId);
HttpServletHelper.assignRequestHeader(commonRequest, "X-FromAppId", partnerName);
-
+
HttpServletHelper.assignRequestUri(commonRequest, "search/this/path/does/not/exist/");
-
+
try {
-
+
/*
* Testing the doGet() operation will hit the doPost() operation in the servlet as well
*/
OperationResult result = doEvaluationTestMDC(true, commonRequest, commonResponse);
-
- assertEquals(transactionId,MDC.get(MdcContext.MDC_REQUEST_ID));
- assertEquals(serviceName,MDC.get(MdcContext.MDC_SERVICE_NAME));
- assertEquals(partnerName,MDC.get(MdcContext.MDC_PARTNER_NAME));
+
+ assertEquals(transactionId, MDC.get(MdcContext.MDC_REQUEST_ID));
+ assertEquals(serviceName, MDC.get(MdcContext.MDC_SERVICE_NAME));
+ assertEquals(partnerName, MDC.get(MdcContext.MDC_PARTNER_NAME));
} catch (Exception exc) {
exc.printStackTrace();
@@ -226,23 +226,24 @@ public class SearchServletTest {
}
}
-
+
/**
- * Test doGet() and doPost() for a non-existent end-point. A test objective would be
- * to either return a 404 Not Found.
+ * Test doGet() and doPost() for a non-existent end-point. A test objective would be to either
+ * return a 404 Not Found.
*/
@Test
public void validateMdcContextLoggingVariablesWhenNotExplicitlySet() {
-
- /*final String transactionId = "1234";
- final String serviceName = "AAI-UI";
- final String partnerName = "SparkyApp";
-
- HttpServletHelper.assignRequestHeader(commonRequest, "X-TransactionId", transactionId);
- HttpServletHelper.assignRequestHeader(commonRequest, "X-FromAppId", serviceName);*/
-
+
+ /*
+ * final String transactionId = "1234"; final String serviceName = "AAI-UI"; final String
+ * partnerName = "SparkyApp";
+ *
+ * HttpServletHelper.assignRequestHeader(commonRequest, "X-TransactionId", transactionId);
+ * HttpServletHelper.assignRequestHeader(commonRequest, "X-FromAppId", serviceName);
+ */
+
HttpServletHelper.assignRequestUri(commonRequest, "search/this/path/does/not/exist/");
-
+
try {
/*
@@ -250,7 +251,7 @@ public class SearchServletTest {
*/
OperationResult result = doEvaluationTestMDC(true, commonRequest, commonResponse);
-
+
assertNotNull(MDC.get(MdcContext.MDC_REQUEST_ID));
assertNotNull(MDC.get(MdcContext.MDC_SERVICE_NAME));
assertNotNull(MDC.get(MdcContext.MDC_PARTNER_NAME));
@@ -261,17 +262,17 @@ public class SearchServletTest {
}
}
-
-
-
+
+
+
/**
- * Test doGet() and doPost() for a non-existent end-point.
+ * Test doGet() and doPost() for a non-existent end-point.
*/
@Test
public void validateViewAndInspectSearchError_invalidRequestUri() {
-
+
HttpServletHelper.assignRequestUri(commonRequest, "search/this/path/does/not/exist/");
-
+
try {
/*
@@ -288,10 +289,10 @@ public class SearchServletTest {
}
}
-
-
+
+
/**
- * Test doGet() and doPost() for Unified Query Search success path
+ * Test doGet() and doPost() for Unified Query Search success path
*/
@Test
public void validateQuerySearch_successPath() {
@@ -302,12 +303,13 @@ public class SearchServletTest {
searchEntity.setMaxResults("10");
searchEntity.setQueryStr("the quick brown fox");
- HttpServletHelper.assignRequestUri(commonRequest, "search/querysearch");
+ HttpServletHelper.assignRequestUri(commonRequest, "search/querysearch");
HttpServletHelper.setRequestPayload(commonRequest, MediaType.JSON_UTF_8.toString(),
NodeUtils.convertObjectToJson(searchEntity, false));
-
- // set search-abstraction-response that we expect to get back from real system, but stubbed through a mock
+
+ // set search-abstraction-response that we expect to get back from real system, but stubbed
+ // through a mock
// to fulfill collaborator behavior
OperationResult mockedEntitySearchResponse = new OperationResult();
@@ -315,22 +317,23 @@ public class SearchServletTest {
mockedEntitySearchResponse.setResult(NodeUtils.convertObjectToJson(
SearchAbstractionEntityBuilder.getSuccessfulEntitySearchResponse(), false));
- // TODO: make parameters expect certain values to lock in invocation attempt against a specific input sequence
+ // TODO: make parameters expect certain values to lock in invocation attempt against a
+ // specific input sequence
Mockito.when(searchAdapter.doPost(anyString(), anyString(), anyString()))
.thenReturn(mockedEntitySearchResponse);
-
+
List<SuggestionEntity> autoSuggestions = new ArrayList<SuggestionEntity>();
- autoSuggestions.add(new SuggestionEntity("vnf","1234", "VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","1111", "Created VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","1122", "ACTIVE VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","2233", "ACTIVE and Error VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","3344", "ACTIVE and NOT ORCHESTRATED VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","4455", "ACTIVE and Running VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","5566", "Activated VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","6677", "CAPPED VNFs"));
- autoSuggestions.add(new SuggestionEntity("vnf","7788", "CAPPED and Created VNFs"));
-
+ autoSuggestions.add(new SuggestionEntity("vnf", "1234", "VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "1111", "Created VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "1122", "ACTIVE VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "2233", "ACTIVE and Error VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "3344", "ACTIVE and NOT ORCHESTRATED VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "4455", "ACTIVE and Running VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "5566", "Activated VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "6677", "CAPPED VNFs"));
+ autoSuggestions.add(new SuggestionEntity("vnf", "7788", "CAPPED and Created VNFs"));
+
Mockito.when(vnfSearchService.getSuggestionsResults(Mockito.anyObject(), Mockito.anyInt()))
.thenReturn(autoSuggestions);
@@ -339,39 +342,39 @@ public class SearchServletTest {
*/
OperationResult result = doEvaluation(true, commonRequest, commonResponse);
-
-
+
+
assertEquals(200, result.getResultCode());
-
+
SearchResponse searchResponse = mapper.readValue(result.getResult(), SearchResponse.class);
-
+
assertEquals(10, searchResponse.getTotalFound());
-
+
int numVnf = 0;
int numViewInspect = 0;
-
- for ( SuggestionEntity suggestion : searchResponse.getSuggestions()) {
-
- if ( VNF_ROUTE.equals(suggestion.getRoute())) {
+
+ for (SuggestionEntity suggestion : searchResponse.getSuggestions()) {
+
+ if (VNF_ROUTE.equals(suggestion.getRoute())) {
numVnf++;
- } else if ( VIEW_INSPECT_ROUTE.equals(suggestion.getRoute())) {
+ } else if (VIEW_INSPECT_ROUTE.equals(suggestion.getRoute())) {
numViewInspect++;
}
}
-
+
assertEquals(5, numVnf);
assertEquals(5, numViewInspect);
-
- //assertTrue(result.getResult().contains("Ignored request-uri"));
+
+ // assertTrue(result.getResult().contains("Ignored request-uri"));
} catch (Exception exc) {
fail("Unexpected exception = " + exc.getLocalizedMessage());
}
}
-
+
/**
- * Test doGet() and doPost() for Unified Query Search success path
+ * Test doGet() and doPost() for Unified Query Search success path
*/
@Test
public void validateSummaryByEntityTypeCount_successPath() {
@@ -379,15 +382,17 @@ public class SearchServletTest {
try {
HttpServletHelper.assignRequestUri(commonRequest, "search/summarybyentitytype/count");
-
- Map<String,String> payloadFields = new HashMap<String,String>();
- payloadFields.put("hashId", "662d1b57c31df70d7ef57ec53c0ace81578ec77b6bc5de055a57c7547ec122dd");
+
+ Map<String, String> payloadFields = new HashMap<String, String>();
+ payloadFields.put("hashId",
+ "662d1b57c31df70d7ef57ec53c0ace81578ec77b6bc5de055a57c7547ec122dd");
payloadFields.put("groupby", "orchestration-status");
-
-
- HttpServletHelper.setRequestPayload(commonRequest, MediaType.JSON_UTF_8.toString(), NodeUtils.convertObjectToJson(payloadFields, false));
-
-
+
+
+ HttpServletHelper.setRequestPayload(commonRequest, MediaType.JSON_UTF_8.toString(),
+ NodeUtils.convertObjectToJson(payloadFields, false));
+
+
/*
* In this test we don't want to mock the vnf search service, only it's collaborator
* interactions with a REST endpoint.
@@ -397,55 +402,57 @@ public class SearchServletTest {
searchWrapper.setVnfSearch(vnfSearchService);
/*
- * The first network response to mock is the one to elastic search to get the suggestion entity by hash id
+ * The first network response to mock is the one to elastic search to get the suggestion
+ * entity by hash id
*
- * http://localhost:9200/entityautosuggestindex-localhost/_search
- * {"query":{"term":{"_id":"2172a3c25ae56e4995038ffbc1f055692bfc76c0b8ceda1205bc745a9f7a805d"}}}
+ * http://localhost:9200/entityautosuggestindex-localhost/_search
+ * {"query":{"term":{"_id":"2172a3c25ae56e4995038ffbc1f055692bfc76c0b8ceda1205bc745a9f7a805d"}
+ * }}
*/
-
+
AutoSuggestElasticSearchResponse elasticResponse = new AutoSuggestElasticSearchResponse();
-
+
elasticResponse.setTook(1);
-
+
elasticResponse.setTimedOut(false);
elasticResponse.addShard("total", "5");
elasticResponse.addShard("successful", "5");
elasticResponse.addShard("failed", "0");
-
+
AutoSuggestElasticHitEntity elasticHit = new AutoSuggestElasticHitEntity();
elasticHit.setIndex("entityautosuggestindex-localhost");
elasticHit.setType("default");
elasticHit.setId("2172a3c25ae56e4995038ffbc1f055692bfc76c0b8ceda1205bc745a9f7a805d");
elasticHit.setScore("1");
-
+
AutoSuggestDocumentEntityFields suggestDocFields = new AutoSuggestDocumentEntityFields();
suggestDocFields.addInput("VNFs");
suggestDocFields.addInput("generic-vnfs");
suggestDocFields.setOutput("VNFs");
suggestDocFields.setPayload(new PayloadEntity());
suggestDocFields.setWeight(100);
-
+
AutoSuggestDocumentEntity autoSuggestDoc = new AutoSuggestDocumentEntity();
autoSuggestDoc.setFields(suggestDocFields);
-
+
elasticHit.setSource(autoSuggestDoc);
-
+
AutoSuggestElasticHitsEntity hits = new AutoSuggestElasticHitsEntity();
hits.addHit(elasticHit);
-
+
elasticResponse.setHits(hits);
-
-
+
+
OperationResult mockedSearchResponse = new OperationResult();
mockedSearchResponse.setResultCode(200);
-
+
mockedSearchResponse.setResult(NodeUtils.convertObjectToJson(elasticResponse, false));
-
+
/*
* The second response is the count API dip to elastic search
*/
-
+
ElasticSearchCountResponse countResponse = new ElasticSearchCountResponse();
countResponse.setCount(3170);
countResponse.addShard("total", "5");
@@ -454,39 +461,41 @@ public class SearchServletTest {
OperationResult searchResponseForCount = new OperationResult();
searchResponseForCount.setResultCode(200);
-
+
searchResponseForCount.setResult(NodeUtils.convertObjectToJson(countResponse, false));
- // TODO: make parameters expect certain values to lock in invocation attempt against a specific input sequence
+ // TODO: make parameters expect certain values to lock in invocation attempt against a
+ // specific input sequence
Mockito.when(searchAdapter.doPost(anyString(), anyString(), anyString()))
.thenReturn(mockedSearchResponse).thenReturn(searchResponseForCount);
-
-
+
+
/*
* Testing the doGet() operation will hit the doPost() operation in the servlet as well
*/
OperationResult result = doEvaluation(true, commonRequest, commonResponse);
-
-
+
+
assertEquals(200, result.getResultCode());
-
+
//
- //{"shards":{"total":"5","failed":"0","successful":"5"},"count":3170}
-
- EntityCountResponse entityCountResponse = mapper.readValue(result.getResult(), EntityCountResponse.class);
-
- assertEquals(3170, entityCountResponse.getCount());
+ // {"shards":{"total":"5","failed":"0","successful":"5"},"count":3170}
+
+ EntityCountResponse entityCountResponse =
+ mapper.readValue(result.getResult(), EntityCountResponse.class);
+
+ assertEquals(3170, entityCountResponse.getCount());
} catch (Exception exc) {
fail("Unexpected exception = " + exc.getLocalizedMessage());
}
}
-
-
+
+
/**
- * Test doGet() and doPost() for Unified Query Search success path
+ * Test doGet() and doPost() for Unified Query Search success path
*/
@Test
public void validateSummaryByEntityType_successPath() {
@@ -494,13 +503,15 @@ public class SearchServletTest {
try {
HttpServletHelper.assignRequestUri(commonRequest, "search/summarybyentitytype");
-
- Map<String,String> payloadFields = new HashMap<String,String>();
- payloadFields.put("hashId", "662d1b57c31df70d7ef57ec53c0ace81578ec77b6bc5de055a57c7547ec122dd");
+
+ Map<String, String> payloadFields = new HashMap<String, String>();
+ payloadFields.put("hashId",
+ "662d1b57c31df70d7ef57ec53c0ace81578ec77b6bc5de055a57c7547ec122dd");
payloadFields.put("groupby", "orchestration-status");
-
- HttpServletHelper.setRequestPayload(commonRequest, MediaType.JSON_UTF_8.toString(), NodeUtils.convertObjectToJson(payloadFields, false));
-
+
+ HttpServletHelper.setRequestPayload(commonRequest, MediaType.JSON_UTF_8.toString(),
+ NodeUtils.convertObjectToJson(payloadFields, false));
+
/*
* In this test we don't want to mock the vnf search service, only it's collaborator
* interactions with a REST endpoint.
@@ -510,128 +521,132 @@ public class SearchServletTest {
searchWrapper.setVnfSearch(vnfSearchService);
/*
- * The first network response to mock is the one to elastic search to get the suggestion entity by hash id
+ * The first network response to mock is the one to elastic search to get the suggestion
+ * entity by hash id
*
- * http://localhost:9200/entityautosuggestindex-localhost/_search
- * {"query":{"term":{"_id":"2172a3c25ae56e4995038ffbc1f055692bfc76c0b8ceda1205bc745a9f7a805d"}}}
+ * http://localhost:9200/entityautosuggestindex-localhost/_search
+ * {"query":{"term":{"_id":"2172a3c25ae56e4995038ffbc1f055692bfc76c0b8ceda1205bc745a9f7a805d"}
+ * }}
*/
-
+
AutoSuggestElasticSearchResponse elasticResponse = new AutoSuggestElasticSearchResponse();
-
+
elasticResponse.setTook(1);
-
+
elasticResponse.setTimedOut(false);
elasticResponse.addShard("total", "5");
elasticResponse.addShard("successful", "5");
elasticResponse.addShard("failed", "0");
-
+
AutoSuggestElasticHitEntity elasticHit = new AutoSuggestElasticHitEntity();
elasticHit.setIndex("entityautosuggestindex-localhost");
elasticHit.setType("default");
elasticHit.setId("2172a3c25ae56e4995038ffbc1f055692bfc76c0b8ceda1205bc745a9f7a805d");
elasticHit.setScore("1");
-
+
AutoSuggestDocumentEntityFields suggestDocFields = new AutoSuggestDocumentEntityFields();
suggestDocFields.addInput("VNFs");
suggestDocFields.addInput("generic-vnfs");
suggestDocFields.setOutput("VNFs");
suggestDocFields.setPayload(new PayloadEntity());
suggestDocFields.setWeight(100);
-
+
AutoSuggestDocumentEntity autoSuggestDoc = new AutoSuggestDocumentEntity();
autoSuggestDoc.setFields(suggestDocFields);
-
+
elasticHit.setSource(autoSuggestDoc);
-
+
AutoSuggestElasticHitsEntity hits = new AutoSuggestElasticHitsEntity();
hits.addHit(elasticHit);
-
+
elasticResponse.setHits(hits);
-
-
+
+
OperationResult mockedSearchResponse = new OperationResult();
mockedSearchResponse.setResultCode(200);
-
+
mockedSearchResponse.setResult(NodeUtils.convertObjectToJson(elasticResponse, false));
-
+
/*
* The second response is the aggregation API dip to elastic search
*/
-
+
ElasticSearchAggegrationResponse aggResponse = new ElasticSearchAggegrationResponse();
-
+
aggResponse.setTook(20);
aggResponse.setTimedOut(false);
-
- aggResponse.addShard("total","5");
- aggResponse.addShard("successful","5");
- aggResponse.addShard("failed","0");
-
+
+ aggResponse.addShard("total", "5");
+ aggResponse.addShard("successful", "5");
+ aggResponse.addShard("failed", "0");
+
ElasticHitsEntity hitsEntity = new ElasticHitsEntity();
-
+
hitsEntity.setTotal(3170);
hitsEntity.setMaxScore(0);
aggResponse.setHits(hitsEntity);
-
+
ElasticSearchAggregation defaultAggregation = new ElasticSearchAggregation();
-
+
defaultAggregation.setDocCountErrorUpperBound(0);
defaultAggregation.setSumOtherDocCount(0);
- defaultAggregation.addBucket(new BucketEntity("created",1876));
- defaultAggregation.addBucket(new BucketEntity("Created",649));
- defaultAggregation.addBucket(new BucketEntity("Activated",158));
- defaultAggregation.addBucket(new BucketEntity("active",59));
- defaultAggregation.addBucket(new BucketEntity("NOT ORCHESTRATED",42));
- defaultAggregation.addBucket(new BucketEntity("Pending-Create",10));
- defaultAggregation.addBucket(new BucketEntity("Running",9));
- defaultAggregation.addBucket(new BucketEntity("Configured",7));
- defaultAggregation.addBucket(new BucketEntity("pending-create",7));
- defaultAggregation.addBucket(new BucketEntity("Error",3));
- defaultAggregation.addBucket(new BucketEntity("planned",3));
- defaultAggregation.addBucket(new BucketEntity("PLANNED",2));
- defaultAggregation.addBucket(new BucketEntity("ERROR",1));
- defaultAggregation.addBucket(new BucketEntity("RUNNING",1));
- defaultAggregation.addBucket(new BucketEntity("example-orchestration-status-val-6176",1));
-
+ defaultAggregation.addBucket(new BucketEntity("created", 1876));
+ defaultAggregation.addBucket(new BucketEntity("Created", 649));
+ defaultAggregation.addBucket(new BucketEntity("Activated", 158));
+ defaultAggregation.addBucket(new BucketEntity("active", 59));
+ defaultAggregation.addBucket(new BucketEntity("NOT ORCHESTRATED", 42));
+ defaultAggregation.addBucket(new BucketEntity("Pending-Create", 10));
+ defaultAggregation.addBucket(new BucketEntity("Running", 9));
+ defaultAggregation.addBucket(new BucketEntity("Configured", 7));
+ defaultAggregation.addBucket(new BucketEntity("pending-create", 7));
+ defaultAggregation.addBucket(new BucketEntity("Error", 3));
+ defaultAggregation.addBucket(new BucketEntity("planned", 3));
+ defaultAggregation.addBucket(new BucketEntity("PLANNED", 2));
+ defaultAggregation.addBucket(new BucketEntity("ERROR", 1));
+ defaultAggregation.addBucket(new BucketEntity("RUNNING", 1));
+ defaultAggregation.addBucket(new BucketEntity("example-orchestration-status-val-6176", 1));
+
aggResponse.addAggregation("default", defaultAggregation);
-
+
OperationResult searchResponseForAggregation = new OperationResult();
searchResponseForAggregation.setResultCode(200);
-
+
searchResponseForAggregation.setResult(NodeUtils.convertObjectToJson(aggResponse, false));
- // TODO: make parameters expect certain values to lock in invocation attempt against a specific input sequence
+ // TODO: make parameters expect certain values to lock in invocation attempt against a
+ // specific input sequence
Mockito.when(searchAdapter.doPost(anyString(), anyString(), anyString()))
.thenReturn(mockedSearchResponse).thenReturn(searchResponseForAggregation);
-
-
+
+
/*
* Testing the doGet() operation will hit the doPost() operation in the servlet as well
*/
OperationResult result = doEvaluation(true, commonRequest, commonResponse);
-
-
+
+
assertEquals(200, result.getResultCode());
-
+
//
- //{"shards":{"total":"5","failed":"0","successful":"5"},"count":3170}
-
- GroupByAggregationResponseEntity groupByResponse = mapper.readValue(result.getResult(), GroupByAggregationResponseEntity.class);
-
- assertEquals(2828, groupByResponse.getAggEntity().getTotalChartHits());
- assertEquals(15, groupByResponse.getAggEntity().getBuckets().size());
+ // {"shards":{"total":"5","failed":"0","successful":"5"},"count":3170}
+
+ GroupByAggregationResponseEntity groupByResponse =
+ mapper.readValue(result.getResult(), GroupByAggregationResponseEntity.class);
+
+ assertEquals(2828, groupByResponse.getAggEntity().getTotalChartHits());
+ assertEquals(15, groupByResponse.getAggEntity().getBuckets().size());
} catch (Exception exc) {
fail("Unexpected exception = " + exc.getLocalizedMessage());
}
}
-
-
-
+
+
+
/**
* Builds the resource entity descriptor.
*
@@ -664,7 +679,7 @@ public class SearchServletTest {
descriptors.put("customer",
buildResourceEntityDescriptor("customer", "service-instance-id", "f1,f2,f3"));
}
-
+
/**
* Builds the view and inspect search request.
*
@@ -703,7 +718,8 @@ public class SearchServletTest {
* @param res the res
* @return the string
*/
- private OperationResult doEvaluationTestMDC(boolean doGet, HttpServletRequest req, HttpServletResponse res) {
+ private OperationResult doEvaluationTestMDC(boolean doGet, HttpServletRequest req,
+ HttpServletResponse res) {
/*
* Test method invocation
@@ -717,7 +733,7 @@ public class SearchServletTest {
e.printStackTrace();
}
ArgumentCaptor<Integer> responseCodeCaptor = ArgumentCaptor.forClass(Integer.class);
-
+
try {
if (doGet) {
searchServlet.doGet(req, res);
@@ -732,16 +748,16 @@ public class SearchServletTest {
responseStringWriter.flush();
Mockito.verify(commonResponse, Mockito.atLeast(1)).setStatus(responseCodeCaptor.capture());
-
+
OperationResult result = new OperationResult();
-
+
result.setResultCode(responseCodeCaptor.getValue());
result.setResult(responseStringWriter.toString());
return result;
}
-
+
/**
* Do evaluation.
*
@@ -750,13 +766,14 @@ public class SearchServletTest {
* @param res the res
* @return the string
*/
- private OperationResult doEvaluation(boolean doGet, HttpServletRequest req, HttpServletResponse res) {
+ private OperationResult doEvaluation(boolean doGet, HttpServletRequest req,
+ HttpServletResponse res) {
/*
* Test method invocation
*/
ArgumentCaptor<Integer> responseCodeCaptor = ArgumentCaptor.forClass(Integer.class);
-
+
try {
if (doGet) {
searchWrapper.doGet(req, res);
@@ -771,9 +788,9 @@ public class SearchServletTest {
responseStringWriter.flush();
Mockito.verify(commonResponse, Mockito.atLeast(1)).setStatus(responseCodeCaptor.capture());
-
+
OperationResult result = new OperationResult();
-
+
result.setResultCode(responseCodeCaptor.getValue());
result.setResult(responseStringWriter.toString());
@@ -781,6 +798,6 @@ public class SearchServletTest {
}
-
+
}
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchableGroupsTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchableGroupsTest.java
index d378c3a..5d9fa3a 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/SearchableGroupsTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/SearchableGroupsTest.java
@@ -36,38 +36,36 @@ public class SearchableGroupsTest {
+ "\"search-paths\" : [\"cloud-infrastructure\", \"business\", \"network\"]" + "}," + "{"
+ "\"group-name\" : \"cloud-infrastructure\","
+ "\"search-paths\" : [\"complexes\", \"cloud-regions\", \"pservers\"]" + "}" + "]" + "}";
- /*
- * @Before public void init() throws NoSuchFieldException, SecurityException,
- * IllegalArgumentException, IllegalAccessException { Field instance =
- * SearchableGroups.class.getDeclaredField("instance"); instance.setAccessible(true);
- * instance.set(null, null); }
- *
- * @Test public void test_FileNotFound() throws ElasticSearchOperationException {
- * System.setProperty("AJSC_HOME", ""); SearchableGroups testGroups =
- * SearchableGroups.getTestInstance(); assertTrue(testGroups.getGroups().isEmpty()); }
- *
- * @Test public void test_FileFoundWithProperlyFormatedConfig() throws
- * ElasticSearchOperationException { ResolverUtils testUtils =
- * Mockito.mock(ResolverUtils.class);
- * Mockito.when(testUtils.getConfigSettings(anyString())).thenReturn(GOOD_TEST_CONFIG);
- * SearchableGroups testGroups = SearchableGroups.getTestInstance();
- *
- * testGroups.setUtils(testUtils); testGroups.initSearchableGroups();
- *
- * assertFalse(testGroups.getGroups().isEmpty());
- *
- * assertFalse(testGroups.getSearchableGroups("inventory").isEmpty()); }
- *
- * @Test public void test_FileFoundGroupDoesNotExist() throws
- * ElasticSearchOperationException {
- * ResolverUtils testUtils = Mockito.mock(ResolverUtils.class);
- * Mockito.when(testUtils.getConfigSettings(anyString())).thenReturn(GOOD_TEST_CONFIG);
- * SearchableGroups testGroups = SearchableGroups.getTestInstance();
- *
- * testGroups.setUtils(testUtils); testGroups.initSearchableGroups();
- *
- * assertFalse(testGroups.getGroups().isEmpty());
- *
- * assertEquals(null, testGroups.getSearchableGroups("Test")); }
- */
+ /*
+ * @Before public void init() throws NoSuchFieldException, SecurityException,
+ * IllegalArgumentException, IllegalAccessException { Field instance =
+ * SearchableGroups.class.getDeclaredField("instance"); instance.setAccessible(true);
+ * instance.set(null, null); }
+ *
+ * @Test public void test_FileNotFound() throws ElasticSearchOperationException {
+ * System.setProperty("AJSC_HOME", ""); SearchableGroups testGroups =
+ * SearchableGroups.getTestInstance(); assertTrue(testGroups.getGroups().isEmpty()); }
+ *
+ * @Test public void test_FileFoundWithProperlyFormatedConfig() throws
+ * ElasticSearchOperationException { ResolverUtils testUtils = Mockito.mock(ResolverUtils.class);
+ * Mockito.when(testUtils.getConfigSettings(anyString())).thenReturn(GOOD_TEST_CONFIG);
+ * SearchableGroups testGroups = SearchableGroups.getTestInstance();
+ *
+ * testGroups.setUtils(testUtils); testGroups.initSearchableGroups();
+ *
+ * assertFalse(testGroups.getGroups().isEmpty());
+ *
+ * assertFalse(testGroups.getSearchableGroups("inventory").isEmpty()); }
+ *
+ * @Test public void test_FileFoundGroupDoesNotExist() throws ElasticSearchOperationException {
+ * ResolverUtils testUtils = Mockito.mock(ResolverUtils.class);
+ * Mockito.when(testUtils.getConfigSettings(anyString())).thenReturn(GOOD_TEST_CONFIG);
+ * SearchableGroups testGroups = SearchableGroups.getTestInstance();
+ *
+ * testGroups.setUtils(testUtils); testGroups.initSearchableGroups();
+ *
+ * assertFalse(testGroups.getGroups().isEmpty());
+ *
+ * assertEquals(null, testGroups.getSearchableGroups("Test")); }
+ */
}
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/ViewAndInspectSearchRequestTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/ViewAndInspectSearchRequestTest.java
index 15d46dd..70dd762 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/ViewAndInspectSearchRequestTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/ViewAndInspectSearchRequestTest.java
@@ -38,7 +38,7 @@ import org.onap.aai.sparky.viewandinspect.entity.QuerySearchEntity;
/**
* The Class ViewAndInspectSearchRequestTest.
*/
-@RunWith(MockitoJUnitRunner.class)
+@RunWith(MockitoJUnitRunner.class)
public class ViewAndInspectSearchRequestTest {
/**
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/entity/EntityEntryTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/entity/EntityEntryTest.java
index 023855b..d5fe2ae 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/entity/EntityEntryTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/entity/EntityEntryTest.java
@@ -39,7 +39,7 @@ import org.mockito.runners.MockitoJUnitRunner;
/**
* The Class EntityEntryTest.
*/
-@RunWith(MockitoJUnitRunner.class)
+@RunWith(MockitoJUnitRunner.class)
public class EntityEntryTest {
/**
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationContextTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationContextTest.java
index 08ce29d..00c6267 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationContextTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationContextTest.java
@@ -56,84 +56,86 @@ import com.fasterxml.jackson.databind.node.ObjectNode;
public class VisualizationContextTest {
- VisualizationContext context;
- ActiveInventoryDataProvider dataProvider;
- long contextId;
- OxmModelLoader oxmModelLoader;
- ExecutorService service;
+ VisualizationContext context;
+ ActiveInventoryDataProvider dataProvider;
+ long contextId;
+ OxmModelLoader oxmModelLoader;
+ ExecutorService service;
- @Before
- public void init() throws Exception {
- MockitoAnnotations.initMocks(this);
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/";
- TierSupportUiConstants.CONFIG_OXM_LOCATION = System.getProperty("AJSC_HOME")+"/bundleconfig-local/oxm/";
- oxmModelLoader = Mockito.spy(OxmModelLoader.getInstance());
- ActiveInventoryDataProvider dataProvider = new ActiveInventoryAdapter(new RestClientBuilder());
- SecureRandom random = new SecureRandom();
- long contextId = random.nextLong();
- ExecutorService service = NodeUtils.createNamedExecutor("SLNC-WORKER",
- 2, LoggerFactory.getInstance().getLogger(VisualizationContextTest.class));
- context = new VisualizationContext(contextId, dataProvider, service, oxmModelLoader);
- }
+ @Before
+ public void init() throws Exception {
+ MockitoAnnotations.initMocks(this);
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION =
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/";
+ TierSupportUiConstants.CONFIG_OXM_LOCATION =
+ System.getProperty("AJSC_HOME") + "/bundleconfig-local/oxm/";
+ oxmModelLoader = Mockito.spy(OxmModelLoader.getInstance());
+ ActiveInventoryDataProvider dataProvider = new ActiveInventoryAdapter(new RestClientBuilder());
+ SecureRandom random = new SecureRandom();
+ long contextId = random.nextLong();
+ ExecutorService service = NodeUtils.createNamedExecutor("SLNC-WORKER", 2,
+ LoggerFactory.getInstance().getLogger(VisualizationContextTest.class));
+ context = new VisualizationContext(contextId, dataProvider, service, oxmModelLoader);
+ }
- @Test
- public void testExtractQueryParamsFromSelfLink_NullLink() {
- List<String> queryParams = context.extractQueryParamsFromSelfLink(null);
- Assert.assertEquals(queryParams.size(), 0);
- }
+ @Test
+ public void testExtractQueryParamsFromSelfLink_NullLink() {
+ List<String> queryParams = context.extractQueryParamsFromSelfLink(null);
+ Assert.assertEquals(queryParams.size(), 0);
+ }
- @Test
- public void testExtractQueryParamsFromSelfLink_NotNullLink() {
- context.extractQueryParamsFromSelfLink("https://localhost:9517/model/aai/webapp/index.html");
- }
+ @Test
+ public void testExtractQueryParamsFromSelfLink_NotNullLink() {
+ context.extractQueryParamsFromSelfLink("https://localhost:9517/model/aai/webapp/index.html");
+ }
- @Test
- public void testDecodeComplexAttributeGroup_NullAttributeGroup() {
- ActiveInventoryNode ain = new ActiveInventoryNode();
- ObjectNode node = JsonNodeFactory.instance.objectNode();
- boolean retValue = context.decodeComplexAttributeGroup(ain, node);
- Assert.assertFalse(retValue);
- }
+ @Test
+ public void testDecodeComplexAttributeGroup_NullAttributeGroup() {
+ ActiveInventoryNode ain = new ActiveInventoryNode();
+ ObjectNode node = JsonNodeFactory.instance.objectNode();
+ boolean retValue = context.decodeComplexAttributeGroup(ain, node);
+ Assert.assertFalse(retValue);
+ }
- @Test
- public void testDecodeComplexAttributeGroup_NotNullAttributeGroup() {
- ActiveInventoryNode ain = new ActiveInventoryNode();
- ObjectNode node1 = JsonNodeFactory.instance.objectNode();
- ObjectNode node2 = JsonNodeFactory.instance.objectNode();
- node1.set("model", node2);
- ObjectNode modelNode = JsonNodeFactory.instance.objectNode();
- node2.set("model-1", modelNode);
- modelNode.set("firstValue", JsonNodeFactory.instance.objectNode());
- modelNode.set("secondValue", JsonNodeFactory.instance.objectNode());
- modelNode.set("thirdValue", JsonNodeFactory.instance.objectNode());
- boolean retValue = context.decodeComplexAttributeGroup(ain, node1);
- Assert.assertFalse(retValue);
- }
+ @Test
+ public void testDecodeComplexAttributeGroup_NotNullAttributeGroup() {
+ ActiveInventoryNode ain = new ActiveInventoryNode();
+ ObjectNode node1 = JsonNodeFactory.instance.objectNode();
+ ObjectNode node2 = JsonNodeFactory.instance.objectNode();
+ node1.set("model", node2);
+ ObjectNode modelNode = JsonNodeFactory.instance.objectNode();
+ node2.set("model-1", modelNode);
+ modelNode.set("firstValue", JsonNodeFactory.instance.objectNode());
+ modelNode.set("secondValue", JsonNodeFactory.instance.objectNode());
+ modelNode.set("thirdValue", JsonNodeFactory.instance.objectNode());
+ boolean retValue = context.decodeComplexAttributeGroup(ain, node1);
+ Assert.assertFalse(retValue);
+ }
- @Test
- public void testProcessSelfLinks() {
- SearchableEntity entity = new SearchableEntity();
- entity.setId("id-1");
- entity.setEntityType("cloud-region");
- entity.setEntityPrimaryKeyValue("cloud-region-1");
- entity.setLink("https://localhost:9517/model/aai/webapp/index.html");
- QueryParams params = new QueryParams();
- params.setSearchTargetNodeId("id-1");
- Map<String, ActiveInventoryNode> nodeMap = context.getNodeCache();
- ActiveInventoryNode node = new ActiveInventoryNode();
- node.setEntityType("cloud-region");
- node.setNodeId("id-1");
- node.setPrimaryKeyName("cloud-region-1");
- node.setPrimaryKeyValue("cloud-region-1");
- node.addQueryParam(
+ @Test
+ public void testProcessSelfLinks() {
+ SearchableEntity entity = new SearchableEntity();
+ entity.setId("id-1");
+ entity.setEntityType("cloud-region");
+ entity.setEntityPrimaryKeyValue("cloud-region-1");
+ entity.setLink("https://localhost:9517/model/aai/webapp/index.html");
+ QueryParams params = new QueryParams();
+ params.setSearchTargetNodeId("id-1");
+ Map<String, ActiveInventoryNode> nodeMap = context.getNodeCache();
+ ActiveInventoryNode node = new ActiveInventoryNode();
+ node.setEntityType("cloud-region");
+ node.setNodeId("id-1");
+ node.setPrimaryKeyName("cloud-region-1");
+ node.setPrimaryKeyValue("cloud-region-1");
+ node.addQueryParam(
node.getEntityType() + "." + node.getPrimaryKeyName() + ":" + node.getPrimaryKeyValue());
- node.setNodeDepth(0);
- node.setRootNode(true);
- node.setSelfLink(entity.getLink());
- nodeMap.put("id-1", node);
- node.setResolvedSelfLink(true);
- context.processSelfLinks(entity, params);
+ node.setNodeDepth(0);
+ node.setRootNode(true);
+ node.setSelfLink(entity.getLink());
+ nodeMap.put("id-1", node);
+ node.setResolvedSelfLink(true);
+ context.processSelfLinks(entity, params);
- }
+ }
}
diff --git a/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationServiceTest.java b/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationServiceTest.java
index 72ea1ed..fef0410 100644
--- a/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationServiceTest.java
+++ b/src/test/java/org/onap/aai/sparky/viewandinspect/services/VisualizationServiceTest.java
@@ -33,79 +33,64 @@ import org.onap.aai.sparky.viewandinspect.entity.QueryRequest;
public class VisualizationServiceTest {
- VisualizationService service;
-
- @Before
- public void init() throws Exception {
- System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
- TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION = System.getProperty("AJSC_HOME")+"/src/test/resources/appconfig/";
- //TierSupportUiConstants.CONFIG_OXM_LOCATION = System.getProperty("AJSC_HOME")+"/bundleconfig-local/oxm/";
- TierSupportUiConstants.STATIC_CONFIG_APP_LOCATION = System.getProperty("AJSC_HOME")+"/bundleconfig-local/etc/appprops";
- OxmModelLoader loader = OxmModelLoader.getInstance();
- service = new VisualizationService(loader);
- }
-
- @Test
- public void testAnalyzeQueryRequestBody_InvalidQuery() {
- QueryRequest request = service.analyzeQueryRequestBody("query-json-1");
- Assert.assertNull(request);
- }
-
- @Test
- public void testAnalyzeQueryRequestBody_ValidQuery() {
- QueryRequest request = service.analyzeQueryRequestBody("{\"hashId\":\"hashid-1\"}");
- Assert.assertNotNull(request);
- }
- @Test
- public void testBuildVisualizationUsingGenericQuery_UnsuccessfulOperationResult() {
- QueryRequest queryRequest = new QueryRequest();
- queryRequest.setHashId("hash-id-1");
- service.buildVisualizationUsingGenericQuery(queryRequest);
- }
+ VisualizationService service;
- String queryRequest = "{\r\n" +
- " \"variables\": [],\r\n" +
- " \"info\": {\r\n" +
- " \"name\": \"NamedQuery\",\r\n" +
- " \"_postman_id\": \"8006823d-35ce-16ef-88e9-cd5b873c9e7b\",\r\n" +
- " \"schema\": \"https://schema.getpostman.com/json/collection/v2.0.0/collection.json\"\r\n" +
- " },\r\n" +
- " \"item\": [\r\n" +
- " {\r\n" +
- " \"name\": \"https://127.0.0.1:8443/aai/v11/service-design-and-creation/named-queries/named-query/0367193e-c785-4d5f-9cb8-7bc89dc9ddb7\",\r\n" +
- " \"request\": {\r\n" +
- " \"url\": \"https://127.0.0.1:8443/aai/v11/service-design-and-creation/named-queries/named-query/0367193e-c785-4d5f-9cb8-7bc89dc9ddb7\",\r\n" +
- " \"method\": \"POST\",\r\n" +
- " \"header\": [\r\n" +
- " {\r\n" +
- " \"key\": \"Content-Type\",\r\n" +
- " \"value\": \"application/json\",\r\n" +
- " \"description\": \"\"\r\n" +
- " },\r\n" +
- " {\r\n" +
- " \"key\": \"X-TransactionId\",\r\n" +
- " \"value\": \"9999\",\r\n" +
- " \"description\": \"\"\r\n" +
- " },\r\n" +
- " {\r\n" +
- " \"key\": \"X-FromAppId\",\r\n" +
- " \"value\": \"jimmy-postman\",\r\n" +
- " \"description\": \"\"\r\n" +
- " },\r\n" +
- " {\r\n" +
- " \"key\": \"Authorization\",\r\n" +
- " \"value\": \"Basic QUFJOkFBSQ==\",\r\n" +
- " \"description\": \"\"\r\n" +
- " }\r\n" +
- " ],\r\n" +
- " \"body\": {\r\n" +
- " \"mode\": \"raw\",\r\n" +
- " \"raw\": \"{\\n \\\"named-query-uuid\\\" : \\\"0367193e-c785-4d5f-9cb8-7bc89dc9ddb7\\\",\\n \\\"named-query-name\\\" : \\\"get-component-list\\\",\\n \\\"named-query-version\\\" : \\\"1.1\\\",\\n \\\"description\\\" : \\\"Named Query - Get Component List\\\",\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"property-collect-list\\\" : [ \\\"service-instance-id\\\", \\\"service-instance-name\\\" ],\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"1b2c9ba7-e449-4831-ba15-3073672f5ef2\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"3d560d81-57d0-438b-a2a1-5334dba0651a\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"fcec1b02-b2d0-4834-aef8-d71be04717dd\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"ff69d4e0-a8e8-4108-bdb0-dd63217e63c7\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"fcec1b02-b2d0-4834-aef8-d71be04717dd\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"1b2c9ba7-e449-4831-ba15-3073672f5ef2\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"3d560d81-57d0-438b-a2a1-5334dba0651a\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"ef86f9c5-2165-44f3-8fc3-96018b609ea5\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"acc6edd8-a8d4-4b93-afaa-0994068be14c\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"82194af1-3c2c-485a-8f44-420e22a9eaa4\\\"\\n } ]\\n } ]\\n }\\n } ]\\n }\\n}\\n\"\r\n" +
- " },\r\n" +
- " \"description\": \"\"\r\n" +
- " },\r\n" +
- " \"response\": []\r\n" +
- " }\r\n" +
- " ]\r\n" +
- "}";
+ @Before
+ public void init() throws Exception {
+ System.setProperty("AJSC_HOME", new File(".").getCanonicalPath().replace('\\', '/'));
+ TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION =
+ System.getProperty("AJSC_HOME") + "/src/test/resources/appconfig/";
+ // TierSupportUiConstants.CONFIG_OXM_LOCATION =
+ // System.getProperty("AJSC_HOME")+"/bundleconfig-local/oxm/";
+ TierSupportUiConstants.STATIC_CONFIG_APP_LOCATION =
+ System.getProperty("AJSC_HOME") + "/bundleconfig-local/etc/appprops";
+ OxmModelLoader loader = OxmModelLoader.getInstance();
+ service = new VisualizationService(loader);
+ }
+
+ @Test
+ public void testAnalyzeQueryRequestBody_InvalidQuery() {
+ QueryRequest request = service.analyzeQueryRequestBody("query-json-1");
+ Assert.assertNull(request);
+ }
+
+ @Test
+ public void testAnalyzeQueryRequestBody_ValidQuery() {
+ QueryRequest request = service.analyzeQueryRequestBody("{\"hashId\":\"hashid-1\"}");
+ Assert.assertNotNull(request);
+ }
+
+ @Test
+ public void testBuildVisualizationUsingGenericQuery_UnsuccessfulOperationResult() {
+ QueryRequest queryRequest = new QueryRequest();
+ queryRequest.setHashId("hash-id-1");
+ service.buildVisualizationUsingGenericQuery(queryRequest);
+ }
+
+ String queryRequest = "{\r\n" + " \"variables\": [],\r\n" + " \"info\": {\r\n"
+ + " \"name\": \"NamedQuery\",\r\n"
+ + " \"_postman_id\": \"8006823d-35ce-16ef-88e9-cd5b873c9e7b\",\r\n"
+ + " \"schema\": \"https://schema.getpostman.com/json/collection/v2.0.0/collection.json\"\r\n"
+ + " },\r\n" + " \"item\": [\r\n" + " {\r\n"
+ + " \"name\": \"https://127.0.0.1:8443/aai/v11/service-design-and-creation/named-queries/named-query/0367193e-c785-4d5f-9cb8-7bc89dc9ddb7\",\r\n"
+ + " \"request\": {\r\n"
+ + " \"url\": \"https://127.0.0.1:8443/aai/v11/service-design-and-creation/named-queries/named-query/0367193e-c785-4d5f-9cb8-7bc89dc9ddb7\",\r\n"
+ + " \"method\": \"POST\",\r\n" + " \"header\": [\r\n"
+ + " {\r\n" + " \"key\": \"Content-Type\",\r\n"
+ + " \"value\": \"application/json\",\r\n"
+ + " \"description\": \"\"\r\n" + " },\r\n"
+ + " {\r\n" + " \"key\": \"X-TransactionId\",\r\n"
+ + " \"value\": \"9999\",\r\n"
+ + " \"description\": \"\"\r\n" + " },\r\n"
+ + " {\r\n" + " \"key\": \"X-FromAppId\",\r\n"
+ + " \"value\": \"jimmy-postman\",\r\n"
+ + " \"description\": \"\"\r\n" + " },\r\n"
+ + " {\r\n" + " \"key\": \"Authorization\",\r\n"
+ + " \"value\": \"Basic QUFJOkFBSQ==\",\r\n"
+ + " \"description\": \"\"\r\n" + " }\r\n"
+ + " ],\r\n" + " \"body\": {\r\n"
+ + " \"mode\": \"raw\",\r\n"
+ + " \"raw\": \"{\\n \\\"named-query-uuid\\\" : \\\"0367193e-c785-4d5f-9cb8-7bc89dc9ddb7\\\",\\n \\\"named-query-name\\\" : \\\"get-component-list\\\",\\n \\\"named-query-version\\\" : \\\"1.1\\\",\\n \\\"description\\\" : \\\"Named Query - Get Component List\\\",\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"property-collect-list\\\" : [ \\\"service-instance-id\\\", \\\"service-instance-name\\\" ],\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"1b2c9ba7-e449-4831-ba15-3073672f5ef2\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"3d560d81-57d0-438b-a2a1-5334dba0651a\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"fcec1b02-b2d0-4834-aef8-d71be04717dd\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"ff69d4e0-a8e8-4108-bdb0-dd63217e63c7\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"fcec1b02-b2d0-4834-aef8-d71be04717dd\\\"\\n } ]\\n } ]\\n }\\n }, {\\n \\\"named-query-elements\\\" : {\\n \\\"named-query-element\\\" : [ {\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"1b2c9ba7-e449-4831-ba15-3073672f5ef2\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"3d560d81-57d0-438b-a2a1-5334dba0651a\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"ef86f9c5-2165-44f3-8fc3-96018b609ea5\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"acc6edd8-a8d4-4b93-afaa-0994068be14c\\\"\\n } ]\\n } ]\\n }\\n } ]\\n },\\n \\\"relationship-list\\\" : {\\n \\\"relationship\\\" : [ {\\n \\\"related-to\\\" : \\\"model\\\",\\n \\\"relationship-data\\\" : [ {\\n \\\"relationship-key\\\" : \\\"model.model-invariant-id\\\",\\n \\\"relationship-value\\\" : \\\"82194af1-3c2c-485a-8f44-420e22a9eaa4\\\"\\n } ]\\n } ]\\n }\\n } ]\\n }\\n}\\n\"\r\n"
+ + " },\r\n" + " \"description\": \"\"\r\n" + " },\r\n"
+ + " \"response\": []\r\n" + " }\r\n" + " ]\r\n" + "}";
}