2  * ============LICENSE_START=======================================================
 
   4  * ================================================================================
 
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights
 
   7  * ================================================================================
 
   8  * Licensed under the Apache License, Version 2.0 (the "License");
 
   9  * you may not use this file except in compliance with the License.
 
  10  * You may obtain a copy of the License at
 
  12  *      http://www.apache.org/licenses/LICENSE-2.0
 
  14  * Unless required by applicable law or agreed to in writing, software
 
  15  * distributed under the License is distributed on an "AS IS" BASIS,
 
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 
  17  * See the License for the specific language governing permissions and
 
  18  * limitations under the License.
 
  19  * ============LICENSE_END=========================================================
 
  22 package org.openecomp.appc.listener.CL.model;
 
  24 import static org.junit.Assert.assertEquals;
 
  25 import static org.junit.Assert.assertFalse;
 
  26 import static org.junit.Assert.assertNotNull;
 
  27 import static org.junit.Assert.assertTrue;
 
  28 import static org.junit.Assert.fail;
 
  30 import org.apache.commons.io.IOUtils;
 
  31 import org.json.JSONObject;
 
  32 import org.junit.Before;
 
  33 import org.junit.Test;
 
  34 import org.openecomp.appc.listener.CL.model.IncomingMessage;
 
  35 import org.openecomp.appc.listener.CL.model.OutgoingMessage;
 
  36 import org.openecomp.appc.listener.CL.model.Status;
 
  37 import org.openecomp.appc.listener.util.Mapper;
 
  39 public class TestMessages {
 
  40     private IncomingMessage in;
 
  41     private OutgoingMessage out;
 
  43     private String incomingStr;
 
  44     private String outgoingStr;
 
  49             incomingStr = IOUtils.toString(getClass().getResourceAsStream("/IncomingMessage.txt"), "UTF-8");
 
  50             outgoingStr = IOUtils.toString(getClass().getResourceAsStream("/OutgoingMessage.txt"), "UTF-8");
 
  51             assertNotNull(incomingStr);
 
  52             assertNotNull(outgoingStr);
 
  54             in = Mapper.mapOne(incomingStr, IncomingMessage.class);
 
  56             out = Mapper.mapOne(in.toOutgoing(Status.PENDING), OutgoingMessage.class);
 
  57             out.updateResponseTime();
 
  61         } catch (Exception e) {
 
  67     // NOTE Test Mapper will be used to test an event from dmaap.
 
  69     public void testGetterSetter() {
 
  71         assertNotNull(in.getRequestClient());
 
  72         assertNotNull(in.getRequestTime());
 
  73         assertNotNull(in.getMessage());
 
  74         assertNotNull(in.getTenantId());
 
  75         assertNotNull(in.getVmId());
 
  76         assertNotNull(in.getVmName());
 
  77         assertNotNull(in.getAction());
 
  78         assertNotNull(in.getId());
 
  79         assertNotNull(in.getPolicyName());
 
  80         assertNotNull(in.getPolicyVersion());
 
  81         assertNotNull(in.getRequest());
 
  83         out = Mapper.mapOne(in.toOutgoing(null), OutgoingMessage.class);
 
  84         assertNotNull(out.getRequestClient());
 
  85         assertEquals(in.getRequestClient(), out.getRequestClient());
 
  86         assertNotNull(out.getRequestTime());
 
  87         assertEquals(in.getRequestTime(), out.getRequestTime());
 
  88         assertNotNull(out.getMessage());
 
  89         assertEquals(in.getMessage(), out.getMessage());
 
  90         assertNotNull(out.getVmName());
 
  91         assertEquals(in.getVmName(), out.getVmName());
 
  92         assertNotNull(out.getPolicyName());
 
  93         assertEquals(in.getPolicyName(), out.getPolicyName());
 
  94         assertNotNull(out.getPolicyVersion());
 
  95         assertEquals(in.getPolicyVersion(), out.getPolicyVersion());
 
  96         assertNotNull(out.getOriginalRequest());
 
  97         assertNotNull(in.getRequest(), out.getOriginalRequest());
 
 101     public void testToString() {
 
 102         in = new IncomingMessage();
 
 103         assertNotNull(in.toString());
 
 106         assertNotNull(in.toString());
 
 107         assertTrue(in.toString().contains(id));
 
 111     public void testOutgoingUpdateTime() {
 
 112         String old = out.getResponseTime();
 
 113         out.updateResponseTime();
 
 114         assertFalse(old.equals(out.getResponseTime()));
 
 119     public void testOutgoingToJson() {
 
 121         String message = "MSG";
 
 122         out.setMessage(message);
 
 123         JSONObject json = out.toResponse();
 
 125         String respStr = json.getString("response");
 
 126         assertTrue(respStr.contains(out.getResponse().getValue()));
 
 128         String msgStr = json.getString("message");
 
 129         assertNotNull(msgStr);
 
 130         assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 
 131         assertTrue(msgStr.contains(out.getMessage()));
 
 134         out.setMessage(null);
 
 135         json = out.toResponse();
 
 137         msgStr = json.getString("message");
 
 138         assertNotNull(msgStr);
 
 139         assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 
 140         assertTrue(msgStr.contains(out.getResponse().getValue()));
 
 143         assertNotNull(out.getOriginalRequest());
 
 147     public void testOutgoingToString() {
 
 148         String s = out.toString();
 
 149         assertTrue(s.contains(out.getId()));