diff options
Diffstat (limited to 'src/main/java/com/wipro/www/sonhms/utils')
3 files changed, 374 insertions, 0 deletions
diff --git a/src/main/java/com/wipro/www/sonhms/utils/BeanUtil.java b/src/main/java/com/wipro/www/sonhms/utils/BeanUtil.java new file mode 100644 index 0000000..9d7cdb3 --- /dev/null +++ b/src/main/java/com/wipro/www/sonhms/utils/BeanUtil.java @@ -0,0 +1,40 @@ +/******************************************************************************* + * ============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 org.springframework.beans.BeansException; +import org.springframework.context.ApplicationContext; +import org.springframework.context.ApplicationContextAware; +import org.springframework.stereotype.Service; + +@Service +public class BeanUtil implements ApplicationContextAware { + private static ApplicationContext context; + + @Override + public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { + context = applicationContext; + } + + public static <T> T getBean(Class<T> beanClass) { + return context.getBean(beanClass); + } +} diff --git a/src/main/java/com/wipro/www/sonhms/utils/FileIo.java b/src/main/java/com/wipro/www/sonhms/utils/FileIo.java new file mode 100644 index 0000000..929ae95 --- /dev/null +++ b/src/main/java/com/wipro/www/sonhms/utils/FileIo.java @@ -0,0 +1,50 @@ +/******************************************************************************* + * ============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.FileReader; + +public class FileIo { + + private FileIo() { + + } + + /** + * Reads from File. + */ + public static String readFromFile(String file) { + String content = ""; + try (BufferedReader bufferedReader = new BufferedReader(new FileReader(file))) { + content = bufferedReader.readLine(); + String temp; + while ((temp = bufferedReader.readLine()) != null) { + content = content.concat(temp); + } + content = content.trim(); + } catch (Exception e) { + content = null; + } + return content; + } + +} 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; + } + +} |