appc-event-listener/appc-event-listener-bundle/src/test/java/org/openecomp/appc/listener/CL/model/TestMessages.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : APP-C
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights
   6  *                                              reserved.
   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
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  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=========================================================
  20  */
  21
  22 package org.openecomp.appc.listener.CL.model;
  23
  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;
  29
  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;
  38
  39 public class TestMessages {
  40     private IncomingMessage in;
  41     private OutgoingMessage out;
  42
  43     private String incomingStr;
  44     private String outgoingStr;
  45
  46     @Before
  47     public void setup() {
  48         try {
  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);
  53
  54             in = Mapper.mapOne(incomingStr, IncomingMessage.class);
  55
  56             out = Mapper.mapOne(in.toOutgoing(Status.PENDING), OutgoingMessage.class);
  57             out.updateResponseTime();
  58
  59             assertNotNull(in);
  60             assertNotNull(out);
  61         } catch (Exception e) {
  62             e.printStackTrace();
  63             fail(e.getMessage());
  64         }
  65     }
  66
  67     // NOTE Test Mapper will be used to test an event from dmaap.
  68     @Test
  69     public void testGetterSetter() {
  70         assertNotNull(in);
  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());
  82
  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());
  98     }
  99
 100     @Test
 101     public void testToString() {
 102         in = new IncomingMessage();
 103         assertNotNull(in.toString());
 104         String id = "test";
 105         in.setId(id);
 106         assertNotNull(in.toString());
 107         assertTrue(in.toString().contains(id));
 108     }
 109
 110     @Test
 111     public void testOutgoingUpdateTime() {
 112         String old = out.getResponseTime();
 113         out.updateResponseTime();
 114         assertFalse(old.equals(out.getResponseTime()));
 115     }
 116
 117     // Testing for 1510
 118     @Test
 119     public void testOutgoingToJson() {
 120         // Message Set
 121         String message = "MSG";
 122         out.setMessage(message);
 123         JSONObject json = out.toResponse();
 124         assertNotNull(json);
 125         String respStr = json.getString("response");
 126         assertTrue(respStr.contains(out.getResponse().getValue()));
 127
 128         String msgStr = json.getString("message");
 129         assertNotNull(msgStr);
 130         assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 131         assertTrue(msgStr.contains(out.getMessage()));
 132
 133         // Null Message
 134         out.setMessage(null);
 135         json = out.toResponse();
 136         assertNotNull(json);
 137         msgStr = json.getString("message");
 138         assertNotNull(msgStr);
 139         assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 140         assertTrue(msgStr.contains(out.getResponse().getValue()));
 141
 142         // Echoing request
 143         assertNotNull(out.getOriginalRequest());
 144     }
 145
 146     @Test
 147     public void testOutgoingToString() {
 148         String s = out.toString();
 149         assertTrue(s.contains(out.getId()));
 150     }
 151 }