diff options
author | Ramya Ravichandran <ramya.ravichandran5@wipro.com> | 2019-02-15 16:26:45 +0530 |
---|---|---|
committer | Ramya Ravichandran <ramya.ravichandran5@wipro.com> | 2019-02-15 16:28:41 +0530 |
commit | 43467ecc6a1624b7fd695883c5c6c214782f6bcd (patch) | |
tree | 13d9bc07475d63fb1e29e44b7e82b33c54df09e7 /src/main/java/com/wipro/www/sonhms/utils/HttpRequester.java | |
parent | 8b5b35c5a7dfe7213e0d1ef824fc7ae5b6c82758 (diff) |
Son-handler microservice seed code
Change-Id: If4000e26044fe267bdd5fae3a1b2599182423950
Issue-ID: DCAEGEN2-1219
Signed-off-by: Ramya Ravichandran<ramya.ravichandran5@wipro.com>
Diffstat (limited to 'src/main/java/com/wipro/www/sonhms/utils/HttpRequester.java')
-rw-r--r-- | src/main/java/com/wipro/www/sonhms/utils/HttpRequester.java | 284 |
1 files changed, 284 insertions, 0 deletions
diff --git a/src/main/java/com/wipro/www/sonhms/utils/HttpRequester.java b/src/main/java/com/wipro/www/sonhms/utils/HttpRequester.java new file mode 100644 index 0000000..4e4e411 --- /dev/null +++ b/src/main/java/com/wipro/www/sonhms/utils/HttpRequester.java @@ -0,0 +1,284 @@ +/******************************************************************************* + * ============LICENSE_START======================================================= + * pcims + * ================================================================================ + * Copyright (C) 2018 Wipro Limited. + * ============================================================================== + * 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 com.wipro.www.sonhms.utils; + +import java.io.BufferedReader; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.OutputStreamWriter; +import java.net.HttpURLConnection; +import java.net.URL; + +import javax.net.ssl.HostnameVerifier; +import javax.net.ssl.HttpsURLConnection; +import javax.net.ssl.SSLSession; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class HttpRequester { + + private static final String ACCEPT = "Accept"; + private static final String JSON = "application/json"; + private static final String CONTENT = "Content-Type"; + private static final String UTF = "UTF-8"; + private static final String FAILMSG = "Post failed"; + private static final String AUTH = "Authorization"; + private static Logger log = LoggerFactory.getLogger(HttpRequester.class); + + public static class MyHostnameVerifier implements HostnameVerifier { + + @Override + public boolean verify(String hostname, SSLSession session) { + // verification of hostname is switched off + log.debug("Hostname: {}", hostname); + return true; + } + } + + /** + * Send Post Request. + */ + public static String sendPostRequest(String requestUrl, String requestBody) { + String response = ""; + + try { + URL url = new URL(requestUrl); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setDoOutput(true); + connection.setDoInput(true); + connection.setRequestMethod("POST"); + connection.setRequestProperty(ACCEPT, JSON); + connection.setRequestProperty(CONTENT, JSON); + OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream(), UTF); + writer.write(requestBody); + writer.close(); + BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream())); + String temp; + int responseCode = connection.getResponseCode(); + log.debug("response code: {}", responseCode); + response = br.readLine(); + while ((temp = br.readLine()) != null) { + response = response.concat(temp); + } + br.close(); + connection.disconnect(); + + if (response == null) { + response = String.valueOf(responseCode); + } + + } catch (Exception e) { + response = FAILMSG; + } + + return response; + } + + /** + * Send Post Request to policy. + */ + public static String sendPostToPolicy(String requestUrl, String requestBody) { + String response = ""; + log.debug("inside post to policy"); + + try { + URL url = new URL(requestUrl); + + HttpsURLConnection connection = (HttpsURLConnection) url.openConnection(); + connection.setHostnameVerifier(new MyHostnameVerifier()); + connection.setDoOutput(true); + connection.setDoInput(true); + connection.setRequestMethod("POST"); + connection.setRequestProperty(ACCEPT, JSON); + connection.setRequestProperty(CONTENT, JSON); + connection.setRequestProperty("ClientAuth", "cHl0aG9uOnRlc3Q="); + connection.setRequestProperty("Environment", "TEST"); + connection.setRequestProperty(AUTH, "Basic dGVzdHBkcDphbHBoYTEyMw=="); + OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream(), UTF); + writer.write(requestBody); + writer.close(); + BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream())); + String temp; + int responseCode = connection.getResponseCode(); + log.debug("response code: {}", responseCode); + response = br.readLine(); + while ((temp = br.readLine()) != null) { + response = response.concat(temp); + } + br.close(); + connection.disconnect(); + + } catch (Exception e) { + log.debug("Exception during post to policy: {}", e); + response = FAILMSG; + } + + return response; + } + + /** + * Send Get Request. + */ + public static String sendGetRequest(String requestUrl) { + String response = ""; + int returnCode = 0; + + try { + URL url = new URL(requestUrl); + HttpURLConnection connection = null; + connection = (HttpURLConnection) url.openConnection(); + connection.setDoInput(true); + connection.setRequestMethod("GET"); + connection.setRequestProperty(ACCEPT, JSON); + returnCode = connection.getResponseCode(); + InputStream connectionIn = null; + if (returnCode == 200) { + connectionIn = connection.getInputStream(); + BufferedReader buffer = new BufferedReader(new InputStreamReader(connectionIn)); + String inputLine; + while ((inputLine = buffer.readLine()) != null) { + response = response.concat(inputLine); + } + buffer.close(); + } + + else { + response = ""; + log.debug("return code: {}", returnCode); + } + } catch (Exception e) { + log.debug("Get failed,Exception : {}", e); + response = ""; + } + return response; + + } + + /** + * Send Get Request to SDNR. + */ + public String sendGetRequest(String requestUrl, String requestBody) { + String response; + try { + URL url = new URL(requestUrl); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setDoOutput(true); + connection.setDoInput(true); + connection.setRequestMethod("POST"); + connection.setRequestProperty(ACCEPT, "text/plain"); + connection.setRequestProperty(CONTENT, JSON); + connection.setRequestProperty(AUTH, "Basic SW5mcmFQb3J0YWxDbGllbnQ6cGFzc3dvcmQxJA=="); + OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream(), UTF); + writer.write(requestBody); + writer.close(); + BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream())); + String temp; + response = br.readLine(); + while ((temp = br.readLine()) != null) { + response = response.concat(temp); + } + br.close(); + connection.disconnect(); + + } catch (Exception e) { + response = FAILMSG; + } + + return response; + } + + /** + * Send Post Request. + */ + public String sendPostRequest1(String requestUrl, String requestBody) { + String response; + try { + URL url = new URL(requestUrl); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setDoOutput(true); + connection.setDoInput(true); + connection.setRequestMethod("POST"); + connection.setRequestProperty(ACCEPT, JSON); + connection.setRequestProperty(CONTENT, JSON); + connection.setRequestProperty(AUTH, "Basic SW5mcmFQb3J0YWxDbGllbnQ6cGFzc3dvcmQxJA=="); + connection.setRequestProperty("Content-Length", "" + requestBody.length()); + OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream(), UTF); + writer.write(requestBody); + writer.close(); + BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream())); + String temp; + response = br.readLine(); + while ((temp = br.readLine()) != null) { + response = response.concat(temp); + } + br.close(); + connection.disconnect(); + + } catch (Exception e) { + response = FAILMSG; + } + + return response; + } + + /** + * Send Post Request to oof. + */ + public static String sendPostRequestToOof(String requestUrl, String requestBody) { + String response = ""; + + try { + URL url = new URL(requestUrl); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setDoOutput(true); + connection.setDoInput(true); + connection.setRequestMethod("POST"); + connection.setRequestProperty(ACCEPT, JSON); + connection.setRequestProperty(CONTENT, JSON); + connection.setRequestProperty(AUTH, "Basic cGNpX3Rlc3Q6cGNpX3Rlc3Rwd2Q="); + OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream(), UTF); + writer.write(requestBody); + writer.close(); + BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream())); + String temp; + int responseCode = connection.getResponseCode(); + log.debug("response code: {}", responseCode); + response = br.readLine(); + while ((temp = br.readLine()) != null) { + response = response.concat(temp); + } + br.close(); + connection.disconnect(); + + if (response == null) { + log.debug("Response code: {}", responseCode); + } + + } catch (Exception e) { + log.debug("exception occured when posting: {}", e); + return null; + } + + return response; + } + +} |