2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights
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
12 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
22 package org.openecomp.appc.listener.CL.model;
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;
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;
39 public class TestMessages {
40 private IncomingMessage in;
41 private OutgoingMessage out;
43 private String incomingStr;
44 private String outgoingStr;
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);
54 in = Mapper.mapOne(incomingStr, IncomingMessage.class);
56 out = Mapper.mapOne(in.toOutgoing(Status.PENDING), OutgoingMessage.class);
57 out.updateResponseTime();
61 } catch (Exception e) {
67 // NOTE Test Mapper will be used to test an event from dmaap.
69 public void testGetterSetter() {
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());
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());
101 public void testToString() {
102 in = new IncomingMessage();
103 assertNotNull(in.toString());
106 assertNotNull(in.toString());
107 assertTrue(in.toString().contains(id));
111 public void testOutgoingUpdateTime() {
112 String old = out.getResponseTime();
113 out.updateResponseTime();
114 assertFalse(old.equals(out.getResponseTime()));
119 public void testOutgoingToJson() {
121 String message = "MSG";
122 out.setMessage(message);
123 JSONObject json = out.toResponse();
125 String respStr = json.getString("response");
126 assertTrue(respStr.contains(out.getResponse().getValue()));
128 String msgStr = json.getString("message");
129 assertNotNull(msgStr);
130 assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
131 assertTrue(msgStr.contains(out.getMessage()));
134 out.setMessage(null);
135 json = out.toResponse();
137 msgStr = json.getString("message");
138 assertNotNull(msgStr);
139 assertFalse(msgStr.contains(out.getOriginalRequest())); // False for 1602
140 assertTrue(msgStr.contains(out.getResponse().getValue()));
143 assertNotNull(out.getOriginalRequest());
147 public void testOutgoingToString() {
148 String s = out.toString();
149 assertTrue(s.contains(out.getId()));