uNc@s~ddklZlZlZlZddklZddklZl Z l Z l Z l Z ddk lZddkZddkZddkZddkZddkZddkZddklZddklZyddklZlZWnej o eZnXy3eZddkZd e ejo e!ZnWnej onXd fd YZ"d e#fd YZ$dS(i(t imaplibutiltimaputilt threadutiltOfflineImapError(t getglobalui(tLocktBoundedSemaphoretThreadtEventt currentThread(t get_identN(texc_info(tgaierror(tSSLErrortcert_time_to_secondstauthGSSClientWrapt IMAPServercBseZdZdZdZdZdZdZdZe dZ dZ d Z d Z d Zd Zd ZdZdZRS(sInitializes all variables from an IMAPRepository() instance Various functions, such as acquireconnection() return an IMAP4 object on which we can operate.iicCst|_||_|i|_|i|_|i|_|iodn |i |_ d|_ d|_ d|_|iodn |i|_|i|_|idjo|iodnd|_n|i|_|i|_|i|_|idjo d|_nd|_d|_|i|_g|_g|_h|_ t!|i|_"t#|_$|i%|_&|i'|_(|i)|_*d|_+t,|_-dS(Nii(.Rtuitrepost getconfigtconfigtgetpreauthtunnelttunneltgetssltusessltNonetgetusertusernametpasswordt passworderrort goodpasswordtgethostthostnametgetporttporttgetsslclientcertt sslclientcerttgetsslclientkeyt sslclientkeytgetsslcacertfilet sslcacertfilet verifycerttdelimtroottgetmaxconnectionstmaxconnectionstavailableconnectionstassignedconnectionst lastownerRt semaphoreRtconnectionlockt getreferencet referencetgetidlefolderst idlefolderstGSS_STATE_STEPtgss_steptgss_vctFalsetgssapi(tselfR((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyt__init__4s>                cCs|idjo|iS|idjo|idjo|iS|iip%|ii|ii|i |i|_d|_|iS(s#Returns the server password or NoneN( RRRRRt getpasswordRtgetpasstgetnameR(R<((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyR>Us  cCs|iS(sqReturns this server's folder delimiter. Can only be called after one or more calls to acquireconnection.(R*(R<((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytgetdelimdscCs|iS(slReturns this server's folder root. Can only be called after one or more calls to acquireconnection.(R+(R<((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytgetrootiscCs||djodS|ii|ii||ip|o|in|ii||ii |i i 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( RR2tacquireR/tremovet TerminatetlogoutR.tappendtreleaseR1(R<t connectiont drop_conn((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytreleaseconnectionos   cCsm|i}|iidd||i}|idti||i}|iidd||S(Ntimapsmd5handler: got challenge %st smd5handler: returning %s(tstripRtdebugR>Rthmactnewt hexdigest(R<tresponset challengetpasswdtretval((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyt md5handlers   #cCs0|iidd|i|i|idS(NRLsAttempting plain authentication(RROtloginRR>(R<timapobj((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyt plainauthscCspti|}y|i|ijox|ip5tid|i\}|_ti|i}nti |i|}|ti jo|i |_qnZ|i|i joFti |i|}ti|i}ti |i||i}nti|i}WnFtij o7}|iidd|dd|ddfdSX|p d}nti|S(Nsimap@RLs%s: %siit(tbase64t b64encodeR8R7R9tkerberostauthGSSClientInitR tauthGSSClientResponsetauthGSSClientSteptAUTH_GSS_CONTINUEtGSS_STATE_WRAPtauthGSSClientUnwrapRRtGSSErrorRRORt b64decode(R<RStdatatrcterr((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytgssauths,  - cCsF|ii|iid}t|iod}x`tt|idddD]?}|i|}|i|tjo|}|i|=PqVqVW|p|id}|id=n|i i |t|i|<|ii |S|ii d}yx|p|i o>|i id|i ti|i dti}d}n|ion|i i|i|i|ii}ti|i|i|i|i|i|idtid|}n>|i i|i|iti|i|idti}|i pyd|ijoto|ii|i i dd y|i!d |i"Wn4|i#j o%}t$|_%|i i dd n0Xt&|_%t'i(|i)d|_)|i*|_+|ii n|i%pd |ijo,|i o!|i i dd |i,nd|ijoV|i i ddy|i!d|i-Wq|i#j o}|i.|qXqd|ijot/dt/i0i1n|i.|nd}|i2|_3Wq|i#j o}t4||_5qXqqW|i6\}}|dgjo#t7|di8i9|_n|i:djo|i;|i<dd} | dgjp | djo|i;|i<dd} n| dgjp | djo<d|ii=|i<f} |i i>| t?| nt@iA| dd\|_:|_Bt@iC|i:|_:t@iC|iB|_Bn|ii|i i |t|i|<|ii |SWnt?j o} |ii |iiDo|ii nt/i0i1} tE| tFjo)d|i|if} t/| | ntGovtH| tGof| iIdjoV|idjod|i|if} nd|i|i| f} t/| | nZtH| ti#oF| iJdtIiKjo/d|i|i|iLf} t/| | nt4| d djo)t/d|i|ift/i0i1qBnXdS(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 fingerprints AUTH=GSSAPIRLs Attempting GSSAPI authenticationtGSSAPIsGSSAPI Authentication failedtSTARTTLSsUsing STARTTLS connections AUTH=CRAM-MD5s"Attempting CRAM-MD5 authenticationsCRAM-MD5t LOGINDISABLEDs4Plaintext login disabled by server. Need to use SSL?s""s"*"s'Server '%s' returned no folders in '%s'sCould not resolve name '%s' for repository '%s'. Make sure you have configured the server name correctly and that you are online.iszCould not connect via SSL to host '%s' and non-standard ssl port %d configured. Make sure you connect to the correct port.sVUnknown SSL protocol connecting to host '%s' forrepository '%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.N(MR1RCR2RtlenR.trangeR0R R/RGRHRRt connectingRt IMAP4_TunneltsockettgetdefaulttimeoutRR R"Rtget_ssl_fingerprinttWrappedIMAP4_SSLR&R$R(R)t WrappedIMAP4t capabilitiesthave_gssROt authenticateRjterrorR:R;tTrueR^tauthGSSClientCleanR9R7R8tstarttlsRWRZRtERRORtREPORRtstrRt capabilityttupletuppertsplitR*tlistR4R@twarnt ExceptionRt imapsplitR+tdequotetlockedttypeR R t isinstanceterrnotargst ECONNREFUSEDt reposname(R<RYtittryobjtsuccessRltvalttyptdattlistresRitetseveritytreason((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytacquireconnections                              ##    '*cCs|ii|iidS(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(R1RCRH(R<((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytconnectionwaitgs cCs|iiti|i|ix"|i|iD]}|iq4Wg|_g|_h|_ |i |_ d|_ t|_|iidS(N(R2RCRtsemaphoreresetR1R-R/R.RFR0R7R8RR9R:R;RH(R<RY((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytclosers       cCs|iiddx|iidd|io|iidddS|iidd|iit|it|i}|ii|iiddg}xt |D]}|iidd||ft|i |jot ||i |}n t |}|i |i ||iidd qW|iidd |i||iidd |iidd x"|D]}|i|iqW|iidd qdS(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.RLskeepalive thread startedskeepalive: top of loops keepalive: event is set; exitingNs#keepalive: acquiring connectionlocks"keepalive: connectionlock releaseds)keepalive: processing connection %d of %dskeepalive: thread startedskeepalive: waiting for timeoutskeepalive: after waitskeepalive: joining threadsskeepalive: bottom of loop(RROtisSetR2RCRpR/R.RHRqR6t IdleThreadtstartRGtwaittstoptjoin(R<RkteventtnumconnectionstthreadsRtidler((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyt keepalives>          c Cswd}|p d|S|i}g}|id}|o,tit|jod||fSnxN|idgD]:}|d\}} |djo|i| iq}q}Wt|djo d|SxD|id gD]0\}} |d jo|i| iqqWxN|D]F} | |jp.d |jo&| d |id d d jodSq%Wd|S(sVerify that cert (in socket.getpeercert() format) matches hostname. CRLs are not handled. Returns error message if any problems are found and None on success. sCA Cert verifying failed: s%s no certificate receivedtnotAfters%s certificate expired %stsubjectit commonNames%%s no commonName found in certificatetsubjectAltNametDNSt.s*.is/%s no matching domain name found in certificateN(tlowertgetttimeRRGRpRR( R<tcertR terrstrtdnsnamet certnamestnotaftertstkeytvaluetcertname((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyR)s4       . (t__name__t __module__t__doc__R7RcR=R>RARBR:RKRWRZRjRRRRR)(((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyR-s  !        ,RcBsJeZddZdZdZdZdZdZdZ RS(cCsy||_||_t|_t|_|djotd|i|_ ntd|i |_ |i i 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_sigRRRRtnooptthreadtidlet setDaemon(R<RR((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyR=s     cCs|iidS(N(RR(R<((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyRscCs|iidS(N(Rtset(R<((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyRscCs|iidS(N(RR(R<((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyRscCs:|ii}|i|ii|ii|dS(N(RRRRRRK(R<RY((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyRs  cCs|ii}|i}|i}|i}|i}|i|i}ti i |i ||||dt t }|itdS(Ntquick(RRtaccountt localrepost remoterepost statusrepost getfolderRt offlineimaptaccountst syncfoldertnameR:RtunregisterthreadR (R<RRRRt remotefolderR((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytdosyncs     % csfd}xiipt_t}x|pii}y|iiWnbtj oV}|i ti i jo1i i |tdii|tq|q4Xt}q4Wd|ijo|id|n"i id|i|iiiy|iWn@|ij o1i id|iii|tnXii|ioiiiqqWdS(s8Invoke IDLE mode until timeout or self.stop() is invokedcsK|\}}}|djoii o t_niidS(sIDLE 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(RRRR}tneedsyncR(Rtresulttcb_argtexc_data(R<(sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pytcallbacks itIDLERsFIMAP IDLE not supported on server '%s'.Sleep until next refresh cycle.s(Attempting NOOP on dropped connection %sN(RRR:RRRtselectRRRRt FOLDER_RETRYRR|R RKR}RyRRt identifierRRtaborttclearR(R<RRRYR((R<sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyRs@            N( RRRR=RRRRRR(((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyRs      (%RRRRRtofflineimap.uiRt threadingRRRRR RR tofflineimap.accountsRPRtR\RRtsysR R tsslR Rt ImportErrorRR:RzR^tdirR}RtobjectR(((sz/projectLibrary/707976 EPBuoyPrototypeAndTesting/SpotWatchCircleAlarm/spaetz-offlineimap-5f3ac2c/offlineimap/imapserver.pyts2"(