2 * ============LICENSE_START=======================================================
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
17 * http://www.apache.org/licenses/LICENSE-2.0
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.
25 * ============LICENSE_END=========================================================
28 package org.onap.appc.listener.demo.model;
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;
48 public class TestMessages {
49 private IncomingMessage in;
50 private OutgoingMessage out;
52 private String incomingStr;
53 private String outgoingStr;
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);
63 in = Mapper.mapOne(incomingStr, IncomingMessage.class);
65 out = Mapper.mapOne(outgoingStr, OutgoingMessage.class);
69 } catch (Exception e) {
74 // NOTE Test Mapper will be used to test an event from dmaap.
76 public void testGetterSetter() {
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());
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());
97 public void testGetRequest()
99 String request="testRequest";
100 in.setRequest(request);
101 assertEquals(request, in.getRequest());
105 public void testIsValid()
107 assertEquals(true, in.isValid());
111 public void testTime() {
113 assertEquals(0, in.getStartTime());
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());
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());
151 public void testToString() {
152 in = new IncomingMessage();
153 assertNotNull(in.toString());
156 assertNotNull(in.toString());
157 assertTrue(in.toString().contains(id));
162 public void testOutgoingUpdateTime() {
163 //String old = out.getResponseTime();
164 out.updateResponseTime();
165 //assertFalse(old.equals(out.getResponseTime()));
171 public void testOutgoingToJson() {
173 String message = "MSG";
174 //out.setMessage(message);
175 JSONObject json = out.toResponse();
177 String respStr = json.getString("response");
178 //assertTrue(respStr.contains(out.getResponse().getValue()));
180 String msgStr = json.getString("message");
181 assertNotNull(msgStr);
182 //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
183 //assertTrue(msgStr.contains(out.getMessage()));
186 //out.setMessage(null);
187 json = out.toResponse();
189 msgStr = json.getString("message");
190 assertNotNull(msgStr);
191 //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
192 //assertTrue(msgStr.contains(out.getResponse().getValue()));
195 //assertNotNull(out.getOriginalRequest());
200 public void testOutgoingToString() {
201 String s = out.toString();
202 //assertTrue(s.contains(out.getId()));