86 lines
3.6 KiB
Java
86 lines
3.6 KiB
Java
package _VisualDVM.Repository.Server;
|
|
import Common.Utils.Utils_;
|
|
import _VisualDVM.Constants;
|
|
import _VisualDVM.Repository.EmailMessage;
|
|
import _VisualDVM.Utils;
|
|
import javafx.util.Pair;
|
|
|
|
import javax.activation.DataHandler;
|
|
import javax.activation.DataSource;
|
|
import javax.activation.FileDataSource;
|
|
import javax.mail.*;
|
|
import javax.mail.internet.InternetAddress;
|
|
import javax.mail.internet.MimeBodyPart;
|
|
import javax.mail.internet.MimeMessage;
|
|
import javax.mail.internet.MimeMultipart;
|
|
import java.io.File;
|
|
import java.util.LinkedHashMap;
|
|
import java.util.Properties;
|
|
public class EmailChecker extends RepositoryServerClient {
|
|
RepositoryServer server;
|
|
@Override
|
|
protected RepositoryServer getServer() {
|
|
return server;
|
|
}
|
|
public EmailChecker(RepositoryServer server_in) {
|
|
server = server_in;
|
|
}
|
|
@Override
|
|
protected int getSleepMillis() {
|
|
return 5000;
|
|
}
|
|
@Override
|
|
protected void perform() throws Exception {
|
|
Pair<String, EmailMessage> messagePair = (Pair<String, EmailMessage>) ServerCommand(ServerCode.GetFirstEmailToSend);
|
|
if (messagePair != null) {
|
|
SendEmail(messagePair.getKey(), messagePair.getValue());
|
|
}
|
|
}
|
|
public void SendEmail(String address_in, EmailMessage message_in) throws Exception {
|
|
Properties props = new Properties();
|
|
props.put("mail.smtp.host", Constants.SMTPHost);
|
|
props.put("mail.smtp.auth", "true");
|
|
props.put("mail.smtp.port", String.valueOf(Constants.SMTPPort));
|
|
props.put("mail.smtp.socketFactory.port", String.valueOf(Constants.MailSocketPort));
|
|
props.put("mail.smtp.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
|
|
props.put("mail.smtp.connectiontimeout", String.valueOf(15000));
|
|
props.put("mail.smtp.timeout", String.valueOf(15000));
|
|
props.put("mail.smtp.writetimeout", String.valueOf(15000));
|
|
//------------------------------
|
|
LinkedHashMap<String, File> innerFiles = new LinkedHashMap<>();
|
|
for (String aName : message_in.files.keySet()) {
|
|
File f = Utils.getTempFileName(aName);
|
|
Utils_.bytesToFile(message_in.files.get(aName), f);
|
|
innerFiles.put(aName, f);
|
|
}
|
|
//------------------------------
|
|
Session session = Session.getDefaultInstance(props,
|
|
new Authenticator() {
|
|
@Override
|
|
protected PasswordAuthentication getPasswordAuthentication() {
|
|
return new PasswordAuthentication(
|
|
Constants.MailAddress,
|
|
Constants.MailPassword);
|
|
}
|
|
});
|
|
MimeMessage message = new MimeMessage(session);
|
|
message.setFrom(new InternetAddress(Constants.MailAddress));
|
|
message.setRecipients(Message.RecipientType.CC, InternetAddress.parse(address_in));
|
|
message.setSubject(message_in.subject);
|
|
Multipart multipart = new MimeMultipart();
|
|
MimeBodyPart textBodyPart = new MimeBodyPart();
|
|
textBodyPart.setText(message_in.text);
|
|
multipart.addBodyPart(textBodyPart);
|
|
for (String aName : innerFiles.keySet()) {
|
|
MimeBodyPart attachmentBodyPart = new MimeBodyPart();
|
|
DataSource source = new FileDataSource(innerFiles.get(aName));
|
|
attachmentBodyPart.setDataHandler(new DataHandler(source));
|
|
attachmentBodyPart.setFileName(aName);
|
|
multipart.addBodyPart(attachmentBodyPart);
|
|
}
|
|
message.setContent(multipart);
|
|
Transport.send(message);
|
|
}
|
|
}
|
|
|