Gh\c@shddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z m Z ddl mZmZmZmZmZddlZddlZddlmZmZmZmZddlmZyddlZeZWnek r7e ZnXde!fd YZ"d e!fd YZ#dS( iN(tgaierror(texc_info(tSSLErrortcert_time_to_seconds(tLocktBoundedSemaphoretThreadtEventt currentThread(t imaplibutiltimaputilt threadutiltOfflineImapError(t getglobaluit IMAPServercBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZedZRS(s"Initializes all variables from an IMAPRepository() instance Various functions, such as acquireconnection() return an IMAP4 object on which we can operate. Public instance variables are: self.: delim The server's folder delimiter. Only valid after acquireconnection() cCs{t|_||_|j|_|j|_|j|_|jrt|jrtt d|dt j j n|jr|jn|j|_ |jrd n |j|_|j|_|j|_d |_d |_d |_|j|_|j|_|jtkr%tj|_n*|jtkrCtj |_n tj!|_|jsa|jrgd n |j"|_#|j$|_%|j%d kr|jrdnd|_%n|j&|_'|j(|_)|j*|_+|j+d krd |_,n|j-|_.|j/|_0|j1|_2|j3|_4|jri|j0dk ri|j2d krit5dn|j6|_7|j8|_9|j:|_;|j<|_=|j>|_?d |_@d |_Ad |_B|jC|_Dg|_Eg|_Fi|_GtH|jD|_ItJ|_K|jL|_M|jN|_Od |_Pt|_Q|jRdtj|_S|jRd|jS|_Td S( s":repos: a IMAPRepository instance.s%s: sMyou must enable precisely one type of tunnel (preauth or transport), not bothiit tls_compatsNWhen 'tls_level' is not 'tls_compat' the 'ssl_version' must be set explicitly.tproxyt authproxyN(UR tuitrepost getconfigtconfigtgetpreauthtunneltpreauth_tunneltgettransporttunnelttransport_tunnelR tERRORtREPOttunneltNonetgetusertusernametget_remote_identityt user_identitytget_auth_mechanismst authmechstpasswordt passworderrort goodpasswordtgetssltusessltgetipv6tuseipv6tTruetsockettAF_INET6taftFalsetAF_INETt AF_UNSPECtgethostthostnametgetporttporttgetsslclientcertt sslclientcerttgetsslclientkeyt sslclientkeytgetsslcacertfilet sslcacertfilet_IMAPServer__verifycerttget_ssl_fingerprintt fingerprintt gettlslevelttlslevelt getsslversiont sslversiont getstarttlststarttlst Exceptiontgetoauth2_refresh_tokentoauth2_refresh_tokentgetoauth2_access_tokentoauth2_access_tokentgetoauth2_client_idtoauth2_client_idtgetoauth2_client_secrettoauth2_client_secrettgetoauth2_request_urltoauth2_request_urltoauth2_access_token_expires_attdelimtroottgetmaxconnectionstmaxconnectionstavailableconnectionstassignedconnectionst lastownerRt semaphoreRtconnectionlockt getreferencet referencetgetidlefolderst idlefolderstgss_vctgssapit _get_proxytproxied_sockettauthproxied_socket(tselfR((s0/usr/share/offlineimap/offlineimap/imapserver.pyt__init__7s|        '            c Csd|jjj}|jj||s,|S|jj||}|dkrTtjSyWddl}|jd\}}}t |}|j t |||||j SWnbt k r|jjdnBttfk r} |jjd||jjj| |fnX|S(NsAccount tit:s-PySocks not installed, ignoring proxy option.s:Bad proxy option %s for account %s: %s Ignoring %s option.(RtaccounttnameRt has_optiontgetR,tsockstsplittinttsetdefaultproxytgetattrt socksockett ImportErrorRtwarntAttributeErrort ValueError( Rct proxysectiont dfltsockett_account_sectionRRkt proxy_typethostR5te((s0/usr/share/offlineimap/offlineimap/imapserver.pyR`s$      !cCs~|jdkr|jS|jdkr;|jdkr;|jS|jjph|jj|j|j |j|_d|_|jS(s#Returns the server password or NoneN( R&RR$R%Rt getpasswordRtgetpassRR(Rc((s0/usr/share/offlineimap/offlineimap/imapserver.pyt __getpasswords$ cCsm|j}|jjdd||j}|jdtj||j}|jjdd||S(Ntimaps__md5handler: got challenge %st s__md5handler: returning %s(tstripRtdebugt_IMAPServer__getpasswordRthmactnewt hexdigest(Rctresponset challengetpasswdtretval((s0/usr/share/offlineimap/offlineimap/imapserver.pyt __md5handlers   #cCs0|jjdd|j|j|jdS(s( Basic authentication via LOGIN command.R~s$Attempting IMAP LOGIN authenticationN(RRtloginRR(Rctimapobj((s0/usr/share/offlineimap/offlineimap/imapserver.pyt __loginauthscCs|j}|s4td|jjtjjn|j}d}|jdkra|j}nd}|j |||f}|j ||df}|j j dd||S(s\Implements SASL PLAIN authentication, RFC 4616, http://tools.ietf.org/html/rfc4616sNo username provided for '%s'Ress(passwd hidden for log)R~s__plainhandler: returning %sN( RR RtgetnameRRRR!RtjoinRR(RcRtauthcRtauthztNULLRtlogsafe_retval((s0/usr/share/offlineimap/offlineimap/imapserver.pyt__plainhandlers    c Cstjj}|jrF|j|krFd|_|jjddn|jdkrF|jdkrtd|tj j ni}|j |d<|j |d<|j |dj?} t@|tAkrd|j|jf} tBjCt+t+| | tDdntE|tFr|jGtGjHkr|jdkr_d|j|j|f} nd|j|j|f} tBjCt+t+| | tDdnjtE|tjIr|jJdtGjKkrd|j|j|jf} tBjCt+t+| | tDdnt,|d dkrZtBjCt+t+d |j|jft+j>j?tDdqanXdS(!sFetches a connection from the pool, making sure to create a new one if needed, to obey the maximum connection limits, etc. Opens a connection to the server and returns an appropriate object.iiiRttimeoutt use_socketR~s%s: level '%s', version '%s'RyR5tkeyfiletcertfiletca_certstcert_verify_cbt ssl_versionR>t tls_levelR.tusecompressions""s"*"s'Server '%s' returned no folders in '%s'NsCould not resolve name '%s' for repository '%s'. Make sure you have configured the server name correctly and that you are online.iisCould not connect via SSL to host '%s' and non-standard ssl port %d configured. Make sure you connect to the correct port. Got: %ssWUnknown SSL protocol connecting to host '%s' for repository '%s'. OpenSSL responded: %ssConnection to host '%s:%d' for repository '%s' was refused. Make sure you have the right host and port configured and that you are actually able to access the network.iscan't open socket; errorsTCould not connect to remote server '%s' for repository '%s'. Remote does not answer.(LRXRRYRRRRUtrangeRWtidentRVRRR/R+RRt connectingRRR t IMAP4_TunnelR,tgetdefaulttimeoutRaR(R3R5RR@RBtWrappedIMAP4_SSLR9R7R;R<R>R.t WrappedIMAP4Rt_IMAPServer__authn_helperR$R&R RR%tgetconfbooleantenable_compressiont capabilityttupletupperRlRRQtlistR[RrRER t imapsplitRRtdequoteRRRRRRRt isinstanceRterrnotEPERMRtargst ECONNREFUSED( Rct curThreadRtittryobjtsuccessRzttyptdattlistresRtseveritytreason((s0/usr/share/offlineimap/offlineimap/imapserver.pytacquireconnections   &                                    "#     !  (    cCs|jj|jjdS(sWaits until there is a connection available. Note that between the time that a connection becomes available and the time it is requested, another thread may have grabbed it. This function is mainly present as a way to avoid spawning thousands of threads to copy messages, then have them all wait for 3 available connections. It's OK if we have maxconnections + 1 or 2 threads, which is what this will help us do.N(RXRR(Rc((s0/usr/share/offlineimap/offlineimap/imapserver.pytconnectionwaits cCs||jmtj|j|jx"|j|jD]}|jq1Wg|_g|_i|_d|_ t |_ WdQXdS(N( RYR tsemaphoreresetRXRTRVRUtlogoutRWRR^R/R_(RcR((s0/usr/share/offlineimap/offlineimap/imapserver.pytcloses     cCsi|jjddx<|jsQ|jjt|jt|j}|jjg}xt |D]t}|jjdd||ft|j |krt ||j |}n t |}|j |j |qkW|jjdd|j||jjddx"|D]}|j|jqW|jjddqW|jjdddS( s;Sends a NOOP to each connection recorded. It will wait a maximum of timeout seconds between doing this, and will continue to do so until the Event object as passed is true. This method is expected to be invoked in a separate thread, which should be join()'d after the event is set.R~skeepalive thread starteds)keepalive: processing connection %d of %dskeepalive: waiting for timeoutskeepalive: after waitskeepalive: all threads joineds keepalive: event is set; exitingN(RRtisSetRYRRRVRURR R]t IdleThreadtstartRtwaittstopR(RcRteventtnumconnectionstthreadsRtidler((s0/usr/share/offlineimap/offlineimap/imapserver.pyt keepalives0        cCsw|dkrdS|jj|jj||js<|rI|jn|jj||jj |j j dS(sReleases a connection, returning it to the pool. :param drop_conn: If True, the connection will be released and not be reused. This can be used to indicate broken connections.N( RRYRRVtremovet TerminateR*RURRRX(Rct connectiont drop_conn((s0/usr/share/offlineimap/offlineimap/imapserver.pytreleaseconnections    (t__name__t __module__t__doc__RdR`RRRRRRRRRRRRRR<R'R(R+R5R/R:(((s0/usr/share/offlineimap/offlineimap/imapserver.pyR-s, \     ; -      H '  )R-cBsJeZddZdZdZdZdZdZdZ RS(cCsw||_||_t|_t|_|dkrNtd|j|_ ntd|j |_ |j j ddS(sIf invoked without 'folder', perform a NOOP and wait for self.stop() to be called. If invoked with folder, switch to IDLE mode and synchronize once we have a new messagettargetiN( tparenttfolderRtstop_sigR RRRtnooptthreadt_IdleThread__idlet setDaemon(RcR?R@((s0/usr/share/offlineimap/offlineimap/imapserver.pyRd s     cCs|jjdS(N(RCR.(Rc((s0/usr/share/offlineimap/offlineimap/imapserver.pyR.scCs|jjdS(N(RAtset(Rc((s0/usr/share/offlineimap/offlineimap/imapserver.pyR0scCs|jjdS(N(RCR(Rc((s0/usr/share/offlineimap/offlineimap/imapserver.pyRscCs|jj}zYy|jWnD|jk rf|jjd|j|jj|td}nXWd|r|jj||j j nXdS(Ns(Attempting NOOP on dropped connection %s( R?R'RBtabortRRrt identifierR:R+RRAR/(RcR((s0/usr/share/offlineimap/offlineimap/imapserver.pyRB!s  cCs|jj}|j}|j}|j}|j}|j|jdt}|j dd}|j |t j j ||dt|j dd}|j |t}|jtdS(Ntdecodet presynchookRetquickt postsynchook(R?RRgt localrepost remoterepost statusrepost getfolderR@R/tgetconftcallhookt offlineimaptaccountst syncfolderR tunregisterthreadR(RcRNRgRMROt remotefolderthookR((s0/usr/share/offlineimap/offlineimap/imapserver.pyt__dosync5s        csfd}fd}xejjst_t}x|sjj}y|jjWntk r}|j tj j krj j |tdjj|tq|j tj jkrj j |tdqqBXt}qBWd|jkr'|jd|n!j jd|j||jj||jr!jjjq!q!WdS(s9Invoke IDLE mode until timeout or self.stop() is invoked.csH|\}}}|dkr7jj r7t_njjdS(s IDLE callback function invoked by imaplib2. This is invoked when a) The IMAP server tells us something while in IDLE mode, b) we get an Exception (e.g. on dropped connections, or c) the standard imaplib IDLE timeout of 29 minutes kicks in.N(RRAR,R+tneedsyncRF(Rtresulttcb_argtexc_data(Rc(s0/usr/share/offlineimap/offlineimap/imapserver.pytcallbackIs cscy|jWn>|jk rNjjd|jjj|tnXjj|dS(sFactorize the noop code.s(Attempting NOOP on dropped connection %sN(RBRGRRrRHR?R:R+(R(Rc(s0/usr/share/offlineimap/offlineimap/imapserver.pyRBWs  itIDLER^sFIMAP IDLE not supported on server '%s'.Sleep until next refresh cycle.N(RAR,R/RZR?R'tselectR@R R%Rt FOLDER_RETRYRRRR:R+tFOLDERRtidleRrRHR/tcleart_IdleThread__dosync(RcR^RBR!RRz((Rcs0/usr/share/offlineimap/offlineimap/imapserver.pyt__idleFs6          N( R;R<RRdR.R0RRBReRD(((s0/usr/share/offlineimap/offlineimap/imapserver.pyR-s      ($RRR,RRRRRtsysRtsslRRt threadingRRRRRRtofflineimap.accountsRSR R R R tofflineimap.uiR R_R+RRqR/tobjectRR-(((s0/usr/share/offlineimap/offlineimap/imapserver.pyts0        (  "