diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java index 2232f07..b304982 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/util/SendMail.java @@ -54,9 +54,8 @@ public class SendMail { retrieveSocialService(); String postBody = createPostBody(subject, body); - String requestForMessage = getRequestMessage(WRITE_MESSAGE_ADDRESS_PATH); - - sendPostRequest(requestForMessage, postBody); + + sendPostRequest(postBody); ***REMOVED*** @@ -83,7 +82,7 @@ public class SendMail { ***REMOVED*** data.put("recipients", recipients); - logger.info("Post Body: " + data); + logger.debug("Post Body: " + data); return data.toString(); ***REMOVED*** catch (EMailException e) { @@ -118,17 +117,6 @@ public class SendMail { ***REMOVED*** - private String getRequestMessage(String addressPath) { - StringBuilder requestMessageBuilder = new StringBuilder(socialServiceAddress); - - if (!socialServiceAddress.endsWith("/")) - requestMessageBuilder.append('/'); - - requestMessageBuilder.append(addressPath).append(SecurityTokenProvider.instance.get()); - String requestForMessage = requestMessageBuilder.toString(); - logger.debug("Request " + requestForMessage); - return requestForMessage; -***REMOVED*** private String username(String token) throws ObjectNotFound, Exception { AuthorizationEntry entry = authorizationService().get(token); @@ -136,10 +124,20 @@ public class SendMail { return entry.getClientInfo().getId(); ***REMOVED*** - private void sendPostRequest(String endpoint, String postBody) throws EMailException { - logger.info("Execute Post:" + endpoint); - logger.info("Post Body:" + postBody); + private void sendPostRequest(String postBody) throws EMailException { + try { + logger.info("Execute Post Body:" + postBody); + + StringBuilder requestMessageBuilder = new StringBuilder(socialServiceAddress); + + if (!socialServiceAddress.endsWith("/")) + requestMessageBuilder.append('/'); + + requestMessageBuilder.append(WRITE_MESSAGE_ADDRESS_PATH); + logger.info("Execute Post Request: " + requestMessageBuilder.toString()); + requestMessageBuilder.append(SecurityTokenProvider.instance.get()); + String endpoint = requestMessageBuilder.toString(); ***REMOVED*** Send the request URL url = new URL(endpoint); @@ -193,7 +191,7 @@ public class SendMail { if (!success) { String message = res.getString("message"); logger.error("Error in send email notification: " + message); - throw new EMailException("Error in send email notification: "+message); + throw new EMailException("Error in send email notification: " + message); ***REMOVED*** ***REMOVED*** catch (JSONException e) { @@ -238,9 +236,16 @@ public class SendMail { ***REMOVED*** Try to retrieve a url like this: ***REMOVED*** https:***REMOVED***api.d4science.org/social-networking-library-ws/rest/2/users/get-usernames-by-role?role-name=DataMiner-Manager&gcube-token=xxx-xxxx-xxxx-xxx - String requestAdminsUrl = getRequestMessage(USER_ROLES_ADDRESS_PATH); + StringBuilder requestMessageBuilder = new StringBuilder(socialServiceAddress); - logger.info("Request Admins Url: " + requestAdminsUrl); + if (!socialServiceAddress.endsWith("/")) + requestMessageBuilder.append('/'); + + requestMessageBuilder.append(USER_ROLES_ADDRESS_PATH); + logger.info("Request Admins Url: " + requestMessageBuilder.toString()); + requestMessageBuilder.append(SecurityTokenProvider.instance.get()); + + String requestAdminsUrl = requestMessageBuilder.toString(); CloseableHttpClient client = HttpClientBuilder.create().build(); HttpGet getReq = new HttpGet(requestAdminsUrl);