mirror of
				https://github.com/python/cpython.git
				synced 2025-10-31 05:31:20 +00:00 
			
		
		
		
	 89d996e5c2
			
		
	
	
		89d996e5c2
		
	
	
	
	
		
			
			svn+ssh://pythondev@svn.python.org/python/trunk ........ r57820 | georg.brandl | 2007-08-31 08:59:27 +0200 (Fri, 31 Aug 2007) | 2 lines Document new shorthand notation for index entries. ........ r57827 | georg.brandl | 2007-08-31 10:47:51 +0200 (Fri, 31 Aug 2007) | 2 lines Fix subitem markup. ........ r57833 | martin.v.loewis | 2007-08-31 12:01:07 +0200 (Fri, 31 Aug 2007) | 1 line Mark registry components as 64-bit on Win64. ........ r57854 | bill.janssen | 2007-08-31 21:02:23 +0200 (Fri, 31 Aug 2007) | 1 line deprecate use of FakeSocket ........ r57855 | bill.janssen | 2007-08-31 21:02:46 +0200 (Fri, 31 Aug 2007) | 1 line remove mentions of socket.ssl in comments ........ r57856 | bill.janssen | 2007-08-31 21:03:31 +0200 (Fri, 31 Aug 2007) | 1 line remove use of non-existent SSLFakeSocket in apparently untested code ........ r57859 | martin.v.loewis | 2007-09-01 08:36:03 +0200 (Sat, 01 Sep 2007) | 3 lines Bug #1737210: Change Manufacturer of Windows installer to PSF. Will backport to 2.5. ........ r57865 | georg.brandl | 2007-09-01 09:51:24 +0200 (Sat, 01 Sep 2007) | 2 lines Fix RST link (backport from Py3k). ........ r57876 | georg.brandl | 2007-09-01 17:49:49 +0200 (Sat, 01 Sep 2007) | 2 lines Document sets' ">" and "<" operations (backport from py3k). ........ r57878 | skip.montanaro | 2007-09-01 19:40:03 +0200 (Sat, 01 Sep 2007) | 4 lines Added a note and examples to explain that re.split does not split on an empty pattern match. (issue 852532). ........ r57879 | walter.doerwald | 2007-09-01 20:18:09 +0200 (Sat, 01 Sep 2007) | 2 lines Fix wrong function names. ........ r57880 | walter.doerwald | 2007-09-01 20:34:05 +0200 (Sat, 01 Sep 2007) | 2 lines Fix typo. ........ r57889 | andrew.kuchling | 2007-09-01 22:31:59 +0200 (Sat, 01 Sep 2007) | 1 line Markup fix ........ r57892 | andrew.kuchling | 2007-09-01 22:43:36 +0200 (Sat, 01 Sep 2007) | 1 line Add various items ........ r57895 | andrew.kuchling | 2007-09-01 23:17:58 +0200 (Sat, 01 Sep 2007) | 1 line Wording change ........ r57896 | andrew.kuchling | 2007-09-01 23:18:31 +0200 (Sat, 01 Sep 2007) | 1 line Add more items ........ r57904 | ronald.oussoren | 2007-09-02 11:46:07 +0200 (Sun, 02 Sep 2007) | 3 lines Macosx: this patch ensures that the value of MACOSX_DEPLOYMENT_TARGET used by the Makefile is also used at configure-time. ........ r57925 | georg.brandl | 2007-09-03 09:16:46 +0200 (Mon, 03 Sep 2007) | 2 lines Fix #883466: don't allow Unicode as arguments to quopri and uu codecs. ........ r57936 | matthias.klose | 2007-09-04 01:33:04 +0200 (Tue, 04 Sep 2007) | 2 lines - Added support for linking the bsddb module against BerkeleyDB 4.6.x. ........ r57954 | mark.summerfield | 2007-09-04 10:16:15 +0200 (Tue, 04 Sep 2007) | 3 lines Added cross-references plus a note about dict & list shallow copying. ........ r57958 | martin.v.loewis | 2007-09-04 11:51:57 +0200 (Tue, 04 Sep 2007) | 3 lines Document that we rely on the OS to release the crypto context. Fixes #1626801. ........ r57960 | martin.v.loewis | 2007-09-04 15:13:14 +0200 (Tue, 04 Sep 2007) | 3 lines Patch #1388440: Add set_completion_display_matches_hook and get_completion_type to readline. ........ r57961 | martin.v.loewis | 2007-09-04 16:19:28 +0200 (Tue, 04 Sep 2007) | 3 lines Patch #1031213: Decode source line in SyntaxErrors back to its original source encoding. Will backport to 2.5. ........ r57972 | matthias.klose | 2007-09-04 20:17:36 +0200 (Tue, 04 Sep 2007) | 3 lines - Makefile.pre.in(buildbottest): Run an optional script pybuildbot.identify to include some information about the build environment. ........ r57973 | matthias.klose | 2007-09-04 21:05:38 +0200 (Tue, 04 Sep 2007) | 2 lines - Makefile.pre.in(buildbottest): Remove whitespace at eol. ........ r57975 | matthias.klose | 2007-09-04 22:46:02 +0200 (Tue, 04 Sep 2007) | 2 lines - Fix libffi configure for hppa*-*-linux* | parisc*-*-linux*. ........ r57980 | bill.janssen | 2007-09-05 02:46:27 +0200 (Wed, 05 Sep 2007) | 1 line SSL certificate distinguished names should be represented by tuples ........ r57985 | martin.v.loewis | 2007-09-05 08:39:17 +0200 (Wed, 05 Sep 2007) | 3 lines Patch #1105: Explain that one needs to build the solution to get dependencies right. ........ r57987 | armin.rigo | 2007-09-05 09:51:21 +0200 (Wed, 05 Sep 2007) | 4 lines PyDict_GetItem() returns a borrowed reference. There are probably a number of places that are open to attacks such as the following one, in bltinmodule.c:min_max(). ........ r57991 | martin.v.loewis | 2007-09-05 13:47:34 +0200 (Wed, 05 Sep 2007) | 3 lines Patch #786737: Allow building in a tree of symlinks pointing to a readonly source. ........ r57993 | georg.brandl | 2007-09-05 15:36:44 +0200 (Wed, 05 Sep 2007) | 2 lines Backport from Py3k: Bug #1684991: explain lookup semantics for __special__ methods (new-style classes only). ........ r58004 | armin.rigo | 2007-09-06 10:30:51 +0200 (Thu, 06 Sep 2007) | 4 lines Patch #1733973 by peaker: ptrace_enter_call() assumes no exception is currently set. This assumption is broken when throwing into a generator. ........ r58006 | armin.rigo | 2007-09-06 11:30:38 +0200 (Thu, 06 Sep 2007) | 4 lines PyDict_GetItem() returns a borrowed reference. This attack is against ceval.c:IMPORT_NAME, which calls an object (__builtin__.__import__) without holding a reference to it. ........ r58013 | georg.brandl | 2007-09-06 16:49:56 +0200 (Thu, 06 Sep 2007) | 2 lines Backport from 3k: #1116: fix reference to old filename. ........ r58021 | thomas.heller | 2007-09-06 22:26:20 +0200 (Thu, 06 Sep 2007) | 1 line Fix typo: c_float represents to C float type. ........ r58022 | skip.montanaro | 2007-09-07 00:29:06 +0200 (Fri, 07 Sep 2007) | 3 lines If this is correct for py3k branch and it's already in the release25-maint branch, seems like it ought to be on the trunk as well. ........ r58023 | gregory.p.smith | 2007-09-07 00:59:59 +0200 (Fri, 07 Sep 2007) | 4 lines Apply the fix from Issue1112 to make this test more robust and keep windows happy. ........ r58031 | brett.cannon | 2007-09-07 05:17:50 +0200 (Fri, 07 Sep 2007) | 4 lines Make uuid1 and uuid4 tests conditional on whether ctypes can be imported; implementation of either function depends on ctypes but uuid as a whole does not. ........ r58032 | brett.cannon | 2007-09-07 06:18:30 +0200 (Fri, 07 Sep 2007) | 6 lines Fix a crasher where Python code managed to infinitely recurse in C code without ever going back out to Python code in PyObject_Call(). Required introducing a static RuntimeError instance so that normalizing an exception there is no reliance on a recursive call that would put the exception system over the recursion check itself. ........ r58034 | thomas.heller | 2007-09-07 08:32:17 +0200 (Fri, 07 Sep 2007) | 1 line Add a 'c_longdouble' type to the ctypes module. ........ r58035 | thomas.heller | 2007-09-07 11:30:40 +0200 (Fri, 07 Sep 2007) | 1 line Remove unneeded #include. ........ r58036 | thomas.heller | 2007-09-07 11:33:24 +0200 (Fri, 07 Sep 2007) | 6 lines Backport from py3k branch: Add a workaround for a strange bug on win64, when _ctypes is compiled with the SDK compiler. This should fix the failing Lib\ctypes\test\test_as_parameter.py test. ........ r58037 | georg.brandl | 2007-09-07 16:14:40 +0200 (Fri, 07 Sep 2007) | 2 lines Fix a wrong indentation for sublists. ........ r58043 | georg.brandl | 2007-09-07 22:10:49 +0200 (Fri, 07 Sep 2007) | 2 lines #1095: ln -f doesn't work portably, fix in Makefile. ........ r58049 | skip.montanaro | 2007-09-08 02:34:17 +0200 (Sat, 08 Sep 2007) | 1 line be explicit about the actual location of the missing file ........
		
			
				
	
	
		
			796 lines
		
	
	
	
		
			29 KiB
		
	
	
	
		
			Python
		
	
	
		
			Executable file
		
	
	
	
	
			
		
		
	
	
			796 lines
		
	
	
	
		
			29 KiB
		
	
	
	
		
			Python
		
	
	
		
			Executable file
		
	
	
	
	
| #! /usr/bin/env python
 | |
| 
 | |
| '''SMTP/ESMTP client class.
 | |
| 
 | |
| This should follow RFC 821 (SMTP), RFC 1869 (ESMTP), RFC 2554 (SMTP
 | |
| Authentication) and RFC 2487 (Secure SMTP over TLS).
 | |
| 
 | |
| Notes:
 | |
| 
 | |
| Please remember, when doing ESMTP, that the names of the SMTP service
 | |
| extensions are NOT the same thing as the option keywords for the RCPT
 | |
| and MAIL commands!
 | |
| 
 | |
| Example:
 | |
| 
 | |
|   >>> import smtplib
 | |
|   >>> s=smtplib.SMTP("localhost")
 | |
|   >>> print(s.help())
 | |
|   This is Sendmail version 8.8.4
 | |
|   Topics:
 | |
|       HELO    EHLO    MAIL    RCPT    DATA
 | |
|       RSET    NOOP    QUIT    HELP    VRFY
 | |
|       EXPN    VERB    ETRN    DSN
 | |
|   For more info use "HELP <topic>".
 | |
|   To report bugs in the implementation send email to
 | |
|       sendmail-bugs@sendmail.org.
 | |
|   For local information send email to Postmaster at your site.
 | |
|   End of HELP info
 | |
|   >>> s.putcmd("vrfy","someone@here")
 | |
|   >>> s.getreply()
 | |
|   (250, "Somebody OverHere <somebody@here.my.org>")
 | |
|   >>> s.quit()
 | |
| '''
 | |
| 
 | |
| # Author: The Dragon De Monsyne <dragondm@integral.org>
 | |
| # ESMTP support, test code and doc fixes added by
 | |
| #     Eric S. Raymond <esr@thyrsus.com>
 | |
| # Better RFC 821 compliance (MAIL and RCPT, and CRLF in data)
 | |
| #     by Carey Evans <c.evans@clear.net.nz>, for picky mail servers.
 | |
| # RFC 2554 (authentication) support by Gerhard Haering <gerhard@bigfoot.de>.
 | |
| #
 | |
| # This was modified from the Python 1.5 library HTTP lib.
 | |
| 
 | |
| import socket
 | |
| import re
 | |
| import email.utils
 | |
| import base64
 | |
| import hmac
 | |
| from email.base64mime import body_encode as encode_base64
 | |
| from sys import stderr
 | |
| 
 | |
| __all__ = ["SMTPException","SMTPServerDisconnected","SMTPResponseException",
 | |
|            "SMTPSenderRefused","SMTPRecipientsRefused","SMTPDataError",
 | |
|            "SMTPConnectError","SMTPHeloError","SMTPAuthenticationError",
 | |
|            "quoteaddr","quotedata","SMTP"]
 | |
| 
 | |
| SMTP_PORT = 25
 | |
| SMTP_SSL_PORT = 465
 | |
| CRLF="\r\n"
 | |
| 
 | |
| OLDSTYLE_AUTH = re.compile(r"auth=(.*)", re.I)
 | |
| 
 | |
| # Exception classes used by this module.
 | |
| class SMTPException(Exception):
 | |
|     """Base class for all exceptions raised by this module."""
 | |
| 
 | |
| class SMTPServerDisconnected(SMTPException):
 | |
|     """Not connected to any SMTP server.
 | |
| 
 | |
|     This exception is raised when the server unexpectedly disconnects,
 | |
|     or when an attempt is made to use the SMTP instance before
 | |
|     connecting it to a server.
 | |
|     """
 | |
| 
 | |
| class SMTPResponseException(SMTPException):
 | |
|     """Base class for all exceptions that include an SMTP error code.
 | |
| 
 | |
|     These exceptions are generated in some instances when the SMTP
 | |
|     server returns an error code.  The error code is stored in the
 | |
|     `smtp_code' attribute of the error, and the `smtp_error' attribute
 | |
|     is set to the error message.
 | |
|     """
 | |
| 
 | |
|     def __init__(self, code, msg):
 | |
|         self.smtp_code = code
 | |
|         self.smtp_error = msg
 | |
|         self.args = (code, msg)
 | |
| 
 | |
| class SMTPSenderRefused(SMTPResponseException):
 | |
|     """Sender address refused.
 | |
| 
 | |
|     In addition to the attributes set by on all SMTPResponseException
 | |
|     exceptions, this sets `sender' to the string that the SMTP refused.
 | |
|     """
 | |
| 
 | |
|     def __init__(self, code, msg, sender):
 | |
|         self.smtp_code = code
 | |
|         self.smtp_error = msg
 | |
|         self.sender = sender
 | |
|         self.args = (code, msg, sender)
 | |
| 
 | |
| class SMTPRecipientsRefused(SMTPException):
 | |
|     """All recipient addresses refused.
 | |
| 
 | |
|     The errors for each recipient are accessible through the attribute
 | |
|     'recipients', which is a dictionary of exactly the same sort as
 | |
|     SMTP.sendmail() returns.
 | |
|     """
 | |
| 
 | |
|     def __init__(self, recipients):
 | |
|         self.recipients = recipients
 | |
|         self.args = ( recipients,)
 | |
| 
 | |
| 
 | |
| class SMTPDataError(SMTPResponseException):
 | |
|     """The SMTP server didn't accept the data."""
 | |
| 
 | |
| class SMTPConnectError(SMTPResponseException):
 | |
|     """Error during connection establishment."""
 | |
| 
 | |
| class SMTPHeloError(SMTPResponseException):
 | |
|     """The server refused our HELO reply."""
 | |
| 
 | |
| class SMTPAuthenticationError(SMTPResponseException):
 | |
|     """Authentication error.
 | |
| 
 | |
|     Most probably the server didn't accept the username/password
 | |
|     combination provided.
 | |
|     """
 | |
| 
 | |
| def quoteaddr(addr):
 | |
|     """Quote a subset of the email addresses defined by RFC 821.
 | |
| 
 | |
|     Should be able to handle anything rfc822.parseaddr can handle.
 | |
|     """
 | |
|     m = (None, None)
 | |
|     try:
 | |
|         m = email.utils.parseaddr(addr)[1]
 | |
|     except AttributeError:
 | |
|         pass
 | |
|     if m == (None, None): # Indicates parse failure or AttributeError
 | |
|         # something weird here.. punt -ddm
 | |
|         return "<%s>" % addr
 | |
|     elif m is None:
 | |
|         # the sender wants an empty return address
 | |
|         return "<>"
 | |
|     else:
 | |
|         return "<%s>" % m
 | |
| 
 | |
| def quotedata(data):
 | |
|     """Quote data for email.
 | |
| 
 | |
|     Double leading '.', and change Unix newline '\\n', or Mac '\\r' into
 | |
|     Internet CRLF end-of-line.
 | |
|     """
 | |
|     return re.sub(r'(?m)^\.', '..',
 | |
|         re.sub(r'(?:\r\n|\n|\r(?!\n))', CRLF, data))
 | |
| 
 | |
| try:
 | |
|     import ssl
 | |
| except ImportError:
 | |
|     _have_ssl = False
 | |
| else:
 | |
|     class SSLFakeFile:
 | |
|         """A fake file like object that really wraps a SSLObject.
 | |
| 
 | |
|         It only supports what is needed in smtplib.
 | |
|         """
 | |
|         def __init__(self, sslobj):
 | |
|             self.sslobj = sslobj
 | |
| 
 | |
|         def readline(self):
 | |
|             str = b""
 | |
|             chr = None
 | |
|             while chr != b"\n":
 | |
|                 chr = self.sslobj.read(1)
 | |
|                 str += chr
 | |
|             return str
 | |
| 
 | |
|         def close(self):
 | |
|             pass
 | |
| 
 | |
|     _have_ssl = True
 | |
| 
 | |
| 
 | |
| class SMTP:
 | |
|     """This class manages a connection to an SMTP or ESMTP server.
 | |
|     SMTP Objects:
 | |
|         SMTP objects have the following attributes:
 | |
|             helo_resp
 | |
|                 This is the message given by the server in response to the
 | |
|                 most recent HELO command.
 | |
| 
 | |
|             ehlo_resp
 | |
|                 This is the message given by the server in response to the
 | |
|                 most recent EHLO command. This is usually multiline.
 | |
| 
 | |
|             does_esmtp
 | |
|                 This is a True value _after you do an EHLO command_, if the
 | |
|                 server supports ESMTP.
 | |
| 
 | |
|             esmtp_features
 | |
|                 This is a dictionary, which, if the server supports ESMTP,
 | |
|                 will _after you do an EHLO command_, contain the names of the
 | |
|                 SMTP service extensions this server supports, and their
 | |
|                 parameters (if any).
 | |
| 
 | |
|                 Note, all extension names are mapped to lower case in the
 | |
|                 dictionary.
 | |
| 
 | |
|         See each method's docstrings for details.  In general, there is a
 | |
|         method of the same name to perform each SMTP command.  There is also a
 | |
|         method called 'sendmail' that will do an entire mail transaction.
 | |
|         """
 | |
|     debuglevel = 0
 | |
|     file = None
 | |
|     helo_resp = None
 | |
|     ehlo_msg = "ehlo"
 | |
|     ehlo_resp = None
 | |
|     does_esmtp = 0
 | |
| 
 | |
|     def __init__(self, host='', port=0, local_hostname=None, timeout=None):
 | |
|         """Initialize a new instance.
 | |
| 
 | |
|         If specified, `host' is the name of the remote host to which to
 | |
|         connect.  If specified, `port' specifies the port to which to connect.
 | |
|         By default, smtplib.SMTP_PORT is used.  An SMTPConnectError is raised
 | |
|         if the specified `host' doesn't respond correctly.  If specified,
 | |
|         `local_hostname` is used as the FQDN of the local host.  By default,
 | |
|         the local hostname is found using socket.getfqdn().
 | |
| 
 | |
|         """
 | |
|         self.timeout = timeout
 | |
|         self.esmtp_features = {}
 | |
|         self.default_port = SMTP_PORT
 | |
|         if host:
 | |
|             (code, msg) = self.connect(host, port)
 | |
|             if code != 220:
 | |
|                 raise SMTPConnectError(code, msg)
 | |
|         if local_hostname is not None:
 | |
|             self.local_hostname = local_hostname
 | |
|         else:
 | |
|             # RFC 2821 says we should use the fqdn in the EHLO/HELO verb, and
 | |
|             # if that can't be calculated, that we should use a domain literal
 | |
|             # instead (essentially an encoded IP address like [A.B.C.D]).
 | |
|             fqdn = socket.getfqdn()
 | |
|             if '.' in fqdn:
 | |
|                 self.local_hostname = fqdn
 | |
|             else:
 | |
|                 # We can't find an fqdn hostname, so use a domain literal
 | |
|                 addr = '127.0.0.1'
 | |
|                 try:
 | |
|                     addr = socket.gethostbyname(socket.gethostname())
 | |
|                 except socket.gaierror:
 | |
|                     pass
 | |
|                 self.local_hostname = '[%s]' % addr
 | |
| 
 | |
|     def set_debuglevel(self, debuglevel):
 | |
|         """Set the debug output level.
 | |
| 
 | |
|         A non-false value results in debug messages for connection and for all
 | |
|         messages sent to and received from the server.
 | |
| 
 | |
|         """
 | |
|         self.debuglevel = debuglevel
 | |
| 
 | |
|     def _get_socket(self, port, host, timeout):
 | |
|         # This makes it simpler for SMTP_SSL to use the SMTP connect code
 | |
|         # and just alter the socket connection bit.
 | |
|         if self.debuglevel > 0: print('connect:', (host, port), file=stderr)
 | |
|         return socket.create_connection((port, host), timeout)
 | |
| 
 | |
|     def connect(self, host='localhost', port = 0):
 | |
|         """Connect to a host on a given port.
 | |
| 
 | |
|         If the hostname ends with a colon (`:') followed by a number, and
 | |
|         there is no port specified, that suffix will be stripped off and the
 | |
|         number interpreted as the port number to use.
 | |
| 
 | |
|         Note: This method is automatically invoked by __init__, if a host is
 | |
|         specified during instantiation.
 | |
| 
 | |
|         """
 | |
|         if not port and (host.find(':') == host.rfind(':')):
 | |
|             i = host.rfind(':')
 | |
|             if i >= 0:
 | |
|                 host, port = host[:i], host[i+1:]
 | |
|                 try: port = int(port)
 | |
|                 except ValueError:
 | |
|                     raise socket.error("nonnumeric port")
 | |
|         if not port: port = self.default_port
 | |
|         if self.debuglevel > 0: print('connect:', (host, port), file=stderr)
 | |
|         self.sock = self._get_socket(host, port, self.timeout)
 | |
|         (code, msg) = self.getreply()
 | |
|         if self.debuglevel > 0: print("connect:", msg, file=stderr)
 | |
|         return (code, msg)
 | |
| 
 | |
|     def send(self, str):
 | |
|         """Send `str' to the server."""
 | |
|         if self.debuglevel > 0: print('send:', repr(str), file=stderr)
 | |
|         if self.sock:
 | |
|             try:
 | |
|                 self.sock.sendall(str)
 | |
|             except socket.error:
 | |
|                 self.close()
 | |
|                 raise SMTPServerDisconnected('Server not connected')
 | |
|         else:
 | |
|             raise SMTPServerDisconnected('please run connect() first')
 | |
| 
 | |
|     def putcmd(self, cmd, args=""):
 | |
|         """Send a command to the server."""
 | |
|         if args == "":
 | |
|             str = '%s%s' % (cmd, CRLF)
 | |
|         else:
 | |
|             str = '%s %s%s' % (cmd, args, CRLF)
 | |
|         self.send(str)
 | |
| 
 | |
|     def getreply(self):
 | |
|         """Get a reply from the server.
 | |
| 
 | |
|         Returns a tuple consisting of:
 | |
| 
 | |
|           - server response code (e.g. '250', or such, if all goes well)
 | |
|             Note: returns -1 if it can't read response code.
 | |
| 
 | |
|           - server response string corresponding to response code (multiline
 | |
|             responses are converted to a single, multiline string).
 | |
| 
 | |
|         Raises SMTPServerDisconnected if end-of-file is reached.
 | |
|         """
 | |
|         resp=[]
 | |
|         if self.file is None:
 | |
|             self.file = self.sock.makefile('rb')
 | |
|         while 1:
 | |
|             line = self.file.readline()
 | |
|             if not line:
 | |
|                 self.close()
 | |
|                 raise SMTPServerDisconnected("Connection unexpectedly closed")
 | |
|             if self.debuglevel > 0: print('reply:', repr(line), file=stderr)
 | |
|             resp.append(line[4:].strip(b' \t\r\n'))
 | |
|             code=line[:3]
 | |
|             # Check that the error code is syntactically correct.
 | |
|             # Don't attempt to read a continuation line if it is broken.
 | |
|             try:
 | |
|                 errcode = int(code)
 | |
|             except ValueError:
 | |
|                 errcode = -1
 | |
|                 break
 | |
|             # Check if multiline response.
 | |
|             if line[3:4] != b"-":
 | |
|                 break
 | |
| 
 | |
|         errmsg = b"\n".join(resp)
 | |
|         if self.debuglevel > 0:
 | |
|             print('reply: retcode (%s); Msg: %s' % (errcode,errmsg), file=stderr)
 | |
|         return errcode, errmsg
 | |
| 
 | |
|     def docmd(self, cmd, args=""):
 | |
|         """Send a command, and return its response code."""
 | |
|         self.putcmd(cmd,args)
 | |
|         return self.getreply()
 | |
| 
 | |
|     # std smtp commands
 | |
|     def helo(self, name=''):
 | |
|         """SMTP 'helo' command.
 | |
|         Hostname to send for this command defaults to the FQDN of the local
 | |
|         host.
 | |
|         """
 | |
|         self.putcmd("helo", name or self.local_hostname)
 | |
|         (code,msg)=self.getreply()
 | |
|         self.helo_resp=msg
 | |
|         return (code,msg)
 | |
| 
 | |
|     def ehlo(self, name=''):
 | |
|         """ SMTP 'ehlo' command.
 | |
|         Hostname to send for this command defaults to the FQDN of the local
 | |
|         host.
 | |
|         """
 | |
|         self.esmtp_features = {}
 | |
|         self.putcmd(self.ehlo_msg, name or self.local_hostname)
 | |
|         (code,msg)=self.getreply()
 | |
|         # According to RFC1869 some (badly written)
 | |
|         # MTA's will disconnect on an ehlo. Toss an exception if
 | |
|         # that happens -ddm
 | |
|         if code == -1 and len(msg) == 0:
 | |
|             self.close()
 | |
|             raise SMTPServerDisconnected("Server not connected")
 | |
|         self.ehlo_resp=msg
 | |
|         if code != 250:
 | |
|             return (code,msg)
 | |
|         self.does_esmtp=1
 | |
|         #parse the ehlo response -ddm
 | |
|         assert isinstance(self.ehlo_resp, bytes), repr(self.ehlo_resp)
 | |
|         resp=self.ehlo_resp.decode("latin-1").split('\n')
 | |
|         del resp[0]
 | |
|         for each in resp:
 | |
|             # To be able to communicate with as many SMTP servers as possible,
 | |
|             # we have to take the old-style auth advertisement into account,
 | |
|             # because:
 | |
|             # 1) Else our SMTP feature parser gets confused.
 | |
|             # 2) There are some servers that only advertise the auth methods we
 | |
|             #    support using the old style.
 | |
|             auth_match = OLDSTYLE_AUTH.match(each)
 | |
|             if auth_match:
 | |
|                 # This doesn't remove duplicates, but that's no problem
 | |
|                 self.esmtp_features["auth"] = self.esmtp_features.get("auth", "") \
 | |
|                         + " " + auth_match.groups(0)[0]
 | |
|                 continue
 | |
| 
 | |
|             # RFC 1869 requires a space between ehlo keyword and parameters.
 | |
|             # It's actually stricter, in that only spaces are allowed between
 | |
|             # parameters, but were not going to check for that here.  Note
 | |
|             # that the space isn't present if there are no parameters.
 | |
|             m=re.match(r'(?P<feature>[A-Za-z0-9][A-Za-z0-9\-]*) ?',each)
 | |
|             if m:
 | |
|                 feature=m.group("feature").lower()
 | |
|                 params=m.string[m.end("feature"):].strip()
 | |
|                 if feature == "auth":
 | |
|                     self.esmtp_features[feature] = self.esmtp_features.get(feature, "") \
 | |
|                             + " " + params
 | |
|                 else:
 | |
|                     self.esmtp_features[feature]=params
 | |
|         return (code,msg)
 | |
| 
 | |
|     def has_extn(self, opt):
 | |
|         """Does the server support a given SMTP service extension?"""
 | |
|         return opt.lower() in self.esmtp_features
 | |
| 
 | |
|     def help(self, args=''):
 | |
|         """SMTP 'help' command.
 | |
|         Returns help text from server."""
 | |
|         self.putcmd("help", args)
 | |
|         return self.getreply()[1]
 | |
| 
 | |
|     def rset(self):
 | |
|         """SMTP 'rset' command -- resets session."""
 | |
|         return self.docmd("rset")
 | |
| 
 | |
|     def noop(self):
 | |
|         """SMTP 'noop' command -- doesn't do anything :>"""
 | |
|         return self.docmd("noop")
 | |
| 
 | |
|     def mail(self,sender,options=[]):
 | |
|         """SMTP 'mail' command -- begins mail xfer session."""
 | |
|         optionlist = ''
 | |
|         if options and self.does_esmtp:
 | |
|             optionlist = ' ' + ' '.join(options)
 | |
|         self.putcmd("mail", "FROM:%s%s" % (quoteaddr(sender) ,optionlist))
 | |
|         return self.getreply()
 | |
| 
 | |
|     def rcpt(self,recip,options=[]):
 | |
|         """SMTP 'rcpt' command -- indicates 1 recipient for this mail."""
 | |
|         optionlist = ''
 | |
|         if options and self.does_esmtp:
 | |
|             optionlist = ' ' + ' '.join(options)
 | |
|         self.putcmd("rcpt","TO:%s%s" % (quoteaddr(recip),optionlist))
 | |
|         return self.getreply()
 | |
| 
 | |
|     def data(self,msg):
 | |
|         """SMTP 'DATA' command -- sends message data to server.
 | |
| 
 | |
|         Automatically quotes lines beginning with a period per rfc821.
 | |
|         Raises SMTPDataError if there is an unexpected reply to the
 | |
|         DATA command; the return value from this method is the final
 | |
|         response code received when the all data is sent.
 | |
|         """
 | |
|         self.putcmd("data")
 | |
|         (code,repl)=self.getreply()
 | |
|         if self.debuglevel >0 : print("data:", (code,repl), file=stderr)
 | |
|         if code != 354:
 | |
|             raise SMTPDataError(code,repl)
 | |
|         else:
 | |
|             q = quotedata(msg)
 | |
|             if q[-2:] != CRLF:
 | |
|                 q = q + CRLF
 | |
|             q = q + "." + CRLF
 | |
|             self.send(q)
 | |
|             (code,msg)=self.getreply()
 | |
|             if self.debuglevel >0 : print("data:", (code,msg), file=stderr)
 | |
|             return (code,msg)
 | |
| 
 | |
|     def verify(self, address):
 | |
|         """SMTP 'verify' command -- checks for address validity."""
 | |
|         self.putcmd("vrfy", quoteaddr(address))
 | |
|         return self.getreply()
 | |
|     # a.k.a.
 | |
|     vrfy=verify
 | |
| 
 | |
|     def expn(self, address):
 | |
|         """SMTP 'verify' command -- checks for address validity."""
 | |
|         self.putcmd("expn", quoteaddr(address))
 | |
|         return self.getreply()
 | |
| 
 | |
|     # some useful methods
 | |
| 
 | |
|     def login(self, user, password):
 | |
|         """Log in on an SMTP server that requires authentication.
 | |
| 
 | |
|         The arguments are:
 | |
|             - user:     The user name to authenticate with.
 | |
|             - password: The password for the authentication.
 | |
| 
 | |
|         If there has been no previous EHLO or HELO command this session, this
 | |
|         method tries ESMTP EHLO first.
 | |
| 
 | |
|         This method will return normally if the authentication was successful.
 | |
| 
 | |
|         This method may raise the following exceptions:
 | |
| 
 | |
|          SMTPHeloError            The server didn't reply properly to
 | |
|                                   the helo greeting.
 | |
|          SMTPAuthenticationError  The server didn't accept the username/
 | |
|                                   password combination.
 | |
|          SMTPException            No suitable authentication method was
 | |
|                                   found.
 | |
|         """
 | |
| 
 | |
|         def encode_cram_md5(challenge, user, password):
 | |
|             challenge = base64.decodestring(challenge)
 | |
|             response = user + " " + hmac.HMAC(password, challenge).hexdigest()
 | |
|             return encode_base64(response)
 | |
| 
 | |
|         def encode_plain(user, password):
 | |
|             return encode_base64("\0%s\0%s" % (user, password))
 | |
| 
 | |
| 
 | |
|         AUTH_PLAIN = "PLAIN"
 | |
|         AUTH_CRAM_MD5 = "CRAM-MD5"
 | |
|         AUTH_LOGIN = "LOGIN"
 | |
| 
 | |
|         if self.helo_resp is None and self.ehlo_resp is None:
 | |
|             if not (200 <= self.ehlo()[0] <= 299):
 | |
|                 (code, resp) = self.helo()
 | |
|                 if not (200 <= code <= 299):
 | |
|                     raise SMTPHeloError(code, resp)
 | |
| 
 | |
|         if not self.has_extn("auth"):
 | |
|             raise SMTPException("SMTP AUTH extension not supported by server.")
 | |
| 
 | |
|         # Authentication methods the server supports:
 | |
|         authlist = self.esmtp_features["auth"].split()
 | |
| 
 | |
|         # List of authentication methods we support: from preferred to
 | |
|         # less preferred methods. Except for the purpose of testing the weaker
 | |
|         # ones, we prefer stronger methods like CRAM-MD5:
 | |
|         preferred_auths = [AUTH_CRAM_MD5, AUTH_PLAIN, AUTH_LOGIN]
 | |
| 
 | |
|         # Determine the authentication method we'll use
 | |
|         authmethod = None
 | |
|         for method in preferred_auths:
 | |
|             if method in authlist:
 | |
|                 authmethod = method
 | |
|                 break
 | |
| 
 | |
|         if authmethod == AUTH_CRAM_MD5:
 | |
|             (code, resp) = self.docmd("AUTH", AUTH_CRAM_MD5)
 | |
|             if code == 503:
 | |
|                 # 503 == 'Error: already authenticated'
 | |
|                 return (code, resp)
 | |
|             (code, resp) = self.docmd(encode_cram_md5(resp, user, password))
 | |
|         elif authmethod == AUTH_PLAIN:
 | |
|             (code, resp) = self.docmd("AUTH",
 | |
|                 AUTH_PLAIN + " " + encode_plain(user, password))
 | |
|         elif authmethod == AUTH_LOGIN:
 | |
|             (code, resp) = self.docmd("AUTH",
 | |
|                 "%s %s" % (AUTH_LOGIN, encode_base64(user)))
 | |
|             if code != 334:
 | |
|                 raise SMTPAuthenticationError(code, resp)
 | |
|             (code, resp) = self.docmd(encode_base64(password))
 | |
|         elif authmethod is None:
 | |
|             raise SMTPException("No suitable authentication method found.")
 | |
|         if code not in (235, 503):
 | |
|             # 235 == 'Authentication successful'
 | |
|             # 503 == 'Error: already authenticated'
 | |
|             raise SMTPAuthenticationError(code, resp)
 | |
|         return (code, resp)
 | |
| 
 | |
|     def starttls(self, keyfile = None, certfile = None):
 | |
|         """Puts the connection to the SMTP server into TLS mode.
 | |
| 
 | |
|         If the server supports TLS, this will encrypt the rest of the SMTP
 | |
|         session. If you provide the keyfile and certfile parameters,
 | |
|         the identity of the SMTP server and client can be checked. This,
 | |
|         however, depends on whether the socket module really checks the
 | |
|         certificates.
 | |
|         """
 | |
|         (resp, reply) = self.docmd("STARTTLS")
 | |
|         if resp == 220:
 | |
|             if not _have_ssl:
 | |
|                 raise RuntimeError("No SSL support included in this Python")
 | |
|             self.sock = ssl.sslsocket(self.sock, keyfile, certfile)
 | |
|             self.file = SSLFakeFile(self.sock)
 | |
|         return (resp, reply)
 | |
| 
 | |
|     def sendmail(self, from_addr, to_addrs, msg, mail_options=[],
 | |
|                  rcpt_options=[]):
 | |
|         """This command performs an entire mail transaction.
 | |
| 
 | |
|         The arguments are:
 | |
|             - from_addr    : The address sending this mail.
 | |
|             - to_addrs     : A list of addresses to send this mail to.  A bare
 | |
|                              string will be treated as a list with 1 address.
 | |
|             - msg          : The message to send.
 | |
|             - mail_options : List of ESMTP options (such as 8bitmime) for the
 | |
|                              mail command.
 | |
|             - rcpt_options : List of ESMTP options (such as DSN commands) for
 | |
|                              all the rcpt commands.
 | |
| 
 | |
|         If there has been no previous EHLO or HELO command this session, this
 | |
|         method tries ESMTP EHLO first.  If the server does ESMTP, message size
 | |
|         and each of the specified options will be passed to it.  If EHLO
 | |
|         fails, HELO will be tried and ESMTP options suppressed.
 | |
| 
 | |
|         This method will return normally if the mail is accepted for at least
 | |
|         one recipient.  It returns a dictionary, with one entry for each
 | |
|         recipient that was refused.  Each entry contains a tuple of the SMTP
 | |
|         error code and the accompanying error message sent by the server.
 | |
| 
 | |
|         This method may raise the following exceptions:
 | |
| 
 | |
|          SMTPHeloError          The server didn't reply properly to
 | |
|                                 the helo greeting.
 | |
|          SMTPRecipientsRefused  The server rejected ALL recipients
 | |
|                                 (no mail was sent).
 | |
|          SMTPSenderRefused      The server didn't accept the from_addr.
 | |
|          SMTPDataError          The server replied with an unexpected
 | |
|                                 error code (other than a refusal of
 | |
|                                 a recipient).
 | |
| 
 | |
|         Note: the connection will be open even after an exception is raised.
 | |
| 
 | |
|         Example:
 | |
| 
 | |
|          >>> import smtplib
 | |
|          >>> s=smtplib.SMTP("localhost")
 | |
|          >>> tolist=["one@one.org","two@two.org","three@three.org","four@four.org"]
 | |
|          >>> msg = '''\\
 | |
|          ... From: Me@my.org
 | |
|          ... Subject: testin'...
 | |
|          ...
 | |
|          ... This is a test '''
 | |
|          >>> s.sendmail("me@my.org",tolist,msg)
 | |
|          { "three@three.org" : ( 550 ,"User unknown" ) }
 | |
|          >>> s.quit()
 | |
| 
 | |
|         In the above example, the message was accepted for delivery to three
 | |
|         of the four addresses, and one was rejected, with the error code
 | |
|         550.  If all addresses are accepted, then the method will return an
 | |
|         empty dictionary.
 | |
| 
 | |
|         """
 | |
|         if self.helo_resp is None and self.ehlo_resp is None:
 | |
|             if not (200 <= self.ehlo()[0] <= 299):
 | |
|                 (code,resp) = self.helo()
 | |
|                 if not (200 <= code <= 299):
 | |
|                     raise SMTPHeloError(code, resp)
 | |
|         esmtp_opts = []
 | |
|         if self.does_esmtp:
 | |
|             # Hmmm? what's this? -ddm
 | |
|             # self.esmtp_features['7bit']=""
 | |
|             if self.has_extn('size'):
 | |
|                 esmtp_opts.append("size=%d" % len(msg))
 | |
|             for option in mail_options:
 | |
|                 esmtp_opts.append(option)
 | |
| 
 | |
|         (code,resp) = self.mail(from_addr, esmtp_opts)
 | |
|         if code != 250:
 | |
|             self.rset()
 | |
|             raise SMTPSenderRefused(code, resp, from_addr)
 | |
|         senderrs={}
 | |
|         if isinstance(to_addrs, basestring):
 | |
|             to_addrs = [to_addrs]
 | |
|         for each in to_addrs:
 | |
|             (code,resp)=self.rcpt(each, rcpt_options)
 | |
|             if (code != 250) and (code != 251):
 | |
|                 senderrs[each]=(code,resp)
 | |
|         if len(senderrs)==len(to_addrs):
 | |
|             # the server refused all our recipients
 | |
|             self.rset()
 | |
|             raise SMTPRecipientsRefused(senderrs)
 | |
|         (code,resp) = self.data(msg)
 | |
|         if code != 250:
 | |
|             self.rset()
 | |
|             raise SMTPDataError(code, resp)
 | |
|         #if we got here then somebody got our mail
 | |
|         return senderrs
 | |
| 
 | |
| 
 | |
|     def close(self):
 | |
|         """Close the connection to the SMTP server."""
 | |
|         if self.file:
 | |
|             self.file.close()
 | |
|         self.file = None
 | |
|         if self.sock:
 | |
|             self.sock.close()
 | |
|         self.sock = None
 | |
| 
 | |
| 
 | |
|     def quit(self):
 | |
|         """Terminate the SMTP session."""
 | |
|         self.docmd("quit")
 | |
|         self.close()
 | |
| 
 | |
| if _have_ssl:
 | |
| 
 | |
|     class SMTP_SSL(SMTP):
 | |
|         """ This is a subclass derived from SMTP that connects over an SSL encrypted
 | |
|         socket (to use this class you need a socket module that was compiled with SSL
 | |
|         support). If host is not specified, '' (the local host) is used. If port is
 | |
|         omitted, the standard SMTP-over-SSL port (465) is used. keyfile and certfile
 | |
|         are also optional - they can contain a PEM formatted private key and
 | |
|         certificate chain file for the SSL connection.
 | |
|         """
 | |
|         def __init__(self, host='', port=0, local_hostname=None,
 | |
|                      keyfile=None, certfile=None, timeout=None):
 | |
|             self.keyfile = keyfile
 | |
|             self.certfile = certfile
 | |
|             SMTP.__init__(self, host, port, local_hostname, timeout)
 | |
|             self.default_port = SMTP_SSL_PORT
 | |
| 
 | |
|         def _get_socket(self, host, port, timeout):
 | |
|             if self.debuglevel > 0: print('connect:', (host, port), file=stderr)
 | |
|             self.sock = socket.create_connection((host, port), timeout)
 | |
|             self.sock = ssl.sslsocket(self.sock, self.keyfile, self.certfile)
 | |
|             self.file = SSLFakeFile(self.sock)
 | |
| 
 | |
|     __all__.append("SMTP_SSL")
 | |
| 
 | |
| #
 | |
| # LMTP extension
 | |
| #
 | |
| LMTP_PORT = 2003
 | |
| 
 | |
| class LMTP(SMTP):
 | |
|     """LMTP - Local Mail Transfer Protocol
 | |
| 
 | |
|     The LMTP protocol, which is very similar to ESMTP, is heavily based
 | |
|     on the standard SMTP client. It's common to use Unix sockets for LMTP,
 | |
|     so our connect() method must support that as well as a regular
 | |
|     host:port server. To specify a Unix socket, you must use an absolute
 | |
|     path as the host, starting with a '/'.
 | |
| 
 | |
|     Authentication is supported, using the regular SMTP mechanism. When
 | |
|     using a Unix socket, LMTP generally don't support or require any
 | |
|     authentication, but your mileage might vary."""
 | |
| 
 | |
|     ehlo_msg = "lhlo"
 | |
| 
 | |
|     def __init__(self, host = '', port = LMTP_PORT, local_hostname = None):
 | |
|         """Initialize a new instance."""
 | |
|         SMTP.__init__(self, host, port, local_hostname)
 | |
| 
 | |
|     def connect(self, host = 'localhost', port = 0):
 | |
|         """Connect to the LMTP daemon, on either a Unix or a TCP socket."""
 | |
|         if host[0] != '/':
 | |
|             return SMTP.connect(self, host, port)
 | |
| 
 | |
|         # Handle Unix-domain sockets.
 | |
|         try:
 | |
|             self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
 | |
|             self.sock.connect(host)
 | |
|         except socket.error as msg:
 | |
|             if self.debuglevel > 0: print>>stderr, 'connect fail:', host
 | |
|             if self.sock:
 | |
|                 self.sock.close()
 | |
|             self.sock = None
 | |
|             raise socket.error(msg)
 | |
|         (code, msg) = self.getreply()
 | |
|         if self.debuglevel > 0: print>>stderr, "connect:", msg
 | |
|         return (code, msg)
 | |
| 
 | |
| 
 | |
| # Test the sendmail method, which tests most of the others.
 | |
| # Note: This always sends to localhost.
 | |
| if __name__ == '__main__':
 | |
|     import sys
 | |
| 
 | |
|     def prompt(prompt):
 | |
|         sys.stdout.write(prompt + ": ")
 | |
|         return sys.stdin.readline().strip()
 | |
| 
 | |
|     fromaddr = prompt("From")
 | |
|     toaddrs  = prompt("To").split(',')
 | |
|     print("Enter message, end with ^D:")
 | |
|     msg = ''
 | |
|     while 1:
 | |
|         line = sys.stdin.readline()
 | |
|         if not line:
 | |
|             break
 | |
|         msg = msg + line
 | |
|     print("Message length is %d" % len(msg))
 | |
| 
 | |
|     server = SMTP('localhost')
 | |
|     server.set_debuglevel(1)
 | |
|     server.sendmail(fromaddr, toaddrs, msg)
 | |
|     server.quit()
 |