src/test/java/org/onap/aai/sa/searchdbabstraction/elasticsearch/dao/ElasticSearchResultItemTest.java

   1 /**\r
   2  * ============LICENSE_START=======================================================\r
   3  * org.onap.aai\r
   4  * ================================================================================\r
   5  * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * Copyright © 2017 Amdocs\r
   7  * ================================================================================\r
   8  * Licensed under the Apache License, Version 2.0 (the "License");\r
   9  * you may not use this file except in compliance with the License.\r
  10  * You may obtain a copy of the License at\r
  11  *\r
  12  *       http://www.apache.org/licenses/LICENSE-2.0\r
  13  *\r
  14  * Unless required by applicable law or agreed to in writing, software\r
  15  * distributed under the License is distributed on an "AS IS" BASIS,\r
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  17  * See the License for the specific language governing permissions and\r
  18  * limitations under the License.\r
  19  * ============LICENSE_END=========================================================\r
  20  *\r
  21  * ECOMP is a trademark and service mark of AT&T Intellectual Property.\r
  22  */\r
  23 package org.onap.aai.sa.searchdbabstraction.elasticsearch.dao;\r
  24 \r
  25 import org.junit.Assert;\r
  26 import org.junit.Test;\r
  27 \r
  28 public class ElasticSearchResultItemTest {\r
  29 \r
  30     @Test\r
  31     public void testAllMethods(){\r
  32         ElasticSearchShardStatus shardStatus = new ElasticSearchShardStatus();\r
  33         shardStatus.setTotal(10);\r
  34         shardStatus.setSuccessful(0);\r
  35         shardStatus.setFailed(1);\r
  36         Assert.assertEquals(shardStatus.getTotal(), 10);\r
  37         Assert.assertEquals(shardStatus.getSuccessful(), 0);\r
  38         Assert.assertEquals(shardStatus.getFailed(), 1);\r
  39 \r
  40         ElasticSearchCause cause = new ElasticSearchCause();\r
  41         cause.setType("type-1");\r
  42         cause.setReason("reason-1");\r
  43         Assert.assertEquals(cause.getType(), "type-1");\r
  44         Assert.assertEquals(cause.getReason(), "reason-1");\r
  45 \r
  46         ElasticSearchError error = new ElasticSearchError();\r
  47         error.setType("type-1");\r
  48         error.setReason("reason-1");\r
  49         error.setCausedBy(cause);\r
  50         Assert.assertEquals(error.getType(), "type-1");\r
  51         Assert.assertEquals(error.getReason(), "reason-1");\r
  52         Assert.assertNotNull(error.getCausedBy());\r
  53         error.setAdditionalProperties("name-1", "value-1");\r
  54         Assert.assertNotNull(error.getAdditionalProperties());\r
  55 \r
  56         //Create Status\r
  57         ElasticSearchResultItem resultItem1 = new ElasticSearchResultItem();\r
  58         resultItem1.setCreate(getStatus(shardStatus, error));\r
  59         Assert.assertNotNull(resultItem1.getCreate());\r
  60         Assert.assertEquals(resultItem1.operationType(), "create");\r
  61         Assert.assertEquals(resultItem1.operationStatus(), resultItem1.getCreate());\r
  62         Assert.assertTrue(resultItem1.toString().contains("create"));\r
  63         Assert.assertNotNull(resultItem1.toJson());\r
  64 \r
  65         //Index Status\r
  66         ElasticSearchResultItem resultItem2 = new ElasticSearchResultItem();\r
  67         resultItem2.setIndex(getStatus(shardStatus, error));\r
  68         Assert.assertNotNull(resultItem2.getIndex());\r
  69         Assert.assertEquals(resultItem2.operationType(), "update");\r
  70         Assert.assertEquals(resultItem2.operationStatus(), resultItem2.getIndex());\r
  71         Assert.assertTrue(resultItem2.toString().contains("index"));\r
  72         Assert.assertNotNull(resultItem2.toJson());\r
  73 \r
  74         //Delete Status\r
  75         ElasticSearchResultItem resultItem3 = new ElasticSearchResultItem();\r
  76         resultItem3.setDelete(getStatus(shardStatus, error));\r
  77         Assert.assertNotNull(resultItem3.getDelete());\r
  78         Assert.assertEquals(resultItem3.operationType(), "delete");\r
  79         Assert.assertEquals(resultItem3.operationStatus(), resultItem3.getDelete());\r
  80         Assert.assertTrue(resultItem3.toString().contains("delete"));\r
  81         Assert.assertNotNull(resultItem3.toJson());\r
  82 \r
  83         //Unknown Status\r
  84         ElasticSearchResultItem resultItem4 = new ElasticSearchResultItem();\r
  85         Assert.assertEquals(resultItem4.operationType(), "unknown");\r
  86         Assert.assertNull(resultItem4.operationStatus());\r
  87 \r
  88         //ElasticSearchBulkOperationResult\r
  89         ElasticSearchResultItem[] resultItems = {resultItem1, resultItem2, resultItem3};\r
  90         ElasticSearchBulkOperationResult result = new ElasticSearchBulkOperationResult();\r
  91         result.setErrors(true);\r
  92         result.setTook(new Integer(10));\r
  93         result.setItems(resultItems);\r
  94         Assert.assertTrue(result.getErrors());\r
  95         Assert.assertEquals(result.getTook(), new Integer(10));\r
  96         Assert.assertNotNull(result.getItems());\r
  97         Assert.assertNotNull(result.toString());\r
  98     }\r
  99 \r
 100     private ElasticSearchOperationStatus getStatus(ElasticSearchShardStatus shardStatus, ElasticSearchError error) {\r
 101         ElasticSearchOperationStatus status = new ElasticSearchOperationStatus();\r
 102         status.setIndex("index-1");\r
 103         status.setType("type-1");\r
 104         status.setId("id-1");\r
 105         status.setVersion("1.0");\r
 106         status.setShards(shardStatus);\r
 107         status.setStatus(new Integer(1));\r
 108         status.setError(error);\r
 109         status.setAdditionalProperties("REQUEST_URL", "http://127.0.0.1");\r
 110         Assert.assertEquals(status.getIndex(), "index-1");\r
 111         Assert.assertEquals(status.getType(), "type-1");\r
 112         Assert.assertEquals(status.getId(), "id-1");\r
 113         Assert.assertEquals(status.getVersion(), "1.0");\r
 114         Assert.assertEquals(status.getStatus(), new Integer(1));\r
 115         Assert.assertNotNull(status.getShards());\r
 116         Assert.assertNotNull(status.getError());\r
 117         Assert.assertNotNull(status.getAdditionalProperties());\r
 118         return status;\r
 119     }\r
 120 \r
 121 }\r