40 private static Pattern doneReply = Pattern.compile("250 .*");
41
42 public static void send(String server, EmailAddress recipient, Email email) throws IOException {
43 var port = 25;
44 if (server.contains(":")) {
45 var parts = server.split(":", 2);
46 server = parts[0];
47 port = Integer.parseInt(parts[1]);
48 }
49 try (var socket = new Socket(server, port);
50 var out = new OutputStreamWriter(socket.getOutputStream());
51 var in = new InputStreamReader(socket.getInputStream())) {
52
53 var session = new SMTPSession(in, out);
54
55 session.waitForPattern(initReply);
56 session.sendCommand("EHLO " + email.sender().domain(), ehloReply);
57 session.sendCommand("MAIL FROM:" + email.sender().address(), mailReply);
58 session.sendCommand("RCPT TO:<" + recipient.address() + ">", rcptReply);
59 session.sendCommand("DATA", dataReply);
60 session.sendCommand("From: " + email.author());
61 session.sendCommand("Message-Id: " + email.id());
62 session.sendCommand("Date: " + email.date().format(DateTimeFormatter.RFC_1123_DATE_TIME));
63 session.sendCommand("Sender: " + email.sender());
64 session.sendCommand("To: " + recipient);
65 for (var header : email.headers()) {
66 session.sendCommand(header + ": " + email.headerValue(header));
67 }
68 session.sendCommand("Subject: " + email.subject());
69 session.sendCommand("");
70 session.sendCommand(email.body());
71 session.sendCommand(".", doneReply);
72 session.sendCommand("QUIT");
73 }
74 }
75 }
|
40 private static Pattern doneReply = Pattern.compile("250 .*");
41
42 public static void send(String server, EmailAddress recipient, Email email) throws IOException {
43 var port = 25;
44 if (server.contains(":")) {
45 var parts = server.split(":", 2);
46 server = parts[0];
47 port = Integer.parseInt(parts[1]);
48 }
49 try (var socket = new Socket(server, port);
50 var out = new OutputStreamWriter(socket.getOutputStream());
51 var in = new InputStreamReader(socket.getInputStream())) {
52
53 var session = new SMTPSession(in, out);
54
55 session.waitForPattern(initReply);
56 session.sendCommand("EHLO " + email.sender().domain(), ehloReply);
57 session.sendCommand("MAIL FROM:" + email.sender().address(), mailReply);
58 session.sendCommand("RCPT TO:<" + recipient.address() + ">", rcptReply);
59 session.sendCommand("DATA", dataReply);
60 session.sendCommand("From: " + MimeText.encode(email.author().toString()));
61 session.sendCommand("Message-Id: " + email.id());
62 session.sendCommand("Date: " + email.date().format(DateTimeFormatter.RFC_1123_DATE_TIME));
63 session.sendCommand("Sender: " + MimeText.encode(email.sender().toString()));
64 session.sendCommand("To: " + MimeText.encode(recipient.toString()));
65 for (var header : email.headers()) {
66 session.sendCommand(header + ": " + MimeText.encode(email.headerValue(header)));
67 }
68 session.sendCommand("Subject: " + MimeText.encode(email.subject()));
69 session.sendCommand("");
70 session.sendCommand(MimeText.encode(email.body()));
71 session.sendCommand(".", doneReply);
72 session.sendCommand("QUIT");
73 }
74 }
75 }
|