diff --git a/src/main/java/de/srsoftware/widerhall/Application.java b/src/main/java/de/srsoftware/widerhall/Application.java index 27d44a6..32398b3 100644 --- a/src/main/java/de/srsoftware/widerhall/Application.java +++ b/src/main/java/de/srsoftware/widerhall/Application.java @@ -15,10 +15,9 @@ public class Application { var config = Files.readString(new File("/tmp/config.json").toPath()); JSONObject json = (JSONObject) parser.parse(config); - //String testSender = (String) json.get("sender"); - //String testReceiver = (String) json.get("receiver"); - // new SmtpClient(json).send(json,testSender,"Stephan Richter",testReceiver,"Test","Dies ist ein Test"); - MessageHandler forward = new Forwarder(); - new ImapClient(json).addListener(forward).start(); + MessageHandler forward = new Forwarder(json); + new ImapClient(json) + .addListener(forward) + .start(); } } diff --git a/src/main/java/de/srsoftware/widerhall/Constants.java b/src/main/java/de/srsoftware/widerhall/Constants.java index ffe7c8c..796f2ba 100644 --- a/src/main/java/de/srsoftware/widerhall/Constants.java +++ b/src/main/java/de/srsoftware/widerhall/Constants.java @@ -6,4 +6,5 @@ public class Constants { public static final String HOST = "host"; public static final String USER = "user"; public static final String PASSWORD = "password"; + public static final String INBOX = "inbox"; } diff --git a/src/main/java/de/srsoftware/widerhall/Forwarder.java b/src/main/java/de/srsoftware/widerhall/Forwarder.java index 5d59c6d..2bd48f1 100644 --- a/src/main/java/de/srsoftware/widerhall/Forwarder.java +++ b/src/main/java/de/srsoftware/widerhall/Forwarder.java @@ -1,15 +1,34 @@ package de.srsoftware.widerhall; +import org.json.simple.JSONObject; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.mail.Message; import javax.mail.MessagingException; +import java.io.UnsupportedEncodingException; public class Forwarder implements MessageHandler { private static final Logger LOG = LoggerFactory.getLogger(Forwarder.class); + private final SmtpClient smtp; + private final JSONObject config; + + public Forwarder(JSONObject config) { + this.config = config; + SmtpClient smtp = new SmtpClient(config); + this.smtp = smtp; + } + @Override public void onMessageReceived(Message message) throws MessagingException { LOG.debug("forwarding {}",message.getSubject()); + String testSender = (String) config.get("sender"); + String testReceiver = (String) config.get("receiver"); + + try { + smtp.send(config,testSender,"Stephan Richter",testReceiver,"Info: "+message.getSubject(),"Neue Mail eingegangen!"); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } } } diff --git a/src/main/java/de/srsoftware/widerhall/ImapClient.java b/src/main/java/de/srsoftware/widerhall/ImapClient.java index 569071c..283b97a 100644 --- a/src/main/java/de/srsoftware/widerhall/ImapClient.java +++ b/src/main/java/de/srsoftware/widerhall/ImapClient.java @@ -24,11 +24,6 @@ public class ImapClient { private class ListeningThread extends Thread { private static final Logger LOG = LoggerFactory.getLogger(ListeningThread.class); - private final JSONObject config; - - ListeningThread(JSONObject config){ - this.config = config; - } @Override public void run() { @@ -50,13 +45,14 @@ public class ImapClient { String host = (String) config.get(Constants.HOST); String username = (String) config.get(Constants.USER); String password = (String) config.get(Constants.PASSWORD); + String folderName = (String) config.get(Constants.INBOX); LOG.debug("Connecting and logging in…"); Properties props = imapProps(); Session session = Session.getInstance(props); Store store = session.getStore(Constants.IMAPS); store.connect(host,username,password); - LOG.debug("Connected, opening inbox:"); - inbox = (IMAPFolder)store.getFolder("INBOX"); + LOG.debug("Connected, opening {}:",folderName); + inbox = (IMAPFolder)store.getFolder(folderName); inbox.open(IMAPFolder.READ_WRITE); while (!stopped){ @@ -116,7 +112,7 @@ public class ImapClient { public void start() { LOG.debug("Creating ListeningThread…"); - new ListeningThread(config).start(); + new ListeningThread().start(); LOG.debug("Creating Heartbeat…"); new Heartbeat().start(); } diff --git a/src/main/java/de/srsoftware/widerhall/SmtpClient.java b/src/main/java/de/srsoftware/widerhall/SmtpClient.java index 3fcaf50..a56b23c 100644 --- a/src/main/java/de/srsoftware/widerhall/SmtpClient.java +++ b/src/main/java/de/srsoftware/widerhall/SmtpClient.java @@ -35,7 +35,6 @@ public class SmtpClient { props.put(PORT,port); props.put(AUTH,true); props.put(SSL,true); -// props.put("mail.smtp.localhost","mail.keawe.de"); session = Session.getInstance(props); LOG.debug("Created new {}: {}", getClass().getSimpleName(),session);