golden hour

/lib64/python2.7

File/Folder	Size	Actions
BaseHTTPServer.py	21.93 KB
BaseHTTPServer.pyc	21.18 KB
BaseHTTPServer.pyo	21.18 KB
Bastion.py	5.61 KB
Bastion.pyc	6.5 KB
Bastion.pyo	6.5 KB
CGIHTTPServer.py	12.84 KB
CGIHTTPServer.pyc	10.84 KB
CGIHTTPServer.pyo	10.84 KB
ConfigParser.py	27.1 KB
ConfigParser.pyc	24.62 KB
ConfigParser.pyo	24.62 KB
Cookie.py	24.66 KB
Cookie.pyc	21.64 KB
Cookie.pyo	21.64 KB
Demo	-
Doc	-
DocXMLRPCServer.py	10.52 KB
DocXMLRPCServer.pyc	9.96 KB
DocXMLRPCServer.pyo	9.85 KB
HTMLParser.py	16.58 KB
HTMLParser.pyc	13.39 KB
HTMLParser.pyo	13.1 KB
MimeWriter.py	6.33 KB
MimeWriter.pyc	7.19 KB
MimeWriter.pyo	7.19 KB
Queue.py	8.36 KB
Queue.pyc	9.19 KB
Queue.pyo	9.19 KB
SimpleHTTPServer.py	7.25 KB
SimpleHTTPServer.pyc	7.55 KB
SimpleHTTPServer.pyo	7.55 KB
SimpleXMLRPCServer.py	25.17 KB
SimpleXMLRPCServer.pyc	22.31 KB
SimpleXMLRPCServer.pyo	22.31 KB
SocketServer.py	23.29 KB
SocketServer.pyc	23.49 KB
SocketServer.pyo	23.49 KB
StringIO.py	10.41 KB
StringIO.pyc	11.21 KB
StringIO.pyo	11.21 KB
Tools	-
UserDict.py	5.67 KB
UserDict.pyc	8.61 KB
UserDict.pyo	8.61 KB
UserList.py	3.56 KB
UserList.pyc	6.42 KB
UserList.pyo	6.42 KB
UserString.py	9.46 KB
UserString.pyc	14.52 KB
UserString.pyo	14.52 KB
_LWPCookieJar.py	6.4 KB
_LWPCookieJar.pyc	5.4 KB
_LWPCookieJar.pyo	5.4 KB
_MozillaCookieJar.py	5.67 KB
_MozillaCookieJar.pyc	4.37 KB
_MozillaCookieJar.pyo	4.33 KB
__future__.py	4.28 KB
__future__.pyc	4.13 KB
__future__.pyo	4.13 KB
__phello__.foo.py	64 B
__phello__.foo.pyc	125 B
__phello__.foo.pyo	125 B
_abcoll.py	17.45 KB
_abcoll.pyc	24.4 KB
_abcoll.pyo	24.4 KB
_osx_support.py	18.03 KB
_osx_support.pyc	11.28 KB
_osx_support.pyo	11.28 KB
_pyio.py	67.24 KB
_pyio.pyc	62.71 KB
_pyio.pyo	62.71 KB
_strptime.py	19.75 KB
_strptime.pyc	14.53 KB
_strptime.pyo	14.53 KB
_sysconfigdata.py	17.56 KB
_sysconfigdata.pyc	20.72 KB
_sysconfigdata.pyo	20.72 KB
_threading_local.py	7.28 KB
_threading_local.pyc	6.45 KB
_threading_local.pyo	6.45 KB
_weakrefset.py	5.48 KB
_weakrefset.pyc	9.25 KB
_weakrefset.pyo	9.25 KB
abc.py	6.98 KB
abc.pyc	6 KB
abc.pyo	5.94 KB
aifc.py	32.94 KB
aifc.pyc	29.31 KB
aifc.pyo	29.31 KB
antigravity.py	60 B
antigravity.pyc	203 B
antigravity.pyo	203 B
anydbm.py	2.6 KB
anydbm.pyc	2.73 KB
anydbm.pyo	2.73 KB
argparse.py	86.46 KB
argparse.pyc	62.57 KB
argparse.pyo	62.41 KB
ast.py	11.53 KB
ast.pyc	12.65 KB
ast.pyo	12.65 KB
asynchat.py	11.13 KB
asynchat.pyc	8.44 KB
asynchat.pyo	8.44 KB
asyncore.py	20.36 KB
asyncore.pyc	18.4 KB
asyncore.pyo	18.4 KB
atexit.py	1.67 KB
atexit.pyc	2.15 KB
atexit.pyo	2.15 KB
audiodev.py	7.42 KB
audiodev.pyc	8.27 KB
audiodev.pyo	8.27 KB
base64.py	11.09 KB
base64.pyc	10.63 KB
base64.pyo	10.63 KB
bdb.py	21.21 KB
bdb.pyc	18.65 KB
bdb.pyo	18.65 KB
binhex.py	14.14 KB
binhex.pyc	15.04 KB
binhex.pyo	15.04 KB
bisect.py	2.53 KB
bisect.pyc	3 KB
bisect.pyo	3 KB
bsddb	-
cProfile.py	6.43 KB
cProfile.pyc	6.25 KB
cProfile.pyo	6.25 KB
calendar.py	22.76 KB
calendar.pyc	27.13 KB
calendar.pyo	27.13 KB
cgi.py	34.31 KB
cgi.pyc	31.99 KB
cgi.pyo	31.99 KB
cgitb.py	11.89 KB
cgitb.pyc	11.9 KB
cgitb.pyo	11.9 KB
chunk.py	5.25 KB
chunk.pyc	5.46 KB
chunk.pyo	5.46 KB
cmd.py	14.67 KB
cmd.pyc	13.71 KB
cmd.pyo	13.71 KB
code.py	9.95 KB
code.pyc	10.09 KB
code.pyo	10.09 KB
codecs.py	34.44 KB
codecs.pyc	35.74 KB
codecs.pyo	35.74 KB
codeop.py	5.86 KB
codeop.pyc	6.44 KB
codeop.pyo	6.44 KB
collections.py	25.28 KB
collections.pyc	23.99 KB
collections.pyo	23.94 KB
colorsys.py	3.6 KB
colorsys.pyc	3.9 KB
colorsys.pyo	3.9 KB
commands.py	2.49 KB
commands.pyc	2.41 KB
commands.pyo	2.41 KB
compileall.py	7.58 KB
compileall.pyc	6.85 KB
compileall.pyo	6.85 KB
compiler	-
config	-
contextlib.py	4.32 KB
contextlib.pyc	4.35 KB
contextlib.pyo	4.35 KB
cookielib.py	63.21 KB
cookielib.pyc	53.55 KB
cookielib.pyo	53.37 KB
copy.py	11.25 KB
copy.pyc	11.91 KB
copy.pyo	11.82 KB
copy_reg.py	6.64 KB
copy_reg.pyc	4.99 KB
copy_reg.pyo	4.95 KB
crypt.py	2.24 KB
crypt.pyc	2.89 KB
crypt.pyo	2.89 KB
csv.py	15.96 KB
csv.pyc	13.14 KB
csv.pyo	13.14 KB
ctypes	-
curses	-
dbhash.py	498 B
dbhash.pyc	718 B
dbhash.pyo	718 B
decimal.py	215.84 KB
decimal.pyc	167.33 KB
decimal.pyo	167.33 KB
difflib.py	80.42 KB
difflib.pyc	60.5 KB
difflib.pyo	60.45 KB
dircache.py	1.1 KB
dircache.pyc	1.54 KB
dircache.pyo	1.54 KB
dis.py	6.35 KB
dis.pyc	6.08 KB
dis.pyo	6.08 KB
distutils	-
doctest.py	102.01 KB
doctest.pyc	81.45 KB
doctest.pyo	81.17 KB
dumbdbm.py	8.61 KB
dumbdbm.pyc	6.41 KB
dumbdbm.pyo	6.41 KB
dummy_thread.py	4.31 KB
dummy_thread.pyc	5.27 KB
dummy_thread.pyo	5.27 KB
dummy_threading.py	2.74 KB
dummy_threading.pyc	1.25 KB
dummy_threading.pyo	1.25 KB
email	-
encodings	-
filecmp.py	9.36 KB
filecmp.pyc	9.4 KB
filecmp.pyo	9.4 KB
fileinput.py	13.81 KB
fileinput.pyc	14.48 KB
fileinput.pyo	14.48 KB
fnmatch.py	3.16 KB
fnmatch.pyc	3.45 KB
fnmatch.pyo	3.45 KB
formatter.py	14.56 KB
formatter.pyc	18.73 KB
formatter.pyo	18.73 KB
fpformat.py	4.59 KB
fpformat.pyc	4.56 KB
fpformat.pyo	4.56 KB
fractions.py	21.87 KB
fractions.pyc	19.27 KB
fractions.pyo	19.27 KB
ftplib.py	36.1 KB
ftplib.pyc	33.38 KB
ftplib.pyo	33.38 KB
functools.py	4.37 KB
functools.pyc	5.95 KB
functools.pyo	5.95 KB
genericpath.py	2.94 KB
genericpath.pyc	3.19 KB
genericpath.pyo	3.19 KB
getopt.py	7.15 KB
getopt.pyc	6.5 KB
getopt.pyo	6.45 KB
getpass.py	5.43 KB
getpass.pyc	4.63 KB
getpass.pyo	4.63 KB
gettext.py	19.47 KB
gettext.pyc	15.19 KB
gettext.pyo	15.19 KB
glob.py	2.86 KB
glob.pyc	2.83 KB
glob.pyo	2.83 KB
gzip.py	18.26 KB
gzip.pyc	14.72 KB
gzip.pyo	14.72 KB
hashlib.py	7.48 KB
hashlib.pyc	6.74 KB
hashlib.pyo	6.74 KB
heapq.py	17.76 KB
heapq.pyc	14.13 KB
heapq.pyo	14.13 KB
hmac.py	4.48 KB
hmac.pyc	4.44 KB
hmac.pyo	4.44 KB
hotshot	-
htmlentitydefs.py	17.63 KB
htmlentitydefs.pyc	6.22 KB
htmlentitydefs.pyo	6.22 KB
htmllib.py	12.57 KB
htmllib.pyc	19.83 KB
htmllib.pyo	19.83 KB
httplib.py	51.37 KB
httplib.pyc	37.54 KB
httplib.pyo	37.37 KB
idlelib	-
ihooks.py	18.54 KB
ihooks.pyc	20.87 KB
ihooks.pyo	20.87 KB
imaplib.py	47.34 KB
imaplib.pyc	44.45 KB
imaplib.pyo	41.8 KB
imghdr.py	3.46 KB
imghdr.pyc	4.73 KB
imghdr.pyo	4.73 KB
importlib	-
imputil.py	25.16 KB
imputil.pyc	15.26 KB
imputil.pyo	15.08 KB
inspect.py	41.47 KB
inspect.pyc	39.04 KB
inspect.pyo	39.04 KB
io.py	3.12 KB
io.pyc	3.4 KB
io.pyo	3.4 KB
json	-
keyword.py	1.95 KB
keyword.pyc	2.06 KB
keyword.pyo	2.06 KB
lib-dynload	-
lib-tk	-
lib2to3	-
linecache.py	3.87 KB
linecache.pyc	3.14 KB
linecache.pyo	3.14 KB
locale.py	87.33 KB
locale.pyc	48.77 KB
locale.pyo	48.77 KB
logging	-
macpath.py	6.11 KB
macpath.pyc	7.47 KB
macpath.pyo	7.47 KB
macurl2path.py	3.2 KB
macurl2path.pyc	2.71 KB
macurl2path.pyo	2.71 KB
mailbox.py	78.86 KB
mailbox.pyc	74.87 KB
mailbox.pyo	74.82 KB
mailcap.py	8.2 KB
mailcap.pyc	7.77 KB
mailcap.pyo	7.77 KB
markupbase.py	14.3 KB
markupbase.pyc	9.08 KB
markupbase.pyo	8.89 KB
md5.py	358 B
md5.pyc	378 B
md5.pyo	378 B
mhlib.py	32.65 KB
mhlib.pyc	33.01 KB
mhlib.pyo	33.01 KB
mimetools.py	7 KB
mimetools.pyc	8.03 KB
mimetools.pyo	8.03 KB
mimetypes.py	20.22 KB
mimetypes.pyc	17.86 KB
mimetypes.pyo	17.86 KB
mimify.py	14.67 KB
mimify.pyc	11.71 KB
mimify.pyo	11.71 KB
modulefinder.py	23.71 KB
modulefinder.pyc	18.27 KB
modulefinder.pyo	18.19 KB
multifile.py	4.71 KB
multifile.pyc	5.29 KB
multifile.pyo	5.25 KB
multiprocessing	-
mutex.py	1.83 KB
mutex.pyc	2.46 KB
mutex.pyo	2.46 KB
netrc.py	4.47 KB
netrc.pyc	3.83 KB
netrc.pyo	3.83 KB
new.py	610 B
new.pyc	862 B
new.pyo	862 B
nntplib.py	20.97 KB
nntplib.pyc	20.55 KB
nntplib.pyo	20.55 KB
ntpath.py	18.02 KB
ntpath.pyc	11.6 KB
ntpath.pyo	11.56 KB
nturl2path.py	2.32 KB
nturl2path.pyc	1.77 KB
nturl2path.pyo	1.77 KB
numbers.py	10.08 KB
numbers.pyc	13.68 KB
numbers.pyo	13.68 KB
opcode.py	5.35 KB
opcode.pyc	6 KB
opcode.pyo	6 KB
optparse.py	59.69 KB
optparse.pyc	52.78 KB
optparse.pyo	52.7 KB
os.py	25.17 KB
os.pyc	24.96 KB
os.pyo	24.96 KB
os2emxpath.py	4.5 KB
os2emxpath.pyc	4.39 KB
os2emxpath.pyo	4.39 KB
pdb.doc	7.73 KB
pdb.py	44.94 KB
pdb.pyc	42.59 KB
pdb.pyo	42.59 KB
pickle.py	44.09 KB
pickle.pyc	37.56 KB
pickle.pyo	37.37 KB
pickletools.py	72.79 KB
pickletools.pyc	55.77 KB
pickletools.pyo	54.95 KB
pipes.py	9.36 KB
pipes.pyc	9.09 KB
pipes.pyo	9.09 KB
pkgutil.py	19.87 KB
pkgutil.pyc	18.49 KB
pkgutil.pyo	18.49 KB
plat-linux2	-
platform.py	51.98 KB
platform.pyc	36.06 KB
platform.pyo	36.06 KB
plistlib.py	15.44 KB
plistlib.pyc	19.52 KB
plistlib.pyo	19.44 KB
popen2.py	8.22 KB
popen2.pyc	8.81 KB
popen2.pyo	8.77 KB
poplib.py	12.64 KB
poplib.pyc	13.16 KB
poplib.pyo	13.16 KB
posixfile.py	7.82 KB
posixfile.pyc	7.47 KB
posixfile.pyo	7.47 KB
posixpath.py	13.27 KB
posixpath.pyc	11.03 KB
posixpath.pyo	11.03 KB
pprint.py	11.73 KB
pprint.pyc	10.06 KB
pprint.pyo	9.89 KB
profile.py	22.25 KB
profile.pyc	16.07 KB
profile.pyo	15.83 KB
pstats.py	26.08 KB
pstats.pyc	24.43 KB
pstats.pyo	24.43 KB
pty.py	4.94 KB
pty.pyc	4.85 KB
pty.pyo	4.85 KB
py_compile.py	5.79 KB
py_compile.pyc	6.27 KB
py_compile.pyo	6.27 KB
pyclbr.py	13.07 KB
pyclbr.pyc	9.42 KB
pyclbr.pyo	9.42 KB
pydoc.py	91.12 KB
pydoc.pyc	88.35 KB
pydoc.pyo	88.29 KB
pydoc_data	-
quopri.py	6.81 KB
quopri.pyc	6.42 KB
quopri.pyo	6.42 KB
random.py	31.45 KB
random.pyc	24.99 KB
random.pyo	24.99 KB
re.py	12.66 KB
re.pyc	12.79 KB
re.pyo	12.79 KB
repr.py	4.2 KB
repr.pyc	5.26 KB
repr.pyo	5.26 KB
rexec.py	19.68 KB
rexec.pyc	23.58 KB
rexec.pyo	23.58 KB
rfc822.py	32.51 KB
rfc822.pyc	31.05 KB
rfc822.pyo	31.05 KB
rlcompleter.py	5.68 KB
rlcompleter.pyc	5.84 KB
rlcompleter.pyo	5.84 KB
robotparser.py	7.03 KB
robotparser.pyc	7.7 KB
robotparser.pyo	7.7 KB
runpy.py	10.45 KB
runpy.pyc	8.21 KB
runpy.pyo	8.21 KB
sched.py	4.97 KB
sched.pyc	4.88 KB
sched.pyo	4.88 KB
sets.py	18.6 KB
sets.pyc	16.5 KB
sets.pyo	16.5 KB
sgmllib.py	17.46 KB
sgmllib.pyc	15.07 KB
sgmllib.pyo	15.07 KB
sha.py	393 B
sha.pyc	421 B
sha.pyo	421 B
shelve.py	7.89 KB
shelve.pyc	10.03 KB
shelve.pyo	10.03 KB
shlex.py	10.88 KB
shlex.pyc	7.37 KB
shlex.pyo	7.37 KB
shutil.py	18.46 KB
shutil.pyc	18.1 KB
shutil.pyo	18.1 KB
site-packages	-
site.py	19.61 KB
site.pyc	19.11 KB
site.pyo	19.11 KB
smtpd.py	18.11 KB
smtpd.pyc	15.52 KB
smtpd.pyo	15.52 KB
smtplib.py	30.9 KB
smtplib.pyc	29.29 KB
smtplib.pyo	29.29 KB
sndhdr.py	5.83 KB
sndhdr.pyc	7.18 KB
sndhdr.pyo	7.18 KB
socket.py	20.03 KB
socket.pyc	15.73 KB
socket.pyo	15.64 KB
sqlite3	-
sre.py	384 B
sre.pyc	519 B
sre.pyo	519 B
sre_compile.py	15.99 KB
sre_compile.pyc	10.76 KB
sre_compile.pyo	10.65 KB
sre_constants.py	6.95 KB
sre_constants.pyc	5.97 KB
sre_constants.pyo	5.97 KB
sre_parse.py	26.84 KB
sre_parse.pyc	18.98 KB
sre_parse.pyo	18.98 KB
ssl.py	38.7 KB
ssl.pyc	32.05 KB
ssl.pyo	32.05 KB
stat.py	1.8 KB
stat.pyc	2.69 KB
stat.pyo	2.69 KB
statvfs.py	898 B
statvfs.pyc	620 B
statvfs.pyo	620 B
string.py	20.27 KB
string.pyc	19.54 KB
string.pyo	19.54 KB
stringold.py	12.16 KB
stringold.pyc	12.25 KB
stringold.pyo	12.25 KB
stringprep.py	13.21 KB
stringprep.pyc	14.15 KB
stringprep.pyo	14.08 KB
struct.py	82 B
struct.pyc	239 B
struct.pyo	239 B
subprocess.py	57.68 KB
subprocess.pyc	40.93 KB
subprocess.pyo	40.93 KB
sunau.py	16.15 KB
sunau.pyc	17.53 KB
sunau.pyo	17.53 KB
sunaudio.py	1.37 KB
sunaudio.pyc	1.94 KB
sunaudio.pyo	1.94 KB
symbol.py	2.01 KB
symbol.pyc	2.96 KB
symbol.pyo	2.96 KB
symtable.py	7.34 KB
symtable.pyc	11.59 KB
symtable.pyo	11.46 KB
sysconfig.py	21.88 KB
sysconfig.pyc	17.23 KB
sysconfig.pyo	17.23 KB
tabnanny.py	11.07 KB
tabnanny.pyc	8.05 KB
tabnanny.pyo	8.05 KB
tarfile.py	88.12 KB
tarfile.pyc	73.84 KB
tarfile.pyo	73.84 KB
telnetlib.py	26.18 KB
telnetlib.pyc	22.53 KB
telnetlib.pyo	22.53 KB
tempfile.py	17.91 KB
tempfile.pyc	19.35 KB
tempfile.pyo	19.35 KB
test	-
textwrap.py	16.64 KB
textwrap.pyc	11.62 KB
textwrap.pyo	11.53 KB
this.py	1002 B
this.pyc	1.19 KB
this.pyo	1.19 KB
threading.py	46.28 KB
threading.pyc	41.7 KB
threading.pyo	39.58 KB
timeit.py	11.82 KB
timeit.pyc	11.5 KB
timeit.pyo	11.5 KB
toaiff.py	3.07 KB
toaiff.pyc	3.03 KB
toaiff.pyo	3.03 KB
token.py	2.88 KB
token.pyc	3.73 KB
token.pyo	3.73 KB
tokenize.py	16.15 KB
tokenize.pyc	13.61 KB
tokenize.pyo	13.52 KB
trace.py	29.19 KB
trace.pyc	22.26 KB
trace.pyo	22.2 KB
traceback.py	10.99 KB
traceback.pyc	11.35 KB
traceback.pyo	11.35 KB
tty.py	879 B
tty.pyc	1.29 KB
tty.pyo	1.29 KB
types.py	1.99 KB
types.pyc	2.45 KB
types.pyo	2.45 KB
unittest	-
urllib.py	57.14 KB
urllib.pyc	49.1 KB
urllib.pyo	49 KB
urllib2.py	52.13 KB
urllib2.pyc	46.61 KB
urllib2.pyo	46.52 KB
urlparse.py	16.82 KB
urlparse.pyc	15.67 KB
urlparse.pyo	15.67 KB
user.py	1.59 KB
user.pyc	1.68 KB
user.pyo	1.68 KB
uu.py	6.4 KB
uu.pyc	4.21 KB
uu.pyo	4.21 KB
uuid.py	20.6 KB
uuid.pyc	20.68 KB
uuid.pyo	20.68 KB
warnings.py	13.71 KB
warnings.pyc	12.84 KB
warnings.pyo	12.02 KB
wave.py	17.67 KB
wave.pyc	19 KB
wave.pyo	18.94 KB
weakref.py	10.44 KB
weakref.pyc	13.72 KB
weakref.pyo	13.72 KB
webbrowser.py	22.68 KB
webbrowser.pyc	19.83 KB
webbrowser.pyo	19.78 KB
whichdb.py	3.3 KB
whichdb.pyc	2.19 KB
whichdb.pyo	2.19 KB
wsgiref	-
wsgiref.egg-info	187 B
xdrlib.py	5.43 KB
xdrlib.pyc	9.07 KB
xdrlib.pyo	9.07 KB
xml	-
xmllib.py	34.05 KB
xmllib.pyc	26.22 KB
xmllib.pyo	26.22 KB
xmlrpclib.py	50.78 KB
xmlrpclib.pyc	42.89 KB
xmlrpclib.pyo	42.71 KB
zipfile.py	56.45 KB
zipfile.pyc	40.33 KB
zipfile.pyo	40.33 KB

Edit: mailbox.py

#! /usr/bin/env python

"""Read/write support for Maildir, mbox, MH, Babyl, and MMDF mailboxes."""

# Notes for authors of new mailbox subclasses:
#
# Remember to fsync() changes to disk before closing a modified file
# or returning from a flush() method.  See functions _sync_flush() and
# _sync_close().

import sys
import os
import time
import calendar
import socket
import errno
import copy
import email
import email.message
import email.generator
import StringIO
try:
    if sys.platform == 'os2emx':
        # OS/2 EMX fcntl() not adequate
        raise ImportError
    import fcntl
except ImportError:
    fcntl = None

import warnings
with warnings.catch_warnings():
    if sys.py3kwarning:
        warnings.filterwarnings("ignore", ".*rfc822 has been removed",
                                DeprecationWarning)
    import rfc822

__all__ = [ 'Mailbox', 'Maildir', 'mbox', 'MH', 'Babyl', 'MMDF',
            'Message', 'MaildirMessage', 'mboxMessage', 'MHMessage',
            'BabylMessage', 'MMDFMessage', 'UnixMailbox',
            'PortableUnixMailbox', 'MmdfMailbox', 'MHMailbox', 'BabylMailbox' ]

class Mailbox:
    """A group of messages in a particular place."""

def __init__(self, path, factory=None, create=True):
        """Initialize a Mailbox instance."""
        self._path = os.path.abspath(os.path.expanduser(path))
        self._factory = factory

def add(self, message):
        """Add message and return assigned key."""
        raise NotImplementedError('Method must be implemented by subclass')

def remove(self, key):
        """Remove the keyed message; raise KeyError if it doesn't exist."""
        raise NotImplementedError('Method must be implemented by subclass')

def __delitem__(self, key):
        self.remove(key)

def discard(self, key):
        """If the keyed message exists, remove it."""
        try:
            self.remove(key)
        except KeyError:
            pass

def __setitem__(self, key, message):
        """Replace the keyed message; raise KeyError if it doesn't exist."""
        raise NotImplementedError('Method must be implemented by subclass')

def get(self, key, default=None):
        """Return the keyed message, or default if it doesn't exist."""
        try:
            return self.__getitem__(key)
        except KeyError:
            return default

def __getitem__(self, key):
        """Return the keyed message; raise KeyError if it doesn't exist."""
        if not self._factory:
            return self.get_message(key)
        else:
            return self._factory(self.get_file(key))

def get_message(self, key):
        """Return a Message representation or raise a KeyError."""
        raise NotImplementedError('Method must be implemented by subclass')

def get_string(self, key):
        """Return a string representation or raise a KeyError."""
        raise NotImplementedError('Method must be implemented by subclass')

def get_file(self, key):
        """Return a file-like representation or raise a KeyError."""
        raise NotImplementedError('Method must be implemented by subclass')

def iterkeys(self):
        """Return an iterator over keys."""
        raise NotImplementedError('Method must be implemented by subclass')

def keys(self):
        """Return a list of keys."""
        return list(self.iterkeys())

def itervalues(self):
        """Return an iterator over all messages."""
        for key in self.iterkeys():
            try:
                value = self[key]
            except KeyError:
                continue
            yield value

def __iter__(self):
        return self.itervalues()

def values(self):
        """Return a list of messages. Memory intensive."""
        return list(self.itervalues())

def iteritems(self):
        """Return an iterator over (key, message) tuples."""
        for key in self.iterkeys():
            try:
                value = self[key]
            except KeyError:
                continue
            yield (key, value)

def items(self):
        """Return a list of (key, message) tuples. Memory intensive."""
        return list(self.iteritems())

def has_key(self, key):
        """Return True if the keyed message exists, False otherwise."""
        raise NotImplementedError('Method must be implemented by subclass')

def __contains__(self, key):
        return self.has_key(key)

def __len__(self):
        """Return a count of messages in the mailbox."""
        raise NotImplementedError('Method must be implemented by subclass')

def clear(self):
        """Delete all messages."""
        for key in self.iterkeys():
            self.discard(key)

def pop(self, key, default=None):
        """Delete the keyed message and return it, or default."""
        try:
            result = self[key]
        except KeyError:
            return default
        self.discard(key)
        return result

def popitem(self):
        """Delete an arbitrary (key, message) pair and return it."""
        for key in self.iterkeys():
            return (key, self.pop(key))     # This is only run once.
        else:
            raise KeyError('No messages in mailbox')

def update(self, arg=None):
        """Change the messages that correspond to certain keys."""
        if hasattr(arg, 'iteritems'):
            source = arg.iteritems()
        elif hasattr(arg, 'items'):
            source = arg.items()
        else:
            source = arg
        bad_key = False
        for key, message in source:
            try:
                self[key] = message
            except KeyError:
                bad_key = True
        if bad_key:
            raise KeyError('No message with key(s)')

def flush(self):
        """Write any pending changes to the disk."""
        raise NotImplementedError('Method must be implemented by subclass')

def lock(self):
        """Lock the mailbox."""
        raise NotImplementedError('Method must be implemented by subclass')

def unlock(self):
        """Unlock the mailbox if it is locked."""
        raise NotImplementedError('Method must be implemented by subclass')

def close(self):
        """Flush and close the mailbox."""
        raise NotImplementedError('Method must be implemented by subclass')

# Whether each message must end in a newline
    _append_newline = False

def _dump_message(self, message, target, mangle_from_=False):
        # Most files are opened in binary mode to allow predictable seeking.
        # To get native line endings on disk, the user-friendly \n line endings
        # used in strings and by email.Message are translated here.
        """Dump message contents to target file."""
        if isinstance(message, email.message.Message):
            buffer = StringIO.StringIO()
            gen = email.generator.Generator(buffer, mangle_from_, 0)
            gen.flatten(message)
            buffer.seek(0)
            data = buffer.read().replace('\n', os.linesep)
            target.write(data)
            if self._append_newline and not data.endswith(os.linesep):
                # Make sure the message ends with a newline
                target.write(os.linesep)
        elif isinstance(message, str):
            if mangle_from_:
                message = message.replace('\nFrom ', '\n>From ')
            message = message.replace('\n', os.linesep)
            target.write(message)
            if self._append_newline and not message.endswith(os.linesep):
                # Make sure the message ends with a newline
                target.write(os.linesep)
        elif hasattr(message, 'read'):
            lastline = None
            while True:
                line = message.readline()
                if line == '':
                    break
                if mangle_from_ and line.startswith('From '):
                    line = '>From ' + line[5:]
                line = line.replace('\n', os.linesep)
                target.write(line)
                lastline = line
            if self._append_newline and lastline and not lastline.endswith(os.linesep):
                # Make sure the message ends with a newline
                target.write(os.linesep)
        else:
            raise TypeError('Invalid message type: %s' % type(message))

class Maildir(Mailbox):
    """A qmail-style Maildir mailbox."""

colon = ':'

def __init__(self, dirname, factory=rfc822.Message, create=True):
        """Initialize a Maildir instance."""
        Mailbox.__init__(self, dirname, factory, create)
        self._paths = {
            'tmp': os.path.join(self._path, 'tmp'),
            'new': os.path.join(self._path, 'new'),
            'cur': os.path.join(self._path, 'cur'),
            }
        if not os.path.exists(self._path):
            if create:
                os.mkdir(self._path, 0700)
                for path in self._paths.values():
                    os.mkdir(path, 0o700)
            else:
                raise NoSuchMailboxError(self._path)
        self._toc = {}
        self._toc_mtimes = {'cur': 0, 'new': 0}
        self._last_read = 0         # Records last time we read cur/new
        self._skewfactor = 0.1      # Adjust if os/fs clocks are skewing

def add(self, message):
        """Add message and return assigned key."""
        tmp_file = self._create_tmp()
        try:
            self._dump_message(message, tmp_file)
        except BaseException:
            tmp_file.close()
            os.remove(tmp_file.name)
            raise
        _sync_close(tmp_file)
        if isinstance(message, MaildirMessage):
            subdir = message.get_subdir()
            suffix = self.colon + message.get_info()
            if suffix == self.colon:
                suffix = ''
        else:
            subdir = 'new'
            suffix = ''
        uniq = os.path.basename(tmp_file.name).split(self.colon)[0]
        dest = os.path.join(self._path, subdir, uniq + suffix)
        try:
            if hasattr(os, 'link'):
                os.link(tmp_file.name, dest)
                os.remove(tmp_file.name)
            else:
                os.rename(tmp_file.name, dest)
        except OSError, e:
            os.remove(tmp_file.name)
            if e.errno == errno.EEXIST:
                raise ExternalClashError('Name clash with existing message: %s'
                                         % dest)
            else:
                raise
        if isinstance(message, MaildirMessage):
            os.utime(dest, (os.path.getatime(dest), message.get_date()))
        return uniq

def remove(self, key):
        """Remove the keyed message; raise KeyError if it doesn't exist."""
        os.remove(os.path.join(self._path, self._lookup(key)))

def discard(self, key):
        """If the keyed message exists, remove it."""
        # This overrides an inapplicable implementation in the superclass.
        try:
            self.remove(key)
        except KeyError:
            pass
        except OSError, e:
            if e.errno != errno.ENOENT:
                raise

def __setitem__(self, key, message):
        """Replace the keyed message; raise KeyError if it doesn't exist."""
        old_subpath = self._lookup(key)
        temp_key = self.add(message)
        temp_subpath = self._lookup(temp_key)
        if isinstance(message, MaildirMessage):
            # temp's subdir and suffix were specified by message.
            dominant_subpath = temp_subpath
        else:
            # temp's subdir and suffix were defaults from add().
            dominant_subpath = old_subpath
        subdir = os.path.dirname(dominant_subpath)
        if self.colon in dominant_subpath:
            suffix = self.colon + dominant_subpath.split(self.colon)[-1]
        else:
            suffix = ''
        self.discard(key)
        new_path = os.path.join(self._path, subdir, key + suffix)
        os.rename(os.path.join(self._path, temp_subpath), new_path)
        if isinstance(message, MaildirMessage):
            os.utime(new_path, (os.path.getatime(new_path),
                                message.get_date()))

def get_message(self, key):
        """Return a Message representation or raise a KeyError."""
        subpath = self._lookup(key)
        f = open(os.path.join(self._path, subpath), 'r')
        try:
            if self._factory:
                msg = self._factory(f)
            else:
                msg = MaildirMessage(f)
        finally:
            f.close()
        subdir, name = os.path.split(subpath)
        msg.set_subdir(subdir)
        if self.colon in name:
            msg.set_info(name.split(self.colon)[-1])
        msg.set_date(os.path.getmtime(os.path.join(self._path, subpath)))
        return msg

def get_string(self, key):
        """Return a string representation or raise a KeyError."""
        f = open(os.path.join(self._path, self._lookup(key)), 'r')
        try:
            return f.read()
        finally:
            f.close()

def get_file(self, key):
        """Return a file-like representation or raise a KeyError."""
        f = open(os.path.join(self._path, self._lookup(key)), 'rb')
        return _ProxyFile(f)

def iterkeys(self):
        """Return an iterator over keys."""
        self._refresh()
        for key in self._toc:
            try:
                self._lookup(key)
            except KeyError:
                continue
            yield key

def has_key(self, key):
        """Return True if the keyed message exists, False otherwise."""
        self._refresh()
        return key in self._toc

def __len__(self):
        """Return a count of messages in the mailbox."""
        self._refresh()
        return len(self._toc)

def flush(self):
        """Write any pending changes to disk."""
        # Maildir changes are always written immediately, so there's nothing
        # to do.
        pass

def lock(self):
        """Lock the mailbox."""
        return

def unlock(self):
        """Unlock the mailbox if it is locked."""
        return

def close(self):
        """Flush and close the mailbox."""
        return

def list_folders(self):
        """Return a list of folder names."""
        result = []
        for entry in os.listdir(self._path):
            if len(entry) > 1 and entry[0] == '.' and \
               os.path.isdir(os.path.join(self._path, entry)):
                result.append(entry[1:])
        return result

def get_folder(self, folder):
        """Return a Maildir instance for the named folder."""
        return Maildir(os.path.join(self._path, '.' + folder),
                       factory=self._factory,
                       create=False)

def add_folder(self, folder):
        """Create a folder and return a Maildir instance representing it."""
        path = os.path.join(self._path, '.' + folder)
        result = Maildir(path, factory=self._factory)
        maildirfolder_path = os.path.join(path, 'maildirfolder')
        if not os.path.exists(maildirfolder_path):
            os.close(os.open(maildirfolder_path, os.O_CREAT | os.O_WRONLY,
                0666))
        return result

def remove_folder(self, folder):
        """Delete the named folder, which must be empty."""
        path = os.path.join(self._path, '.' + folder)
        for entry in os.listdir(os.path.join(path, 'new')) + \
                     os.listdir(os.path.join(path, 'cur')):
            if len(entry) < 1 or entry[0] != '.':
                raise NotEmptyError('Folder contains message(s): %s' % folder)
        for entry in os.listdir(path):
            if entry != 'new' and entry != 'cur' and entry != 'tmp' and \
               os.path.isdir(os.path.join(path, entry)):
                raise NotEmptyError("Folder contains subdirectory '%s': %s" %
                                    (folder, entry))
        for root, dirs, files in os.walk(path, topdown=False):
            for entry in files:
                os.remove(os.path.join(root, entry))
            for entry in dirs:
                os.rmdir(os.path.join(root, entry))
        os.rmdir(path)

def clean(self):
        """Delete old files in "tmp"."""
        now = time.time()
        for entry in os.listdir(os.path.join(self._path, 'tmp')):
            path = os.path.join(self._path, 'tmp', entry)
            if now - os.path.getatime(path) > 129600:   # 60 * 60 * 36
                os.remove(path)

_count = 1  # This is used to generate unique file names.

def _create_tmp(self):
        """Create a file in the tmp subdirectory and open and return it."""
        now = time.time()
        hostname = socket.gethostname()
        if '/' in hostname:
            hostname = hostname.replace('/', r'\057')
        if ':' in hostname:
            hostname = hostname.replace(':', r'\072')
        uniq = "%s.M%sP%sQ%s.%s" % (int(now), int(now % 1 * 1e6), os.getpid(),
                                    Maildir._count, hostname)
        path = os.path.join(self._path, 'tmp', uniq)
        try:
            os.stat(path)
        except OSError, e:
            if e.errno == errno.ENOENT:
                Maildir._count += 1
                try:
                    return _create_carefully(path)
                except OSError, e:
                    if e.errno != errno.EEXIST:
                        raise
            else:
                raise

# Fall through to here if stat succeeded or open raised EEXIST.
        raise ExternalClashError('Name clash prevented file creation: %s' %
                                 path)

def _refresh(self):
        """Update table of contents mapping."""
        # If it has been less than two seconds since the last _refresh() call,
        # we have to unconditionally re-read the mailbox just in case it has
        # been modified, because os.path.mtime() has a 2 sec resolution in the
        # most common worst case (FAT) and a 1 sec resolution typically.  This
        # results in a few unnecessary re-reads when _refresh() is called
        # multiple times in that interval, but once the clock ticks over, we
        # will only re-read as needed.  Because the filesystem might be being
        # served by an independent system with its own clock, we record and
        # compare with the mtimes from the filesystem.  Because the other
        # system's clock might be skewing relative to our clock, we add an
        # extra delta to our wait.  The default is one tenth second, but is an
        # instance variable and so can be adjusted if dealing with a
        # particularly skewed or irregular system.
        if time.time() - self._last_read > 2 + self._skewfactor:
            refresh = False
            for subdir in self._toc_mtimes:
                mtime = os.path.getmtime(self._paths[subdir])
                if mtime > self._toc_mtimes[subdir]:
                    refresh = True
                self._toc_mtimes[subdir] = mtime
            if not refresh:
                return
        # Refresh toc
        self._toc = {}
        for subdir in self._toc_mtimes:
            path = self._paths[subdir]
            for entry in os.listdir(path):
                p = os.path.join(path, entry)
                if os.path.isdir(p):
                    continue
                uniq = entry.split(self.colon)[0]
                self._toc[uniq] = os.path.join(subdir, entry)
        self._last_read = time.time()

def _lookup(self, key):
        """Use TOC to return subpath for given key, or raise a KeyError."""
        try:
            if os.path.exists(os.path.join(self._path, self._toc[key])):
                return self._toc[key]
        except KeyError:
            pass
        self._refresh()
        try:
            return self._toc[key]
        except KeyError:
            raise KeyError('No message with key: %s' % key)

# This method is for backward compatibility only.
    def next(self):
        """Return the next message in a one-time iteration."""
        if not hasattr(self, '_onetime_keys'):
            self._onetime_keys = self.iterkeys()
        while True:
            try:
                return self[self._onetime_keys.next()]
            except StopIteration:
                return None
            except KeyError:
                continue

class _singlefileMailbox(Mailbox):
    """A single-file mailbox."""

def __init__(self, path, factory=None, create=True):
        """Initialize a single-file mailbox."""
        Mailbox.__init__(self, path, factory, create)
        try:
            f = open(self._path, 'rb+')
        except IOError, e:
            if e.errno == errno.ENOENT:
                if create:
                    f = open(self._path, 'wb+')
                else:
                    raise NoSuchMailboxError(self._path)
            elif e.errno in (errno.EACCES, errno.EROFS):
                f = open(self._path, 'rb')
            else:
                raise
        self._file = f
        self._toc = None
        self._next_key = 0
        self._pending = False       # No changes require rewriting the file.
        self._pending_sync = False  # No need to sync the file
        self._locked = False
        self._file_length = None    # Used to record mailbox size

def add(self, message):
        """Add message and return assigned key."""
        self._lookup()
        self._toc[self._next_key] = self._append_message(message)
        self._next_key += 1
        # _append_message appends the message to the mailbox file. We
        # don't need a full rewrite + rename, sync is enough.
        self._pending_sync = True
        return self._next_key - 1

def remove(self, key):
        """Remove the keyed message; raise KeyError if it doesn't exist."""
        self._lookup(key)
        del self._toc[key]
        self._pending = True

def __setitem__(self, key, message):
        """Replace the keyed message; raise KeyError if it doesn't exist."""
        self._lookup(key)
        self._toc[key] = self._append_message(message)
        self._pending = True

def iterkeys(self):
        """Return an iterator over keys."""
        self._lookup()
        for key in self._toc.keys():
            yield key

def has_key(self, key):
        """Return True if the keyed message exists, False otherwise."""
        self._lookup()
        return key in self._toc

def __len__(self):
        """Return a count of messages in the mailbox."""
        self._lookup()
        return len(self._toc)

def lock(self):
        """Lock the mailbox."""
        if not self._locked:
            _lock_file(self._file)
            self._locked = True

def unlock(self):
        """Unlock the mailbox if it is locked."""
        if self._locked:
            _unlock_file(self._file)
            self._locked = False

def flush(self):
        """Write any pending changes to disk."""
        if not self._pending:
            if self._pending_sync:
                # Messages have only been added, so syncing the file
                # is enough.
                _sync_flush(self._file)
                self._pending_sync = False
            return

# In order to be writing anything out at all, self._toc must
        # already have been generated (and presumably has been modified
        # by adding or deleting an item).
        assert self._toc is not None

# Check length of self._file; if it's changed, some other process
        # has modified the mailbox since we scanned it.
        self._file.seek(0, 2)
        cur_len = self._file.tell()
        if cur_len != self._file_length:
            raise ExternalClashError('Size of mailbox file changed '
                                     '(expected %i, found %i)' %
                                     (self._file_length, cur_len))

new_file = _create_temporary(self._path)
        try:
            new_toc = {}
            self._pre_mailbox_hook(new_file)
            for key in sorted(self._toc.keys()):
                start, stop = self._toc[key]
                self._file.seek(start)
                self._pre_message_hook(new_file)
                new_start = new_file.tell()
                while True:
                    buffer = self._file.read(min(4096,
                                                 stop - self._file.tell()))
                    if buffer == '':
                        break
                    new_file.write(buffer)
                new_toc[key] = (new_start, new_file.tell())
                self._post_message_hook(new_file)
            self._file_length = new_file.tell()
        except:
            new_file.close()
            os.remove(new_file.name)
            raise
        _sync_close(new_file)
        # self._file is about to get replaced, so no need to sync.
        self._file.close()
        # Make sure the new file's mode is the same as the old file's
        mode = os.stat(self._path).st_mode
        os.chmod(new_file.name, mode)
        try:
            os.rename(new_file.name, self._path)
        except OSError, e:
            if e.errno == errno.EEXIST or \
              (os.name == 'os2' and e.errno == errno.EACCES):
                os.remove(self._path)
                os.rename(new_file.name, self._path)
            else:
                raise
        self._file = open(self._path, 'rb+')
        self._toc = new_toc
        self._pending = False
        self._pending_sync = False
        if self._locked:
            _lock_file(self._file, dotlock=False)

def _pre_mailbox_hook(self, f):
        """Called before writing the mailbox to file f."""
        return

def _pre_message_hook(self, f):
        """Called before writing each message to file f."""
        return

def _post_message_hook(self, f):
        """Called after writing each message to file f."""
        return

def close(self):
        """Flush and close the mailbox."""
        self.flush()
        if self._locked:
            self.unlock()
        self._file.close()  # Sync has been done by self.flush() above.

def _lookup(self, key=None):
        """Return (start, stop) or raise KeyError."""
        if self._toc is None:
            self._generate_toc()
        if key is not None:
            try:
                return self._toc[key]
            except KeyError:
                raise KeyError('No message with key: %s' % key)

def _append_message(self, message):
        """Append message to mailbox and return (start, stop) offsets."""
        self._file.seek(0, 2)
        before = self._file.tell()
        if len(self._toc) == 0 and not self._pending:
            # This is the first message, and the _pre_mailbox_hook
            # hasn't yet been called. If self._pending is True,
            # messages have been removed, so _pre_mailbox_hook must
            # have been called already.
            self._pre_mailbox_hook(self._file)
        try:
            self._pre_message_hook(self._file)
            offsets = self._install_message(message)
            self._post_message_hook(self._file)
        except BaseException:
            self._file.truncate(before)
            raise
        self._file.flush()
        self._file_length = self._file.tell()  # Record current length of mailbox
        return offsets

class _mboxMMDF(_singlefileMailbox):
    """An mbox or MMDF mailbox."""

_mangle_from_ = True

def get_message(self, key):
        """Return a Message representation or raise a KeyError."""
        start, stop = self._lookup(key)
        self._file.seek(start)
        from_line = self._file.readline().replace(os.linesep, '')
        string = self._file.read(stop - self._file.tell())
        msg = self._message_factory(string.replace(os.linesep, '\n'))
        msg.set_from(from_line[5:])
        return msg

def get_string(self, key, from_=False):
        """Return a string representation or raise a KeyError."""
        start, stop = self._lookup(key)
        self._file.seek(start)
        if not from_:
            self._file.readline()
        string = self._file.read(stop - self._file.tell())
        return string.replace(os.linesep, '\n')

def get_file(self, key, from_=False):
        """Return a file-like representation or raise a KeyError."""
        start, stop = self._lookup(key)
        self._file.seek(start)
        if not from_:
            self._file.readline()
        return _PartialFile(self._file, self._file.tell(), stop)

def _install_message(self, message):
        """Format a message and blindly write to self._file."""
        from_line = None
        if isinstance(message, str) and message.startswith('From '):
            newline = message.find('\n')
            if newline != -1:
                from_line = message[:newline]
                message = message[newline + 1:]
            else:
                from_line = message
                message = ''
        elif isinstance(message, _mboxMMDFMessage):
            from_line = 'From ' + message.get_from()
        elif isinstance(message, email.message.Message):
            from_line = message.get_unixfrom()  # May be None.
        if from_line is None:
            from_line = 'From MAILER-DAEMON %s' % time.asctime(time.gmtime())
        start = self._file.tell()
        self._file.write(from_line + os.linesep)
        self._dump_message(message, self._file, self._mangle_from_)
        stop = self._file.tell()
        return (start, stop)

class mbox(_mboxMMDF):
    """A classic mbox mailbox."""

_mangle_from_ = True

# All messages must end in a newline character, and
    # _post_message_hooks outputs an empty line between messages.
    _append_newline = True

def __init__(self, path, factory=None, create=True):
        """Initialize an mbox mailbox."""
        self._message_factory = mboxMessage
        _mboxMMDF.__init__(self, path, factory, create)

def _post_message_hook(self, f):
        """Called after writing each message to file f."""
        f.write(os.linesep)

def _generate_toc(self):
        """Generate key-to-(start, stop) table of contents."""
        starts, stops = [], []
        last_was_empty = False
        self._file.seek(0)
        while True:
            line_pos = self._file.tell()
            line = self._file.readline()
            if line.startswith('From '):
                if len(stops) < len(starts):
                    if last_was_empty:
                        stops.append(line_pos - len(os.linesep))
                    else:
                        # The last line before the "From " line wasn't
                        # blank, but we consider it a start of a
                        # message anyway.
                        stops.append(line_pos)
                starts.append(line_pos)
                last_was_empty = False
            elif not line:
                if last_was_empty:
                    stops.append(line_pos - len(os.linesep))
                else:
                    stops.append(line_pos)
                break
            elif line == os.linesep:
                last_was_empty = True
            else:
                last_was_empty = False
        self._toc = dict(enumerate(zip(starts, stops)))
        self._next_key = len(self._toc)
        self._file_length = self._file.tell()

class MMDF(_mboxMMDF):
    """An MMDF mailbox."""

def __init__(self, path, factory=None, create=True):
        """Initialize an MMDF mailbox."""
        self._message_factory = MMDFMessage
        _mboxMMDF.__init__(self, path, factory, create)

def _pre_message_hook(self, f):
        """Called before writing each message to file f."""
        f.write('\001\001\001\001' + os.linesep)

def _post_message_hook(self, f):
        """Called after writing each message to file f."""
        f.write(os.linesep + '\001\001\001\001' + os.linesep)

def _generate_toc(self):
        """Generate key-to-(start, stop) table of contents."""
        starts, stops = [], []
        self._file.seek(0)
        next_pos = 0
        while True:
            line_pos = next_pos
            line = self._file.readline()
            next_pos = self._file.tell()
            if line.startswith('\001\001\001\001' + os.linesep):
                starts.append(next_pos)
                while True:
                    line_pos = next_pos
                    line = self._file.readline()
                    next_pos = self._file.tell()
                    if line == '\001\001\001\001' + os.linesep:
                        stops.append(line_pos - len(os.linesep))
                        break
                    elif line == '':
                        stops.append(line_pos)
                        break
            elif line == '':
                break
        self._toc = dict(enumerate(zip(starts, stops)))
        self._next_key = len(self._toc)
        self._file.seek(0, 2)
        self._file_length = self._file.tell()

class MH(Mailbox):
    """An MH mailbox."""

def __init__(self, path, factory=None, create=True):
        """Initialize an MH instance."""
        Mailbox.__init__(self, path, factory, create)
        if not os.path.exists(self._path):
            if create:
                os.mkdir(self._path, 0700)
                os.close(os.open(os.path.join(self._path, '.mh_sequences'),
                                 os.O_CREAT | os.O_EXCL | os.O_WRONLY, 0600))
            else:
                raise NoSuchMailboxError(self._path)
        self._locked = False

def add(self, message):
        """Add message and return assigned key."""
        keys = self.keys()
        if len(keys) == 0:
            new_key = 1
        else:
            new_key = max(keys) + 1
        new_path = os.path.join(self._path, str(new_key))
        f = _create_carefully(new_path)
        closed = False
        try:
            if self._locked:
                _lock_file(f)
            try:
                try:
                    self._dump_message(message, f)
                except BaseException:
                    # Unlock and close so it can be deleted on Windows
                    if self._locked:
                        _unlock_file(f)
                    _sync_close(f)
                    closed = True
                    os.remove(new_path)
                    raise
                if isinstance(message, MHMessage):
                    self._dump_sequences(message, new_key)
            finally:
                if self._locked:
                    _unlock_file(f)
        finally:
            if not closed:
                _sync_close(f)
        return new_key

def remove(self, key):
        """Remove the keyed message; raise KeyError if it doesn't exist."""
        path = os.path.join(self._path, str(key))
        try:
            f = open(path, 'rb+')
        except IOError, e:
            if e.errno == errno.ENOENT:
                raise KeyError('No message with key: %s' % key)
            else:
                raise
        else:
            f.close()
            os.remove(path)

def __setitem__(self, key, message):
        """Replace the keyed message; raise KeyError if it doesn't exist."""
        path = os.path.join(self._path, str(key))
        try:
            f = open(path, 'rb+')
        except IOError, e:
            if e.errno == errno.ENOENT:
                raise KeyError('No message with key: %s' % key)
            else:
                raise
        try:
            if self._locked:
                _lock_file(f)
            try:
                os.close(os.open(path, os.O_WRONLY | os.O_TRUNC))
                self._dump_message(message, f)
                if isinstance(message, MHMessage):
                    self._dump_sequences(message, key)
            finally:
                if self._locked:
                    _unlock_file(f)
        finally:
            _sync_close(f)

def get_message(self, key):
        """Return a Message representation or raise a KeyError."""
        try:
            if self._locked:
                f = open(os.path.join(self._path, str(key)), 'r+')
            else:
                f = open(os.path.join(self._path, str(key)), 'r')
        except IOError, e:
            if e.errno == errno.ENOENT:
                raise KeyError('No message with key: %s' % key)
            else:
                raise
        try:
            if self._locked:
                _lock_file(f)
            try:
                msg = MHMessage(f)
            finally:
                if self._locked:
                    _unlock_file(f)
        finally:
            f.close()
        for name, key_list in self.get_sequences().iteritems():
            if key in key_list:
                msg.add_sequence(name)
        return msg

def get_string(self, key):
        """Return a string representation or raise a KeyError."""
        try:
            if self._locked:
                f = open(os.path.join(self._path, str(key)), 'r+')
            else:
                f = open(os.path.join(self._path, str(key)), 'r')
        except IOError, e:
            if e.errno == errno.ENOENT:
                raise KeyError('No message with key: %s' % key)
            else:
                raise
        try:
            if self._locked:
                _lock_file(f)
            try:
                return f.read()
            finally:
                if self._locked:
                    _unlock_file(f)
        finally:
            f.close()

def get_file(self, key):
        """Return a file-like representation or raise a KeyError."""
        try:
            f = open(os.path.join(self._path, str(key)), 'rb')
        except IOError, e:
            if e.errno == errno.ENOENT:
                raise KeyError('No message with key: %s' % key)
            else:
                raise
        return _ProxyFile(f)

def iterkeys(self):
        """Return an iterator over keys."""
        return iter(sorted(int(entry) for entry in os.listdir(self._path)
                                      if entry.isdigit()))

def has_key(self, key):
        """Return True if the keyed message exists, False otherwise."""
        return os.path.exists(os.path.join(self._path, str(key)))

def __len__(self):
        """Return a count of messages in the mailbox."""
        return len(list(self.iterkeys()))

def lock(self):
        """Lock the mailbox."""
        if not self._locked:
            self._file = open(os.path.join(self._path, '.mh_sequences'), 'rb+')
            _lock_file(self._file)
            self._locked = True

def unlock(self):
        """Unlock the mailbox if it is locked."""
        if self._locked:
            _unlock_file(self._file)
            _sync_close(self._file)
            del self._file
            self._locked = False

def flush(self):
        """Write any pending changes to the disk."""
        return

def close(self):
        """Flush and close the mailbox."""
        if self._locked:
            self.unlock()

def list_folders(self):
        """Return a list of folder names."""
        result = []
        for entry in os.listdir(self._path):
            if os.path.isdir(os.path.join(self._path, entry)):
                result.append(entry)
        return result

def get_folder(self, folder):
        """Return an MH instance for the named folder."""
        return MH(os.path.join(self._path, folder),
                  factory=self._factory, create=False)

def add_folder(self, folder):
        """Create a folder and return an MH instance representing it."""
        return MH(os.path.join(self._path, folder),
                  factory=self._factory)

def remove_folder(self, folder):
        """Delete the named folder, which must be empty."""
        path = os.path.join(self._path, folder)
        entries = os.listdir(path)
        if entries == ['.mh_sequences']:
            os.remove(os.path.join(path, '.mh_sequences'))
        elif entries == []:
            pass
        else:
            raise NotEmptyError('Folder not empty: %s' % self._path)
        os.rmdir(path)

def get_sequences(self):
        """Return a name-to-key-list dictionary to define each sequence."""
        results = {}
        f = open(os.path.join(self._path, '.mh_sequences'), 'r')
        try:
            all_keys = set(self.keys())
            for line in f:
                try:
                    name, contents = line.split(':')
                    keys = set()
                    for spec in contents.split():
                        if spec.isdigit():
                            keys.add(int(spec))
                        else:
                            start, stop = (int(x) for x in spec.split('-'))
                            keys.update(range(start, stop + 1))
                    results[name] = [key for key in sorted(keys) \
                                         if key in all_keys]
                    if len(results[name]) == 0:
                        del results[name]
                except ValueError:
                    raise FormatError('Invalid sequence specification: %s' %
                                      line.rstrip())
        finally:
            f.close()
        return results

def set_sequences(self, sequences):
        """Set sequences using the given name-to-key-list dictionary."""
        f = open(os.path.join(self._path, '.mh_sequences'), 'r+')
        try:
            os.close(os.open(f.name, os.O_WRONLY | os.O_TRUNC))
            for name, keys in sequences.iteritems():
                if len(keys) == 0:
                    continue
                f.write('%s:' % name)
                prev = None
                completing = False
                for key in sorted(set(keys)):
                    if key - 1 == prev:
                        if not completing:
                            completing = True
                            f.write('-')
                    elif completing:
                        completing = False
                        f.write('%s %s' % (prev, key))
                    else:
                        f.write(' %s' % key)
                    prev = key
                if completing:
                    f.write(str(prev) + '\n')
                else:
                    f.write('\n')
        finally:
            _sync_close(f)

def pack(self):
        """Re-name messages to eliminate numbering gaps. Invalidates keys."""
        sequences = self.get_sequences()
        prev = 0
        changes = []
        for key in self.iterkeys():
            if key - 1 != prev:
                changes.append((key, prev + 1))
                if hasattr(os, 'link'):
                    os.link(os.path.join(self._path, str(key)),
                            os.path.join(self._path, str(prev + 1)))
                    os.unlink(os.path.join(self._path, str(key)))
                else:
                    os.rename(os.path.join(self._path, str(key)),
                              os.path.join(self._path, str(prev + 1)))
            prev += 1
        self._next_key = prev + 1
        if len(changes) == 0:
            return
        for name, key_list in sequences.items():
            for old, new in changes:
                if old in key_list:
                    key_list[key_list.index(old)] = new
        self.set_sequences(sequences)

def _dump_sequences(self, message, key):
        """Inspect a new MHMessage and update sequences appropriately."""
        pending_sequences = message.get_sequences()
        all_sequences = self.get_sequences()
        for name, key_list in all_sequences.iteritems():
            if name in pending_sequences:
                key_list.append(key)
            elif key in key_list:
                del key_list[key_list.index(key)]
        for sequence in pending_sequences:
            if sequence not in all_sequences:
                all_sequences[sequence] = [key]
        self.set_sequences(all_sequences)

class Babyl(_singlefileMailbox):
    """An Rmail-style Babyl mailbox."""

_special_labels = frozenset(('unseen', 'deleted', 'filed', 'answered',
                                 'forwarded', 'edited', 'resent'))

def __init__(self, path, factory=None, create=True):
        """Initialize a Babyl mailbox."""
        _singlefileMailbox.__init__(self, path, factory, create)
        self._labels = {}

def add(self, message):
        """Add message and return assigned key."""
        key = _singlefileMailbox.add(self, message)
        if isinstance(message, BabylMessage):
            self._labels[key] = message.get_labels()
        return key

def remove(self, key):
        """Remove the keyed message; raise KeyError if it doesn't exist."""
        _singlefileMailbox.remove(self, key)
        if key in self._labels:
            del self._labels[key]

def __setitem__(self, key, message):
        """Replace the keyed message; raise KeyError if it doesn't exist."""
        _singlefileMailbox.__setitem__(self, key, message)
        if isinstance(message, BabylMessage):
            self._labels[key] = message.get_labels()

def get_message(self, key):
        """Return a Message representation or raise a KeyError."""
        start, stop = self._lookup(key)
        self._file.seek(start)
        self._file.readline()   # Skip '1,' line specifying labels.
        original_headers = StringIO.StringIO()
        while True:
            line = self._file.readline()
            if line == '*** EOOH ***' + os.linesep or line == '':
                break
            original_headers.write(line.replace(os.linesep, '\n'))
        visible_headers = StringIO.StringIO()
        while True:
            line = self._file.readline()
            if line == os.linesep or line == '':
                break
            visible_headers.write(line.replace(os.linesep, '\n'))
        body = self._file.read(stop - self._file.tell()).replace(os.linesep,
                                                                 '\n')
        msg = BabylMessage(original_headers.getvalue() + body)
        msg.set_visible(visible_headers.getvalue())
        if key in self._labels:
            msg.set_labels(self._labels[key])
        return msg

def get_string(self, key):
        """Return a string representation or raise a KeyError."""
        start, stop = self._lookup(key)
        self._file.seek(start)
        self._file.readline()   # Skip '1,' line specifying labels.
        original_headers = StringIO.StringIO()
        while True:
            line = self._file.readline()
            if line == '*** EOOH ***' + os.linesep or line == '':
                break
            original_headers.write(line.replace(os.linesep, '\n'))
        while True:
            line = self._file.readline()
            if line == os.linesep or line == '':
                break
        return original_headers.getvalue() + \
               self._file.read(stop - self._file.tell()).replace(os.linesep,
                                                                 '\n')

def get_file(self, key):
        """Return a file-like representation or raise a KeyError."""
        return StringIO.StringIO(self.get_string(key).replace('\n',
                                                              os.linesep))

def get_labels(self):
        """Return a list of user-defined labels in the mailbox."""
        self._lookup()
        labels = set()
        for label_list in self._labels.values():
            labels.update(label_list)
        labels.difference_update(self._special_labels)
        return list(labels)

def _generate_toc(self):
        """Generate key-to-(start, stop) table of contents."""
        starts, stops = [], []
        self._file.seek(0)
        next_pos = 0
        label_lists = []
        while True:
            line_pos = next_pos
            line = self._file.readline()
            next_pos = self._file.tell()
            if line == '\037\014' + os.linesep:
                if len(stops) < len(starts):
                    stops.append(line_pos - len(os.linesep))
                starts.append(next_pos)
                labels = [label.strip() for label
                                        in self._file.readline()[1:].split(',')
                                        if label.strip() != '']
                label_lists.append(labels)
            elif line == '\037' or line == '\037' + os.linesep:
                if len(stops) < len(starts):
                    stops.append(line_pos - len(os.linesep))
            elif line == '':
                stops.append(line_pos - len(os.linesep))
                break
        self._toc = dict(enumerate(zip(starts, stops)))
        self._labels = dict(enumerate(label_lists))
        self._next_key = len(self._toc)
        self._file.seek(0, 2)
        self._file_length = self._file.tell()

def _pre_mailbox_hook(self, f):
        """Called before writing the mailbox to file f."""
        f.write('BABYL OPTIONS:%sVersion: 5%sLabels:%s%s\037' %
                (os.linesep, os.linesep, ','.join(self.get_labels()),
                 os.linesep))

def _pre_message_hook(self, f):
        """Called before writing each message to file f."""
        f.write('\014' + os.linesep)

def _post_message_hook(self, f):
        """Called after writing each message to file f."""
        f.write(os.linesep + '\037')

def _install_message(self, message):
        """Write message contents and return (start, stop)."""
        start = self._file.tell()
        if isinstance(message, BabylMessage):
            special_labels = []
            labels = []
            for label in message.get_labels():
                if label in self._special_labels:
                    special_labels.append(label)
                else:
                    labels.append(label)
            self._file.write('1')
            for label in special_labels:
                self._file.write(', ' + label)
            self._file.write(',,')
            for label in labels:
                self._file.write(' ' + label + ',')
            self._file.write(os.linesep)
        else:
            self._file.write('1,,' + os.linesep)
        if isinstance(message, email.message.Message):
            orig_buffer = StringIO.StringIO()
            orig_generator = email.generator.Generator(orig_buffer, False, 0)
            orig_generator.flatten(message)
            orig_buffer.seek(0)
            while True:
                line = orig_buffer.readline()
                self._file.write(line.replace('\n', os.linesep))
                if line == '\n' or line == '':
                    break
            self._file.write('*** EOOH ***' + os.linesep)
            if isinstance(message, BabylMessage):
                vis_buffer = StringIO.StringIO()
                vis_generator = email.generator.Generator(vis_buffer, False, 0)
                vis_generator.flatten(message.get_visible())
                while True:
                    line = vis_buffer.readline()
                    self._file.write(line.replace('\n', os.linesep))
                    if line == '\n' or line == '':
                        break
            else:
                orig_buffer.seek(0)
                while True:
                    line = orig_buffer.readline()
                    self._file.write(line.replace('\n', os.linesep))
                    if line == '\n' or line == '':
                        break
            while True:
                buffer = orig_buffer.read(4096) # Buffer size is arbitrary.
                if buffer == '':
                    break
                self._file.write(buffer.replace('\n', os.linesep))
        elif isinstance(message, str):
            body_start = message.find('\n\n') + 2
            if body_start - 2 != -1:
                self._file.write(message[:body_start].replace('\n',
                                                              os.linesep))
                self._file.write('*** EOOH ***' + os.linesep)
                self._file.write(message[:body_start].replace('\n',
                                                              os.linesep))
                self._file.write(message[body_start:].replace('\n',
                                                              os.linesep))
            else:
                self._file.write('*** EOOH ***' + os.linesep + os.linesep)
                self._file.write(message.replace('\n', os.linesep))
        elif hasattr(message, 'readline'):
            original_pos = message.tell()
            first_pass = True
            while True:
                line = message.readline()
                self._file.write(line.replace('\n', os.linesep))
                if line == '\n' or line == '':
                    if first_pass:
                        first_pass = False
                        self._file.write('*** EOOH ***' + os.linesep)
                        message.seek(original_pos)
                    else:
                        break
            while True:
                buffer = message.read(4096)     # Buffer size is arbitrary.
                if buffer == '':
                    break
                self._file.write(buffer.replace('\n', os.linesep))
        else:
            raise TypeError('Invalid message type: %s' % type(message))
        stop = self._file.tell()
        return (start, stop)

class Message(email.message.Message):
    """Message with mailbox-format-specific properties."""

def __init__(self, message=None):
        """Initialize a Message instance."""
        if isinstance(message, email.message.Message):
            self._become_message(copy.deepcopy(message))
            if isinstance(message, Message):
                message._explain_to(self)
        elif isinstance(message, str):
            self._become_message(email.message_from_string(message))
        elif hasattr(message, "read"):
            self._become_message(email.message_from_file(message))
        elif message is None:
            email.message.Message.__init__(self)
        else:
            raise TypeError('Invalid message type: %s' % type(message))

def _become_message(self, message):
        """Assume the non-format-specific state of message."""
        for name in ('_headers', '_unixfrom', '_payload', '_charset',
                     'preamble', 'epilogue', 'defects', '_default_type'):
            self.__dict__[name] = message.__dict__[name]

def _explain_to(self, message):
        """Copy format-specific state to message insofar as possible."""
        if isinstance(message, Message):
            return  # There's nothing format-specific to explain.
        else:
            raise TypeError('Cannot convert to specified type')

class MaildirMessage(Message):
    """Message with Maildir-specific properties."""

def __init__(self, message=None):
        """Initialize a MaildirMessage instance."""
        self._subdir = 'new'
        self._info = ''
        self._date = time.time()
        Message.__init__(self, message)

def get_subdir(self):
        """Return 'new' or 'cur'."""
        return self._subdir

def set_subdir(self, subdir):
        """Set subdir to 'new' or 'cur'."""
        if subdir == 'new' or subdir == 'cur':
            self._subdir = subdir
        else:
            raise ValueError("subdir must be 'new' or 'cur': %s" % subdir)

def get_flags(self):
        """Return as a string the flags that are set."""
        if self._info.startswith('2,'):
            return self._info[2:]
        else:
            return ''

def set_flags(self, flags):
        """Set the given flags and unset all others."""
        self._info = '2,' + ''.join(sorted(flags))

def add_flag(self, flag):
        """Set the given flag(s) without changing others."""
        self.set_flags(''.join(set(self.get_flags()) | set(flag)))

def remove_flag(self, flag):
        """Unset the given string flag(s) without changing others."""
        if self.get_flags() != '':
            self.set_flags(''.join(set(self.get_flags()) - set(flag)))

def get_date(self):
        """Return delivery date of message, in seconds since the epoch."""
        return self._date

def set_date(self, date):
        """Set delivery date of message, in seconds since the epoch."""
        try:
            self._date = float(date)
        except ValueError:
            raise TypeError("can't convert to float: %s" % date)

def get_info(self):
        """Get the message's "info" as a string."""
        return self._info

def set_info(self, info):
        """Set the message's "info" string."""
        if isinstance(info, str):
            self._info = info
        else:
            raise TypeError('info must be a string: %s' % type(info))

def _explain_to(self, message):
        """Copy Maildir-specific state to message insofar as possible."""
        if isinstance(message, MaildirMessage):
            message.set_flags(self.get_flags())
            message.set_subdir(self.get_subdir())
            message.set_date(self.get_date())
        elif isinstance(message, _mboxMMDFMessage):
            flags = set(self.get_flags())
            if 'S' in flags:
                message.add_flag('R')
            if self.get_subdir() == 'cur':
                message.add_flag('O')
            if 'T' in flags:
                message.add_flag('D')
            if 'F' in flags:
                message.add_flag('F')
            if 'R' in flags:
                message.add_flag('A')
            message.set_from('MAILER-DAEMON', time.gmtime(self.get_date()))
        elif isinstance(message, MHMessage):
            flags = set(self.get_flags())
            if 'S' not in flags:
                message.add_sequence('unseen')
            if 'R' in flags:
                message.add_sequence('replied')
            if 'F' in flags:
                message.add_sequence('flagged')
        elif isinstance(message, BabylMessage):
            flags = set(self.get_flags())
            if 'S' not in flags:
                message.add_label('unseen')
            if 'T' in flags:
                message.add_label('deleted')
            if 'R' in flags:
                message.add_label('answered')
            if 'P' in flags:
                message.add_label('forwarded')
        elif isinstance(message, Message):
            pass
        else:
            raise TypeError('Cannot convert to specified type: %s' %
                            type(message))

class _mboxMMDFMessage(Message):
    """Message with mbox- or MMDF-specific properties."""

def __init__(self, message=None):
        """Initialize an mboxMMDFMessage instance."""
        self.set_from('MAILER-DAEMON', True)
        if isinstance(message, email.message.Message):
            unixfrom = message.get_unixfrom()
            if unixfrom is not None and unixfrom.startswith('From '):
                self.set_from(unixfrom[5:])
        Message.__init__(self, message)

def get_from(self):
        """Return contents of "From " line."""
        return self._from

def set_from(self, from_, time_=None):
        """Set "From " line, formatting and appending time_ if specified."""
        if time_ is not None:
            if time_ is True:
                time_ = time.gmtime()
            from_ += ' ' + time.asctime(time_)
        self._from = from_

def get_flags(self):
        """Return as a string the flags that are set."""
        return self.get('Status', '') + self.get('X-Status', '')

def set_flags(self, flags):
        """Set the given flags and unset all others."""
        flags = set(flags)
        status_flags, xstatus_flags = '', ''
        for flag in ('R', 'O'):
            if flag in flags:
                status_flags += flag
                flags.remove(flag)
        for flag in ('D', 'F', 'A'):
            if flag in flags:
                xstatus_flags += flag
                flags.remove(flag)
        xstatus_flags += ''.join(sorted(flags))
        try:
            self.replace_header('Status', status_flags)
        except KeyError:
            self.add_header('Status', status_flags)
        try:
            self.replace_header('X-Status', xstatus_flags)
        except KeyError:
            self.add_header('X-Status', xstatus_flags)

def add_flag(self, flag):
        """Set the given flag(s) without changing others."""
        self.set_flags(''.join(set(self.get_flags()) | set(flag)))

def remove_flag(self, flag):
        """Unset the given string flag(s) without changing others."""
        if 'Status' in self or 'X-Status' in self:
            self.set_flags(''.join(set(self.get_flags()) - set(flag)))

def _explain_to(self, message):
        """Copy mbox- or MMDF-specific state to message insofar as possible."""
        if isinstance(message, MaildirMessage):
            flags = set(self.get_flags())
            if 'O' in flags:
                message.set_subdir('cur')
            if 'F' in flags:
                message.add_flag('F')
            if 'A' in flags:
                message.add_flag('R')
            if 'R' in flags:
                message.add_flag('S')
            if 'D' in flags:
                message.add_flag('T')
            del message['status']
            del message['x-status']
            maybe_date = ' '.join(self.get_from().split()[-5:])
            try:
                message.set_date(calendar.timegm(time.strptime(maybe_date,
                                                      '%a %b %d %H:%M:%S %Y')))
            except (ValueError, OverflowError):
                pass
        elif isinstance(message, _mboxMMDFMessage):
            message.set_flags(self.get_flags())
            message.set_from(self.get_from())
        elif isinstance(message, MHMessage):
            flags = set(self.get_flags())
            if 'R' not in flags:
                message.add_sequence('unseen')
            if 'A' in flags:
                message.add_sequence('replied')
            if 'F' in flags:
                message.add_sequence('flagged')
            del message['status']
            del message['x-status']
        elif isinstance(message, BabylMessage):
            flags = set(self.get_flags())
            if 'R' not in flags:
                message.add_label('unseen')
            if 'D' in flags:
                message.add_label('deleted')
            if 'A' in flags:
                message.add_label('answered')
            del message['status']
            del message['x-status']
        elif isinstance(message, Message):
            pass
        else:
            raise TypeError('Cannot convert to specified type: %s' %
                            type(message))

class mboxMessage(_mboxMMDFMessage):
    """Message with mbox-specific properties."""

class MHMessage(Message):
    """Message with MH-specific properties."""

def __init__(self, message=None):
        """Initialize an MHMessage instance."""
        self._sequences = []
        Message.__init__(self, message)

def get_sequences(self):
        """Return a list of sequences that include the message."""
        return self._sequences[:]

def set_sequences(self, sequences):
        """Set the list of sequences that include the message."""
        self._sequences = list(sequences)

def add_sequence(self, sequence):
        """Add sequence to list of sequences including the message."""
        if isinstance(sequence, str):
            if not sequence in self._sequences:
                self._sequences.append(sequence)
        else:
            raise TypeError('sequence must be a string: %s' % type(sequence))

def remove_sequence(self, sequence):
        """Remove sequence from the list of sequences including the message."""
        try:
            self._sequences.remove(sequence)
        except ValueError:
            pass

def _explain_to(self, message):
        """Copy MH-specific state to message insofar as possible."""
        if isinstance(message, MaildirMessage):
            sequences = set(self.get_sequences())
            if 'unseen' in sequences:
                message.set_subdir('cur')
            else:
                message.set_subdir('cur')
                message.add_flag('S')
            if 'flagged' in sequences:
                message.add_flag('F')
            if 'replied' in sequences:
                message.add_flag('R')
        elif isinstance(message, _mboxMMDFMessage):
            sequences = set(self.get_sequences())
            if 'unseen' not in sequences:
                message.add_flag('RO')
            else:
                message.add_flag('O')
            if 'flagged' in sequences:
                message.add_flag('F')
            if 'replied' in sequences:
                message.add_flag('A')
        elif isinstance(message, MHMessage):
            for sequence in self.get_sequences():
                message.add_sequence(sequence)
        elif isinstance(message, BabylMessage):
            sequences = set(self.get_sequences())
            if 'unseen' in sequences:
                message.add_label('unseen')
            if 'replied' in sequences:
                message.add_label('answered')
        elif isinstance(message, Message):
            pass
        else:
            raise TypeError('Cannot convert to specified type: %s' %
                            type(message))

class BabylMessage(Message):
    """Message with Babyl-specific properties."""

def __init__(self, message=None):
        """Initialize an BabylMessage instance."""
        self._labels = []
        self._visible = Message()
        Message.__init__(self, message)

def get_labels(self):
        """Return a list of labels on the message."""
        return self._labels[:]

def set_labels(self, labels):
        """Set the list of labels on the message."""
        self._labels = list(labels)

def add_label(self, label):
        """Add label to list of labels on the message."""
        if isinstance(label, str):
            if label not in self._labels:
                self._labels.append(label)
        else:
            raise TypeError('label must be a string: %s' % type(label))

def remove_label(self, label):
        """Remove label from the list of labels on the message."""
        try:
            self._labels.remove(label)
        except ValueError:
            pass

def get_visible(self):
        """Return a Message representation of visible headers."""
        return Message(self._visible)

def set_visible(self, visible):
        """Set the Message representation of visible headers."""
        self._visible = Message(visible)

def update_visible(self):
        """Update and/or sensibly generate a set of visible headers."""
        for header in self._visible.keys():
            if header in self:
                self._visible.replace_header(header, self[header])
            else:
                del self._visible[header]
        for header in ('Date', 'From', 'Reply-To', 'To', 'CC', 'Subject'):
            if header in self and header not in self._visible:
                self._visible[header] = self[header]

def _explain_to(self, message):
        """Copy Babyl-specific state to message insofar as possible."""
        if isinstance(message, MaildirMessage):
            labels = set(self.get_labels())
            if 'unseen' in labels:
                message.set_subdir('cur')
            else:
                message.set_subdir('cur')
                message.add_flag('S')
            if 'forwarded' in labels or 'resent' in labels:
                message.add_flag('P')
            if 'answered' in labels:
                message.add_flag('R')
            if 'deleted' in labels:
                message.add_flag('T')
        elif isinstance(message, _mboxMMDFMessage):
            labels = set(self.get_labels())
            if 'unseen' not in labels:
                message.add_flag('RO')
            else:
                message.add_flag('O')
            if 'deleted' in labels:
                message.add_flag('D')
            if 'answered' in labels:
                message.add_flag('A')
        elif isinstance(message, MHMessage):
            labels = set(self.get_labels())
            if 'unseen' in labels:
                message.add_sequence('unseen')
            if 'answered' in labels:
                message.add_sequence('replied')
        elif isinstance(message, BabylMessage):
            message.set_visible(self.get_visible())
            for label in self.get_labels():
                message.add_label(label)
        elif isinstance(message, Message):
            pass
        else:
            raise TypeError('Cannot convert to specified type: %s' %
                            type(message))

class MMDFMessage(_mboxMMDFMessage):
    """Message with MMDF-specific properties."""

class _ProxyFile:
    """A read-only wrapper of a file."""

def __init__(self, f, pos=None):
        """Initialize a _ProxyFile."""
        self._file = f
        if pos is None:
            self._pos = f.tell()
        else:
            self._pos = pos

def read(self, size=None):
        """Read bytes."""
        return self._read(size, self._file.read)

def readline(self, size=None):
        """Read a line."""
        return self._read(size, self._file.readline)

def readlines(self, sizehint=None):
        """Read multiple lines."""
        result = []
        for line in self:
            result.append(line)
            if sizehint is not None:
                sizehint -= len(line)
                if sizehint <= 0:
                    break
        return result

def __iter__(self):
        """Iterate over lines."""
        return iter(self.readline, "")

def tell(self):
        """Return the position."""
        return self._pos

def seek(self, offset, whence=0):
        """Change position."""
        if whence == 1:
            self._file.seek(self._pos)
        self._file.seek(offset, whence)
        self._pos = self._file.tell()

def close(self):
        """Close the file."""
        if hasattr(self, '_file'):
            if hasattr(self._file, 'close'):
                self._file.close()
            del self._file

def _read(self, size, read_method):
        """Read size bytes using read_method."""
        if size is None:
            size = -1
        self._file.seek(self._pos)
        result = read_method(size)
        self._pos = self._file.tell()
        return result

class _PartialFile(_ProxyFile):
    """A read-only wrapper of part of a file."""

def __init__(self, f, start=None, stop=None):
        """Initialize a _PartialFile."""
        _ProxyFile.__init__(self, f, start)
        self._start = start
        self._stop = stop

def tell(self):
        """Return the position with respect to start."""
        return _ProxyFile.tell(self) - self._start

def seek(self, offset, whence=0):
        """Change position, possibly with respect to start or stop."""
        if whence == 0:
            self._pos = self._start
            whence = 1
        elif whence == 2:
            self._pos = self._stop
            whence = 1
        _ProxyFile.seek(self, offset, whence)

def _read(self, size, read_method):
        """Read size bytes using read_method, honoring start and stop."""
        remaining = self._stop - self._pos
        if remaining <= 0:
            return ''
        if size is None or size < 0 or size > remaining:
            size = remaining
        return _ProxyFile._read(self, size, read_method)

def close(self):
        # do *not* close the underlying file object for partial files,
        # since it's global to the mailbox object
        if hasattr(self, '_file'):
            del self._file

def _lock_file(f, dotlock=True):
    """Lock file f using lockf and dot locking."""
    dotlock_done = False
    try:
        if fcntl:
            try:
                fcntl.lockf(f, fcntl.LOCK_EX | fcntl.LOCK_NB)
            except IOError, e:
                if e.errno in (errno.EAGAIN, errno.EACCES, errno.EROFS):
                    raise ExternalClashError('lockf: lock unavailable: %s' %
                                             f.name)
                else:
                    raise
        if dotlock:
            try:
                pre_lock = _create_temporary(f.name + '.lock')
                pre_lock.close()
            except IOError, e:
                if e.errno in (errno.EACCES, errno.EROFS):
                    return  # Without write access, just skip dotlocking.
                else:
                    raise
            try:
                if hasattr(os, 'link'):
                    os.link(pre_lock.name, f.name + '.lock')
                    dotlock_done = True
                    os.unlink(pre_lock.name)
                else:
                    os.rename(pre_lock.name, f.name + '.lock')
                    dotlock_done = True
            except OSError, e:
                if e.errno == errno.EEXIST or \
                  (os.name == 'os2' and e.errno == errno.EACCES):
                    os.remove(pre_lock.name)
                    raise ExternalClashError('dot lock unavailable: %s' %
                                             f.name)
                else:
                    raise
    except:
        if fcntl:
            fcntl.lockf(f, fcntl.LOCK_UN)
        if dotlock_done:
            os.remove(f.name + '.lock')
        raise

def _unlock_file(f):
    """Unlock file f using lockf and dot locking."""
    if fcntl:
        fcntl.lockf(f, fcntl.LOCK_UN)
    if os.path.exists(f.name + '.lock'):
        os.remove(f.name + '.lock')

def _create_carefully(path):
    """Create a file if it doesn't exist and open for reading and writing."""
    fd = os.open(path, os.O_CREAT | os.O_EXCL | os.O_RDWR, 0666)
    try:
        return open(path, 'rb+')
    finally:
        os.close(fd)

def _create_temporary(path):
    """Create a temp file based on path and open for reading and writing."""
    return _create_carefully('%s.%s.%s.%s' % (path, int(time.time()),
                                              socket.gethostname(),
                                              os.getpid()))

def _sync_flush(f):
    """Ensure changes to file f are physically on disk."""
    f.flush()
    if hasattr(os, 'fsync'):
        os.fsync(f.fileno())

def _sync_close(f):
    """Close file f, ensuring all changes are physically on disk."""
    _sync_flush(f)
    f.close()

## Start: classes from the original module (for backward compatibility).

# Note that the Maildir class, whose name is unchanged, itself offers a next()
# method for backward compatibility.

class _Mailbox:

def __init__(self, fp, factory=rfc822.Message):
        self.fp = fp
        self.seekp = 0
        self.factory = factory

def __iter__(self):
        return iter(self.next, None)

def next(self):
        while 1:
            self.fp.seek(self.seekp)
            try:
                self._search_start()
            except EOFError:
                self.seekp = self.fp.tell()
                return None
            start = self.fp.tell()
            self._search_end()
            self.seekp = stop = self.fp.tell()
            if start != stop:
                break
        return self.factory(_PartialFile(self.fp, start, stop))

# Recommended to use PortableUnixMailbox instead!
class UnixMailbox(_Mailbox):

def _search_start(self):
        while 1:
            pos = self.fp.tell()
            line = self.fp.readline()
            if not line:
                raise EOFError
            if line[:5] == 'From ' and self._isrealfromline(line):
                self.fp.seek(pos)
                return

def _search_end(self):
        self.fp.readline()      # Throw away header line
        while 1:
            pos = self.fp.tell()
            line = self.fp.readline()
            if not line:
                return
            if line[:5] == 'From ' and self._isrealfromline(line):
                self.fp.seek(pos)
                return

# An overridable mechanism to test for From-line-ness.  You can either
    # specify a different regular expression or define a whole new
    # _isrealfromline() method.  Note that this only gets called for lines
    # starting with the 5 characters "From ".
    #
    # BAW: According to
    #http://home.netscape.com/eng/mozilla/2.0/relnotes/demo/content-length.html
    # the only portable, reliable way to find message delimiters in a BSD (i.e
    # Unix mailbox) style folder is to search for "\n\nFrom .*\n", or at the
    # beginning of the file, "^From .*\n".  While _fromlinepattern below seems
    # like a good idea, in practice, there are too many variations for more
    # strict parsing of the line to be completely accurate.
    #
    # _strict_isrealfromline() is the old version which tries to do stricter
    # parsing of the From_ line.  _portable_isrealfromline() simply returns
    # true, since it's never called if the line doesn't already start with
    # "From ".
    #
    # This algorithm, and the way it interacts with _search_start() and
    # _search_end() may not be completely correct, because it doesn't check
    # that the two characters preceding "From " are \n\n or the beginning of
    # the file.  Fixing this would require a more extensive rewrite than is
    # necessary.  For convenience, we've added a PortableUnixMailbox class
    # which does no checking of the format of the 'From' line.

_fromlinepattern = (r"From \s*[^\s]+\s+\w\w\w\s+\w\w\w\s+\d?\d\s+"
                        r"\d?\d:\d\d(:\d\d)?(\s+[^\s]+)?\s+\d\d\d\d\s*"
                        r"[^\s]*\s*"
                        "$")
    _regexp = None

def _strict_isrealfromline(self, line):
        if not self._regexp:
            import re
            self._regexp = re.compile(self._fromlinepattern)
        return self._regexp.match(line)

def _portable_isrealfromline(self, line):
        return True

_isrealfromline = _strict_isrealfromline

class PortableUnixMailbox(UnixMailbox):
    _isrealfromline = UnixMailbox._portable_isrealfromline

class MmdfMailbox(_Mailbox):

def _search_start(self):
        while 1:
            line = self.fp.readline()
            if not line:
                raise EOFError
            if line[:5] == '\001\001\001\001\n':
                return

def _search_end(self):
        while 1:
            pos = self.fp.tell()
            line = self.fp.readline()
            if not line:
                return
            if line == '\001\001\001\001\n':
                self.fp.seek(pos)
                return

class MHMailbox:

def __init__(self, dirname, factory=rfc822.Message):
        import re
        pat = re.compile('^[1-9][0-9]*$')
        self.dirname = dirname
        # the three following lines could be combined into:
        # list = map(long, filter(pat.match, os.listdir(self.dirname)))
        list = os.listdir(self.dirname)
        list = filter(pat.match, list)
        list = map(long, list)
        list.sort()
        # This only works in Python 1.6 or later;
        # before that str() added 'L':
        self.boxes = map(str, list)
        self.boxes.reverse()
        self.factory = factory

def __iter__(self):
        return iter(self.next, None)

def next(self):
        if not self.boxes:
            return None
        fn = self.boxes.pop()
        fp = open(os.path.join(self.dirname, fn))
        msg = self.factory(fp)
        try:
            msg._mh_msgno = fn
        except (AttributeError, TypeError):
            pass
        return msg

class BabylMailbox(_Mailbox):

def _search_start(self):
        while 1:
            line = self.fp.readline()
            if not line:
                raise EOFError
            if line == '*** EOOH ***\n':
                return

def _search_end(self):
        while 1:
            pos = self.fp.tell()
            line = self.fp.readline()
            if not line:
                return
            if line == '\037\014\n' or line == '\037':
                self.fp.seek(pos)
                return

## End: classes from the original module (for backward compatibility).

class Error(Exception):
    """Raised for module-specific errors."""

class NoSuchMailboxError(Error):
    """The specified mailbox does not exist and won't be created."""

class NotEmptyError(Error):
    """The specified mailbox is not empty and deletion was requested."""

class ExternalClashError(Error):
    """Another process caused an action to fail."""

class FormatError(Error):
    """A file appears to have an invalid format."""