
    i`k                    0   d Z dZdZdZdZdZdZdZdZd	d
l	Z	d	d
l
Z
d	d
lZd	d
lZd	d
lZd	d
lZd	d
lZd	d
lZd	d
lZd	d
lZd	d
lZd	d
lZd	d
lZeZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"d	Z#dZ$d\  Z%Z&Z'Z(i de&e'fdfde%fdfde%e&e'fdfde'fdfde'fdfd e&fdfd!e'fdfd"e&e'fdfd#e&e'fdfd$e&e'fdfd%e&fdfd&e&e'fdfd'e'fdfd(e'fdfd)e&e'fdfd*e&e'fdfd+e&e'fdfi d,e&e'fdfd-e%e&e(e'fdfd.e'fdfd/e&e'fdfd0e%fdfd1e%e&e(e'fdfd2e&e'fdfd3e&e'fdfd4e&e'fdfd5e%e&e'fdfd6e'fdfd7e&fdfd8e&e'fdfd9e'fdfd:e&e'fdfd;e&e'fdfd<e&e'fdfe&e'fdfe'fdfe%fdfe&e'fdfe'fdfe&e'fdfe'fdfe'fdfe&e'fdfd=	Z)d>Z*d? Z+ G d@ dAe,      Z- G dB dCe,      Z. G dD dEe.      Z/ G dF dGe.      Z0 G dH dIe,      Z1 G dJ dKe,      Z2g dLZ3 e4e3dd
       D  ci c]  \  } }|jk                         | dz    c}} Z6 ejn                  dM      Z8dN Z9e9Z:dO Z; ejn                  dP      Z<dQ Z=e>dRk(  r	 d	d
l@Z@d	d
lAZA	  e@j                  ej                  dd
 dS      \  ZCZDdU\  ZGZHZIZJZKZLZMeCD ]W  \  ZNZFeNdVk(  r eOeF      ZGeGdz
  ZHeNdWk(  rdZM!eNdXk(  r	 eFj                  dY      \  ZKZL<eNdZk(  r	 eOeF      ZIJeNd[k(  sPeFZJeDrUeJfZDY eDsd\ZDeIseKd
uxr exs eZIeDd	   ZQ eAj                         ZS eTej                  j                  d]      xr d]xs eW      j                  d^      ZYd_eSd`eYdaz  ZZdbdcdddedfdgdhd
d
eZffdidjdkdldmdndodpdqgZ[drdsdtdgd
d
d
eZffdudrdvdudrdwdxdydpfZ\dz\  a]Z^d{ Z_dd|Z`	  ej                         j                  d}       eKeKsd
ZKeLsd
ZL e/eQeIeKeLd~eGddeHd
      Z^neJr e0eJeGddeH      Z^n e.eQeIeGddeH      Z^e^j                  dk7  r3 eAj                  deSdeQxs dd      Zde[j                  d	deSedff       e^j                  d	de^j                  z         de^j                  v re^j                          e[D ]  \  ZjZD e`ejeD         e`ddd      D ]F  Zk ej                  dek      Zmemremj                  d      ZUnekj                         d   ZU e`deUf       H d-e^j                  v r1 e`dd        e`dd        e`dded ej                         d	   f       e\D ]_  \  ZjZDejeDfdk7  r
 e`ejeD        e`ejeDd      Zpepd   j                         Zqeqs8 e`dd(eqd   df        e`ddeqd   ddf        e`dd       a d.e^j                  v r e`ddd        e`dd        ej                  d        e`ddd        e`dgd
d
d
eZfd        e`ddd      d	   j                         d	   Zs e`desdfd      Zpe^j                  desd euep              e`dd        e`desddfd      f  e`desdfd      Zpe^j                  desd euep              e`ddesddf        e`dd       eMr1e^j                  d       	  e`ddd       neMre^j                  d        e`ddd       eGrre^j                  d       e^j                          e^j                  d       e^j                  d       e^j                         D ]  \  ZyZpe^j                  deydep         ezd       y
y
c c}} w # e@j                  $ rZFdT\  ZCZDY d
ZF[Fd
ZF[Fww xY w# e?$ r	 eFeFcZKZLY w xY w# ev$ r$ e^j                  d       e^j                  d        w xY w#  eMre^d.e^j                  vr# ezd       eGs ezdej                  d	   z          Y y
xY w)a  Threaded IMAP4 client for Python 3.

Based on RFC 3501 and original imaplib module.

Public classes:   IMAP4
                  IMAP4_SSL
                  IMAP4_stream

Public functions: Internaldate2Time
                  ParseFlags
                  Time2Internaldate
)	IMAP4	IMAP4_SSLIMAP4_streamInternaldate2Time
ParseFlagsTime2InternaldateMon2num
MonthNamesInternalDatez3.05305a
  
Authentication code contributed by Donn Cave <donn@u.washington.edu> June 1998.
String method conversion by ESR, February 2001.
GET/SETACL contributed by Anthony Baxter <anthony@interlink.com.au> April 2001.
IMAP4_SSL contributed by Tino Lange <Tino.Lange@isg.de> March 2002.
GET/SETQUOTA contributed by Andreas Zeidler <az@kreativkombinat.de> June 2002.
PROXYAUTH contributed by Rick Holbert <holbert.13@osu.edu> November 2002.
IDLE via threads suggested by Philippe Normand <phil@respyre.org> January 2005.
GET/SETANNOTATION contributed by Tomas Lindroos <skitta@abo.fi> June 2005.
COMPRESS/DEFLATE contributed by Bron Gondwana <brong@brong.net> May 2009.
STARTTLS from Jython's imaplib by Alan Kennedy.
ID contributed by Dave Baggett <dave@baggett.org> November 2009.
Improved untagged responses handling suggested by Dave Baggett <dave@baggett.org> November 2009.
Improved thread naming, and 0 read detection contributed by Grant Edwards <grant.b.edwards@gmail.com> June 2010.
Improved timeout handling contributed by Ivan Vovnenko <ivovnenko@gmail.com> October 2010.
Timeout handling further improved by Ethan Glasser-Camp <glasse@cs.rpi.edu> December 2010.
Time2Internaldate() patch to match RFC2060 specification of English month names from bugs.python.org/issue11024 March 2011.
starttls() bug fixed with the help of Sebastian Spaeth <sebastian@sspaeth.de> April 2011.
Threads now set the "daemon" flag (suggested by offlineimap-project) April 2011.
Single quoting introduced with the help of Vladimir Marek <vladimir.marek@oracle.com> August 2011.
Support for specifying SSL version by Ryan Kavanagh <rak@debian.org> July 2013.
Fix for gmail "read 0" error provided by Jim Greenleaf <james.a.greenleaf@gmail.com> August 2013.
Fix for offlineimap "indexerror: string index out of range" bug provided by Eygene Ryabinkin <rea@codelabs.ru> August 2013.
Fix for missing idle_lock in _handler() provided by Franklin Brook <franklin@brook.se> August 2014.
Conversion to Python3 provided by F. Malina <fmalina@gmail.com> February 2015.
Fix for READ-ONLY error from multiple EXAMINE/SELECT calls by Pierre-Louis Bonicoli <pierre-louis.bonicoli@gmx.fr> March 2015.
Fix for null strings appended to untagged responses by Pierre-Louis Bonicoli <pierre-louis.bonicoli@gmx.fr> March 2015.
Fix for correct byte encoding for _CRAM_MD5_AUTH taken from python3.5 imaplib.py June 2015.
Fix for correct Python 3 exception handling by Tobias Brink <tobias.brink@gmail.com> August 2015.
Fix to allow interruptible IDLE command by Tim Peoples <dromedary512@users.sf.net> September 2015.
Add support for TLS levels by Ben Boeckel <mathstuf@gmail.com> September 2015.
Fix for shutown exception by Sebastien Gross <seb@chezwam.org> November 2015.z!Piers Lauder <piers@janeelix.com>zhttp://imaplib2.sourceforge.netzPython License    Ns   
   i  s   * IDLE TIMEOUT
i     i      
tls_secure
tls_no_ssl
tls_compat)	IMAP4REV1r      )NONAUTHAUTHSELECTEDLOGOUTAPPENDFAUTHENTICATE
CAPABILITYTCHECKCLOSECOMPRESSCOPYCREATEDELETE	DELETEACLENABLEEXAMINEEXPUNGEFETCHGETACLGETANNOTATIONGETQUOTAGETQUOTAROOTIDIDLELISTLOGINr   LSUBMYRIGHTS	NAMESPACENOOPPARTIAL	PROXYAUTHRENAMESEARCHSELECTSETACLSETANNOTATION)	SETQUOTASORTSTARTTLSSTATUSSTORE	SUBSCRIBETHREADUIDUNSUBSCRIBE)r7   r<   rA   c                 t    d}d}t        t        |             } | rt        | d      \  } }|||dz    |z   }| r|S )zdstring = Int2AP(num)
    Return 'num' converted to bytes using characters from the set 'A'..'P'
        s   ABCDEFGHIJKLMNOP   r   )intabsdivmod)numvalAPmods       */usr/lib/python3/dist-packages/imaplib2.pyInt2APrO      sM     C'r
c#h-C
#r?SSUmc!  JrE   c                   ,    e Zd ZdZddZd ZddZd Zy)	Requestz7Private class to represent a request awaiting response.Nc                 <   || _         || _        || _        |s|| _        n	| |f| _        |j                  t        t        |j                        d      z   | _        |xj                  dz  c_        t        j                         | _        d | _        d | _        d | _        y )NASCIIr   )parentnamecallbackcallback_argtagprebytesstrtagnumtag	threadingEventreadyresponseaborteddata)selfrT   rU   rV   cb_argcb_selfs         rN   __init__zRequest.__init__   s    	  &D!%vD==5V]]);W#EE__&
	rE   c                 8    ||f| _         | j                  d        y N)ra   deliver)rc   typrK   s      rN   abortzRequest.abort   s    SzTrE   c                 4   d | _         | j                  j                  d| j                  d| j                  d       | j
                  j                          | j                  *| j                  \  }}|d|z  } ||t        |      z        | j                  S )Nr   :z.ready.waitz%s - %%s)
rV   rT   _logrU   r\   r_   waitra   rZ   r`   )rc   exc_fmtrj   rK   s       rN   get_responsezRequest.get_response   s|    kk&&q		488*TU

<<#||HC$s*gC())}}rE   c                    | j                   )| j                  || j                  | j                  f       y || _        | j                  j                          | j                  j                  d| j                  d| j                  d       y )Nr   rm   z
.ready.set)
rV   rW   ra   r`   r_   setrT   rn   rU   r\   )rc   r`   s     rN   ri   zRequest.deliver   sb    ==$MM8T%6%6EF 

kk&&qtyy$((*STrE   )NNNFrh   )__name__
__module____qualname____doc__rf   rk   rq   ri    rE   rN   rQ   rQ      s    A$
UrE   rQ   c                   L   e Zd ZdZ G d de      Z G d de      Z G d de      ZdZd	Z	 e
j                  d
      Z e
j                  d      Z e
j                  d      Z e
j                  d      ZdmdZd Zd Zd Zd Zd ZdndZd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d  Z!d! Z"d" Z#d# Z$d$ Z%d% Z&d& Z'd' Z(d( Z)d) Z*d* Z+dod+Z,d, Z-d- Z.d. Z/d/ Z0d0 Z1d1 Z2d2 Z3dpd3Z4dqd4Z5d5 Z6d6 Z7d7 Z8d8 Z9dqd9Z:d: Z;d; Z<d< Z=d= Z>d> Z?d? Z@d@ ZAdrdAZBdB ZCdC ZDdD ZEdE ZFdddddFeGfdGZHdH ZIdI ZJdJ ZKdK ZLdL ZMdM ZNdN ZOdO ZPdP ZQdQ ZRdR ZSdS ZTdT ZUdU ZVdV ZWdW ZXdX ZYdsdYZZdZ Z[d[ Z\d\ Z]d] Z^d^ Z_dnd_Z`d` Zada Zbdb Zcdc Zd eeefdd      rde Zgndf Zgdg Zh	 dtdhZidi Zjdj ZkdndkZldl Zmy)ur   al  Threaded IMAP4 client class.

    Instantiate with:
        IMAP4(host=None, port=None, debug=None, debug_file=None, identifier=None, timeout=None, debug_buf_lvl=None)

        host          - host's name (default: localhost);
        port          - port number (default: standard IMAP4 port);
        debug         - debug level (default: 0 - no debug);
        debug_file    - debug stream (default: sys.stderr);
        identifier    - thread identifier prefix (default: host);
        timeout       - timeout in seconds when expecting a command response (default: no timeout),
        debug_buf_lvl - debug level at which buffering is turned off.

    All IMAP4rev1 commands are supported by methods of the same name.

    Each command returns a tuple: (type, [data, ...]) where 'type'
    is usually 'OK' or 'NO', and 'data' is either the text from the
    tagged response, or untagged results from command. Each 'data' is
    either a string, or a tuple. If a tuple, then the first part is the
    header of the response, and the second part contains the data (ie:
    'literal' value).

    Errors raise the exception class <instance>.error("<reason>").
    IMAP4 server errors raise <instance>.abort("<reason>"), which is
    a sub-class of 'error'. Mailbox status changes from READ-WRITE to
    READ-ONLY raise the exception class <instance>.readonly("<reason>"),
    which is a sub-class of 'abort'.

    "error" exceptions imply a program error.
    "abort" exceptions imply the connection should be reset, and
            the command re-tried.
    "readonly" exceptions imply the command should be re-tried.

    All commands take two optional named arguments:
        'callback' and 'cb_arg'
    If 'callback' is provided then the command is asynchronous, so after
    the command is queued for transmission, the call returns immediately
    with the tuple (None, None).
    The result will be posted by invoking "callback" with one arg, a tuple:
        callback((result, cb_arg, None))
    or, if there was a problem:
        callback((None, cb_arg, (exception class, reason)))

    Otherwise the command is synchronous (waits for result). But note
    that state-changing commands will both block until previous commands
    have completed, and block subsequent commands until they have finished.

    All (non-callback) string arguments to commands are converted to bytes,
    except for AUTHENTICATE, and the last argument to APPEND which is
    passed as an IMAP4 literal.  NB: the 'password' argument to the LOGIN
    command is always quoted.

    There is one instance variable, 'state', that is useful for tracking
    whether the client needs to login to the server. If it has the
    value "AUTH" after instantiating the class, then the connection
    is pre-authenticated (otherwise it will be "NONAUTH"). Selecting a
    mailbox changes the state to be "SELECTED", closing a mailbox changes
    back to "AUTH", and once the client has logged out, the state changes
    to "LOGOUT" and no further commands may be issued.

    Note: to use this module, you must read the RFCs pertaining to the
    IMAP4 protocol, as the semantics of the arguments to each IMAP4
    command are left to the invoker, not to mention the results. Also,
    most IMAP servers implement a sub-set of the commands available here.

    Note also that you must call logout() to shut down threads before
    discarding an instance.
    c                       e Zd Zy)IMAP4.errorNrt   ru   rv   rx   rE   rN   errorr{         rE   r}   c                       e Zd Zy)IMAP4.abortNr|   rx   rE   rN   rk   r     r~   rE   rk   c                       e Zd Zy)IMAP4.readonlyNr|   rx   rE   rN   readonlyr     r~   rE   r   s   .*{(?P<size>\d+)}$s3   \* (?P<data>\d+) (?P<type>[A-Z-]+)( (?P<data2>.*))?s   \+( (?P<data>.*))?s
   \r\n|\r|\ns)   \[(?P<type>[A-Z-]+)( (?P<data>[^\]]*))?\]s$   \* (?P<type>[A-Z-]+)( (?P<data>.*))?Nc                    t         | _        d | _        i | _        g | _        d | _        d| _        d | _        d | _        d| _	        d| _
        g | _        d | _        d | _        d | _        d| _        d| _        t#        t%        j&                  dd            | _        t+        j,                  d| j(                  z   dz   t*        j.                        | _        | j3                          | j5                  |||       || _        ||t8        k  r|| _        nt8        | _        t<        | _        | jA                  ||       	 |r+| jC                  d| jD                  d	| jF                         ||| _$        n| jD                  | _$        | jH                  r| xjH                  d
z  c_$        dx| _%        | _&        tO        jP                         | _)        tO        jT                         | _+        tO        jT                         | _,        tO        jT                         | _-        t]        j^                  d      | _0        t]        j^                         | _1        tO        jd                  | jf                        | _4        | jh                  jk                  d       | jh                  jm                          tO        jd                  | jn                        | _8        | jp                  jk                  d       | jp                  jm                          tO        jd                  | jr                        | _:        | jt                  jk                  d       | jt                  jm                          	 | jw                  dd      jy                  d      d   | _=        | j}                  d      rt~        | _        | j                  dd       nK| j}                  d      r| j                  dd       n'| j                  dt        | jz                        z        | j                          | j                  dd| j                         t        D ]  }|| j                  vr|| _F         y  | j                  d      #  | j                           xY w)NFr   i   i  s   (?P<tag>s"   \d+) (?P<type>[A-Z]+) (?P<data>.*)Tzconnected to z	 on port  
   targetwelcomecontinuationrU   r\   zIMAP4 protocol error: %sr   PREAUTHstate => AUTHOKzstate => NONAUTHz'unrecognised server welcome message: %szCAPABILITY: zserver not IMAP4 compliant)Hr   stateliteraltagged_commandsuntagged_responsesmailboxis_readonlyidle_rqbidle_timeout_expecting_data_expecting_data_len_accumulated_data_literal_expected
compressordecompressor_tls_establishedr[   rO   randomrandintrX   recompilerS   tagre_mode_ascii_init_debugresp_timeoutREAD_POLL_TIMEOUTread_poll_timeout	READ_SIZE	read_sizeopen_mesghostport
identifier	TerminateTerminateReaderr]   r^   state_change_freeLockstate_change_pendingcommands_lock	idle_lockqueueQueueouqinqThread_writerwrth	setDaemonstart_readerrdth_handlerinth_request_pushrq   r   _get_untagged_responser   rn   r}   repr_get_capabilitiescapabilitiesAllowedVersionsPROTOCOL_VERSION_close_threads)	rc   r   r   debug
debug_filer   timeoutdebug_buf_lvlversions	            rN   rf   zIMAP4.__init__%  s|   
!"$  $#$ !#!%  %
 V^^D%89ZZ++!&@!ABD((L
 	&&uj-H#7->#>%,D"%6D"" 			$

499diiPQ !(DO"iiDO??OOs"O055-!*!2$-NN$4!&^^-");;r?;;=$$DLL9			D!		$$DLL9			D!		$$DMM:			D!		
	--9.-Q^^_yz{|}DL**95!
"ii?;,,T2"ii+=>jj!JTRVR^R^M_!_``""$))A4;L;L'NO* ?$"3"33(/%	? jj!=>>	!s   C3Q 	Q Q.c                 b    |t         v rt        | |j                               S t        d|z        )NzUnknown IMAP4 command: '%s')CommandsgetattrlowerAttributeError)rc   attrs     rN   __getattr__zIMAP4.__getattr__  s.    84..:TABBrE   c                     | S rh   rx   rc   s    rN   	__enter__zIMAP4.__enter__  s    rE   c                 D    	 | j                          y # t        $ r Y y w xY wrh   )logoutOSError)rc   argss     rN   __exit__zIMAP4.__exit__  s"    	KKM 		s    	c                     d| _         d| _        t        j                  | j                  t        j
                        | _        t        j                  | j                  t        j
                        | _        y )NFascii)	utf8_enabled	_encodingr   r   _literalrS   literal_cre_untagged_statusuntagged_status_crer   s    rN   r   zIMAP4._mode_ascii  sI    ! ::dmmRXX>#%::d.C.CRXX#N rE   c                     d| _         d| _        t        j                  | j                        | _        t        j                  | j                        | _        y )NTutf-8)r   r   r   r   r   r   r   r   r   s    rN   
_mode_utf8zIMAP4._mode_utf8  s=      ::dmm4#%::d.C.C#D rE   c                     | j                  d|      | _        | j                  t        |      | _        | j	                         | _        | j
                  j                         | _        y)zopen(host=None, port=None)
        Setup connection to remote server on "host:port"
            (default: localhost:standard IMAP4 port).
        This connection will be used by the routines:
            read, send, shutdown, socket. N)_choose_nonull_or_dfltr   
IMAP4_PORTr   open_socketsockfilenoread_fdrc   r   r   s      rN   r   z
IMAP4.open  sP     //D9	//
DA	$$&	yy'')rE   c                 X    t        j                  | j                  | j                  f      S )zJopen_socket()
        Open socket choosing first address family available.)socketcreate_connectionr   r   r   s    rN   r   zIMAP4.open_socket  s"     ''DII(>??rE   c                    	 dd l }i }t        |d      r!|j                  |j                  d|t        <   n	i |t        <   |t           j                         |t        <   |t           j                  d|j                  i       |t           j                         |t        <   |t           j                  |j                  |j                  d       t        |d      r$|t           j                  d|j                  i       | j                  |j                  }n|j                  }| j                  |vrt!        d| j                  z        | j"                  || j                     vr0t%        j&                  d	| j"                  d
| j                  d      || j                     | j"                     }t)        |dd      r|j+                  |      }||_        | j                  |j/                  | j                         | j0                  s| j2                  r&|j5                  | j0                  | j2                         |j7                  | j8                  | j:                        | _        nD|j7                  | j8                  | j2                  | j0                  | j                  ||      | _        |j<                  }| j8                  j?                         | _         | jD                  >| jE                  | j8                  jG                         | j:                        }|r ||      | j8                  jI                  t$        jJ                  t$        jL                  d       y # tB        $ r t%        j&                  d      w xY w)Nr   PROTOCOL_TLSv1_2)tls1_2tls1_1tls1)ssl23NPROTOCOL_SSLv3ssl3zunknown tls_level: %szInvalid SSL version 'z' requested for tls_version ''HAS_SNIF)server_hostname)ca_certs	cert_reqsssl_versionz1imaplib SSL mode does not work without ssl moduler   )'sslhasattrr   PROTOCOL_TLSv1_1
TLS_SECUREcopy
TLS_NO_SSLupdatePROTOCOL_TLSv1
TLS_COMPATPROTOCOL_SSLv23r   r  CERT_REQUIRED	CERT_NONE	tls_levelRuntimeErrorr  r   sslerrorr   
SSLContextverify_modeload_verify_locationscertfilekeyfileload_cert_chainwrap_socketr   r   SSLErrorr   r   ImportErrorcert_verify_cbgetpeercert
setsockopt
SOL_SOCKETSO_KEEPALIVE)rc   r  TLS_MAPr  r  ctxssl_exccert_errs           rN   ssl_wrap_socketzIMAP4.ssl_wrap_socket  s   5	WGs./!22!22'
#
 ')
#")*"5":":"<GJJ&&**(  #**"5":":"<GJJ&&,,))(  s,-
#**C..,  }}(--	MM	~~W,"#:T^^#KLLwt~~'>>oocgcscsuy  vD  vD  'E  F  F"4>>243C3CDKsIu-nn[1"+==,--dmm<==DLL''t||DOODIItyyOQ	OODIIt||T]]]a]j]jv  NYO  Z	llG99++-DL
 ***499+@+@+BDIINHh'' 			V..0C0CQG  	W//"UVV	Ws   KM M8c                     t        j                  d      | _        t        j                  t         j                  t         j
                  d      | _        y)zPstart_compressing()
        Enable deflate compression on the socket (RFC 4978).iN)zlibdecompressobjr   compressobjZ_DEFAULT_COMPRESSIONDEFLATEDr   r   s    rN   start_compressingzIMAP4.start_compressing  s8    
 !..s3**4+E+Et}}VYZrE   c                     | j                   | j                  j                  |      S | j                   j                  r| j                   j                  }n| j                  j                  t              }| j                   j                  ||      S z@data = read(size)
        Read at most 'size' bytes from remote.)r   r   recvunconsumed_tailr   
decompressrc   sizerb   s      rN   readz
IMAP4.read  n     $99>>$'',,$$44D99>>),D  ++D$77rE   c                     | j                   G| j                   j                  |      }|| j                   j                  t        j                        z  }| j
                  j                  |       y))send(data)
        Send 'data' to remote.N)r   compressflushr'  Z_SYNC_FLUSHr   sendallrc   rb   s     rN   sendz
IMAP4.send#  sS     ??&??++D1DDOO))$*;*;<<D		$rE   c                 2   	 | j                   j                  t        j                         | j                   j                          y# t        $ r(}|j
                  t
        j                  k7  r Y d}~Gd}~ww xY w# | j                   j                          w xY w)z3shutdown()
        Close I/O established in "open".N)r   shutdownr   	SHUT_RDWR	ExceptionerrnoENOTCONNclose)rc   es     rN   r?  zIMAP4.shutdown.  sj    	IIv//0 IIOO  	ww%..( )	
 IIOOs)   )A 	A7A2-A: 2A77A: :Bc                     | j                   S )zQsocket = socket()
        Return socket instance used to connect to IMAP4 server.r   r   s    rN   r   zIMAP4.socket<       yyrE   c                     	 | j                  dd      \  }}|dk(  r"| j                          | j                  dd       | j                          y# | j                          w xY w)a  enable_compression()
        Ask the server to start compressing the connection.
        Should be called from user of this class after instantiation, as in:
            if 'COMPRESS=DEFLATE' in imapobj.capabilities:
                imapobj.enable_compression()r   DEFLATEr   r   zEnabled COMPRESS=DEFLATEN)_simple_commandr,  rn   _release_state_changerc   rj   dats      rN   enable_compressionzIMAP4.enable_compressionG  sX    	)++J	BHCd{&&("ii+EF&&(D&&(s   <A A!c              #   "  K   | j                   r`| j                  j                          	 | j                   j                  d       | j                  j	                          | j                   r_yy# | j                  j	                          w xY ww)z for typ,data in pop_untagged_responses(): pass
        Generator for any remaining untagged responses.
        Returns and removes untagged responses in order of reception.
        Use at your own risk!r   N)r   r   acquirepopreleaser   s    rN   pop_untagged_responseszIMAP4.pop_untagged_responsesW  sq      %%&&(---11!44""**, %%
 ""**,s"   'BA0 &B.B0BBc                     d}| j                  ddg|      \  }}|dgk7  r| j                  |||      S ||d<    | j                  di |S )z(typ, [data]) = recent()
        Return 'RECENT' responses if any exist,
        else prompt server for an update using the 'NOOP' command.
        'data' is None if no new messages,
        else list of RECENT responses, most recent last.RECENTNuntagged_responserx   )_untagged_response_deliver_datnoop)rc   kwrU   rj   rN  s        rN   recentzIMAP4.recente  s^     **4$>S4&=$$S#r22"&tyy2rE   c                 r    | j                  |dg|j                               \  }}| j                  |||      S )z(code, [data]) = response(code)
        Return data for response 'code' if received, or None.
        Old value for response 'code' is cleared.N)rX  upperrY  )rc   coder[  rj   rN  s        rN   r`   zIMAP4.responset  s9    
 **4$FS  c2..rE   c                    d}|sd}|r|d   |d   fdk7  rd|z  }nd}|rt        |      }nd}t        |t              rt        |d      }| j                  j                  t        |      }| j                  rd	|z   d
z   }|| _        	  | j                  ||||fi || j                          S # | j                          w xY w)z(typ, [data]) = append(mailbox, flags, date_time, message)
        Append message to named mailbox.
        All args except `message' can be None.r   INBOXr   ()(%s)NrS   s   UTF8 (   ))r   
isinstancerZ   rY   mapCRLF_cresubCRLFr   r   rK  rL  )rc   r   flags	date_timemessager[  rU   r   s           rN   appendzIMAP4.append  s    
 Gar#y0E))4IIgs#GW-G""&&tW5')D0G	)'4''guiN2N&&(D&&(s   B, ,B>c                 t   t        |      j                  | _        	 | j                  d|j	                               \  }}|dk7  r | j                  | j                  |d   |       t        | _        | j                  dd       	 | j                          | j                  |||      S # | j                          w xY w)a  (typ, [data]) = authenticate(mechanism, authobject)
        Authenticate command - requires response processing.

        'mechanism' specifies which authentication mechanism is to
        be used - it must appear in <instance>.capabilities in the
        form AUTH=<mechanism>.

        'authobject' must be a callable object:

                data = authobject(response)

        It will be called to process server continuation responses,
        the 'response' argument will be a 'bytes'.  It should return
        bytes that will be encoded and sent to server.  It should
        return None if the client abort response '*' should be sent
        instead.r   r   rb  r   r   )_Authenticatorprocessr   rK  r^  _deliver_excr}   r   r   rn   rL  rY  )rc   	mechanism
authobjectr[  rj   rN  s         rN   authenticatezIMAP4.authenticate  s    $ &j199	)++NIOO<MNHCd{!!$**c"gr:DJ))A7&&(  c2.. &&(s   A%B% %B7c                 6    d}||d<    | j                   |fi |S )zI(typ, [data]) = capability()
        Fetch capabilities list from server.r   rW  rK  rc   r[  rU   s      rN   
capabilityzIMAP4.capability  s,     "&#t##D/B//rE   c                 &     | j                   di |S )z=(typ, [data]) = check()
        Checkpoint mailbox on server.)r   rx  rc   r[  s     rN   checkzIMAP4.check  s     $t##2r22rE   c                 P   | j                   dk7  r| j                  d      	 | j                  d      \  }}t        | _         | j	                  dd       | j                          | j                  |||      S # t        | _         | j	                  dd       | j                          w xY w)z(typ, [data]) = close()
        Close currently selected mailbox.

        Deleted messages are removed from writable mailbox.
        This is the recommended command before 'LOGOUT'.r   zNo mailbox selected.r   r   r   )r   r}   rK  r   rn   rL  rY  )rc   r[  rj   rN  s       rN   rD  zIMAP4.close  s     ::#**344	)++G4HCDJ))A7&&(  c2.. DJ))A7&&(s   A6 6/B%c                 ,     | j                   d||fi |S )zm(typ, [data]) = copy(message_set, new_mailbox)
        Copy 'message_set' messages onto end of 'new_mailbox'.r    rx  )rc   message_setnew_mailboxr[  s       rN   r  z
IMAP4.copy  s      $t##FKKKKrE   c                 *     | j                   d|fi |S )z;(typ, [data]) = create(mailbox)
        Create new mailbox.r!   rx  rc   r   r[  s      rN   createzIMAP4.create       $t##Hg<<<rE   c                 *     | j                   d|fi |S )z;(typ, [data]) = delete(mailbox)
        Delete old mailbox.r"   rx  r  s      rN   deletezIMAP4.delete  r  rE   c                 ,     | j                   d||fi |S )zk(typ, [data]) = deleteacl(mailbox, who)
        Delete the ACLs (remove any rights) set for who on mailbox.r#   rx  )rc   r   whor[  s       rN   	deleteaclzIMAP4.deleteacl  s      $t##K#DDDrE   c                     d| j                   vr| j                  d      | j                  d|      \  }}|dk(  r"d|j                         v r| j	                          ||fS )zkSend an RFC5161 enable string to the server.

        (typ, [data]) = <intance>.enable(capability)
        r$   zServer does not support ENABLEr   zUTF8=ACCEPT)r   r}   rK  r^  r   )rc   rz  rj   rb   s       rN   enablezIMAP4.enable  sc    
 4,,,**=>>((:>	T$;=J,<,<,>>OODyrE   c                 ,     | j                   d|dd|S )aU  (typ, [data]) = examine(mailbox='INBOX')
        Select a mailbox for READ-ONLY access. (Flushes all untagged responses.)
        'data' is count of messages in mailbox ('EXISTS' response).
        Mandated responses are ('FLAGS', 'EXISTS', 'RECENT', 'UIDVALIDITY'), so
        other responses should be obtained via "response('FLAGS')" etc.T)r   r   rx   )selectr  s      rN   examinezIMAP4.examine  s     t{{@7T@R@@rE   c                 6    d}||d<    | j                   |fi |S )z(typ, [data]) = expunge()
        Permanently remove deleted items from selected mailbox.
        Generates 'EXPUNGE' response for each deleted message.
        'data' is list of 'EXPUNGE'd message numbers in order received.r&   rW  rx  ry  s      rN   expungezIMAP4.expunge  s,     "&#t##D/B//rE   c                 :    d}||d<    | j                   |||fi |S )aA  (typ, [data, ...]) = fetch(message_set, message_parts)
        Fetch (parts of) messages.
        'message_parts' should be a string of selected parts
        enclosed in parentheses, eg: "(UID BODY[TEXT])".
        'data' are tuples of message part envelope and data,
        followed by a string containing the trailer.r'   rW  rx  )rc   r  message_partsr[  rU   s        rN   fetchzIMAP4.fetch  s0     "&#t##D+}KKKrE   c                 4    d|d<    | j                   d|fi |S )zC(typ, [data]) = getacl(mailbox)
        Get the ACLs for a mailbox.ACLrW  r(   rx  r  s      rN   getaclzIMAP4.getacl*  s)     #(#t##Hg<<<rE   c                 8    d|d<    | j                   d|||fi |S )zV(typ, [data]) = getannotation(mailbox, entry, attribute)
        Retrieve ANNOTATIONs.
ANNOTATIONrW  r)   rx  )rc   r   entry	attributer[  s        rN   getannotationzIMAP4.getannotation2  s.     #/#t##OWeYURTUUrE   c                 4    d|d<    | j                   d|fi |S )z(typ, [data]) = getquota(root)
        Get the quota root's resource usage and limits.
        (Part of the IMAP4 QUOTA extension defined in rfc2087.)QUOTArW  r*   rx  )rc   rootr[  s      rN   getquotazIMAP4.getquota:  s)    
 #*#t##J;;;rE   c                     | j                  d|      \  }}| j                  ||d      \  }}| j                  ||d      \  }}| j                  |||g|      S )z(typ, [[QUOTAROOT responses...], [QUOTA responses...]]) = getquotaroot(mailbox)
        Get the list of quota roots for the named mailbox.r+   r  	QUOTAROOT)rK  rX  rY  )rc   r   r[  rj   rN  quota	quotaroots          rN   getquotarootzIMAP4.getquotarootC  sd     ''@S,,S#w?
U00c;GY  y%&8"==rE   c           	          d}||d<   |sd}nMt        |      dk(  r|d   }n9ddj                  |D cg c]  }|xr | j                  |      xs d c}      z  } | j                  ||fi |S c c}w )a  (typ, [data]) = <instance>.id(kv_pairs)
        'kv_pairs' is a possibly empty list of keys and values.
        'data' is a list of ID key value pairs or NIL.
        NB: a single argument is assumed to be correctly formatted and is passed through unchanged
        (for backward compatibility with earlier version).
        Exchange information for problem analysis and determination.
        The ID extension is defined in RFC 2971. r,   rW  NILr   r   rf  r   )lenjoin_quoterK  )rc   kv_pairsr[  rU   rb   args         rN   idzIMAP4.idQ  s     "&D]aA;DCHHU]%^cs'?t{{3/?'H5'H%^__D#t##D$5"55 &_s    A.
c                     d}t        | |      j                  | _        	  | j                  |fi || j	                          S # | j	                          w xY w)z"(typ, [data]) = idle(timeout=None)
        Put server into IDLE mode until server notifies some change,
        or 'timeout' (secs) occurs (default: 29 minutes),
        or another IMAP4 command is scheduled.r-   )	_IdleContrr  r   rK  rL  )rc   r   r[  rU   s       rN   idlez
IMAP4.idleg  sP      w/77	)'4''33&&(D&&(s   A Ac                 :    d}||d<    | j                   |||fi |S )aN  (typ, [data]) = list(directory='""', pattern='*')
        List mailbox names in directory matching pattern.
        'data' is list of LIST responses.

        NB: for 'pattern':
        % matches all except separator ( so LIST "" "%" returns names at root)
        * matches all (so LIST "" "*" returns whole directory tree from root)r.   rW  rx  rc   	directorypatternr[  rU   s        rN   listz
IMAP4.listu  s0     "&#t##D)WCCCrE   c                 D   	 | j                  d|| j                  |            \  }}|dk7  r | j                  | j                  |d   |       t        | _        | j                  dd       	 | j                          | j                  |||      S # | j                          w xY w)z~(typ, [data]) = login(user, password)
        Identify client using plaintext password.
        NB: 'password' will be quoted.r/   r   rb  r   r   )	rK  r  rs  r}   r   r   rn   rL  rY  )rc   userpasswordr[  rj   rN  s         rN   loginzIMAP4.login  s    
	)++GT4;;x;PQHCd{!!$**c"gr:DJ))A7&&(  c2.. &&(s   A'B Bc                 \    ||c| _         | _         | j                  d| j                  fi |S )z\(typ, [data]) = login_cram_md5(user, password)
        Force use of CRAM-MD5 authentication.zCRAM-MD5)r  r  rv  _CRAM_MD5_AUTH)rc   r  r  r[  s       rN   login_cram_md5zIMAP4.login_cram_md5  s4     $( 	4= t  T-@-@GBGGrE   c                     ddl }t        | j                  t              r| j                  j	                  d      n| j                  }| j
                  dz   |j                  ||d      j                         z   S )z/Authobject to use with CRAM-MD5 authentication.r   Nr   r   md5)hmacrh  r  rZ   encoder  HMAC	hexdigest)rc   	challenger  pwds       rN   r  zIMAP4._CRAM_MD5_AUTH  sY    0:4==#0Nt}}##G,26-- 	yy33	5!A!K!K!MMMrE   c                    t         | _        | j                  dd       	 	 | j                  d      \  }}| j                          | j                          | j                  dd	       | j                  d
d      }|rd
|}}| j                  |||      S #  ddt	        j
                         dd z  g}}| j                  d|       Y xY w# | j                          w xY w)z(typ, [data]) = logout()
        Shutdown connection to server.
        Returns server 'BYE' response.
        NB: You must call this to shut down threads before discarding an instance.Tr   zstate => LOGOUTr   NOz%s: %sN   connection closedBYEleave)
r   r   rn   rK  sysexc_infor   rL  r   rY  )rc   r[  rj   rN  byes        rN   r   zIMAP4.logout  s     
ii#45		)0//9S
 !&&(ii#67))%t)<cC  c2..0(S\\^BQ-?"?!@S"ii3/ &&(s   B C 1CC Cc                 :    d}||d<    | j                   |||fi |S )z(typ, [data, ...]) = lsub(directory='""', pattern='*')
        List 'subscribed' mailbox names in directory matching pattern.
        'data' are tuples of message part envelope and data.r0   rW  rx  r  s        rN   lsubz
IMAP4.lsub  s0    
 "&#t##D)WCCCrE   c                 8    d}||d<    | j                   ||fi |S )zn(typ, [data]) = myrights(mailbox)
        Show my ACLs for a mailbox (i.e. the rights that I have on mailbox).r1   rW  rx  )rc   r   r[  rU   s       rN   myrightszIMAP4.myrights  s.     "&#t##D'8R88rE   c                 6    d}||d<    | j                   |fi |S )zM(typ, [data, ...]) = namespace()
        Returns IMAP namespaces ala rfc2342.r2   rW  rx  ry  s      rN   	namespacezIMAP4.namespace  s,     "&#t##D/B//rE   c                 H    | j                  d        | j                  di |S )z1(typ, [data]) = noop()
        Send NOOP command.r   )r3   )_dump_urrK  r|  s     rN   rZ  z
IMAP4.noop  s&     mmA&#t##1b11rE   c                 >    d}d|d<    | j                   |||||fi |S )z(typ, [data, ...]) = partial(message_num, message_part, start, length)
        Fetch truncated part of a message.
        'data' is tuple of message part envelope and data.
        NB: obsolete.r4   r'   rW  rx  )rc   message_nummessage_partr   lengthr[  rU   s          rN   partialzIMAP4.partial  s5     ")#t##D+|UFYVXYYrE   c                 v    	  | j                   d|fi || j                          S # | j                          w xY w)z(typ, [data]) = proxyauth(user)
        Assume authentication as 'user'.
        (Allows an authorised administrator to proxy into any user's mailbox.)r5   rK  rL  )rc   r  r[  s      rN   	proxyauthzIMAP4.proxyauth  s7    
	)'4''T@R@&&(D&&(   & 8c                 ,     | j                   d||fi |S )zV(typ, [data]) = rename(oldmailbox, newmailbox)
        Rename old mailbox name to new.r6   rx  )rc   
oldmailbox
newmailboxr[  s       rN   renamezIMAP4.rename  s      $t##Hj*KKKrE   c                     d}||d<   |r5| j                   r| j                  d       | j                  |d|g|i |S  | j                  |g|i |S )z(typ, [data]) = search(charset, criterion, ...)
        Search mailbox for matching messages.
        If UTF8 is enabled, charset MUST be None.
        'data' is space separated list of matching message numbers.r7   rW  z'Non-None charset not valid in UTF8 modeCHARSET)r   r}   rK  )rc   charsetcriteriar[  rU   s        rN   searchzIMAP4.search   sn     "&  jj!JKK'4''iR8RrRR#t##D:8:r::rE   c                    || _         t        |      | _        |rd}nd}	 | j                  ||      }|j	                  d|j
                  z        \  }}|dk7  r|| j                  t        k(  rt        | _        | j                  dd       |dk(  r$| j                  | j                  d	||||fz  |       | j                  |||      | j                          S t        | _        | j                  dd
       	 | j                          | j                  dd      r3|s1| j                  d       | j                  | j                   d|z  |       | j#                  |dgd      \  }}| j                  |||      S # | j                          w xY w)aO  (typ, [data]) = select(mailbox='INBOX', readonly=False)
        Select a mailbox. (Flushes all untagged responses.)
        'data' is count of messages in mailbox ('EXISTS' response).
        Mandated responses are ('FLAGS', 'EXISTS', 'RECENT', 'UIDVALIDITY'), so
        other responses should be obtained via "response('FLAGS')" etc.r%   r8   command: %s => %%sr   Tr   r   BAD%%s command error: %s %s. Data: %.100szstate => SELECTED	READ-ONLYr  z%s is not writableNEXISTS)r   boolr   _commandrq   rU   r   r   r   rn   rs  r}   rY  rL  r   r  r   rX  )rc   r   r   r[  rU   rqbrj   rN  s           rN   r  zIMAP4.select  sp    >DD	)--g.C''(<sxx(GHHCd{::)!%DJ"ii?;%<%%djj2Y]acfhkmt\u2uwyz((c26 &&( "DJ))A':;&&(&&{$&?--*dmm-AG-KRP**3AS  c2.. &&(s   B#E2 E2 2Fc                 z    	  | j                   d|||fi || j                          S # | j                          w xY w)zE(typ, [data]) = setacl(mailbox, who, what)
        Set a mailbox acl.r9   r  )rc   r   r  whatr[  s        rN   setaclzIMAP4.setacl3  s;    	)'4'''3KK&&(D&&(s   ( :c                 8    d|d<    | j                   dg|i |S )zT(typ, [data]) = setannotation(mailbox[, entry, attribute]+)
        Set ANNOTATIONs.r  rW  r:   rx  )rc   r   r[  s      rN   setannotationzIMAP4.setannotation=  s,     #/#t##OAdAbAArE   c                     d|d<   	  | j                   d||fi || j                          S # | j                          w xY w)zT(typ, [data]) = setquota(root, limits)
        Set the quota root's resource limits.r  rW  r;   r  )rc   r  limitsr[  s       rN   setquotazIMAP4.setquotaE  sF     #*	)'4''
D&GBG&&(D&&(s   , >c                 d    d}|d   |d   fdk7  rd|z  }||d<    | j                   |||g|i |S )zl(typ, [data]) = sort(sort_criteria, charset, search_criteria, ...)
        IMAP4rev1 extension SORT command.r<   r   rb  rc  rf  rW  rx  )rc   sort_criteriar  search_criteriar[  rU   s         rN   sortz
IMAP4.sortP  sW     !]2./9<"]2M"&#t##D-Y?YVXYYrE   r   c                    d}|| j                   vr| j                  d      | j                  r| j                  d      d| _        d| _        	 | j                  |      \  }	}
| j                          | j                  j                          d| _        t        | _        |	dk7  rnt        j                  | j                        | _        | j                  j                  d       | j                  j                          | j                  d	|
z        || _        || _        || _        || _        || _        || _        	 | j-                          t        j                  | j                        | _        | j                  j                  d       | j                  j                          | j/                          d| _        | j1                  |	|
|      \  }	}
| j3                  |	|
|      S # | j                          | j                  j                          d| _        t        | _        w xY w# t        j                  | j                        | _        | j                  j                  d       | j                  j                          w xY w)
z(typ, [data]) = starttls(keyfile=None, certfile=None, ca_certs=None, cert_verify_cb=None, ssl_version="ssl23", tls_level="tls_compat")
        Start TLS negotiation as per RFC 2595.r=   zTLS not supported by serverzTLS session already establishedr   TFr   r   z"Couldn't establish TLS session: %s)r   rk   r   r   r   rK  rL  r   r  r   r]   r   r   r   r   r}   r  r  r  r  r  r  r%  r   rX  rY  )rc   r  r  r  r  r  r  r[  rU   rj   rN  s              rN   starttlszIMAP4.starttls[  s    t(((**:;;  **>?? #	'++D1HC&&(IINN#(D &DN$;!((=DIII%IIOO**ACGHH  ,&"	  " "((=DIII%IIOO  $**3T:S  c2..A &&(IINN#(D &DN( "((=DIII%IIOOs   G& <H' &>H$'AJc                 :    d}||d<    | j                   |||fi |S )z[(typ, [data]) = status(mailbox, names)
        Request named status conditions for mailbox.r>   rW  rx  )rc   r   namesr[  rU   s        rN   statuszIMAP4.status  s0     "&#t##D'5?B??rE   c                 \    |d   |d   fdk7  rd|z  }d|d<    | j                   d|||fi |S )zl(typ, [data]) = store(message_set, command, flags)
        Alters flag dispositions for messages in mailbox.r   rb  rc  rf  r'   rW  r?   rx  )rc   r  commandrl  r[  s        rN   storezIMAP4.store  sK     !HU2Y9,UNE")#t##G['5OBOOrE   c                 v    	  | j                   d|fi || j                          S # | j                          w xY w)zD(typ, [data]) = subscribe(mailbox)
        Subscribe to new mailbox.r@   r  r  s      rN   	subscribezIMAP4.subscribe  s7    	)'4''WCC&&(D&&(r  c                 @    d}||d<    | j                   |||g|i |S )zv(type, [data]) = thread(threading_alogrithm, charset, search_criteria, ...)
        IMAPrev1 extension THREAD command.rA   rW  rx  )rc   threading_algorithmr  r  r[  rU   s         rN   threadzIMAP4.thread  s7     "&#t##D*=w__\^__rE   c                 t    |j                         }|t        v r|}nd}||d<    | j                  d|g|i |S )z(typ, [data]) = uid(command, arg, ...)
        Execute "command arg ..." with messages identified by UID,
            rather than message number.
        Assumes 'command' is legal in current state.
        Returns response appropriate to 'command'.r'   rW  rB   )r^  
UID_directrK  )rc   r  r   r[  resps        rN   uidz	IMAP4.uid  sK     --/j DD"&#t##E7@T@R@@rE   c                 v    	  | j                   d|fi || j                          S # | j                          w xY w)zJ(typ, [data]) = unsubscribe(mailbox)
        Unsubscribe from old mailbox.rC   r  r  s      rN   unsubscribezIMAP4.unsubscribe  s7    	)'4''wE"E&&(D&&(r  c                     |j                         }|t        vr| j                  fdft        |<   	  | j                  |g|i || j	                          S # | j	                          w xY w)z(typ, [data]) = xatom(name, arg, ...)
        Allow simple extension commands notified by server in CAPABILITY response.
        Assumes extension command 'name' is legal in current state.
        Returns response appropriate to extension command 'name'.F)r^  r   r   rK  rL  rc   rU   r   r[  s       rN   xatomzIMAP4.xatom  sc     zz|x#zzmU3HTN	)'4'':t:r:&&(D&&(s   A A(c           
      z   |d}| j                   j                          | j                  r| j                  d   \  }}||k7  rd }nd }|g }| j                  j                  ||g       |j                  |       | j                   j	                          | j                  dd|dt        |      dz
  d|dd	       y )
NrE   rb     zuntagged_responses[] r   z += [".80z"])r   rQ  r   ro  rS  rn   r  )rc   rj   rN  urnurds        rN   _append_untaggedzIMAP4._append_untagged  s    
 ;c""$""..r2HCczC;C##**C:6

3""$iisTWX[T\]^T^`c#derE   c                 v    | j                  dd      }|r$| j                  |d   j                  dd            y )Nr  Tr  rb  rS   replace)r   rk   decode)rc   r  s     rN   
_check_byezIMAP4._check_bye   s=    ))%t)<**SW^^GY?@@ rE   c                     t        |t              rt        }nt        |      }|D ]6  }|t        ||      r|c S | j                  ddt        |      d|       8 |S )Nr   zbad arg is z, expecting )rh  rZ   typern   )rc   dfltr   dflttypr  s        rN   r   zIMAP4._choose_nonull_or_dflt  s_    dC G4jG 	bCsG,Z#yyTRUYX_,`a		b
 rE   c           	         t         |   t           rd}nd}| j                  dd|d|d|       | j                  dd	       | j                  j	                          | j                          |dk(  r-| j                  j                          | j                  dd
       n| j                          | j                  j	                          | j                  r| j                  j                          d}nd}| j                  j                          |rD| j                  dd|z         | j                  j                          | j                  dd|z         | j                  t         |   t           vr(d | _        | j!                  d|d| j                        | j                          |dv r<| j                  j	                          g | _        | j                  j                          nPdD ]  }| j%                  |      s | j&                  s+| j%                  dd      rd | _        | j)                  d      | j*                  r| j-                  d       | j.                  d#d|i|}t1        || j2                        }|j4                  dz   |z   }|D ]3  }	|	t7        |	t8              rt1        |	| j2                        }	|dz   |	z   }5 | j                  }
|
Qd | _        t;        |
      t;        | j<                        u r|
}n'd }|t1        dt?        |
      z  | j2                        z   }| j                  dd|z         |t@        z   |_!        |
| jD                  jG                  |       |S | j/                  |d      }| jD                  jG                  |       	 |jI                  d|z        \  }}| j                  dd|d|       |s	 |S |d k(  rd!}	 |||      }
|
	 |S || j/                  |d      }| j                  dd"t?        |
      z         |
t@        z   |_!        | jD                  jG                  |       |	 |S )$NasyncsyncTr   [r  r   r   zstate_change_pending.acquirestate_change_pending.releaseFz,sync command %s waiting for empty commands Qzsync command %s proceedingzcommand z illegal in state )r%   r8   r   r  r  r  r  z#mailbox status changed to READ-ONLYr  rU       z {%s}   zdata=%rr   r   r  zcontinuation => , zgo aheadr   zwrite literal size %srx   )%r   CMD_VAL_ASYNCrn   r   rQ  	_end_idlerS  r  r   r   r   clearro   r   CMD_VAL_STATESr   r}   r   r   r   r   r   rk   r   rY   r   r\   rh  rZ   r   r  r  rk  rb   r   putrq   )rc   rU   r   r[  cmdtyp
need_eventrj   r  rb   r  r   	literatorcrqboks                 rN   r  zIMAP4._command  s   D>-(FFii64#FGii#AB!!))+W%%--/))A'EF OO&&(##&&,,.!
"
&&("ii+Y\`+`a&&++-"ii+G$+NO::Xd^N;;DL**#'5 6 6 	((&&(&(D#&&(* 11#6 ##(C(CKW[(C(\#mm$IJJ>>**011 d  1d1b1T4>>*ww~$ 	%C{H#s#C0$;$D		% ,,DLG}T]] 33#	 	eGc'l$:DNNKKii9t#34$;?HHLLJ !!t!@S (()=)DEHB))A2t'LM 0 
- z! $#D#. 
 $))t)H))A'>W'MN$DIHHLL 
C rE   c                 "   | j                          |j                  d|j                  z        \  }}|dk(  r<| j                          | j	                  d|j                  |||j
                  fz        d|v r| j                  |||d         S ||fS )Nr  r  r  rW  )r  rq   rU   
_print_logr}   rb   rX  )rc   r  r[  rj   rN  s        rN   _command_completezIMAP4._command_complete  s     	##$8388$CDS%<//+**DRUWZ\_\d\dGeeff"$**3R8K5LMMCxrE   c           	      |   |\  }}}|\  }}|d   |_         |j                  d      |_        |(| j                          |\  }}|j	                  ||       y | j                  dd      }	|	r0|j	                  | j                  |	d   j                  dd             y |\  }}
|d	k(  rH| j                          |j	                  | j                  d
|j                  ||
|j                  fz         y | j                  dd|d|d|j                         d|v r| j                  ||
|d         }|j                  |       y )NrV   rd   Tr  r  rb  rS   r  r  r  r*  z_command_completer(r+  z
, None) = rW  )rV   getrW   r7  rk   r   r  r}   rU   rb   rn   r\   rX  ri   )rc   cb_arg_listr`   rd   r}   r  r[  rj   rK   r  rN  s              rN   _command_completerzIMAP4._command_completer  s1    #.&%R*~66(+//+HCIIc3))%t)<IIdjj#b'..)"DES%<//+IIdjj"ISXXWZ\_adaiaiLj"jkiihX^`c`g`g#hi"$..sC<O9PQHHrE   c                 P    d|v r |d   ||f|j                  d      d f       ||fS NrV   rd   r:  )rc   rj   rN  r[  s       rN   rY  zIMAP4._deliver_dat  s5    BzNS#Jx(8$?@CxrE   c                 X    d|v r |d   d |j                  d      ||ff        ||      r>  r?  )rc   excrN  r[  s       rN   rs  zIMAP4._deliver_exc  s5    BzND"&&"2S#J?@#hrE   c                 d   | j                   j                          | j                  }|| j                   j                          y d | _        d | _        | j                   j                          t        dd      t        z   |_        | j                  j                  |       | j                  dd       y )NDONErS   r  zserver IDLE finished)r   rQ  r   rS  r   rY   rk  rb   r   r0  rn   )rc   irqbs     rN   r-  zIMAP4._end_idle  s     }}<NN""$  &'*T1	Tii#9:rE   c                     | j                         \  }}|d gk(  r| j                  d      t        |d   d      }|j                         }t	        |j                               | _        y )Nz"no CAPABILITY response from serverrb  rS   )rz  r}   rZ   r^  tuplesplitr   rM  s      rN   r   zIMAP4._get_capabilities  sY    ??$S4&=**ABB#b'7#iik!#))+.rE   c           	      B   | j                   j                          t        | j                        D ]S  \  }\  }}||k(  s|s| j                  |= | j                   j	                          | j                  dd|d|d       |c S  | j                   j	                          y )Nr  z_get_untagged_response() => r  )r   rQ  	enumerater   rS  rn   )rc   rU   r  irj   rN  s         rN   r   zIMAP4._get_untagged_response  s    ""$&t'>'>? 	MAzSd{//2""**,"iiTXZ]+^_
	 	""$rE   c                 J    |j                  |      | _        | j                  d uS rh   )matchmo)rc   cress      rN   _matchzIMAP4._match  s"    
 ))A,wwd""rE   c                 $   | j                   rt        |      }t        | j                  |      }| j	                  dd| j                  d|       | xj                  |z  c_        | j                  dk7  | _         ||k  r| j
                  j                  |       y | j
                  j                  |d |        ||d  }| j
                  rC| j                  \  }}| j                  ||dj                  | j
                        f       g | _        |d d }| j	                  dd|z         d	| j                  v rd}nd
}| j                  |}| j                  | j                  |      r_|| j                  d<   d| _         t        | j                  j                  d            | _        | j	                  dd| j                  z         y | j                  d   }d | _        |r| j                  ||       | j	                  dd       nS| j                  | j                   |      r| j                  j                  d      }t#        | j                  j                  d      d      }| j                  j                  d      }|dv rj| j                  | j$                  |      rN| j                  t#        | j                  j                  d      d      | j                  j                  d             || j                  vr| j	                  dd|z         nH| j'                  |||gf       n1d }| j                  | j(                  |      s7| j                  | j*                  |      r| j                  j                  d      }| j                  x| j                  | j,                  |      rF|s| j	                  dd|z         y | j'                  d	d| j                  j                  d      f       y | j	                  dd|z         y t#        | j                  j                  d      d      }| j                  j                  d      }|d}|r|dz   |z   }| j                  | j                  |      rYd| _         t        | j                  j                  d            | _        | j	                  dd| j                  z         ||g| _        y | j                  ||       |dv rj| j                  | j$                  |      rN| j                  t#        | j                  j                  d      d      | j                  j                  d             |dk7  r| j/                          |r| j'                  d	d
|f       |dv r$|dk(  rd| _        | j	                  d|d|       y y )NTr  z!_put_response expecting data len z, got r   rE   z_put_response(%r)r   Fr   r3  r*  zexpecting literal size %szliteral completedr\   r   rS   rb   r(  zunexpected tagged response: %rdata2z&unexpected continuation response: '%r'zunexpected response: '%r'r)  zread literal size %sr   )r  r  r  r  z response: )r   r  minr   rn   r   ro  r   r  r  r   rQ  r   rG   rN  groupr   rZ   response_code_cre_request_popuntagged_response_crer   continuation_crer-  r   )	rc   r  rlendlenrj   rN  continuation_expectedr\   dat2s	            rN   _put_responsezIMAP4._put_response  s   t9Dt//6D))AX\XpXprv'wx$$,$$($<$<$AD t|&&--d3""))$u+6;D!!--HC!!#SXXd6L6L-M'NO%'D" CRyii#6#=>T111$(!$)!!!-C{{4++S1,/&&q)'+$+.tww}}V/D+E("ii+FIaIa+ab((+C%)D"%%c3/))A':; {{4::t,ggmmE*$''--/9ggmmF+--$++d>T>TVY2Z))#dggmmF.CW*Mtww}}]cOded222"&))A/ORV/V"W%%cC#<8 {{4#=#=tD{{4#;#;TB#ww}}W577? {{4#8#8$?4*.))A7_bf7f*g")).4vAV:WX"&))A/JT/Q"R$''--/9ggmmF+;csTzD0 ;;t//5+/D(/2477==3H/ID,"&))A/EH`H`/`"a.13ZD*%%c3/--$++d>T>TVY2Z))#dggmmF.CW*Mtww}}]cOde$;NN$ !nudm< &&e|!%))AC'EF 'rE   c                 L    d|j                  dd      j                  dd      z  S )Nz"%s"\z\\"z\")r  )rc   r  s     rN   r  zIMAP4._quoted  s%    D&199#uEEErE   c                     | j                   j                         r-| j                   j                          | j                  dd       y y )Nr   r'  )r   lockedrS  rn   r   s    rN   rL  zIMAP4._release_state_changei  s:    $$++-%%--/))A'EF .rE   c           	         | j                   j                          | j                  j                  |      }| j                  sd}nd}| j                   j	                          | j                  dd||t        | j                        |j                  fz         |j                  |       |r-| j                  dd       | j                  j                          y y )NTFr*  z_request_pop(%s, %r) [%d] = %sr   state_change_free.set)r   rQ  r   rR  rS  rn   r  r\   ri   r   rs   )rc   rU   rb   r  r2  s        rN   rX  zIMAP4._request_popp  s    ""$""&&t,##JJ""$ii#CtTSVW[WkWkSlnqnunuFv#vwD))A'>?""&&( rE   c                 &   | j                   j                          t        | fd|i|}||j                  }|| j                  |<   | j                   j                          | j                  dd|d|dt        |      d|j                         |S )NrU   r*  z_request_push(r+  z) = )r   rQ  rQ   r\   r   rS  rn   r   )rc   r\   rU   r[  r  s        rN   r   zIMAP4._request_push  s    ""$d,,,;''C$'S!""$iisDRVWYRZ\_\c\c#de
rE   c                     d|v r# | j                   |g|| j                  |dd y| j                   | j                   |g| |      S )NrV   T)rV   rd   re   NN)r  r<  r8  r  s       rN   rK  zIMAP4._simple_command  sT    DMM$a\`a)@)@UYa%%mdmmD&@4&@"EErE   c           
          |dk(  r||fS | j                  |      }|s|d gfS 	 | j                  |      }|sn||z  }| j                  dd|d|d|d       ||fS )Nr  r*  z_untagged_response(z, ?, rI  r  )r   rn   )rc   rj   rN  rU   rb   s        rN   rX  zIMAP4._untagged_response  s{    $;8O**40;--d3CCKD	 
 iisTXZ^#_`DyrE   c                 >   | j                  dd       | j                  j                  d        | j                  j	                          | j                  dd       | j                          | j                  j	                          | j                  j	                          y )Nr   r   zcall shutdown)rn   r   r0  r   r  r?  r   r   r   s    rN   r   zIMAP4._close_threads  sb    ii#34T		ii?3				rE   c                 ~   | j                   }t        j                         j                  | j                  dz          t        j                  d       | j                  dd       | j                  d}}| j                  s| j                  j                          | j                  K| j                  t        j
                         z
  }|dk  rd}	 | j                  | j                  dd	|z         n|}| j                  j                          	 | j                  j!                  d|      }|| j                  dd       n5t+        |t,              s|\  }}n	 | j/                  |       | j                  sd| _	        | j                  ddt7        |      z         | j8                  j;                         sJ	 | j8                  j=                         }||j                  ||       | j8                  j;                         sJ| j8                  j?                  d        | j@                  j                          tC        | j&                  jE                               D ]/  }| j&                  jG                  |      }|j                  ||       1 | jH                  jK                          | j@                  j                          | j                  dd       | j                  dd       y # t"        j$                  $ r | j                  7|2| j&                  r&| j                  dd
       | j                  d|z  }}Y Y | j                  t        j
                         kD  rY | j                  dd       t(        }Y Kw xY w#  | j0                  dt3        j4                         d d z  }}Y 0xY w# t"        j$                  $ r Y w xY w)Nhandler皙?Tr   startingzconnection terminatedr   r  zserver IDLING, timeout=%.2fzresponse timeoutzno response after %s secsr  zserver IDLE timedoutzinq None - terminatingzprogram error: %s - %szterminating: %sr   rf  finished)&r   r]   currentThreadsetNamer   timesleeprn   rk   r   r   rQ  r   r   rS  r   r:  r   Emptyr   IDLE_TIMEOUT_RESPONSErh  rY   r_  r}   r  r  r   r   empty
get_nowaitr0  r   r  keysrR  r   rs   )	rc   r   rj   rK   r   lineqelrU   r  s	            rN   r   zIMAP4._handler  s   ((!))$//I*EF

3ii:.::6S..NN""$  ,++diik9a<G}}0		!%BW%LM&NN""$-xx||D'2 |"ii+CDdE*S""4(K ..T ii#4tCy#@A((.."hh))+?IIc3'	 ((.." 	T""$--2245 	 D&&**40CIIc3	  	""$""$ii#:;ii:._ ;; 
-==(#/D4H4H&*ii3E&F#'::/J\/YS$$tyy{2"ii+AB,
-,::'?#,,.QSRSBT'TS ;; s=   K M7 2.N% AM44!M4M43M47(N"%N<;N<pollc                    t        j                         j                  | j                  dz          | j	                  dd       d }d}t        j                         }|j                  | j                  t
        j                         d}d}| j                  d	z  }|s| j                  s|| j                  t        k(  rd
}n|}	 |j                  |      }| j	                  ddt        |      z         |s[|d   \  }	}
|
t
        j                  z  r| j                  | j                         }d}t#        |      }| j	                  dd|z         |dk(  r+|dz  }|dkD  rt%        d      t'        j(                  d       d}	 |j+                  d|      }|dk  r	|||d  z  }nP|dz  }d||||| z   }}}| j	                  dd|z         | j,                  j/                  |       | j0                  rd}p|
t
        j                   z  rt%         ||
            	 |s| j                  s||j=                  | j                         | j	                  dd       y #  dt3        j4                         d d z  }	 | j                  sC| j7                          | j8                  r| xj8                  dz  c_        | j	                  d|       | j,                  j/                  | j:                  |f       Y xY w)NreaderTr   zstarting using pollc                     t         j                  dt         j                  dt         j                  di}dj	                  |j                         D cg c]  }|| z  s	||    c}      S c c}w )NErrorzHang upz$Invalid request: descriptor not openr   )r  POLLERRPOLLHUPPOLLNVALr  ry  )r   
PollErrorsrP  s      rN   
poll_errorz!IMAP4._reader.<locals>.poll_error  sU    GI$JJ
 88JOO4EUq!e)Z]UVVUs   
A)A)rE   r   F  r   r  z
poll => %srcvd %sToo many read 0rn     
r*  < %rsocket error: %s - %sr  rp  )r]   rq  rr  r   rn   r  r|  registerr   POLLINr   r   r   r   r   r4  r   r  IOErrorrs  rt  findr   r0  r   r  r  r7  r   rk   
unregister)rc   r  	line_partr|  rxzero	terminater   r   rfdr   rb   r   r\  stoprz  reasons                    rN   r   zIMAP4._reader
  s   !))$//H*DEii#89	W 	{{}dllFMM2	 22T9zzV#+,IIg&"ii<$q'+ABQ456==(99T^^4DEt9D"&))Ay4/?"@qy!!A:")*;"<<

3 F#yy6!8%ef5I!	y4d3C'C +/5	&*ii6D=&AT*//(,I  V]]++!*U"344 ,O f 	%ii:.03<<>"13EE>>)::tzzQz		!V,djj&12s   1I 4BI <BI BK(c           	         t        j                         j                  | j                  dz          | j	                  dd       d}d}d}|sv| j
                  si| j                  t        k(  rd}n| j                  }	 t        j                  | j                  gg g |      \  }}}| j	                  dd	|d
|d
|       |sx| j                  | j                        }d}	t        |      }
| j	                  dd|
z         |
dk(  r+|dz  }|dkD  rt        d      t        j                   d       d}	 |j#                  d|	      }|dk  r	|||	d  z  }n`|dz  }d||||	| z   j%                  d      }}	}| j	                  dd|z         | j&                  j)                  |       | j*                  rd}	 |s| j
                  si| j	                  dd       y #  dt-        j.                         d d z  }	 | j
                  sC| j1                          | j2                  r| xj2                  dz  c_        | j	                  d|       | j&                  j)                  | j4                  |f       Y xY w)Nr~  Tr   zstarting using selectrE   r   Fr  z
select => r+  r  r  rn  r  ignore)errorsr*  r  r  r  rp  )r]   rq  rr  r   rn   r   r   r   r   r  r   r4  r   r  r  rs  rt  r  r  r   r0  r   r  r  r7  r   rk   )rc   r  r  r  r   r  wrE  rb   r   r\  r  rz  r  s                 rN   r   zIMAP4._reader]  s4   !))$//H*DEii#:;		zzV#00&t||nb"gF!A"iiQq+KLyy04y"ii9t+;<19aKFz%&788JJsO99UE2Dax!T%&\1	AIDTIU40@$@#H#HPX#H#Y '+uI"&))Av}"=HHLL&++$(	  7 Z ii:.03<<>"13EE>>)::tzzQz		!V,djj&12s   <AG A,G .BG BI*c                    t        j                         j                  | j                  dz          | j	                  dd       d}| j
                  sf| j                  j                         }|nI	 | j                  |j                         | j	                  dd|j                  z         	 | j
                  sf| j                  j!                  | j                  |f       | j	                  dd	       y #  dt        j                         d d z  }	 | j
                  sC| j                          | j                  r| xj                  dz  c_        | j	                  d|       |j                  | j                  |       Y xY w)
Nwriterr   ro  
Terminatedr*  z> %rr  r  rp  )r]   rq  rr  r   rn   r   r   r:  r=  rb   r  r  r7  r   rk   r   r0  )rc   r  r  s      rN   r   zIMAP4._writer  s   !))$//H*DEii:...((,,.C{		#((#"ii6CHH+<= ..$ 	djj&)*ii:.03<<>"13EE>>)::tzzQz		!V,		$**f-s   /:C1 1BE;c                    t        j                         | _        | j                  d|      | _        | j                  t
        j                  |      | _        | j                  t        |      | _	        d| _
        d| _        i | _        | j                  rD| j                  dt        z         | j                  d| j                  d| j                         y y )Nr      zimaplib2 version %szimaplib2 debug level z, buffer level )r]   r   
debug_lockr   r   r  stderrr   DFLT_DEBUG_BUF_LVLr   _cmd_log_len_cmd_log_idx_cmd_logr   __version__)rc   r   r   r   s       rN   r   zIMAP4._init_debug  s    'nn.DO44Q>DJ"99#**jQDO!%!<!<=OQ^!_D "D !DDMzz

0;>?

UYUgUghi rE   c           	      r   || j                   kD  ry | j                  }|sy d}|D cg c]-  }|d   d|d   d   xr dj                  |d         xs dd/ }}| j                  j	                          | j                  d||j                  |             | j                  j                          y c c}w )	Nz
		r   z: "r   s   " "r   rb  zuntagged responses dump:)r   r   r  r  rQ  r   rS  )rc   lvlltxs        rN   r  zIMAP4._dump_ur  s    TZZ''AASTUaqtQqT!W%BQqT1B%Hb%HIUAUOO##%JJAFF1IFGOO##% Vs   2B4c                    || j                   kD  ry |dd  t        k(  r|d d dz   }t        j                         j	                         }|dk  s| j                   | j
                  kD  rL| j                  j                          | j                  ||       | j                  j                          |dk7  ry | j                  j                          ||t        j                         f| j                  | j                  <   | xj                  dz  c_        | j                  | j                  k\  rd| _        | j                  j                          y )NrS  z\r\nr   r   )r   rk  r]   rq  getNamer   r  rQ  r   rS  rs  r  r  r  )rc   r  rz  tns       rN   rn   z
IMAP4._log  s   TZZBCyD CRy8+((*224Bax4::(:(::'')

4$'')!8 OO##%04b$))+/FDMM$++,"  D$5$55$%!OO##%rE   c                 Z   |t        j                          }|"t        j                         j                         }t        j                  dt        j
                  |            }	 | j                  j                  d||dz  dz  ||fz         | j                  j                          y # w xY w)Nz%M:%Sz  %s.%02d %s %s
d   )	rs  r]   rq  r  strftime	localtimer   writer9  )rc   rP  r  secstms        rN   r   zIMAP4._mesg  s    |yy{z,,.668wt(<=B%%&9R$s(CQSUV<W&WX%%'s   %AB( (B*c                 P   | j                   j                          | j                  | j                  }}|r| j	                  d|z         |r;	  | j                  | j
                  |     |dz  }|| j                  k\  rd}|dz  }|r;| j                   j                          y #  Y =xY w)Nzlast %d log messages:r   r   )r  rQ  r  r  r   r  rS  )rc   rK  ns      rN   r7  zIMAP4._print_log  s    OO##%$$d&7&7qA$**4q89DJJa 01 Q)))AQ  OO##%s   B! !B%NNNNNNNri  )ra  rh   )""*)ra  F)F)NNN)nrt   ru   rv   rw   rA  r}   rk   r   r   r   r   r   rZ  ri  rW  rY  rf   r   r   r   r   r   r   r   r%  r,  r4  r=  r?  r   rO  rT  r\  r`   ro  rv  rz  r}  rD  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r   r  r  r  rZ  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r
  r  r  r  r  r  r   r  r8  r<  rY  rs  r-  r   r   rQ  r_  r  rL  rX  r   rK  rX  r   r   r  select_moduler   r   r   r  rn   r   r7  rx   rE   rN   r   r      s   CJ !	 5 &HN!rzz"89"**^,K"

#PQ&BJJ'OPhVCOE
*@@HH[8 ) -/):/<03/$L==E
A0
L=V<>6,)D/ HN/8D902Z)L;!/H)B)Z  $dTRVdk  xB 4/n@P)`A ))&f6A
xv6;/ #jGZF
G)$	F(K/\ }f%M/f8/v/F 	j	&	&2
		&rE   r   c                   L    e Zd ZdZddddddddddddefdZd	dZd Zd Zd Z	y)
r   aJ  IMAP4 client class over SSL connection

    Instantiate with:
        IMAP4_SSL(host=None, port=None, keyfile=None, certfile=None, ca_certs=None, cert_verify_cb=None, ssl_version="ssl23", debug=None, debug_file=None, identifier=None, timeout=None, debug_buf_lvl=None, tls_level="tls_compat")

        host           - host's name (default: localhost);
        port           - port number (default: standard IMAP4 SSL port);
        keyfile        - PEM formatted file that contains your private key (default: None);
        certfile       - PEM formatted certificate chain file (default: None);
        ca_certs       - PEM formatted certificate chain file used to validate server certificates (default: None);
        cert_verify_cb - function to verify authenticity of server certificates (default: None);
        ssl_version    - SSL version to use (default: "ssl23", choose from: "tls1","ssl3","ssl23");
        debug          - debug level (default: 0 - no debug);
        debug_file     - debug stream (default: sys.stderr);
        identifier     - thread identifier prefix (default: host);
        timeout        - timeout in seconds when expecting a command response.
        debug_buf_lvl  - debug level at which buffering is turned off.
        tls_level      - TLS security level (default: "tls_compat").

    The recognized values for tls_level are:
        tls_secure: accept only TLS protocols recognized as "secure"
        tls_no_ssl: disable SSLv2 and SSLv3 support
        tls_compat: accept all SSL/TLS versions

    For more documentation see the docstring of the parent class IMAP4.
    Nr   c           
          || _         || _        || _        || _        || _        || _        t        j                  | ||||	|
||       y rh   )r  r  r  r  r  r  r   rf   )rc   r   r   r  r  r  r  r  r   r   r   r   r   r  s                 rN   rf   zIMAP4_SSL.__init__0  sI      ,&"tT4
JQ^_rE   c                     | j                  d|      | _        | j                  t        |      | _        | j	                         | _        | j                          y)zopen(host=None, port=None)
        Setup secure connection to remote server on "host:port"
            (default: localhost:standard IMAP4 SSL port).
        This connection will be used by the routines:
            read, send, shutdown, socket, ssl.r   N)r   r   IMAP4_SSL_PORTr   r   r   r%  r   s      rN   r   zIMAP4_SSL.open:  sH     //D9	//E	$$&	rE   c                     | j                   | j                  j                  |      S | j                   j                  r| j                   j                  }n| j                  j                  t              }| j                   j                  ||      S r.  )r   r   r4  r0  r   r1  r2  s      rN   r4  zIMAP4_SSL.readG  r5  rE   c                    | j                   G| j                   j                  |      }|| j                   j                  t        j                        z  }t        | j                  d      r| j                  j                  |       yt        |      }|dkD  r2| j                  j                  |      }||k(  ry||d }||z
  }|dkD  r1yy)r7  Nr;  r   )
r   r8  r9  r'  r:  r  r   r;  r  r  )rc   rb   r\  sents       rN   r=  zIMAP4_SSL.sendV  s     ??&??++D1DDOO))$*;*;<<D499i(IId#t9D(yyt,4<DE{d{ (rE   c                     | j                   S )zRssl = ssl()
        Return ssl instance used to communicate with the IMAP4 server.rG  r   s    rN   r  zIMAP4_SSL.sslj  rH  rE   ri  )
rt   ru   rv   rw   r  rf   r   r4  r=  r  rx   rE   rN   r   r     sc    8 !tTDSWhl  {B  JN  [_  lp  z~  NR  ^h `
8#(rE   r   c                   2    e Zd ZdZddZd	dZd Zd Zd Zy)
r   a  IMAP4 client class over a stream

    Instantiate with:
        IMAP4_stream(command, debug=None, debug_file=None, identifier=None, timeout=None, debug_buf_lvl=None)

        command        - string that can be passed to subprocess.Popen();
        debug          - debug level (default: 0 - no debug);
        debug_file     - debug stream (default: sys.stderr);
        identifier     - thread identifier prefix (default: host);
        timeout        - timeout in seconds when expecting a command response.
        debug_buf_lvl  - debug level at which buffering is turned off.

    For more documentation see the docstring of the parent class IMAP4.
    Nc           
          || _         || _        d | _        d | _        d\  | _        | _        d | _        t        j                  | d d |||||       y )Nri  )	r  r   r   r   	writefilereadfiler   r   rf   )rc   r  r   r   r   r   r   s          rN   rf   zIMAP4_stream.__init__  sN    			(2%tT4
JQ^_rE   c                 D   ddl m}m} ddlm} | j                  dd| j                  z          || j                  d||d|      | _        | j                  j                  | j                  j                  c| _
        | _        | j                  j                         | _        y)zopen(host=None, port=None)
        Setup a stream connection via 'self.command'.
        This connection will be used by the routines:
            read, send, shutdown, socket.r   )PopenPIPE)DEFAULT_BUFFER_SIZETz opening stream from command "%s")shellstdinstdout	close_fdsbufsizeN)
subprocessr  r  ior  rn   r  _Pr  r  r  r  r   r   )rc   r   r   r  r  r  s         rN   r   zIMAP4_stream.open  sr     	+*ii#E#TUDTUYcvw(,tww~~%}}++-rE   c                 4   | j                    t        j                  | j                  |      S | j                   j                  r| j                   j                  }n$t        j                  | j                  t
              }| j                   j                  ||      S )zRead 'size' bytes from remote.)r   osr4  r   r0  r   r1  r2  s      rN   r4  zIMAP4_stream.read  sr     $774<<..,,$$44D774<<3D  ++D$77rE   c                    | j                   G| j                   j                  |      }|| j                   j                  t        j                        z  }| j
                  j                  |       | j
                  j                          y)zSend data to remote.N)r   r8  r9  r'  r:  r  r  r<  s     rN   r=  zIMAP4_stream.send  sc     ??&??++D1DDOO))$*;*;<<DT"rE   c                     | j                   j                          | j                  j                          | j                  j	                          y)z Close I/O established in "open".N)r  rD  r  r  ro   r   s    rN   r?  zIMAP4_stream.shutdown  s1     	rE   )NNNNNri  )	rt   ru   rv   rw   rf   r   r4  r=  r?  rx   rE   rN   r   r   r  s!     `.8rE   r   c                   (    e Zd ZdZd Zd Zd Zd Zy)rq  zQPrivate class to provide en/de-coding
    for base64 authentication conversation.c                     || _         y rh   )mech)rc   mechinsts     rN   rf   z_Authenticator.__init__  s	    	rE   c                 j    | j                  | j                  |            }|y| j                  |      S )N   *)r  r  r  )rc   rb   r  rets       rN   rr  z_Authenticator.process  s0    iiD)*;{{3rE   c                     d}t        |t              r|j                  d      }|r?t        |      dkD  r|d d }|dd  }n|}d}t	        j
                  |      }|r||d d z   }|r?|S )NrE   r   0   rb  )rh  rZ   r  r  binascii
b2a_base64)rc   inpoupr  rE  s        rN   r  z_Authenticator.encode  s}     c3**W%C3x"}H"#h##A&AAcrFl  
rE   c                 2    |syt        j                  |      S )NrE   )r  
a2b_base64)rc   r  s     rN   r  z_Authenticator.decode  s    ""3''rE   N)rt   ru   rv   rw   rf   rr  r  r  rx   rE   rN   rq  rq    s    / 0(rE   rq  c                       e Zd ZdZd Zd Zy)r  zWWhen process is called, server is in IDLE state
    and will send asynchronous changes.c                     || _         |j                  t        |      | _        | j                  t	        j                         z   | j                   _        y rh   )rT   r   IDLE_TIMEOUTr   rs  r   )rc   rT   r   s      rN   rf   z_IdleCont.__init__  s8    44\7K#'<<$))+#= rE   c                 h   | j                   j                  j                          || j                   _        | j                  t        j
                         z   | j                   _        | j                   j                  j                          | j                   j                  dd| j                  z         y )Nr  z)server IDLE started, timeout in %.2f secs)	rT   r   rQ  r   r   rs  r   rS  rn   )rc   rb   r  s      rN   rr  z_IdleCont.process  sy    %%'"#'<<$))+#= %%'kk&&q*UX\XdXd*derE   N)rt   ru   rv   rw   rf   rr  rx   rE   rN   r  r    s    +>
rE   r  )NJanFebMarAprMayJunJulAugSepOctNovDecs   .*INTERNALDATE "(?P<day>[ 0123][0-9])-(?P<mon>[A-Z][a-z][a-z])-(?P<year>[0-9][0-9][0-9][0-9]) (?P<hour>[0-9][0-9]):(?P<min>[0-9][0-9]):(?P<sec>[0-9][0-9]) (?P<zonen>[-+])(?P<zoneh>[0-9][0-9])(?P<zonem>[0-9][0-9])"c           	         t         j                  |       }|syt        |j                  d         }|j                  d      }t	        |j                  d            }t	        |j                  d            }t	        |j                  d            }t	        |j                  d            }t	        |j                  d            }t	        |j                  d	            }	t	        |j                  d
            }
|	dz  |
z   dz  }|dk(  r| }||||||dddf	}t        j                  t        j                  |      |z
        S )ztime_tuple = Internaldate2Time(resp)

    Parse an IMAP4 INTERNALDATE string.

    Return corresponding local time.  The return value is a
    time.struct_time instance or None if the string has wrong format.NmonzonendayyearhourrU  seczonehzonem<      -rb  )	r
   rM  r   rV  rG   rs  r  calendartimegm)r  rN  r  r  r  r  r  rU  r  r  r   zonetts                rN   r   r   	  s    
		D	!B
"((5/
"CHHWE
bhhuo
Crxx Drxx D
bhhuo
C
bhhuo
C!"E!"E "Hub D}u
S$S"b"	5B>>(//"-455rE   c                    ddl m }m}m} t        | t        t
        f      rt        j                  |       }nt        | t              r(	 | j                  } ||      } || dd d ||      i}nPt        | |      r| j                  t        d	      | }n*t        | t               r| d   | d   fd
k(  r| S t        d      dj#                  t$        j&                           }	|j)                  |	      S # t        $ r t        j                  rZ| d   }|dk(  r+t        j                  t        j                  |             d   }t        j                  t        j                  f|    }nt        j                   }Y %w xY w)a  '"DD-Mmm-YYYY HH:MM:SS +HHMM"' = Time2Internaldate(date_time)

    Convert 'date_time' to IMAP4 INTERNALDATE representation.

    The date_time argument can be a number (int or float) representing
    seconds since epoch (as returned by time.time()), a 9-tuple
    representing local time, an instance of time.struct_time (as
    returned by time.localtime()), an aware datetime instance or a
    double-quoted string.  In the last case, it is assumed to already
    be in the correct format.r   )datetimetimezone	timedelta   rb  )secondsN   tzinfozdate_time must be aware)rb  rb  zdate_time not of a known typez"%d-{}-%Y %H:%M:%S %z")r  r	  r
  rh  rG   floatrs  r  rF  	tm_gmtoffr   daylightmktimealtzoner  
ValueErrorrZ   formatr	   monthr  )
rm  r  r	  r
  r  gmtoffdstdeltadtfmts
             rN   r   r   1	  sN    76)c5\*^^I&	Iu	%		(((F &)y!}=Xe_=	Ix	(#677	Is	#1im(D	(Q899
"
)
)*RXX*>
?C;;s)  	(}}l"9..Y)?@CC==$,,7<<--	(s   C2 2BE:9E:s   .*FLAGS \((?P<flags>[^\)]*)\)c                     t         j                  |       }|syt        |j                  d      j	                               S )zR('flag', ...) = ParseFlags(line)
    Convert IMAP4 flags response to python tuple.rx   rl  )	FLAGS_crerM  rF  rV  rG  )r  rN  s     rN   r   r   _	  s5    
 
	B'"((*++rE   __main__z	d:il:s:p:)rx   rx   r  z-dz-iz-lrm   z-pz-s)r   z	test.datar  zEFrom: %(user)s@localhost%(lf)sSubject: IMAP4 test%(lf)s%(lf)s%(data)s
)r  lfrb   )r  )r  r  )r  )r  z"%")r  )imaplib2_test0)r  )r!  imaplib2_test1)r!   imaplib2_test2ro  r$  )r  r  z"imaplib2_test%")r  r#  )r  )NSUBJECT"IMAP4 test")r  )1:*(FLAGS INTERNALDATE RFC822))r  )1FLAGS
(\Deleted))r  rx   )r  rx   )r\  rx   )rD  rx   )r  rx   )r`   )UIDVALIDITY)r`   )r  )r  rx   )r  )r(  z(FLAGS UID))r  )r7   r&  r'  )r  )r7   ALL)r  )rA   
referenceszUTF-8z(SEEN)ri  c                     | \  }}}|\  }}||a t        j                  dd|||fz         y |\  }}t        j                  dd||||fz         |dk(  rt        |d   fa y y )Nr   z[cb] ERROR %s %.100s => %sz[cb] %s %.100s => %s %.100sr  )
AsyncErrorMrn   rA  )r;  r`   rd   r}   cmdr   rj   rN  s           rN   	responderr4  	  s    "-&%	TJFF12c45GGHS	q/3c32GGH$;#SV,J rE   c                    t         rKt        j                  ddt        t               z         t        j	                          t         \  }} ||      t        j
                  st        j                  dd| |fz         	 |r> t        t        |       |t        | |fd\  }}t        j                  dd| |||fz         n3 t        t        |       | \  }}t        j                  dd| |||fz         |d	k(  r8t        j                  dd	       t        j	                          t        |d         |S #  t        j                  ddt        j                         d d z         t        j	                           xY w)
Nr   zAsyncError %sr   z	%s %.100s)rV   rd   z%s %.100s => %s %.100sz%s - %sr  r  )r1  r2  rn   r   r   r   r   r4  r  r  rA  )r3  r   cbrj   rK   rN  s         rN   runr7  	  s2   FF1oZ(889HHJ!HCc(Nwwq+d";<
	*71c?TXIsDkYSq2c4c5JJK*71c?D1Sq2c4c5JJK
 $;FF1dOHHJCF##
	FF1i#,,.!"445HHJs   >A3D0 0AE5mainr   r   r   )
r   r   r  r  r  r   r   r   r   r  )r   r   r   r   )r   r   r   r   r   r   r   zIMAP password for z on 	localhostz: r  zPROTOCOL_VERSION = %szCOMPRESS=DEFLATEr  r%  )r6  s   .*"([^"]+)"$rb  r  r  rx   )z(name imaplib2)r   r  )r  )r7   r&  z
IMAP4 testr  z:(FLAGS INTERNALDATE RFC822.SIZE RFC822.HEADER RFC822.TEXT)r?   r+  r,  r  r  )r  )c   rZ  r  )Nr.  r  r)  zfetch z => r  z-FLAGSz(\Seen)zHIT CTRL-C to interrupt IDLEzThanks!z-chosen server does not report IDLE capabilityr   z5unused untagged responses in order, most recent last:	r   zAll tests OK.zTests failed.z8
If you would like to see debugging output,
try: %s -d5
)T){rw   __all__r  __release____revision____credits__
__author____URL____license__r  r  rB  r  r   r   r   r  r   r  rs  r]   r'  r  rk  r   r  rv  r  r   r   r  r  r	  r  r   r/  r,  r   r   r   r   r   r  rO   objectrQ   r   r   r   rq  r  r	   rJ  r  r   r   r
   r   Internaldate2tupler   r  r   rt   r  getoptgetpassargvoptlistr   r}   rK   r   r   r   stream_commandr  r  	idle_introptrG   rG  r   getuserUSERr   pathexists__file__r4  rb   	test_mesg	test_seq1	test_seq2r1  r2  r4  r7  rq  rr  r   PASSWDinsertrn   r   r   rO  r3  mlrM  rN  rV  unamerN  r  rt  rJ   r   r   KeyboardInterruptr7  rT  rj   print)r  rP  s   00rN   <module>rZ     sb  4 Q@ 1

+ c c c c c c c  
-  	 


( "I x-
$)e<-
 	'e<-
 	'42d;	-

 	(d;-
 	(e<-
 	$e<-
 	(d;-
 	$)d;-
 	$)d;-
 	$)d;-
 	$e<-
 	$)e<-
 	(d;-
 	(d;-
  	$)d;!-
" 	$)d;#-
$ 	$)d;%-
& 	$)d;'-
( 	'4:dC)-
* 	(e<+-
, 	$)d;--
. 	'e</-
0 	'4:eD1-
2 	$)d;3-
4 	$)d;5-
6 	$)d;7-
8 	'42d;9-
: 	(d;;-
< 	$e<=-
> 	$)d;?-
@ 	(d;A-
B 	$)e<C-
D 	$)e<E-
F 	$)d;G-
H )e<"d;!e<)d;"d;)e<"d;"d;)e<Y-
^ *
0Uf 0Uj~&F ~&D:\ \@I5 IX)(V )(\ (:
 '0
12&?
@da188:ac>
@rzz 
 6B ' (X BJJ89		, z  %chhqrlK@ PYLE=$9 2C$;HE!AIMD[ID[+#&99S>  D[s8DD[ N 12" ,@.NJ7D7??D{+;GxHMMdSDW#$t<=I #4# $i89(#15+I& "dD),-%28I" MJ-0]	!))&1dGXt$(`fns  AC  MO  _l  xD  EA^5RQScpqA4d%BPRbopA77f$W__tTM`U`M`%abFQ4. 9:	q)A,>,>>?/  "! 	HCTN	 f8UC 	#B*B/B"((1+4B$4'"		# 1>>!bM*+y+tXRXXZ]CD! 	HCDzIICc4E*Cb'--/CRPR SR'<@A	2	 Q^^#'DJJqMu%4tY7EBh%8;AACAFCg%BCNCGGT#Y78#x3>?g%BCNCGGT#Y78g|<=	267%0
 GGCDHbU#GGBKLLNGGBKGGKL335VCqwwCQT?U7VVoY S At <<   +#&s +| ) GGI&GGBK$
AIVq~~-E/"  
hhqk 
  .FsV   [7<#[= \'K'] \0 B] =\\\
\-,\-0)]] 7^