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 * Licensed under the Apache License, Version 2.0 (the "License");
12 * you may not use this file except in compliance with the License.
13 * You may obtain a copy of the License at
15 * http://www.apache.org/licenses/LICENSE-2.0
17 * Unless required by applicable law or agreed to in writing, software
18 * distributed under the License is distributed on an "AS IS" BASIS,
19 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
20 * See the License for the specific language governing permissions and
21 * limitations under the License.
23 * ============LICENSE_END=========================================================
26 package org.onap.appc.listener.demo.model;
29 import static org.junit.Assert.assertEquals;
30 import static org.junit.Assert.assertFalse;
31 import static org.junit.Assert.assertNotNull;
32 import static org.junit.Assert.assertTrue;
33 import static org.junit.Assert.fail;
35 import org.apache.commons.io.IOUtils;
36 import org.json.JSONObject;
37 import org.junit.Before;
38 import org.junit.Ignore;
39 import org.junit.Test;
40 import org.onap.appc.listener.demo.model.IncomingMessage;
41 import org.onap.appc.listener.demo.model.OutgoingMessage;
42 import org.onap.appc.listener.demo.model.Status;
43 import org.onap.appc.listener.util.Mapper;
45 public class TestMessages {
46 private IncomingMessage in;
47 private OutgoingMessage out;
49 private String incomingStr;
50 private String outgoingStr;
55 incomingStr = IOUtils.toString(getClass().getResourceAsStream("/IncomingMessagedemo.txt"), "UTF-8");
56 outgoingStr = IOUtils.toString(getClass().getResourceAsStream("/OutgoingMessagedemo.txt"), "UTF-8");
57 assertNotNull(incomingStr);
58 assertNotNull(outgoingStr);
60 in = Mapper.mapOne(incomingStr, IncomingMessage.class);
62 out = Mapper.mapOne(outgoingStr, OutgoingMessage.class);
66 } catch (Exception e) {
72 // NOTE Test Mapper will be used to test an event from dmaap.
74 public void testGetterSetter() {
76 assertNotNull(in.getAction());
77 assertNotNull(in.getHeader().getApiVer());
78 assertNotNull(in.getHeader().getOriginatorId());
79 assertNotNull(in.getHeader().getRequestID());
80 assertNotNull(in.getHeader().getSubRequestId());
81 assertNotNull(in.getHeader().getTimeStamp());
84 assertNotNull(out.getHeader().getApiVer());
85 assertNotNull(out.getHeader().getOriginatorId());
86 assertNotNull(out.getHeader().getRequestID());
87 assertNotNull(out.getHeader().getSubRequestId());
88 assertNotNull(out.getHeader().getTimeStamp());
89 assertNotNull(out.getStatus().getCode());
90 assertNotNull(out.getStatus().getValue());
95 public void testGetRequest()
97 String request="testRequest";
98 in.setRequest(request);
99 assertEquals(request, in.getRequest());
103 public void testIsValid()
105 assertEquals(true, in.isValid());
110 public void testIncommingToOutgoing(){
111 OutgoingMessage newOut;
112 newOut = Mapper.mapOne(in.toOutgoing(Status.ACCEPTED), OutgoingMessage.class);
113 assertNotNull(newOut);
114 assertNotNull(newOut.getHeader().getApiVer());
115 assertNotNull(newOut.getHeader().getOriginatorId());
116 assertNotNull(newOut.getHeader().getRequestID());
117 assertNotNull(newOut.getHeader().getSubRequestId());
118 assertNotNull(newOut.getHeader().getTimeStamp());
119 assertNotNull(newOut.getStatus().getCode());
120 assertNotNull(newOut.getStatus().getValue());
125 public void testToString() {
126 in = new IncomingMessage();
127 assertNotNull(in.toString());
130 assertNotNull(in.toString());
131 assertTrue(in.toString().contains(id));
137 public void testOutgoingUpdateTime() {
138 //String old = out.getResponseTime();
139 out.updateResponseTime();
140 //assertFalse(old.equals(out.getResponseTime()));
146 public void testOutgoingToJson() {
148 String message = "MSG";
149 //out.setMessage(message);
150 JSONObject json = out.toResponse();
152 String respStr = json.getString("response");
153 //assertTrue(respStr.contains(out.getResponse().getValue()));
155 String msgStr = json.getString("message");
156 assertNotNull(msgStr);
157 //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
158 //assertTrue(msgStr.contains(out.getMessage()));
161 //out.setMessage(null);
162 json = out.toResponse();
164 msgStr = json.getString("message");
165 assertNotNull(msgStr);
166 //assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
167 //assertTrue(msgStr.contains(out.getResponse().getValue()));
170 //assertNotNull(out.getOriginalRequest());
175 public void testOutgoingToString() {
176 String s = out.toString();
177 //assertTrue(s.contains(out.getId()));