PullFeeder sends an addition "MODE READER" to peers.
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.io.IOException;
22 import java.util.ArrayList;
23 import java.util.List;
24 import javax.mail.Address;
25 import javax.mail.Authenticator;
26 import javax.mail.Message;
27 import javax.mail.MessagingException;
28 import javax.mail.PasswordAuthentication;
29 import javax.mail.internet.InternetAddress;
30 import org.sonews.config.Config;
31 import org.sonews.storage.Article;
32 import org.sonews.storage.Headers;
33 import org.sonews.storage.StorageBackendException;
34 import org.sonews.storage.StorageManager;
35 import org.sonews.util.Log;
36 import org.sonews.util.Stats;
39 * Dispatches messages from mailing list or newsserver or vice versa.
40 * @author Christian Lins
43 public class Dispatcher
46 static class PasswordAuthenticator extends Authenticator
50 public PasswordAuthentication getPasswordAuthentication()
52 final String username =
53 Config.inst().get(Config.MLSEND_USER, "user");
54 final String password =
55 Config.inst().get(Config.MLSEND_PASSWORD, "mysecret");
57 return new PasswordAuthentication(username, password);
63 * Posts a message that was received from a mailing list to the
64 * appropriate newsgroup.
67 public static boolean toGroup(final Message msg)
71 Address[] to = msg.getAllRecipients(); // includes TO/CC/BCC
72 if(to == null || to.length <= 0)
74 to = msg.getReplyTo();
77 if(to == null || to.length <= 0)
79 Log.msg("Skipping message because no recipient!", false);
84 boolean posted = false;
85 List<String> newsgroups = new ArrayList<String>();
87 for (Address toa : to) // Address can have '<' '>' around
89 if (toa instanceof InternetAddress)
91 List<String> groups = StorageManager.current()
92 .getGroupsForList((InternetAddress)toa);
93 newsgroups.addAll(groups);
97 if (newsgroups.size() > 0)
99 StringBuilder groups = new StringBuilder();
100 for(int n = 0; n < newsgroups.size(); n++)
102 groups.append(newsgroups.get(n));
103 if(n + 1 != newsgroups.size())
108 Log.msg("Posting to group " + groups.toString(), true);
110 // Create new Article object
111 Article article = new Article(msg);
112 article.setGroup(groups.toString());
113 article.removeHeader(Headers.REPLY_TO);
114 article.removeHeader(Headers.TO);
116 // Write article to database
117 if(!StorageManager.current().isArticleExisting(article.getMessageID()))
119 StorageManager.current().addArticle(article);
120 Stats.getInstance().mailGatewayed(
121 article.getHeader(Headers.NEWSGROUPS)[0]);
125 Log.msg("Article " + article.getMessageID() + " already existing.", true);
131 StringBuilder buf = new StringBuilder();
132 for(Address toa : to)
135 buf.append(toa.toString());
137 Log.msg("No group for" + buf.toString(), false);
144 ex.printStackTrace();
150 * Mails a message received through NNTP to the appropriate mailing list.
152 public static void toList(Article article)
153 throws IOException, MessagingException, StorageBackendException
155 // Get mailing lists for the group of this article
156 List<String> listAddresses = new ArrayList<String>();
157 String[] groupnames = article.getHeader(Headers.NEWSGROUPS)[0].split(",");
159 for(String groupname : groupnames)
161 String listAddress = StorageManager.current().getListForGroup(groupname);
162 if(listAddress != null)
164 listAddresses.add(listAddress);
168 for(String listAddress : listAddresses)
170 // Compose message and send it via given SMTP-Host
171 String smtpHost = Config.inst().get(Config.MLSEND_HOST, "localhost");
172 int smtpPort = Config.inst().get(Config.MLSEND_PORT, 25);
173 String smtpUser = Config.inst().get(Config.MLSEND_USER, "user");
174 String smtpPw = Config.inst().get(Config.MLSEND_PASSWORD, "mysecret");
175 String smtpFrom = Config.inst().get(
176 Config.MLSEND_ADDRESS, article.getHeader(Headers.FROM)[0]);
178 // TODO: Make Article cloneable()
179 String group = article.getHeader(Headers.NEWSGROUPS)[0];
180 article.getMessageID(); // Make sure an ID is existing
181 article.removeHeader(Headers.NEWSGROUPS);
182 article.removeHeader(Headers.PATH);
183 article.removeHeader(Headers.LINES);
184 article.removeHeader(Headers.BYTES);
186 article.setHeader("To", listAddress);
187 article.setHeader("Reply-To", listAddress);
189 if(Config.inst().get(Config.MLSEND_RW_SENDER, false))
191 rewriteSenderAddress(article); // Set the SENDER address
194 SMTPTransport smtpTransport = new SMTPTransport(smtpHost, smtpPort);
195 smtpTransport.send(article, smtpFrom, listAddress);
196 smtpTransport.close();
198 Stats.getInstance().mailGatewayed(group);
199 Log.msg("MLGateway: Mail " + article.getHeader("Subject")[0]
200 + " was delivered to " + listAddress + ".", true);
205 * Sets the SENDER header of the given MimeMessage. This might be necessary
206 * for moderated groups that does not allow the "normal" FROM sender.
208 * @throws javax.mail.MessagingException
210 private static void rewriteSenderAddress(Article msg)
211 throws MessagingException
213 String mlAddress = Config.inst().get(Config.MLSEND_ADDRESS, null);
215 if(mlAddress != null)
217 msg.setHeader(Headers.SENDER, mlAddress);
221 throw new MessagingException("Cannot rewrite SENDER header!");