1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
/*
* ============LICENSE_START=======================================================
* org.onap.dcae
* ================================================================================
* Copyright (c) 2020 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.onap.dcaegen2.platform.mod.web.service;
import org.onap.dcaegen2.platform.mod.model.specification.DeploymentType;
import org.onap.dcaegen2.platform.mod.model.microserviceinstance.MsInstance;
import org.onap.dcaegen2.platform.mod.model.restapi.SpecificationRequest;
import org.onap.dcaegen2.platform.mod.model.specification.Specification;
import org.onap.dcaegen2.platform.mod.model.specification.SpecificationStatus;
import org.onap.dcaegen2.platform.mod.objectmothers.MsInstanceObjectMother;
import org.onap.dcaegen2.platform.mod.web.service.microserviceinstance.MsInstanceService;
import org.onap.dcaegen2.platform.mod.web.service.specification.SpecificationGateway;
import org.onap.dcaegen2.platform.mod.web.service.specification.SpecificationServiceImpl;
import org.onap.dcaegen2.platform.mod.web.service.specification.SpecificationValidatorService;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
import static org.assertj.core.api.Assertions.assertThat;
import static org.onap.dcaegen2.platform.mod.objectmothers.MsInstanceObjectMother.MS_INSTANCE_ID;
import static org.onap.dcaegen2.platform.mod.objectmothers.SpecificationObjectMother.getMockSpecification;
import static org.onap.dcaegen2.platform.mod.objectmothers.SpecificationObjectMother.getSpecificationRequest;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.*;
@ExtendWith({MockitoExtension.class})
public class SpecificationServiceTest {
private SpecificationServiceImpl service;
@Mock
private SpecificationGateway specRepo;
@Mock
private MsInstanceService msInstanceService;
@Mock
private SpecificationValidatorService validatorService;
@BeforeEach
void setUp() {
service = new SpecificationServiceImpl();
service.setMsInstanceService(msInstanceService);
service.setSpecificationValidatorService(validatorService);
service.setSpecificationGateway(specRepo);
}
@Test
void createSpecificationTest() throws Exception {
//given
SpecificationRequest request = getSpecificationRequest();
Specification specFromRepo = getMockSpecification(DeploymentType.K8S);
MsInstance msInstance = MsInstanceObjectMother.createMsInstance();
when(msInstanceService.getMsInstanceById(MS_INSTANCE_ID)).thenReturn(msInstance);
when(specRepo.save(any(Specification.class))).thenReturn(specFromRepo);
//when
Specification spec = service.createSpecification(MS_INSTANCE_ID, request);
//then
assertThatFieldsAreCorrect(request, spec);
verifyCalls(request, msInstance);
}
private void assertThatFieldsAreCorrect(SpecificationRequest request, Specification spec) {
assertThat(spec.getStatus()).isEqualTo(SpecificationStatus.ACTIVE);
assertThat(spec.getSpecContent()).isEqualTo(request.getSpecContent());
assertThat(spec.getPolicyJson()).isEqualTo(request.getPolicyJson());
assertThat(spec.getType()).isEqualTo(request.getType());
assertThat(spec.getMetadata().get("createdBy")).isEqualTo(request.getUser());
assertThat(spec.getMetadata().get("createdOn")).isNotNull();
assertThat(spec.getMsInstanceInfo()).isNotNull();
}
private void verifyCalls(SpecificationRequest request, MsInstance msInstance) {
verify(msInstanceService, times(1)).getMsInstanceById(MS_INSTANCE_ID);
verify(validatorService, times(1)).validateSpecForRelease(request, msInstance.getRelease());
verify(specRepo, times(2)).save(any(Specification.class));
verify(msInstanceService, times(1)).updateMsInstance(msInstance);
}
}
|