|
|
|
@ -8,12 +8,10 @@ import java.io.BufferedReader;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
import java.io.InputStreamReader;
|
|
|
|
|
import java.io.OutputStreamWriter;
|
|
|
|
|
import java.io.UnsupportedEncodingException;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|
import java.net.URLConnection;
|
|
|
|
|
import java.net.URLEncoder;
|
|
|
|
|
import java.util.LinkedList;
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
import org.apache.http.client.methods.HttpGet;
|
|
|
|
@ -24,140 +22,134 @@ import org.apache.http.util.EntityUtils;
|
|
|
|
|
import org.gcube.common.authorization.library.AuthorizationEntry;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
import org.gcube.common.resources.gcore.GCoreEndpoint;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.clients.configuration.DMPMClientConfiguratorManager;
|
|
|
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.util.exception.EMailException;
|
|
|
|
|
import org.gcube.resources.discovery.client.api.DiscoveryClient;
|
|
|
|
|
import org.gcube.resources.discovery.client.queries.api.SimpleQuery;
|
|
|
|
|
import org.json.JSONArray;
|
|
|
|
|
import org.json.JSONException;
|
|
|
|
|
import org.json.JSONObject;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public class SendMail ***REMOVED***
|
|
|
|
|
|
|
|
|
|
private Logger logger;
|
|
|
|
|
private final String WRITE_MESSAGE_ADDRESS_PATH ="messages/writeMessageToUsers?gcube-token=",
|
|
|
|
|
private Logger logger = LoggerFactory.getLogger(SendMail.class);
|
|
|
|
|
private final String WRITE_MESSAGE_ADDRESS_PATH = "2/messages/write-message?gcube-token=",
|
|
|
|
|
USER_ROLES_ADDRESS_PATH = "2/users/get-usernames-by-role?role-name=DataMiner-Manager&gcube-token=",
|
|
|
|
|
ENCODING = "UTF-8",
|
|
|
|
|
SENDER_PARAMETER_FORMAT = "&sender=dataminer&recipients=%s&subject=%s&body=%s",
|
|
|
|
|
SOCIAL_SERVICE_QUERY_CONDITION = "$resource/Profile/ServiceName/text() eq 'SocialNetworking'",
|
|
|
|
|
SOCIAL_SERVICE_URI="jersey-servlet",
|
|
|
|
|
JSON_MIME_TYPE = "application/json";
|
|
|
|
|
SOCIAL_SERVICE_URI = "jersey-servlet", JSON_MIME_TYPE = "application/json";
|
|
|
|
|
|
|
|
|
|
private String socialServiceAddress;
|
|
|
|
|
|
|
|
|
|
public SendMail() ***REMOVED***
|
|
|
|
|
this.logger = LoggerFactory.getLogger(SendMail.class);
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
private String getRequestMessage (String addressPath)
|
|
|
|
|
***REMOVED***
|
|
|
|
|
String serviceAddress = this.getSocialService();
|
|
|
|
|
StringBuilder requestMessageBuilder = new StringBuilder(serviceAddress);
|
|
|
|
|
public void sendNotification(String subject, String body) throws EMailException ***REMOVED***
|
|
|
|
|
logger.debug("SendNotification");
|
|
|
|
|
logger.debug("Notification Subject: " + subject);
|
|
|
|
|
logger.debug("Notification Body: " + body);
|
|
|
|
|
|
|
|
|
|
if (!serviceAddress.endsWith("/")) requestMessageBuilder.append('/');
|
|
|
|
|
|
|
|
|
|
requestMessageBuilder.append(addressPath).append(SecurityTokenProvider.instance.get());
|
|
|
|
|
String requestForMessage = requestMessageBuilder.toString();
|
|
|
|
|
this.logger.debug("Request "+requestForMessage);
|
|
|
|
|
return requestForMessage;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
public void sendNotification(String subject, String body) throws EMailException
|
|
|
|
|
***REMOVED***
|
|
|
|
|
this.logger.debug("Sending mail notification for "+subject);
|
|
|
|
|
this.logger.debug("Body "+body);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
***REMOVED***AnalysisLogger.getLogger().debug("Emailing System->Request url is going to be " + requestForMessage);
|
|
|
|
|
|
|
|
|
|
***REMOVED*** put the sender, the recipients, subject and body of the mail here
|
|
|
|
|
|
|
|
|
|
try
|
|
|
|
|
***REMOVED***
|
|
|
|
|
subject = URLEncoder.encode(subject, ENCODING);
|
|
|
|
|
body = URLEncoder.encode(body, ENCODING);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
catch (UnsupportedEncodingException e)
|
|
|
|
|
***REMOVED***
|
|
|
|
|
throw new EMailException(e);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
retrieveSocialService();
|
|
|
|
|
|
|
|
|
|
String postBody = createPostBody(subject, body);
|
|
|
|
|
String requestForMessage = getRequestMessage(WRITE_MESSAGE_ADDRESS_PATH);
|
|
|
|
|
requestForMessage = requestForMessage.replace("http:***REMOVED***", "https:***REMOVED***").replace(":80", "");
|
|
|
|
|
|
|
|
|
|
String requestParameters = String.format(SENDER_PARAMETER_FORMAT, this.getAdmins(), subject , body);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
String response = this.sendPostRequest(requestForMessage, requestParameters);
|
|
|
|
|
***REMOVED***AnalysisLogger.getLogger().debug("Emailing System->Emailing response OK ");
|
|
|
|
|
|
|
|
|
|
if (response == null) throw new EMailException();
|
|
|
|
|
sendPostRequest(requestForMessage, postBody);
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED*** public void notifySubmitter(String a, String b) throws Exception ***REMOVED***
|
|
|
|
|
***REMOVED*** NotificationHelper nh = new NotificationHelper();
|
|
|
|
|
***REMOVED*** super.sendNotification(nh.getSubject(),
|
|
|
|
|
***REMOVED*** nh.getBody());
|
|
|
|
|
***REMOVED*** ***REMOVED***
|
|
|
|
|
|
|
|
|
|
public String username(String token) throws ObjectNotFound, Exception ***REMOVED***
|
|
|
|
|
AuthorizationEntry entry = authorizationService().get(token);
|
|
|
|
|
this.logger.debug(entry.getClientInfo().getId());
|
|
|
|
|
return entry.getClientInfo().getId();
|
|
|
|
|
private String createPostBody(String subject, String body) throws EMailException ***REMOVED***
|
|
|
|
|
try ***REMOVED***
|
|
|
|
|
List<String> recipientsList = getRecipients();
|
|
|
|
|
if (recipientsList == null || recipientsList.isEmpty()) ***REMOVED***
|
|
|
|
|
logger.error("Invalid recipient list: " + recipientsList);
|
|
|
|
|
throw new EMailException("Unable to send email notification. Invalid recipient list:" + recipientsList);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED*** public String retrieveAdminRole() throws Exception ***REMOVED***
|
|
|
|
|
***REMOVED*** String serviceAddress = InfraRetrieval.findEmailingSystemAddress(ScopeProvider.instance.get());
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** if (!serviceAddress.endsWith("/"))
|
|
|
|
|
***REMOVED*** serviceAddress = serviceAddress + "/";
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** String requestForMessage = serviceAddress + "2/users/get-usernames-by-global-role";
|
|
|
|
|
***REMOVED*** requestForMessage = requestForMessage.replace("https:***REMOVED***", "http:***REMOVED***").replace(":80", "");
|
|
|
|
|
***REMOVED*** String requestParameters = "&role-name=Administrator" + "&gcube-token=" + SecurityTokenProvider.instance.get();
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** String response = HttpRequest.sendGetRequest(requestForMessage, requestParameters);
|
|
|
|
|
***REMOVED*** System.out.println(response.toString());
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** if (response == null) ***REMOVED***
|
|
|
|
|
***REMOVED*** Exception e = new Exception("Error in querying the recipient");
|
|
|
|
|
***REMOVED*** throw e;
|
|
|
|
|
***REMOVED*** ***REMOVED***
|
|
|
|
|
***REMOVED*** return response;
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED******REMOVED***
|
|
|
|
|
***REMOVED*** ***REMOVED***"subject": "subject-content", "body": "body-content",
|
|
|
|
|
***REMOVED*** "recipients":[***REMOVED***"id":"userid"***REMOVED***]***REMOVED***
|
|
|
|
|
|
|
|
|
|
public String getSocialService() ***REMOVED***
|
|
|
|
|
JSONObject data = new JSONObject();
|
|
|
|
|
data.put("subject", subject);
|
|
|
|
|
data.put("body", body);
|
|
|
|
|
|
|
|
|
|
JSONArray recipients = new JSONArray();
|
|
|
|
|
for (String recipient : recipientsList) ***REMOVED***
|
|
|
|
|
JSONObject d = new JSONObject();
|
|
|
|
|
d.put("id", recipient);
|
|
|
|
|
recipients.put(d);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
data.put("recipients", recipients);
|
|
|
|
|
|
|
|
|
|
logger.info("Post Body: " + data);
|
|
|
|
|
return data.toString();
|
|
|
|
|
|
|
|
|
|
***REMOVED*** catch (EMailException e) ***REMOVED***
|
|
|
|
|
throw e;
|
|
|
|
|
***REMOVED*** catch (Throwable e) ***REMOVED***
|
|
|
|
|
logger.error("Error creating the notification body: " + e.getLocalizedMessage(), e);
|
|
|
|
|
throw new EMailException(e);
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
private void retrieveSocialService() throws EMailException ***REMOVED***
|
|
|
|
|
try ***REMOVED***
|
|
|
|
|
SimpleQuery query = queryFor(GCoreEndpoint.class);
|
|
|
|
|
query.addCondition(SOCIAL_SERVICE_QUERY_CONDITION);
|
|
|
|
|
DiscoveryClient<GCoreEndpoint> client = clientFor(GCoreEndpoint.class);
|
|
|
|
|
List<GCoreEndpoint> resources = client.submit(query);
|
|
|
|
|
String a = resources.get(0).profile().endpointMap().get(SOCIAL_SERVICE_URI).uri().toString();
|
|
|
|
|
return a;
|
|
|
|
|
socialServiceAddress = resources.get(0).profile().endpointMap().get(SOCIAL_SERVICE_URI).uri().toString();
|
|
|
|
|
logger.info("Retrieved Social Service Address: " + socialServiceAddress);
|
|
|
|
|
if (socialServiceAddress == null || socialServiceAddress.isEmpty()) ***REMOVED***
|
|
|
|
|
throw new EMailException(
|
|
|
|
|
"Unable to send email notification. Invalid address in GCoreEndpoint resource on IS.");
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** catch (EMailException e) ***REMOVED***
|
|
|
|
|
logger.error(e.getLocalizedMessage(), e);
|
|
|
|
|
throw e;
|
|
|
|
|
***REMOVED*** catch (Throwable e) ***REMOVED***
|
|
|
|
|
logger.error(e.getLocalizedMessage(), e);
|
|
|
|
|
throw new EMailException(e);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
private String getRequestMessage(String addressPath) ***REMOVED***
|
|
|
|
|
StringBuilder requestMessageBuilder = new StringBuilder(socialServiceAddress);
|
|
|
|
|
|
|
|
|
|
public String sendPostRequest(String endpoint, String requestParameters) ***REMOVED***
|
|
|
|
|
if (!socialServiceAddress.endsWith("/"))
|
|
|
|
|
requestMessageBuilder.append('/');
|
|
|
|
|
|
|
|
|
|
this.logger.debug("Sending post request");
|
|
|
|
|
***REMOVED*** Build parameter string
|
|
|
|
|
String data = requestParameters;
|
|
|
|
|
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 ***REMOVED***
|
|
|
|
|
AuthorizationEntry entry = authorizationService().get(token);
|
|
|
|
|
logger.debug(entry.getClientInfo().getId());
|
|
|
|
|
return entry.getClientInfo().getId();
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
private void sendPostRequest(String endpoint, String postBody) throws EMailException ***REMOVED***
|
|
|
|
|
logger.info("Execute Post:" + endpoint);
|
|
|
|
|
logger.info("Post Body:" + postBody);
|
|
|
|
|
try ***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED*** Send the request
|
|
|
|
|
URL url = new URL(endpoint);
|
|
|
|
|
URLConnection conn = url.openConnection();
|
|
|
|
|
|
|
|
|
|
conn.setRequestProperty("Accept", JSON_MIME_TYPE);
|
|
|
|
|
conn.setRequestProperty("Content-Type", JSON_MIME_TYPE);
|
|
|
|
|
conn.setDoOutput(true);
|
|
|
|
|
OutputStreamWriter writer = new OutputStreamWriter(conn.getOutputStream());
|
|
|
|
|
|
|
|
|
|
***REMOVED*** write parameters
|
|
|
|
|
writer.write(data);
|
|
|
|
|
OutputStreamWriter writer = new OutputStreamWriter(conn.getOutputStream());
|
|
|
|
|
writer.write(postBody);
|
|
|
|
|
writer.flush();
|
|
|
|
|
|
|
|
|
|
***REMOVED*** Get the response
|
|
|
|
@ -170,125 +162,94 @@ public class SendMail ***REMOVED***
|
|
|
|
|
writer.close();
|
|
|
|
|
reader.close();
|
|
|
|
|
|
|
|
|
|
this.logger.debug("Operation completed");
|
|
|
|
|
logger.debug("Operation completed");
|
|
|
|
|
String response = answer.toString();
|
|
|
|
|
this.logger.debug("Response "+response);
|
|
|
|
|
***REMOVED*** Output the response
|
|
|
|
|
return response;
|
|
|
|
|
logger.info("Notification Response: " + response);
|
|
|
|
|
checkResponse(response);
|
|
|
|
|
|
|
|
|
|
***REMOVED*** catch (MalformedURLException ex) ***REMOVED***
|
|
|
|
|
this.logger.error("Invalid URL",ex);
|
|
|
|
|
***REMOVED*** catch (IOException ex) ***REMOVED***
|
|
|
|
|
|
|
|
|
|
this.logger.error("Error in the IO process",ex);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** catch (EMailException e) ***REMOVED***
|
|
|
|
|
throw e;
|
|
|
|
|
***REMOVED*** catch (MalformedURLException e) ***REMOVED***
|
|
|
|
|
logger.error("Invalid URL: " + e.getLocalizedMessage(), e);
|
|
|
|
|
throw new EMailException(e);
|
|
|
|
|
***REMOVED*** catch (IOException e) ***REMOVED***
|
|
|
|
|
logger.error("Error in the IO process: " + e.getLocalizedMessage(), e);
|
|
|
|
|
throw new EMailException(e);
|
|
|
|
|
***REMOVED*** catch (Throwable e) ***REMOVED***
|
|
|
|
|
logger.error("Error executing post:" + e.getLocalizedMessage(), e);
|
|
|
|
|
throw new EMailException(e);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
private void checkResponse(String response) throws EMailException ***REMOVED***
|
|
|
|
|
if (response == null) ***REMOVED***
|
|
|
|
|
logger.error("Invalid notification response: " + response);
|
|
|
|
|
throw new EMailException();***REMOVED*** TODO
|
|
|
|
|
***REMOVED*** else ***REMOVED***
|
|
|
|
|
try ***REMOVED***
|
|
|
|
|
JSONObject res = new JSONObject(response);
|
|
|
|
|
boolean success = res.getBoolean("success");
|
|
|
|
|
if (!success) ***REMOVED***
|
|
|
|
|
String message = res.getString("message");
|
|
|
|
|
logger.error("Error in send email notification: " + message);
|
|
|
|
|
throw new EMailException("Error in send email notification: "+message);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED*** catch (JSONException e) ***REMOVED***
|
|
|
|
|
logger.error("Invalid notification response: " + response);
|
|
|
|
|
throw new EMailException(e);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
public String getAdminRoles() throws Exception***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED*** discover social gcore endpoint
|
|
|
|
|
private List<String> getRecipients() ***REMOVED***
|
|
|
|
|
try ***REMOVED***
|
|
|
|
|
List<String> recipients = new ArrayList<String>();
|
|
|
|
|
String dataMinerManagers = retrieveDataMinerManagers();
|
|
|
|
|
logger.debug("Retrieved DataMiner Managers: " + dataMinerManagers);
|
|
|
|
|
if (dataMinerManagers != null && !dataMinerManagers.isEmpty()) ***REMOVED***
|
|
|
|
|
JSONObject obj = new JSONObject(dataMinerManagers);
|
|
|
|
|
JSONArray data = obj.getJSONArray("result");
|
|
|
|
|
if (data != null) ***REMOVED***
|
|
|
|
|
for (int i = 0; i < data.length(); i++) ***REMOVED***
|
|
|
|
|
recipients.add(data.getString(i));
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** else ***REMOVED***
|
|
|
|
|
logger.info("Use the default admins how workaround ");
|
|
|
|
|
List<String> defaultManagers = DMPMClientConfiguratorManager.getInstance().getDefaultAdmins();
|
|
|
|
|
recipients.addAll(defaultManagers);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
recipients.add(this.username(SecurityTokenProvider.instance.get()));
|
|
|
|
|
|
|
|
|
|
***REMOVED***GcoreEndpointReader ep = new GcoreEndpointReader(ScopeProvider.instance.get());
|
|
|
|
|
logger.info("Retrieved Recipients: " + recipients);
|
|
|
|
|
return recipients;
|
|
|
|
|
***REMOVED*** catch (Exception e) ***REMOVED***
|
|
|
|
|
logger.error("Error retrieving recipients: " + e.getLocalizedMessage(), e);
|
|
|
|
|
logger.info("Use the default admins how workaround ");
|
|
|
|
|
return DMPMClientConfiguratorManager.getInstance().getDefaultAdmins();
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
String serviceAddress = getRequestMessage(USER_ROLES_ADDRESS_PATH);
|
|
|
|
|
***REMOVED***String serviceAddress = InfraRetrieval.findEmailingSystemAddress(ScopeProvider.instance.get());
|
|
|
|
|
private String retrieveDataMinerManagers() throws Exception ***REMOVED***
|
|
|
|
|
***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);
|
|
|
|
|
|
|
|
|
|
***REMOVED***String serviceAddress = ep.getResourceEntyName();***REMOVED***"https:***REMOVED***socialnetworking1.d4science.org/social-networking-library-ws/rest/";
|
|
|
|
|
***REMOVED*** serviceAddress = serviceAddress.endsWith("/") ? serviceAddress : serviceAddress + "/";
|
|
|
|
|
***REMOVED*** serviceAddress+= "2/users/get-usernames-by-role?role-name=DataMiner-Manager&gcube-token=" + SecurityTokenProvider.instance.get();
|
|
|
|
|
|
|
|
|
|
this.logger.debug("Admin roles url is " + serviceAddress);
|
|
|
|
|
logger.info("Request Admins Url: " + requestAdminsUrl);
|
|
|
|
|
|
|
|
|
|
CloseableHttpClient client = HttpClientBuilder.create().build();
|
|
|
|
|
HttpGet getReq = new HttpGet(serviceAddress);
|
|
|
|
|
HttpGet getReq = new HttpGet(requestAdminsUrl);
|
|
|
|
|
getReq.setHeader("accept", JSON_MIME_TYPE);
|
|
|
|
|
getReq.setHeader("content-type", JSON_MIME_TYPE);
|
|
|
|
|
this.logger.info(EntityUtils.toString(client.execute(getReq).getEntity()));
|
|
|
|
|
logger.info("Response: " + EntityUtils.toString(client.execute(getReq).getEntity()));
|
|
|
|
|
|
|
|
|
|
return EntityUtils.toString(client.execute(getReq).getEntity());
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public String getAdmins()***REMOVED***
|
|
|
|
|
try***REMOVED***
|
|
|
|
|
List<String> s = new LinkedList<String>();
|
|
|
|
|
JSONObject obj = new JSONObject(this.getAdminRoles());
|
|
|
|
|
JSONArray data = obj.getJSONArray("result");
|
|
|
|
|
if (data != null) ***REMOVED***
|
|
|
|
|
String[] names = new String[data.length()];
|
|
|
|
|
for (int i = 0; i < data.length(); i++) ***REMOVED***
|
|
|
|
|
names[i] = data.getString(i);
|
|
|
|
|
s.add(names[i]);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
s.add(this.username(SecurityTokenProvider.instance.get()));
|
|
|
|
|
***REMOVED***
|
|
|
|
|
return s.toString().replace("[", "").replace("]", "");
|
|
|
|
|
***REMOVED***
|
|
|
|
|
catch(Exception a)***REMOVED***return DMPMClientConfiguratorManager.getInstance().getDefaultAdmins(); ***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
***REMOVED*** public String getRootToken() throws Exception ***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** ***REMOVED***ApplicationContext ctx = ContextProvider.get(); ***REMOVED*** get this info from
|
|
|
|
|
***REMOVED*** ***REMOVED*** SmartGears
|
|
|
|
|
***REMOVED*** ***REMOVED***System.out.println(ctx.container().configuration().infrastructure());
|
|
|
|
|
***REMOVED*** String a = "";
|
|
|
|
|
***REMOVED*** SimpleQuery query2 = queryFor(ServiceEndpoint.class);
|
|
|
|
|
***REMOVED*** query2.addCondition("$resource/Profile/Name/text() eq 'SAIService'").setResult("$resource");
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** DiscoveryClient<ServiceEndpoint> client2 = clientFor(ServiceEndpoint.class);
|
|
|
|
|
***REMOVED*** List<ServiceEndpoint> df = client2.submit(query2);
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED*** for (ServiceEndpoint b : df) ***REMOVED***
|
|
|
|
|
***REMOVED*** a = StringEncrypter.getEncrypter().decrypt(b.profile().accessPoints().iterator().next().password());
|
|
|
|
|
***REMOVED*** ***REMOVED***
|
|
|
|
|
***REMOVED*** return a;
|
|
|
|
|
***REMOVED******REMOVED***
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public static void main(String[] args) throws Exception ***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED***ScopeProvider.instance.set("/d4science.research-infrastructures.eu/gCubeApps/RPrototypingLab");
|
|
|
|
|
***REMOVED***SecurityTokenProvider.instance.set("***REMOVED***");
|
|
|
|
|
|
|
|
|
|
***REMOVED***ScopeProvider.instance.set("/gcube/devNext");
|
|
|
|
|
***REMOVED***SecurityTokenProvider.instance.set("aa6eec71-fe07-43ab-bd1c-f03df293e430-98187548");
|
|
|
|
|
|
|
|
|
|
***REMOVED***NotificationHelper nh = new NotificationHelper();
|
|
|
|
|
|
|
|
|
|
SendMail sm = new SendMail();
|
|
|
|
|
|
|
|
|
|
***REMOVED***ScopeProvider.instance.set("/gcube/devNext/NextNext");
|
|
|
|
|
***REMOVED***SecurityTokenProvider.instance.set("***REMOVED***");
|
|
|
|
|
***REMOVED***System.out.println(sm.getRootToken());
|
|
|
|
|
***REMOVED***sm.getGenericResourceByName("");
|
|
|
|
|
|
|
|
|
|
ScopeProvider.instance.set("/gcube/preprod/preVRE");
|
|
|
|
|
SecurityTokenProvider.instance.set("2eceaf27-0e22-4dbe-8075-e09eff199bf9-98187548");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
***REMOVED***sm.sendNotification(nh.getFailedSubject(), nh.getFailedBody("test failed"));
|
|
|
|
|
***REMOVED*** sm.username(SecurityTokenProvider.instance.get());
|
|
|
|
|
***REMOVED***sm.retrieveAdminRole();
|
|
|
|
|
***REMOVED***sm.getAdminRoles();
|
|
|
|
|
System.out.println(sm.getAdmins());
|
|
|
|
|
***REMOVED***System.out.println(sm.getAdmins());
|
|
|
|
|
***REMOVED***sm.sendNotification("test", "test");
|
|
|
|
|
***REMOVED***System.out.println(sm.getSocialService());
|
|
|
|
|
***REMOVED***
|
|
|
|
|
***REMOVED***
|
|
|
|
|