7067bbeefb571b2e7540e2277ac50045d1986273
[ccsdk/features.git] /
1 /*
2  * ============LICENSE_START=======================================================
3  * ONAP : CCSDK.apps.sdnr.wt.apigateway
4  * ================================================================================
5  * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property.
6  * All rights reserved.
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
11  *
12  *      http://www.apache.org/licenses/LICENSE-2.0
13  *
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=========================================================
20  */
21 package org.onap.ccsdk.features.sdnr.wt.apigateway.test;
22
23 import org.junit.After;
24 import org.junit.Before;
25 import org.junit.Test;
26 import org.onap.ccsdk.features.sdnr.wt.apigateway.MyProperties;
27 import org.onap.ccsdk.features.sdnr.wt.apigateway.test.helper.HelpEsServlet;
28 import org.onap.ccsdk.features.sdnr.wt.apigateway.test.helper.HelpServletBase;
29 import java.io.*;
30 import javax.servlet.ServletException;
31
32 public class TestDatabaseServlet extends HelpServletBase {
33
34     private static final int PORT = 40002;
35
36     public TestDatabaseServlet() {
37         super("/database", PORT);
38     }
39
40     final String LR = "\n";
41
42     @Test
43     public void test() throws ServletException, IOException {
44
45         String tmpFilename = "tmp1.cfg";
46         File tmpFile = new File(tmpFilename);
47         if (tmpFile.exists())
48             tmpFile.delete();
49         MyProperties properties = MyProperties.Instantiate(tmpFile, true);
50         String query = "{\"query\":{\"match_all\":{}}}";
51         String tmpconfigcontent =
52                 "aai=off" + LR + "aaiHeaders=[]" + LR + "database=off" + LR + "insecure=0" + LR + "cors=0";
53         String tmpconfigcontent2 = "aai=off" + LR + "aaiHeaders=[]" + LR + "database=http://" + HOST + ":" + PORT + LR
54                 + "insecure=1" + LR + "cors=1";
55         this.setServlet(new HelpEsServlet());
56         // test diabled message
57         properties.load(new ByteArrayInputStream(tmpconfigcontent.getBytes()));
58         String expectedResponse = "offline";
59         testrequest(HTTPMETHOD_GET, query, expectedResponse, false);
60         testrequest(HTTPMETHOD_POST, query, expectedResponse, false);
61         testrequest(HTTPMETHOD_PUT, query, expectedResponse, false);
62         testrequest(HTTPMETHOD_DELETE, query, expectedResponse, false);
63
64         // initEsTestWebserver(port);
65         properties.load(new ByteArrayInputStream(tmpconfigcontent2.getBytes()));
66         testrequest(HTTPMETHOD_GET, query, RESPONSE_GET, true);
67         testrequest(HTTPMETHOD_POST, query, RESPONSE_POST, true);
68         testrequest(HTTPMETHOD_PUT, query, RESPONSE_PUT, true);
69         testrequest(HTTPMETHOD_DELETE, query, RESPONSE_DELETE, true);
70         testrequest(HTTPMETHOD_OPTIONS, query, "", false);
71         // stopTestWebserver();
72
73
74         if (tmpFile.exists())
75             tmpFile.delete();
76
77
78     }
79
80     @Before
81     public void init() throws IOException {
82         HelpServletBase.initEsTestWebserver(PORT);
83     }
84
85     @After
86     public void deinit() {
87         HelpServletBase.stopTestWebserver();
88     }
89 }