aboutsummaryrefslogtreecommitdiffstats
path: root/news2mail.py
diff options
context:
space:
mode:
authorMatěj Cepl <mcepl@cepl.eu>2014-12-21 22:18:48 +0100
committerMatěj Cepl <mcepl@cepl.eu>2014-12-21 22:43:08 +0100
commit52b3df8247561fa138b273efd18e7f03a54880ef (patch)
treedb629d4d90eded920160dbf2c63b80e483fa8a4b /news2mail.py
parentaaba562ae6e30c3b8e18938eea58f0a8df73bd57 (diff)
downloadpyg-52b3df8247561fa138b273efd18e7f03a54880ef.tar.gz
switch to argparse in pygn2m
and cleanup in pygn2m, news2mail.py (and some leftovers in pygm2n)
Diffstat (limited to 'news2mail.py')
-rw-r--r--news2mail.py519
1 files changed, 255 insertions, 264 deletions
diff --git a/news2mail.py b/news2mail.py
index 73808b3..bfd6fd1 100644
--- a/news2mail.py
+++ b/news2mail.py
@@ -3,7 +3,7 @@
Author: Cosimo Alfarano
Date: June 11 2000
-news2mail.py - Copyright 2000 by Cosimo Alfarano <Alfarano@Students.CS.UniBo.It>
+news2mail.py - (C) 2000 by Cosimo Alfarano <Alfarano@Students.CS.UniBo.It>
You can use this software under the terms of the GPL. If we meet some day,
and you think this stuff is worth it, you can buy me a beer in return.
@@ -20,280 +20,271 @@ normal (what pygs does) operations flow is:
3) merges NNTP and SMTP heads into a unique heads
4) adds, renames and removes some heads
5) sorts remaining headers starting at top with Received: From: To: Subject:
- Date:, normal headers ending with X-* and Resent-* headers.
+ Date:, normal headers ending with X-* and Resent-* headers.
"""
-
import sys
import smtplib
-import string
-from re import compile
-#import getopt
import time
-#import rfc822
from socket import gethostbyaddr, gethostname
import tempfile
import pyginfo
+
class news2mail:
- """news to mail gateway class"""
-
- TMPFILE = tempfile.mktemp()
- wlfile = None
- logfile = None
-
- sender = ''
- rcpt = ''
- envelope = ''
-
- smtpserver = 'localhost'
-
- hostname = gethostbyaddr(gethostname())[0]
-
- heads_dict, smtpheads, nntpheads = {}, {}, {}
- article, headers, body = [], [], []
-
- debug = 1
-
- def readfile(self):
-
- for line in sys.stdin.readlines():
- self.article.append(line)
-
- if (len(self.article) == 1 and self.article[0][0] == '/'):
- file = self.article[0][:-1]
- del self.article[0]
- for line in open(file,'r').readlines():
- self.article.append(line)
-
-
- def parsearticle(self):
- """get news article from file or stdin and separate heads from body
-
- REMEBER: headers value has '\n' as last char.
- Use string[:-1] to ignore newline.
- """
-
- try:
- body = 0 # are we in body or in headers?
-
-# voidline = compile('^$') # I need '\n', ^$ matches anything
-# spaceending = compile('\s*\n$')
-
- for line in self.article:
- if not body and len(line) == 1:
- body = 1 # starts article body section
-
- if not body:
- try:
- head, value = string.split(line, ' ', 1)
- self.nntpheads[head] = value
- except (string.index_error), message:
- print 'string error: %s' % message
- print '(probably missing couple "Header: value" in %s)' % line
- sys.exit(1)
-
- elif len(line) > 0 and body:
- self.body.append(line)
-
- return self.nntpheads, self.body
-
-# except (re.error, string.index_error), message:
- except (string.index_error), message:
- print message
- sys.exit(1)
-
-
- def puthead(self, dict, list, key):
- """private, x-form dict entries in list entries"""
-
- if dict.has_key(key):
- list.append(key + ' ' + dict.get(key))
- else:
- return 0
- return 1
-
- def sortheads(self):
- """make list sorting heads, Received: From: To: Subject: first, others, X-*, Resent-* last"""
-
- set = ('Received:','From:','To:','Subject:','Date:') # put at top
-
- for k in set:
- self.puthead(self.heads_dict,self.headers,k)
-
- for k in self.heads_dict.keys():
- if k[:2] != 'X-' and k[:7] != 'Resent-' and k not in set:
- self.puthead(self.heads_dict,self.headers,k)
-
- for k in self.heads_dict.keys():
- if k[:2] == 'X-':
- self.puthead(self.heads_dict,self.headers,k)
-
- for k in self.heads_dict.keys():
- if k[:7] == 'Resent-':
- self.puthead(self.heads_dict,self.headers,k)
-
- return self.headers
-
-
- def mergeheads(self):
- """make a unique headers dictionary from NNTP and SMTP
- single headers dictionaries."""
-
- self.heads_dict = {}
-
-
- try:
- for header in self.nntpheads.keys(): # fill it w/ nntp old heads
- self.heads_dict[header] = self.nntpheads[header]
-
- for header in self.smtpheads.keys(): # and replace them w/ smtp new heads
- self.heads_dict[header] = self.smtpheads[header]
-
- except KeyError, message:
- print message
-
- return self.heads_dict
-
- def addheads(self):
- """add new header like X-Gateway: Received:
- """
-
- info = pyginfo.pygsinfo()
-
- try:
- self.heads_dict['X-Gateway:'] = info.PROGNAME + ' ' + \
- info.__doc__ + '\n'
-
- ##self.heads_dict['X-Gateway:'] = '%s %s\n' % (info.PROGNAME, info.__doc__)
-
- # to make Received: header
- t = time.ctime(time.time())
-
- if time.daylight:
- tzone = time.tzname[1]
- else:
- tzone = time.tzname[0]
-
- # An exemple from debian-italian:
- # Received: from murphy.debian.org (murphy.debian.org [216.234.231.6])
- # by smv04.iname.net (8.9.3/8.9.1SMV2) with SMTP id JAA26407
- # for <kame.primo@innocent.com> sent by
- # <debian-italian-request@lists.debian.org
-
- tmp = 'from GATEWAY by ' + self.hostname + \
- ' with ' + info.PROGNAME + \
- '\n\tfor <' + self.rcpt + '> ; ' + \
- t + ' (' + tzone +')\n'
-
- self.heads_dict['Received:'] = tmp
- except KeyError, message:
- print message
-
- return self.heads_dict
-
- def renameheads(self):
- """rename headers such as Newsgroups: to X-Newsgroups:
-
- headers renamed are useless or not rfc 822 copliant
- """
- try:
- if self.heads_dict.has_key('Newsgroups:'):
- self.heads_dict['X-Newsgroups:'] = self.heads_dict['Newsgroups:']
- del self.heads_dict['Newsgroups:']
-
- if self.heads_dict.has_key('NNTP-Posting-Host:'):
- self.heads_dict['X-NNTP-Posting-Host:'] = self.heads_dict['NNTP-Posting-Host:']
- del self.heads_dict['NNTP-Posting-Host:']
- except KeyError, message:
- print message
-
- return self.heads_dict
-
-
- def removeheads(self):
- """remove headers like Xref: Path: Lines:
- """
-
- try:
- # removing some others useless headers ....
-
- if self.heads_dict.has_key('Approved:'):
- del self.heads_dict['Approved:']
-
- if self.heads_dict.has_key('From'): # neither 'From ' nor 'From:'
- del self.heads_dict['From']
-
- if self.heads_dict.has_key('Xref:'):
- del self.heads_dict['Xref:']
-
- if self.heads_dict.has_key('Path:'):
- del self.heads_dict['Path:']
-
- if self.heads_dict.has_key('Lines:'):
- del self.heads_dict['Lines:']
-
- # it is usually set by INN, if ng is moderated...
- if self.heads_dict.has_key('Sender:'):
- del self.heads_dict['Sender:']
-
-
- if self.heads_dict.has_key('Message-id:'):
- self.heads_dict['Message-Id:'] = self.heads_dict['Message-id']
- del(self.heads_dict['Message-id'])
-
- if self.heads_dict.has_key('Message-ID:'):
- self.heads_dict['Message-Id:'] = self.heads_dict['Message-ID']
- del(self.heads_dict['Message-ID'])
-
- # If message-id is not present, I generate it
- if not self.heads_dict.has_key('Message-Id:'):
- # It should put a real user@domain
- msgid = 'pyg@puppapera.org'
-
- except KeyError, message:
- print message
-
- return self.heads_dict
-
- def sendarticle(self):
- """Talk to SMTP server and try to send email."""
- try:
- msglist = []
-
- s = smtplib.SMTP(self.smtpserver)
-
- # put real locahost domain name.
- s.helo(self.hostname)
- if s.helo_resp is None and s.ehlo_resp is None:
- print 'No helo resp'
- sys.exit(1)
-
- resp = s.mail(self.envelope)
- if resp[0] != 250:
- print 'SMTP error during MAIL cmd: %s %s' % (resp[0], resp[1])
- print 'envelope %s gave problem?' % self.envelope
- sys.exit(1)
- resp = s.rcpt(self.rcpt)
- if resp[0] != 250:
- print 'SMTP error during MAIL cmd: %s %s' % (resp[0], resp[1])
- sys.exit(1)
-
-
- msglist.append(string.join(self.headers,''))
-
- msglist.append(string.join(self.body,''))
- msg = string.join(msglist,'')
-
- s.data(msg)
- s.quit()
-
- return 1
-
- except (smtplib.SMTPException), messaggio:
- print messaggio
- sys.exit(1)
+ """news to mail gateway class"""
+
+ TMPFILE = tempfile.mktemp()
+ wlfile = None
+ logfile = None
+
+ sender = ''
+ rcpt = ''
+ envelope = ''
+
+ smtpserver = 'localhost'
+
+ hostname = gethostbyaddr(gethostname())[0]
+
+ heads_dict, smtpheads, nntpheads = {}, {}, {}
+ article, headers, body = [], [], []
+
+ debug = 1
+
+ def readfile(self):
+
+ for line in sys.stdin.readlines():
+ self.article.append(line)
+
+ if (len(self.article) == 1 and self.article[0][0] == '/'):
+ file = self.article[0][:-1]
+ del self.article[0]
+ for line in open(file, 'r').readlines():
+ self.article.append(line)
+
+ def parsearticle(self):
+ """get news article from file or stdin and separate heads from body
+
+ REMEBER: headers value has '\n' as last char.
+ Use string[:-1] to ignore newline.
+ """
+
+ try:
+ body = 0 # are we in body or in headers?
+
+# voidline = compile('^$') # I need '\n', ^$ matches anything
+# spaceending = compile('\s*\n$')
+
+ for line in self.article:
+ if not body and len(line) == 1:
+ body = 1 # starts article body section
+
+ if not body:
+ try:
+ head, value = line.split(' ', 1)
+ self.nntpheads[head] = value
+ except (ValueError), message:
+ print('string error: %s' % message)
+ print('(probably missing couple "Header: value" in %s)'
+ % line)
+ sys.exit(1)
+
+ elif len(line) > 0 and body:
+ self.body.append(line)
+
+ return self.nntpheads, self.body
+
+# except (re.error, ValueError), message:
+ except (ValueError), message:
+ print message
+ sys.exit(1)
+
+ def puthead(self, dict, list, key):
+ """private, x-form dict entries in list entries"""
+
+ if key in dict:
+ list.append(key + ' ' + dict.get(key))
+ else:
+ return 0
+ return 1
+
+ def sortheads(self):
+ """make list sorting heads, Received: From: To: Subject: first,
+ others, X-*, Resent-* last"""
+
+ set = ('Received:', 'From:', 'To:', 'Subject:', 'Date:') # put at top
+
+ for k in set:
+ self.puthead(self.heads_dict, self.headers, k)
+
+ for k in self.heads_dict.keys():
+ if k[:2] != 'X-' and k[:7] != 'Resent-' and k not in set:
+ self.puthead(self.heads_dict, self.headers, k)
+
+ for k in self.heads_dict.keys():
+ if k[:2] == 'X-':
+ self.puthead(self.heads_dict, self.headers, k)
+
+ for k in self.heads_dict.keys():
+ if k[:7] == 'Resent-':
+ self.puthead(self.heads_dict, self.headers, k)
+
+ return self.headers
+
+ def mergeheads(self):
+ """make a unique headers dictionary from NNTP and SMTP
+ single headers dictionaries."""
+
+ self.heads_dict = {}
+
+ try:
+ for header in self.nntpheads.keys(): # fill it w/ nntp old heads
+ self.heads_dict[header] = self.nntpheads[header]
+
+ # and replace them w/ smtp new heads
+ for header in self.smtpheads.keys():
+ self.heads_dict[header] = self.smtpheads[header]
+
+ except KeyError, message:
+ print message
+
+ return self.heads_dict
+
+ def addheads(self):
+ """add new header like X-Gateway: Received:
+ """
+
+ info = pyginfo.pygsinfo()
+
+ try:
+ self.heads_dict['X-Gateway:'] = info.PROGNAME + ' ' + \
+ info.__doc__ + '\n'
+
+ ##self.heads_dict['X-Gateway:'] = '%s %s\n' %
+ ## (info.PROGNAME, info.__doc__)
+
+ # to make Received: header
+ t = time.ctime(time.time())
+
+ if time.daylight:
+ tzone = time.tzname[1]
+ else:
+ tzone = time.tzname[0]
+
+ # An exemple from debian-italian:
+ # Received: from murphy.debian.org (murphy.debian.org [216.234.231.6])
+ # by smv04.iname.net (8.9.3/8.9.1SMV2) with SMTP id JAA26407
+ # for <kame.primo@innocent.com> sent by
+ # <debian-italian-request@lists.debian.org
+
+ tmp = 'from GATEWAY by ' + self.hostname + \
+ ' with ' + info.PROGNAME + \
+ '\n\tfor <' + self.rcpt + '> ; ' + \
+ t + ' (' + tzone + ')\n'
+
+ self.heads_dict['Received:'] = tmp
+ except KeyError, message:
+ print message
+
+ return self.heads_dict
+
+ def renameheads(self):
+ """rename headers such as Newsgroups: to X-Newsgroups:
+
+ headers renamed are useless or not rfc 822 copliant
+ """
+ try:
+ if 'Newsgroups:' in self.heads_dict:
+ self.heads_dict['X-Newsgroups:'] = \
+ self.heads_dict['Newsgroups:']
+ del self.heads_dict['Newsgroups:']
+
+ if 'NNTP-Posting-Host:' in self.heads_dict:
+ self.heads_dict['X-NNTP-Posting-Host:'] = \
+ self.heads_dict['NNTP-Posting-Host:']
+ del self.heads_dict['NNTP-Posting-Host:']
+ except KeyError, message:
+ print message
+
+ return self.heads_dict
+
+ def removeheads(self):
+ """remove headers like Xref: Path: Lines:
+ """
+
+ try:
+ # removing some others useless headers ....
+
+ if 'Approved:' in self.heads_dict:
+ del self.heads_dict['Approved:']
+
+ if 'From' in self.heads_dict: # neither 'From ' nor 'From:'
+ del self.heads_dict['From']
+
+ if 'Xref:' in self.heads_dict:
+ del self.heads_dict['Xref:']
+
+ if 'Path:' in self.heads_dict:
+ del self.heads_dict['Path:']
+
+ if 'Lines:' in self.heads_dict:
+ del self.heads_dict['Lines:']
+
+ # it is usually set by INN, if ng is moderated...
+ if 'Sender:' in self.heads_dict:
+ del self.heads_dict['Sender:']
+
+ if 'Message-id:' in self.heads_dict:
+ self.heads_dict['Message-Id:'] = self.heads_dict['Message-id']
+ del(self.heads_dict['Message-id'])
+
+ if 'Message-ID:' in self.heads_dict:
+ self.heads_dict['Message-Id:'] = self.heads_dict['Message-ID']
+ del(self.heads_dict['Message-ID'])
+
+ # If message-id is not present, I generate it
+ if 'Message-Id:' not in self.heads_dict:
+ # It should put a real user@domain
+ msgid = 'pyg@puppapera.org' # FIXME unused variable
+
+ except KeyError, message:
+ print message
+
+ return self.heads_dict
+
+ def sendarticle(self):
+ """Talk to SMTP server and try to send email."""
+ try:
+ msglist = []
+
+ s = smtplib.SMTP(self.smtpserver)
+
+ # put real locahost domain name.
+ s.helo(self.hostname)
+ if s.helo_resp is None and s.ehlo_resp is None:
+ print 'No helo resp'
+ sys.exit(1)
+
+ resp = s.mail(self.envelope)
+ if resp[0] != 250:
+ print 'SMTP error during MAIL cmd: %s %s' % (resp[0], resp[1])
+ print 'envelope %s gave problem?' % self.envelope
+ sys.exit(1)
+ resp = s.rcpt(self.rcpt)
+ if resp[0] != 250:
+ print 'SMTP error during MAIL cmd: %s %s' % (resp[0], resp[1])
+ sys.exit(1)
+
+ msglist.append(''.join(self.headers))
+ msglist.append(''.join(self.body))
+ msg = ''.join(msglist)
+ s.data(msg)
+ s.quit()
+ return 1
+ except (smtplib.SMTPException), messaggio:
+ print messaggio
+ sys.exit(1)