Added presentation of owner of EiJob
[portal/nonrtric-controlpanel.git] / webapp-backend / src / test / java / org / oransc / portal / nonrtric / controlpanel / RestApiTest.java
1 /*-
2  * ========================LICENSE_START=================================
3  * O-RAN-SC
4  * %%
5  * Copyright (C) 2020 Nordix Foundation
6  * %%
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ========================LICENSE_END===================================
19  */
20
21 package org.oransc.portal.nonrtric.controlpanel;
22
23 import static org.assertj.core.api.Assertions.assertThat;
24
25 import com.google.gson.Gson;
26 import com.google.gson.GsonBuilder;
27 import com.google.gson.JsonArray;
28 import com.google.gson.JsonElement;
29 import com.google.gson.JsonParser;
30
31 import java.io.BufferedReader;
32 import java.io.FileNotFoundException;
33 import java.io.FileOutputStream;
34 import java.io.InputStream;
35 import java.io.InputStreamReader;
36 import java.io.PrintStream;
37 import java.lang.invoke.MethodHandles;
38 import java.util.stream.Collectors;
39
40 import org.junit.jupiter.api.Test;
41 import org.junit.jupiter.api.extension.ExtendWith;
42 import org.oransc.portal.nonrtric.controlpanel.model.JobInfo;
43 import org.oransc.portal.nonrtric.controlpanel.model.ProducerInfo;
44 import org.oransc.portal.nonrtric.controlpanel.util.AsyncRestClient;
45 import org.slf4j.Logger;
46 import org.slf4j.LoggerFactory;
47 import org.springframework.beans.factory.annotation.Autowired;
48 import org.springframework.boot.test.context.SpringBootTest;
49 import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
50 import org.springframework.boot.web.server.LocalServerPort;
51 import org.springframework.context.ApplicationContext;
52 import org.springframework.http.HttpStatus;
53 import org.springframework.http.ResponseEntity;
54 import org.springframework.test.context.junit.jupiter.SpringExtension;
55
56 @ExtendWith(SpringExtension.class)
57 @SpringBootTest(webEnvironment = WebEnvironment.RANDOM_PORT)
58 class RestApiTest {
59
60     private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
61
62     private static Gson gson = new GsonBuilder().setPrettyPrinting().create();
63
64     @Autowired
65     ApplicationContext context;
66
67     @LocalServerPort
68     private int port;
69
70     @Test
71     void createApiDoc() throws FileNotFoundException {
72         String url = "/v2/api-docs";
73         ResponseEntity<String> resp = restClient().getForEntity(url).block();
74         assertThat(resp.getStatusCode()).isEqualTo(HttpStatus.OK);
75         JsonElement jsonElement = JsonParser.parseString(resp.getBody());
76         String indented = gson.toJson(jsonElement);
77         try (PrintStream out = new PrintStream(new FileOutputStream("../docs/api.json"))) {
78             out.println(indented);
79         }
80     }
81
82     @Test
83     void getJobs() throws FileNotFoundException {
84         String url = "/api/enrichment/eijobs";
85         ResponseEntity<String> resp = restClient().getForEntity(url).block();
86         assertThat(resp.getStatusCode()).isEqualTo(HttpStatus.OK);
87
88         JsonArray jobs = JsonParser.parseString(resp.getBody()).getAsJsonArray();
89         JobInfo wantedJobInfo = JobInfo.builder() //
90             .id("job1") //
91             .typeId("type1") //
92             .jobData(getStringFromFile("job-1.json")) //
93             .targetUri("http://example.com/") //
94             .owner("owner") //
95             .build();
96         assertThat(jobs).hasSize(1) //
97             .contains(gson.toJsonTree(wantedJobInfo));
98     }
99
100     @Test
101     void getProducers() {
102         String url = "/api/enrichment/eiproducers";
103         ResponseEntity<String> resp = restClient().getForEntity(url).block();
104         assertThat(resp.getStatusCode()).isEqualTo(HttpStatus.OK);
105
106         JsonArray producers = JsonParser.parseString(resp.getBody()).getAsJsonArray();
107
108         ProducerInfo wantedProducerInfo = ProducerInfo.builder() //
109             .id("prod-1") //
110             .types(new String[] {"type1", "type2"}) //
111             .status("ENABLED") //
112             .build();
113         assertThat(producers).hasSize(1) //
114             .contains(gson.toJsonTree(wantedProducerInfo));
115     }
116
117     private AsyncRestClient restClient() {
118         return new AsyncRestClient(baseUrl());
119     }
120
121     private String baseUrl() {
122         return "https://localhost:" + this.port;
123     }
124
125     private String getStringFromFile(String path) {
126         try {
127             InputStream inputStream = MethodHandles.lookup().lookupClass().getClassLoader().getResourceAsStream(path);
128             return new BufferedReader(new InputStreamReader(inputStream)).lines().collect(Collectors.joining("\n"));
129         } catch (Exception e) {
130             logger.error("Cannot read file :" + path, e);
131             return "";
132         }
133     }
134 }