1 files changed, 169 insertions, 0 deletions
diff --git a/CdtProxyService/src/main/java/org/onap/appc/cdt/service/controller/CdtController.java b/CdtProxyService/src/main/java/org/onap/appc/cdt/service/controller/CdtController.java
new file mode 100644
index 0000000..78a94f6
--- /dev/null
+++ b/CdtProxyService/src/main/java/org/onap/appc/cdt/service/controller/CdtController.java
@@ -0,0 +1,169 @@
+/*
+============LICENSE_START==========================================
+===================================================================
+Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+===================================================================
+
+Unless otherwise specified, all software contained herein is licensed
+under the Apache License, Version 2.0 (the License);
+you may not use this software 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.appc.cdt.service.controller;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiResponse;
+import io.swagger.annotations.ApiResponses;
+import org.apache.http.client.HttpClient;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.client.ClientHttpRequestFactory;
+import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.client.RestTemplate;
+
+import java.net.UnknownHostException;
+import java.util.Base64;
+
+/**
+ * Created by Amaresh Kumar on 09/May/2018.
+ */
+
+@RestController
+@RequestMapping("/cdtService")
+@CrossOrigin(origins = "*", allowedHeaders = "*")
+@Api(value = "cdtService", description = "Backend service to eliminate CORS issue for CDT Tool")
+public class CdtController {
+
+    private static final Logger logger = LoggerFactory.getLogger(CdtController.class);
+    private RestTemplate restTemplate = new RestTemplate();
+    private String urlAddress;
+
+    @Value("${restConf.backend.hostname}")
+    private String restConfHostname;
+
+    @Value("${restConf.backend.port}")
+    private String restConfPort;
+
+    @Value("${restConf.username}")
+    private String restConfUsername;
+
+    @Value("${restConf.password}")
+    private String restConfPassword;
+
+    @ApiOperation(value = "Return All Test Data for a given user", response = CdtController.class)
+    @ApiResponses(value = {
+            @ApiResponse(code = 200, message = "OK"),
+            @ApiResponse(code = 404, message = "The resource not found")
+    })
+    @RequestMapping(value = "", method = RequestMethod.GET)
+    @CrossOrigin(origins = "*", allowedHeaders = "*")
+    public String DefaultEndpoint()  {
+        return  "CDT Proxy Service is up and running.";
+
+    }
+
+    @ApiOperation(value = "Return All Test Data for a given user", response = CdtController.class)
+    @ApiResponses(value = {
+            @ApiResponse(code = 200, message = "OK"),
+            @ApiResponse(code = 404, message = "The resource not found")
+    })
+    @RequestMapping(value = "/getDesigns", method = RequestMethod.POST)
+    @CrossOrigin(origins = "*", allowedHeaders = "*")
+    public String getDesigns(@RequestBody String getDesignsRequest) throws UnknownHostException {
+        HttpEntity<String> entity = getStringHttpEntity(getDesignsRequest);
+        HttpClient httpClient = HttpClientBuilder.create().build();
+        ClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient);
+        restTemplate.setRequestFactory(factory);
+        String getDesignsResponse = restTemplate.postForObject(getUrl("getDesigns"), entity, String.class);
+        return getDesignsResponse;
+    }
+
+    @ApiOperation(value = "Test VNF", response = CdtController.class)
+    @ApiResponses(value = {
+            @ApiResponse(code = 200, message = "OK"),
+            @ApiResponse(code = 404, message = "The resource not found")
+    })
+    @RequestMapping(value = "/testVnf", method = RequestMethod.POST)
+    @CrossOrigin(origins = "*", allowedHeaders = "*")
+    public String testVnf(@RequestParam String urlAction, @RequestBody String testVnf) throws UnknownHostException {
+        HttpEntity<String> entity = getStringHttpEntity(testVnf);
+        String testVnfResponse = restTemplate.postForObject(getUrl("testVnf")+urlAction, entity, String.class);
+        return testVnfResponse;
+    }
+
+    @ApiOperation(value = "Check status of submitted Test", response = CdtController.class)
+    @ApiResponses(value = {
+            @ApiResponse(code = 200, message = "OK"),
+            @ApiResponse(code = 404, message = "The resource not found")
+    })
+    @RequestMapping(value = "/checkTestStatus", method = RequestMethod.POST)
+    @CrossOrigin(origins = "*", allowedHeaders = "*")
+    public String checkTestStatus(@RequestBody String checkTestStatusRequest) throws UnknownHostException {
+        HttpEntity<String> entity = getStringHttpEntity(checkTestStatusRequest);
+        String checkTestStatusResponse = restTemplate.postForObject(getUrl("checkTestStatus"), entity, String.class);
+        return checkTestStatusResponse;
+    }
+
+    @ApiOperation(value = "Validate a template which is being uploaded", response = CdtController.class)
+    @ApiResponses(value = {
+            @ApiResponse(code = 200, message = "OK"),
+            @ApiResponse(code = 404, message = "The resource not found")
+    })
+    @RequestMapping(value = "/validateTemplate", method = RequestMethod.POST)
+    @CrossOrigin(origins = "*", allowedHeaders = "*")
+    public String validateTemplate(@RequestBody String validateTemplateRequest) throws UnknownHostException {
+        HttpEntity<String> entity = getStringHttpEntity(validateTemplateRequest);
+        String validateTemplateResponse = restTemplate.postForObject(getUrl("validateTemplate"), entity, String.class);
+        return validateTemplateResponse;
+    }
+
+    private HttpEntity<String> getStringHttpEntity(@RequestBody String getDesignsRequest) {
+        HttpHeaders headers = new HttpHeaders();
+        headers.setAccessControlAllowCredentials(true);
+        headers.setContentType(MediaType.APPLICATION_JSON);
+        String planCredentials = restConfUsername + ":" + restConfPassword;
+        String base64Credentails = Base64.getEncoder().encodeToString(planCredentials.getBytes());
+        headers.set("Authorization", "Basic " + base64Credentails);
+        return new HttpEntity<String>(getDesignsRequest, headers);
+    }
+
+    private String getUrl(String ApiName) throws UnknownHostException {
+
+        switch (ApiName) {
+            case "getDesigns":
+                urlAddress = "http://" + restConfHostname + ":" + restConfPort + "/restconf/operations/design-services:dbservice";
+                break;
+            case "testVnf":
+                urlAddress = "http://" + restConfHostname + ":" + restConfPort + "/restconf/operations/appc-provider-lcm:";
+                break;
+            case "checkTestStatus":
+                urlAddress = "http://" + restConfHostname + ":" + restConfPort + "/restconf/operations/appc-provider-lcm:action-status";
+                break;
+            case "validateTemplate":
+                urlAddress = "http://" + restConfHostname + ":" + restConfPort + "/restconf/operations/design-services:validator";
+                break;
+            default:
+                logger.error("URI not resolved because Api call not supported ");
+        }
+        logger.info("Calling Endpoint..... " + urlAddress);
+        return urlAddress;
+    }
+}