services/appc-dmaap-service/appc-event-listener-bundle/src/test/java/org/onap/appc/listener/demo/model/TestMessages.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : APPC
   4  * ================================================================================
   5  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Copyright (C) 2017 Amdocs
   8  * =============================================================================
   9  * Modification Copyright (C) 2018 IBM.
  10  * ================================================================================
  11  * Modifications Copyright (C) 2019 Ericsson
  12  * =============================================================================
  13  * Licensed under the Apache License, Version 2.0 (the "License");
  14  * you may not use this file except in compliance with the License.
  15  * You may obtain a copy of the License at
  16  *
  17  *      http://www.apache.org/licenses/LICENSE-2.0
  18  *
  19  * Unless required by applicable law or agreed to in writing, software
  20  * distributed under the License is distributed on an "AS IS" BASIS,
  21  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  22  * See the License for the specific language governing permissions and
  23  * limitations under the License.
  24  *
  25  * ============LICENSE_END=========================================================
  26  */
  27
  28 package org.onap.appc.listener.demo.model;
  29
  30
  31 import static org.junit.Assert.assertEquals;
  32 import static org.junit.Assert.assertNotNull;
  33 import static org.junit.Assert.assertTrue;
  34 import static org.junit.Assert.fail;
  35 import java.util.ArrayList;
  36 import java.util.Collection;
  37 import org.apache.commons.io.IOUtils;
  38 import org.json.JSONObject;
  39 import org.junit.Before;
  40 import org.junit.Ignore;
  41 import org.junit.Test;
  42 import org.onap.appc.listener.demo.model.CommonMessage.Streams;
  43 import org.onap.appc.listener.demo.model.IncomingMessage;
  44 import org.onap.appc.listener.demo.model.OutgoingMessage;
  45 import org.onap.appc.listener.demo.model.Status;
  46 import org.onap.appc.listener.util.Mapper;
  47
  48 public class TestMessages {
  49     private IncomingMessage in;
  50     private OutgoingMessage out;
  51
  52     private String incomingStr;
  53     private String outgoingStr;
  54
  55     @Before
  56     public void setup() {
  57         try {
  58             incomingStr = IOUtils.toString(getClass().getResourceAsStream("/IncomingMessagedemo.txt"), "UTF-8");
  59             outgoingStr = IOUtils.toString(getClass().getResourceAsStream("/OutgoingMessagedemo.txt"), "UTF-8");
  60             assertNotNull(incomingStr);
  61             assertNotNull(outgoingStr);
  62
  63             in = Mapper.mapOne(incomingStr, IncomingMessage.class);
  64
  65             out = Mapper.mapOne(outgoingStr, OutgoingMessage.class);
  66
  67             assertNotNull(in);
  68             assertNotNull(out);
  69         } catch (Exception e) {
  70             fail(e.getMessage());
  71         }
  72     }
  73
  74     // NOTE Test Mapper will be used to test an event from dmaap.
  75     @Test
  76     public void testGetterSetter() {
  77         assertNotNull(in);
  78         assertNotNull(in.getAction());
  79         assertNotNull(in.getHeader().getApiVer());
  80         assertNotNull(in.getHeader().getOriginatorId());
  81         assertNotNull(in.getHeader().getRequestID());
  82         assertNotNull(in.getHeader().getSubRequestId());
  83         assertNotNull(in.getHeader().getTimeStamp());
  84
  85         assertNotNull(out);
  86         assertNotNull(out.getHeader().getApiVer());
  87         assertNotNull(out.getHeader().getOriginatorId());
  88         assertNotNull(out.getHeader().getRequestID());
  89         assertNotNull(out.getHeader().getSubRequestId());
  90         assertNotNull(out.getHeader().getTimeStamp());
  91         assertNotNull(out.getStatus().getCode());
  92         assertNotNull(out.getStatus().getValue());
  93
  94     }
  95
  96     @Test
  97     public void testGetRequest()
  98     {
  99         String request="testRequest";
 100         in.setRequest(request);
 101         assertEquals(request, in.getRequest());
 102     }
 103
 104     @Test
 105     public void testIsValid()
 106     {
 107         assertEquals(true, in.isValid());
 108     }
 109
 110     @Test
 111     public void testTime() {
 112         in.setStartTime(0);
 113         assertEquals(0, in.getStartTime());
 114     }
 115
 116     @Test
 117     public void testPayload() {
 118         CommonMessage.Payload payload = new CommonMessage.Payload();
 119         payload.setGenericVnfId("VNF_ID");
 120         CommonMessage.Streams streams = new CommonMessage.Streams();
 121         streams.setActiveStreams(7);
 122         payload.setStreams(streams);
 123         in.setPayload(payload);
 124         assertEquals("VNF_ID", in.getPayload().getGenericVnfId());
 125         assertEquals("{\\\"streams\\\": {\\\"active-streams\\\": 7}}",
 126                 in.getPayload().getStreams());
 127     }
 128
 129     @Test
 130     @Ignore
 131     public void testIncommingToOutgoing(){
 132         OutgoingMessage newOut;
 133         newOut = Mapper.mapOne(in.toOutgoing(Status.ACCEPTED), OutgoingMessage.class);
 134         assertNotNull(newOut);
 135         assertNotNull(newOut.getHeader().getApiVer());
 136         assertNotNull(newOut.getHeader().getOriginatorId());
 137         assertNotNull(newOut.getHeader().getRequestID());
 138         assertNotNull(newOut.getHeader().getSubRequestId());
 139         assertNotNull(newOut.getHeader().getTimeStamp());
 140         assertNotNull(newOut.getStatus().getCode());
 141         assertNotNull(newOut.getStatus().getValue());
 142     }
 143
 144     @Test
 145     @Ignore
 146     public void testToString() {
 147         in = new IncomingMessage();
 148         assertNotNull(in.toString());
 149         String id = "test";
 150         //in.setId(id);
 151         assertNotNull(in.toString());
 152         assertTrue(in.toString().contains(id));
 153     }
 154
 155     @Test
 156     @Ignore
 157     public void testOutgoingUpdateTime() {
 158         //String old = out.getResponseTime();
 159         out.updateResponseTime();
 160         //assertFalse(old.equals(out.getResponseTime()));
 161     }
 162
 163     // Testing for 1510
 164     @Test
 165     @Ignore
 166     public void testOutgoingToJson() {
 167         // Message Set
 168         String message = "MSG";
 169         //out.setMessage(message);
 170         JSONObject json = out.toResponse();
 171         assertNotNull(json);
 172         String respStr = json.getString("response");
 173         //assertTrue(respStr.contains(out.getResponse().getValue()));
 174
 175         String msgStr = json.getString("message");
 176         assertNotNull(msgStr);
 177         //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 178         //assertTrue(msgStr.contains(out.getMessage()));
 179
 180         // Null Message
 181         //out.setMessage(null);
 182         json = out.toResponse();
 183         assertNotNull(json);
 184         msgStr = json.getString("message");
 185         assertNotNull(msgStr);
 186         //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 187         //assertTrue(msgStr.contains(out.getResponse().getValue()));
 188
 189         // Echoing request
 190         //assertNotNull(out.getOriginalRequest());
 191     }
 192
 193     @Test
 194     @Ignore
 195     public void testOutgoingToString() {
 196         String s = out.toString();
 197         //assertTrue(s.contains(out.getId()));
 198     }
 199 }