src/org/sonews/mlgw/MailPoller.java
author cli
Sun, 29 Aug 2010 17:28:58 +0200
changeset 35 ed84c8bdd87b
parent 27 org/sonews/mlgw/MailPoller.java@d879bab39600
child 37 74139325d305
permissions -rw-r--r--
Moving source files into src/-subdir.
     1 /*
     2  *   SONEWS News Server
     3  *   see AUTHORS for the list of contributors
     4  *
     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.
     9  *
    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.
    14  *
    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/>.
    17  */
    18 
    19 package org.sonews.mlgw;
    20 
    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;
    36 
    37 /**
    38  * Daemon polling for new mails in a POP3 account to be delivered to newsgroups.
    39  * @author Christian Lins
    40  * @since sonews/0.5.0
    41  */
    42 public class MailPoller extends AbstractDaemon
    43 {
    44 
    45   static class PasswordAuthenticator extends Authenticator
    46   {
    47     
    48     @Override
    49     public PasswordAuthentication getPasswordAuthentication()
    50     {
    51       final String username = 
    52         Config.inst().get(Config.MLPOLL_USER, "user");
    53       final String password = 
    54         Config.inst().get(Config.MLPOLL_PASSWORD, "mysecret");
    55 
    56       return new PasswordAuthentication(username, password);
    57     }
    58     
    59   }
    60   
    61   @Override
    62   public void run()
    63   {
    64     Log.get().info("Starting Mailinglist Poller...");
    65     int errors = 0;
    66     while(isRunning())
    67     {
    68       try
    69       {
    70         // Wait some time between runs. At the beginning has advantages,
    71         // because the wait is not skipped if an exception occurs.
    72         Thread.sleep(60000 * (errors + 1)); // one minute * errors
    73         
    74         final String host     = 
    75           Config.inst().get(Config.MLPOLL_HOST, "samplehost");
    76         final String username = 
    77           Config.inst().get(Config.MLPOLL_USER, "user");
    78         final String password = 
    79           Config.inst().get(Config.MLPOLL_PASSWORD, "mysecret");
    80         
    81         Stats.getInstance().mlgwRunStart();
    82         
    83         // Create empty properties
    84         Properties props = System.getProperties();
    85         props.put("mail.pop3.host", host);
    86         props.put("mail.mime.address.strict", "false");
    87 
    88         // Get session
    89         Session session = Session.getInstance(props);
    90 
    91         // Get the store
    92         Store store = session.getStore("pop3");
    93         store.connect(host, 110, username, password);
    94 
    95         // Get folder
    96         Folder folder = store.getFolder("INBOX");
    97         folder.open(Folder.READ_WRITE);
    98 
    99         // Get directory
   100         Message[] messages = folder.getMessages();
   101 
   102         // Dispatch messages and delete it afterwards on the inbox
   103         for(Message message : messages)
   104         {
   105           if(Dispatcher.toGroup(message)
   106             || Config.inst().get(Config.MLPOLL_DELETEUNKNOWN, false))
   107           {
   108             // Delete the message
   109             message.setFlag(Flag.DELETED, true);
   110           }
   111         }
   112 
   113         // Close connection 
   114         folder.close(true); // true to expunge deleted messages
   115         store.close();
   116         errors = 0;
   117         
   118         Stats.getInstance().mlgwRunEnd();
   119       }
   120       catch(NoSuchProviderException ex)
   121       {
   122         Log.get().severe(ex.toString());
   123         shutdown();
   124       }
   125       catch(AuthenticationFailedException ex)
   126       {
   127         // AuthentificationFailedException may be thrown if credentials are
   128         // bad or if the Mailbox is in use (locked).
   129         ex.printStackTrace();
   130         errors = errors < 5 ? errors + 1 : errors;
   131       }
   132       catch(InterruptedException ex)
   133       {
   134         System.out.println("sonews: " + this + " returns: " + ex);
   135         return;
   136       }
   137       catch(MessagingException ex)
   138       {
   139         ex.printStackTrace();
   140         errors = errors < 5 ? errors + 1 : errors;
   141       }
   142       catch(Exception ex)
   143       {
   144         ex.printStackTrace();
   145         errors = errors < 5 ? errors + 1 : errors;
   146       }
   147     }
   148     Log.get().severe("MailPoller exited.");
   149   }
   150   
   151 }