chris@1: /* chris@1: * SONEWS News Server chris@1: * see AUTHORS for the list of contributors chris@1: * chris@1: * This program is free software: you can redistribute it and/or modify chris@1: * it under the terms of the GNU General Public License as published by chris@1: * the Free Software Foundation, either version 3 of the License, or chris@1: * (at your option) any later version. chris@1: * chris@1: * This program is distributed in the hope that it will be useful, chris@1: * but WITHOUT ANY WARRANTY; without even the implied warranty of chris@1: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the chris@1: * GNU General Public License for more details. chris@1: * chris@1: * You should have received a copy of the GNU General Public License chris@1: * along with this program. If not, see . chris@1: */ chris@1: chris@1: package org.sonews.mlgw; chris@1: chris@1: import java.util.Properties; chris@1: import javax.mail.AuthenticationFailedException; chris@1: import javax.mail.Authenticator; chris@1: import javax.mail.Flags.Flag; chris@1: import javax.mail.Folder; chris@1: import javax.mail.Message; chris@1: import javax.mail.MessagingException; chris@1: import javax.mail.NoSuchProviderException; chris@1: import javax.mail.PasswordAuthentication; chris@1: import javax.mail.Session; chris@1: import javax.mail.Store; chris@1: import org.sonews.daemon.Config; chris@1: import org.sonews.daemon.AbstractDaemon; chris@1: import org.sonews.util.Log; chris@1: import org.sonews.util.Stats; chris@1: chris@1: /** chris@1: * Daemon polling for new mails in a POP3 account to be delivered to newsgroups. chris@1: * @author Christian Lins chris@1: * @since sonews/0.5.0 chris@1: */ chris@1: public class MailPoller extends AbstractDaemon chris@1: { chris@1: chris@1: static class PasswordAuthenticator extends Authenticator chris@1: { chris@1: chris@1: @Override chris@1: public PasswordAuthentication getPasswordAuthentication() chris@1: { chris@1: final String username = chris@1: Config.getInstance().get(Config.MLPOLL_USER, "user"); chris@1: final String password = chris@1: Config.getInstance().get(Config.MLPOLL_PASSWORD, "mysecret"); chris@1: chris@1: return new PasswordAuthentication(username, password); chris@1: } chris@1: chris@1: } chris@1: chris@1: @Override chris@1: public void run() chris@1: { chris@1: Log.msg("Starting Mailinglist Poller...", false); chris@1: int errors = 0; chris@1: while(isRunning() && errors < 5) chris@1: { chris@1: try chris@1: { chris@1: // Wait some time between runs. At the beginning has advantages, chris@1: // because the wait is not skipped if an exception occurs. chris@1: Thread.sleep(60000 * (errors + 1)); // one minute * errors chris@1: chris@1: final String host = chris@1: Config.getInstance().get(Config.MLPOLL_HOST, "samplehost"); chris@1: final String username = chris@1: Config.getInstance().get(Config.MLPOLL_USER, "user"); chris@1: final String password = chris@1: Config.getInstance().get(Config.MLPOLL_PASSWORD, "mysecret"); chris@1: chris@1: Stats.getInstance().mlgwRunStart(); chris@1: chris@1: // Create empty properties chris@1: Properties props = System.getProperties(); chris@1: props.put("mail.pop3.host", host); chris@1: chris@1: // Get session chris@1: Session session = Session.getInstance(props); chris@1: chris@1: // Get the store chris@1: Store store = session.getStore("pop3"); chris@1: store.connect(host, 110, username, password); chris@1: chris@1: // Get folder chris@1: Folder folder = store.getFolder("INBOX"); chris@1: folder.open(Folder.READ_WRITE); chris@1: chris@1: // Get directory chris@1: Message[] messages = folder.getMessages(); chris@1: chris@1: // Dispatch messages and delete it afterwards on the inbox chris@1: for(Message message : messages) chris@1: { chris@1: String subject = message.getSubject(); chris@1: System.out.println("MLGateway: message with subject \"" + subject + "\" received."); chris@1: if(Dispatcher.toGroup(message) chris@1: || Config.getInstance().get(Config.MLPOLL_DELETEUNKNOWN, false)) chris@1: { chris@1: // Delete the message chris@1: message.setFlag(Flag.DELETED, true); chris@1: } chris@1: } chris@1: chris@1: // Close connection chris@1: folder.close(true); // true to expunge deleted messages chris@1: store.close(); chris@1: errors = 0; chris@1: chris@1: Stats.getInstance().mlgwRunEnd(); chris@1: } chris@1: catch(NoSuchProviderException ex) chris@1: { chris@1: Log.msg(ex.toString(), false); chris@1: shutdown(); chris@1: } chris@1: catch(AuthenticationFailedException ex) chris@1: { chris@1: // AuthentificationFailedException may be thrown if credentials are chris@1: // bad or if the Mailbox is in use (locked). chris@1: ex.printStackTrace(); chris@1: errors++; chris@1: } chris@1: catch(InterruptedException ex) chris@1: { chris@1: System.out.println("sonews: " + this + " returns."); chris@1: return; chris@1: } chris@1: catch(MessagingException ex) chris@1: { chris@1: ex.printStackTrace(); chris@1: errors++; chris@1: } chris@1: catch(Exception ex) chris@1: { chris@1: ex.printStackTrace(); chris@1: errors++; chris@1: } chris@1: } chris@1: Log.msg("MailPoller exited.", false); chris@1: } chris@1: chris@1: }