df82ab071a0cdb15e93dafa8d4bfa6b52b4ce167
[policy/clamp.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  * Copyright (C) 2021 Nordix Foundation.
4  * ================================================================================
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  *      http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  *
17  * SPDX-License-Identifier: Apache-2.0
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.onap.policy.clamp.controlloop.models.messages.dmaap.participant;
22
23 import static org.assertj.core.api.Assertions.assertThatThrownBy;
24 import static org.junit.Assert.assertEquals;
25 import static org.junit.Assert.assertFalse;
26 import static org.junit.Assert.assertTrue;
27 import static org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantMessageUtils.assertSerializable;
28
29 import java.util.UUID;
30 import org.junit.jupiter.api.Test;
31 import org.onap.policy.common.utils.coder.CoderException;
32 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
33
34 class ParticipantAckMessageTest {
35     private ParticipantAckMessage message;
36
37     private static final ToscaConceptIdentifier PTYPE_456 = new ToscaConceptIdentifier("PType", "4.5.6");
38     private static final ToscaConceptIdentifier PTYPE_457 = new ToscaConceptIdentifier("PType", "4.5.7");
39     private static final ToscaConceptIdentifier ID_123 = new ToscaConceptIdentifier("id", "1.2.3");
40     private static final ToscaConceptIdentifier ID_124 = new ToscaConceptIdentifier("id", "1.2.4");
41
42     @Test
43     void testCopyConstructor() throws CoderException {
44         assertThatThrownBy(() -> new ParticipantAckMessage((ParticipantAckMessage) null))
45                 .isInstanceOf(NullPointerException.class);
46
47         // verify with null values
48         message = new ParticipantAckMessage(ParticipantMessageType.PARTICIPANT_STATE_CHANGE);
49         ParticipantAckMessage newmsg = new ParticipantAckMessage(message);
50         newmsg.setResponseTo(message.getResponseTo());
51         assertEquals(message.toString(), newmsg.toString());
52
53         // verify with all values
54         message = makeMessage();
55         newmsg = new ParticipantAckMessage(message);
56         newmsg.setResponseTo(message.getResponseTo());
57         assertEquals(message.toString(), newmsg.toString());
58
59         assertSerializable(message, ParticipantAckMessage.class);
60     }
61
62     @Test
63     void testAppliesTo_NullParticipantId() {
64         message = makeMessage();
65
66         assertThatThrownBy(() -> message.appliesTo(null, null)).isInstanceOf(NullPointerException.class);
67         assertThatThrownBy(() -> message.appliesTo(PTYPE_456, null)).isInstanceOf(NullPointerException.class);
68         assertThatThrownBy(() -> message.appliesTo(null, ID_123)).isInstanceOf(NullPointerException.class);
69     }
70
71     @Test
72     void testAppliesTo_ParticipantIdMatches() {
73         message = makeMessage();
74
75         // ParticipantId matches
76         assertTrue(message.appliesTo(PTYPE_456, ID_123));
77         assertFalse(message.appliesTo(PTYPE_456, ID_124));
78         assertFalse(message.appliesTo(PTYPE_457, ID_123));
79     }
80
81     @Test
82     void testAppliesTo_ParticipantIdNoMatch() {
83         message = makeMessage();
84
85         // ParticipantId does not match
86         ToscaConceptIdentifier id = new ToscaConceptIdentifier();
87         id.setName("id1111");
88         id.setVersion("3.2.1");
89         assertFalse(message.appliesTo(id, id));
90         message.setParticipantType(null);
91         assertTrue(message.appliesTo(id, id));
92     }
93
94     private ParticipantAckMessage makeMessage() {
95         ParticipantAckMessage msg = new ParticipantAckMessage(ParticipantMessageType.PARTICIPANT_DEREGISTER_ACK);
96
97         msg.setParticipantType(PTYPE_456);
98         msg.setParticipantId(ID_123);
99         msg.setMessage("Successfull Ack");
100         msg.setResult(true);
101         msg.setResponseTo(UUID.randomUUID());
102
103         return msg;
104     }
105 }