appc-event-listener/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.pgStream;
  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.pgStream pgStream = new CommonMessage.pgStream();
 121         pgStream.setId("ID");
 122         pgStream.setIsEnabled("true");
 123         CommonMessage.pgStreams pgStreams = new CommonMessage.pgStreams();
 124         Collection<pgStream> collectionPgStreams = new ArrayList<pgStream>();
 125         collectionPgStreams.add(pgStream);
 126         pgStreams.setStreams(collectionPgStreams);
 127         payload.setPgStreams(pgStreams);
 128         in.setPayload(payload);
 129         assertEquals("VNF_ID", in.getPayload().getGenericVnfId());
 130         assertEquals("{\\\"pg-streams\\\": {\\\"pg-stream\\\":[{\\\"id\\\":\\\"ID\\\", \\\"is-enabled\\\":\\\"true\\\"}]}}",
 131                 in.getPayload().getPgStreams());
 132     }
 133
 134     @Test
 135     @Ignore
 136     public void testIncommingToOutgoing(){
 137         OutgoingMessage newOut;
 138         newOut = Mapper.mapOne(in.toOutgoing(Status.ACCEPTED), OutgoingMessage.class);
 139         assertNotNull(newOut);
 140         assertNotNull(newOut.getHeader().getApiVer());
 141         assertNotNull(newOut.getHeader().getOriginatorId());
 142         assertNotNull(newOut.getHeader().getRequestID());
 143         assertNotNull(newOut.getHeader().getSubRequestId());
 144         assertNotNull(newOut.getHeader().getTimeStamp());
 145         assertNotNull(newOut.getStatus().getCode());
 146         assertNotNull(newOut.getStatus().getValue());
 147     }
 148
 149     @Test
 150     @Ignore
 151     public void testToString() {
 152         in = new IncomingMessage();
 153         assertNotNull(in.toString());
 154         String id = "test";
 155         //in.setId(id);
 156         assertNotNull(in.toString());
 157         assertTrue(in.toString().contains(id));
 158     }
 159
 160     @Test
 161     @Ignore
 162     public void testOutgoingUpdateTime() {
 163         //String old = out.getResponseTime();
 164         out.updateResponseTime();
 165         //assertFalse(old.equals(out.getResponseTime()));
 166     }
 167
 168     // Testing for 1510
 169     @Test
 170     @Ignore
 171     public void testOutgoingToJson() {
 172         // Message Set
 173         String message = "MSG";
 174         //out.setMessage(message);
 175         JSONObject json = out.toResponse();
 176         assertNotNull(json);
 177         String respStr = json.getString("response");
 178         //assertTrue(respStr.contains(out.getResponse().getValue()));
 179
 180         String msgStr = json.getString("message");
 181         assertNotNull(msgStr);
 182         //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 183         //assertTrue(msgStr.contains(out.getMessage()));
 184
 185         // Null Message
 186         //out.setMessage(null);
 187         json = out.toResponse();
 188         assertNotNull(json);
 189         msgStr = json.getString("message");
 190         assertNotNull(msgStr);
 191         //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
 192         //assertTrue(msgStr.contains(out.getResponse().getValue()));
 193
 194         // Echoing request
 195         //assertNotNull(out.getOriginalRequest());
 196     }
 197
 198     @Test
 199     @Ignore
 200     public void testOutgoingToString() {
 201         String s = out.toString();
 202         //assertTrue(s.contains(out.getId()));
 203     }
 204 }