-
Notifications
You must be signed in to change notification settings - Fork 0
/
K6ReportIngressApiResourceTest.java
54 lines (42 loc) · 1.99 KB
/
K6ReportIngressApiResourceTest.java
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
package io.github.bbortt.k6.report.ingress.web.rest;
import io.github.bbortt.k6.report.ingress.service.K6ReportService;
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 org.springframework.http.ResponseEntity;
import org.springframework.web.multipart.MultipartFile;
import java.util.UUID;
import static io.github.bbortt.k6.report.ingress.web.rest.K6ReportIngressApiResource.PROCESSING_ID_HEADER_NAME;
import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.Mockito.doReturn;
import static org.springframework.http.HttpStatus.ACCEPTED;
@ExtendWith({MockitoExtension.class})
class K6ReportIngressApiResourceTest {
@Mock
private K6ReportService k6ReportServiceMock;
@Mock
private MultipartFile reportFileMock;
private K6ReportIngressApiResource k6ReportIngressApiResource;
@BeforeEach
void setUp() {
k6ReportIngressApiResource = new K6ReportIngressApiResource(k6ReportServiceMock);
}
@Test
void uploadJSONReportRespondsDespiteBeingProcessedAsynchronously() {
var mockProcessingId = UUID.fromString("20c8fc34-934e-47ee-9f33-c6325e479d58");
doReturn(mockProcessingId).when(k6ReportServiceMock).processFileAsync(reportFileMock);
ResponseEntity<Void> responseEntity = k6ReportIngressApiResource.uploadJSONReport(reportFileMock);
assertThat(responseEntity)
.satisfies(
r -> assertThat(r)
.extracting(ResponseEntity::getStatusCode)
.isEqualTo(ACCEPTED),
r -> assertThat(r)
.extracting(ResponseEntity::getHeaders)
.extracting(header -> header.getFirst(PROCESSING_ID_HEADER_NAME))
.isEqualTo(mockProcessingId.toString())
);
}
}