3 * see AUTHORS for the list of contributors
5 * This program is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation, either version 3 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program. If not, see <http://www.gnu.org/licenses/>.
19 package org.sonews.mlgw;
21 import java.util.Properties;
22 import javax.mail.AuthenticationFailedException;
23 import javax.mail.Authenticator;
24 import javax.mail.Flags.Flag;
25 import javax.mail.Folder;
26 import javax.mail.Message;
27 import javax.mail.MessagingException;
28 import javax.mail.NoSuchProviderException;
29 import javax.mail.PasswordAuthentication;
30 import javax.mail.Session;
31 import javax.mail.Store;
32 import org.sonews.config.Config;
33 import org.sonews.daemon.AbstractDaemon;
34 import org.sonews.util.Log;
35 import org.sonews.util.Stats;
38 * Daemon polling for new mails in a POP3 account to be delivered to newsgroups.
39 * @author Christian Lins
42 public class MailPoller extends AbstractDaemon
45 static class PasswordAuthenticator extends Authenticator
49 public PasswordAuthentication getPasswordAuthentication()
51 final String username =
52 Config.inst().get(Config.MLPOLL_USER, "user");
53 final String password =
54 Config.inst().get(Config.MLPOLL_PASSWORD, "mysecret");
56 return new PasswordAuthentication(username, password);
63 Log.get().info("Starting Mailinglist Poller...");
67 // Wait some time between runs. At the beginning has advantages,
68 // because the wait is not skipped if an exception occurs.
69 Thread.sleep(60000 * (errors + 1)); // one minute * errors
72 Config.inst().get(Config.MLPOLL_HOST, "samplehost");
73 final String username =
74 Config.inst().get(Config.MLPOLL_USER, "user");
75 final String password =
76 Config.inst().get(Config.MLPOLL_PASSWORD, "mysecret");
78 Stats.getInstance().mlgwRunStart();
80 // Create empty properties
81 Properties props = System.getProperties();
82 props.put("mail.pop3.host", host);
83 props.put("mail.mime.address.strict", "false");
86 Session session = Session.getInstance(props);
89 Store store = session.getStore("pop3");
90 store.connect(host, 110, username, password);
93 Folder folder = store.getFolder("INBOX");
94 folder.open(Folder.READ_WRITE);
97 Message[] messages = folder.getMessages();
99 // Dispatch messages and delete it afterwards on the inbox
100 for (Message message : messages) {
101 if (Dispatcher.toGroup(message)
102 || Config.inst().get(Config.MLPOLL_DELETEUNKNOWN, false)) {
103 // Delete the message
104 message.setFlag(Flag.DELETED, true);
109 folder.close(true); // true to expunge deleted messages
113 Stats.getInstance().mlgwRunEnd();
114 } catch (NoSuchProviderException ex) {
115 Log.get().severe(ex.toString());
117 } catch (AuthenticationFailedException ex) {
118 // AuthentificationFailedException may be thrown if credentials are
119 // bad or if the Mailbox is in use (locked).
120 ex.printStackTrace();
121 errors = errors < 5 ? errors + 1 : errors;
122 } catch (InterruptedException ex) {
123 System.out.println("sonews: " + this + " returns: " + ex);
125 } catch (MessagingException ex) {
126 ex.printStackTrace();
127 errors = errors < 5 ? errors + 1 : errors;
128 } catch (Exception ex) {
129 ex.printStackTrace();
130 errors = errors < 5 ? errors + 1 : errors;
133 Log.get().severe("MailPoller exited.");