diff options
Diffstat (limited to 'Mailman/GatewayManager.py')
| -rw-r--r-- | Mailman/GatewayManager.py | 119 |
1 files changed, 119 insertions, 0 deletions
diff --git a/Mailman/GatewayManager.py b/Mailman/GatewayManager.py new file mode 100644 index 000000000..f90c7aeaf --- /dev/null +++ b/Mailman/GatewayManager.py @@ -0,0 +1,119 @@ +# Copyright (C) 1998 by the Free Software Foundation, Inc. +# +# This program is free software; you can redistribute it and/or +# modify it under the terms of the GNU General Public License +# as published by the Free Software Foundation; either version 2 +# of the License, or (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + +'''Mixin class for gatewaying mail to news, and news to mail.''' + +ImproperNNTPConfigError = "ImproperNNTPConfigError" +class GatewayManager: + def InitVars(self): + # Configurable + self.nntp_host = '' + self.linked_newsgroup = '' + self.gateway_to_news = 0 + self.gateway_to_mail = 0 + + def GetConfigInfo(self): + import mm_cfg + return [ + 'Mail to news and news to mail gateway services.', + ('nntp_host', mm_cfg.String, 50, 0, + 'The internet address of the machine your news server is running on.', + + 'The news server is not part of Mailman proper. You have to already' + ' have access to a nntp server, and that nntp server has to recognize' + ' the machine this mailing list runs on as a machine capable of' + ' reading and posting news.'), + ('linked_newsgroup', mm_cfg.String, 50, 0, + 'The name of the usenet group to gateway to and/or from.'), + ('gateway_to_news', mm_cfg.Toggle, ('No', 'Yes'), 0, + 'Should posts to the mailing list be resent to the newsgroup?'), + ('gateway_to_mail', mm_cfg.Toggle, ('No', 'Yes'), 0, + 'Should newsgroup posts not sent from the list be resent to the' + ' list?') + ] + + # Watermarks are kept externally to avoid locking problems. + def PollNewsGroup(self, watermark): + if (not self.gateway_to_mail or not self.nntp_host or + not self.linked_newsgroup): + return 0 + import nntplib, os, string, mm_cfg + con = nntplib.NNTP(self.nntp_host) + r,c,f,l,n = con.group(self.linked_newsgroup) + # NEWNEWS is not portable and has synchronization issues... + # Use a watermark system instead. + if watermark == 0: + return eval(l) + for num in range(watermark, eval(l)+1): + try: + headers = con.head(`num`)[3] + for header in headers: + i = string.index(header, ':') + if header[:i] <> 'X-Remailer': + continue + if header[i:] == ': %s@%s' % (self._internal_name, + self.host_name): + raise "QuickEscape" + body = con.body(`num`)[3] + file = os.popen("%s %s nonews" % (os.path.join(mm_cfg.SCRIPTS_DIR, + "post"), self._internal_name), "w") + file.write(string.join(headers,'\n')) + file.write('\n\n') + file.write(string.join(body,'\n')) + file.write('\n') + file.close() + except nntplib.error_temp: + pass # Probably canceled, etc... + except "QuickEscape": + pass # We gated this TO news, don't repost it! + return l + + def SendMailToNewsGroup(self, msg): + import os + if self.gateway_to_news == 0: + return + if self.linked_newsgroup == '' or self.nntp_host == '': + raise ImproperNNTPConfigError + try: + if self.tmp_prevent_gate: + return + except AttributeError: + pass # Wasn't remailed by the news gater then. Let it through. + # Fork in case the nntp connection hangs. + if not os.fork(): + import nntplib,string + msg.headers.append("Newsgroups: %s\n" % self.linked_newsgroup) + msg.headers.append("X-Remailer: %s@%s\n" % + (self._internal_name,self.host_name)) + # Note: Need to be sure 2 messages aren't ever sent to the same + # list in the same process, since message ID's need to be unique. + # could make the ID be mm.listname.postnum instead if that happens + if msg.getheader('Message-ID') == None: + import time + msg.headers.append("Message-ID: <mm.%s.%s@%s>\n" % + (time.time(), os.getpid(), self.host_name)) + if msg.getheader('Lines') == None: + msg.headers.append("Lines: %s\n" % + len(string.split(msg.body,"\n"))) + # NNTP is strict about spaces after the colon in headers. + for n in len(msg.headers): + line = msg.headers[n] + i = string.index(line,":") + if line[i+1] <> ' ': + msg.headers[n] = line[:i+1] + ' ' + line[i+1:] + con = nntplib.NNTP(self.nntp_host) + con.quit() + os._exit(0) |