2  * ============LICENSE_START=======================================================
\r 
   4  * ================================================================================
\r 
   5  * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
\r 
   6  * Copyright © 2017-2018 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 
  12  *       http://www.apache.org/licenses/LICENSE-2.0
\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 
  21 package org.onap.aai.sa.searchdbabstraction.elasticsearch.dao;
\r 
  23 import org.junit.Assert;
\r 
  24 import org.junit.Test;
\r 
  26 public class ElasticSearchResultItemTest {
\r 
  29     public void testAllMethods(){
\r 
  30         ElasticSearchShardStatus shardStatus = new ElasticSearchShardStatus();
\r 
  31         shardStatus.setTotal(10);
\r 
  32         shardStatus.setSuccessful(0);
\r 
  33         shardStatus.setFailed(1);
\r 
  34         Assert.assertEquals(shardStatus.getTotal(), 10);
\r 
  35         Assert.assertEquals(shardStatus.getSuccessful(), 0);
\r 
  36         Assert.assertEquals(shardStatus.getFailed(), 1);
\r 
  38         ElasticSearchCause cause = new ElasticSearchCause();
\r 
  39         cause.setType("type-1");
\r 
  40         cause.setReason("reason-1");
\r 
  41         Assert.assertEquals(cause.getType(), "type-1");
\r 
  42         Assert.assertEquals(cause.getReason(), "reason-1");
\r 
  44         ElasticSearchError error = new ElasticSearchError();
\r 
  45         error.setType("type-1");
\r 
  46         error.setReason("reason-1");
\r 
  47         error.setCausedBy(cause);
\r 
  48         Assert.assertEquals(error.getType(), "type-1");
\r 
  49         Assert.assertEquals(error.getReason(), "reason-1");
\r 
  50         Assert.assertNotNull(error.getCausedBy());
\r 
  51         error.setAdditionalProperties("name-1", "value-1");
\r 
  52         Assert.assertNotNull(error.getAdditionalProperties());
\r 
  55         ElasticSearchResultItem resultItem1 = new ElasticSearchResultItem();
\r 
  56         resultItem1.setCreate(getStatus(shardStatus, error));
\r 
  57         Assert.assertNotNull(resultItem1.getCreate());
\r 
  58         Assert.assertEquals(resultItem1.operationType(), "create");
\r 
  59         Assert.assertEquals(resultItem1.operationStatus(), resultItem1.getCreate());
\r 
  60         Assert.assertTrue(resultItem1.toString().contains("create"));
\r 
  61         Assert.assertNotNull(resultItem1.toJson());
\r 
  64         ElasticSearchResultItem resultItem2 = new ElasticSearchResultItem();
\r 
  65         resultItem2.setIndex(getStatus(shardStatus, error));
\r 
  66         Assert.assertNotNull(resultItem2.getIndex());
\r 
  67         Assert.assertEquals(resultItem2.operationType(), "update");
\r 
  68         Assert.assertEquals(resultItem2.operationStatus(), resultItem2.getIndex());
\r 
  69         Assert.assertTrue(resultItem2.toString().contains("index"));
\r 
  70         Assert.assertNotNull(resultItem2.toJson());
\r 
  73         ElasticSearchResultItem resultItem3 = new ElasticSearchResultItem();
\r 
  74         resultItem3.setDelete(getStatus(shardStatus, error));
\r 
  75         Assert.assertNotNull(resultItem3.getDelete());
\r 
  76         Assert.assertEquals(resultItem3.operationType(), "delete");
\r 
  77         Assert.assertEquals(resultItem3.operationStatus(), resultItem3.getDelete());
\r 
  78         Assert.assertTrue(resultItem3.toString().contains("delete"));
\r 
  79         Assert.assertNotNull(resultItem3.toJson());
\r 
  82         ElasticSearchResultItem resultItem4 = new ElasticSearchResultItem();
\r 
  83         Assert.assertEquals(resultItem4.operationType(), "unknown");
\r 
  84         Assert.assertNull(resultItem4.operationStatus());
\r 
  86         //ElasticSearchBulkOperationResult
\r 
  87         ElasticSearchResultItem[] resultItems = {resultItem1, resultItem2, resultItem3};
\r 
  88         ElasticSearchBulkOperationResult result = new ElasticSearchBulkOperationResult();
\r 
  89         result.setErrors(true);
\r 
  90         result.setTook(new Integer(10));
\r 
  91         result.setItems(resultItems);
\r 
  92         Assert.assertTrue(result.getErrors());
\r 
  93         Assert.assertEquals(result.getTook(), new Integer(10));
\r 
  94         Assert.assertNotNull(result.getItems());
\r 
  95         Assert.assertNotNull(result.toString());
\r 
  98     private ElasticSearchOperationStatus getStatus(ElasticSearchShardStatus shardStatus, ElasticSearchError error) {
\r 
  99         ElasticSearchOperationStatus status = new ElasticSearchOperationStatus();
\r 
 100         status.setIndex("index-1");
\r 
 101         status.setType("type-1");
\r 
 102         status.setId("id-1");
\r 
 103         status.setVersion("1.0");
\r 
 104         status.setShards(shardStatus);
\r 
 105         status.setStatus(new Integer(1));
\r 
 106         status.setError(error);
\r 
 107         status.setAdditionalProperties("REQUEST_URL", "http://127.0.0.1");
\r 
 108         Assert.assertEquals(status.getIndex(), "index-1");
\r 
 109         Assert.assertEquals(status.getType(), "type-1");
\r 
 110         Assert.assertEquals(status.getId(), "id-1");
\r 
 111         Assert.assertEquals(status.getVersion(), "1.0");
\r 
 112         Assert.assertEquals(status.getStatus(), new Integer(1));
\r 
 113         Assert.assertNotNull(status.getShards());
\r 
 114         Assert.assertNotNull(status.getError());
\r 
 115         Assert.assertNotNull(status.getAdditionalProperties());
\r