Gh\c@sdZddlZddlZddlZddlZddlmZddlmZddl Z ddl m Z m Z m Z mZddlmZddlmZddlmZmZd efd YZd efd YZdS( s IMAP repository support iN(texc_info(tEvent(tfoldertimaputilt imapservertOfflineImapError(tBaseRepository(tExitNotifyThread(tget_os_sslcertfiletget_os_sslcertfile_searchpathtIMAPRepositorycBseZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&e'd%Z(d&Z)d'Z*d(Z+d)Z,d*Z-d+Z.RS(,cCsd|_tj|||d|_d|_tj||_d|_d|_ d|_ d|_ |j j |jdr|jj|jd|_n|jddr|jjd|ndS(Nt newmail_hooktsepsOThe 'sep' setting is being ignored for IMAP repository '%s' (it's autodetected)(tNonet idlefoldersRt__init__t_hosttoauth2_request_urlRt IMAPServertfolderstcopy_ignore_evaltkaeventtkathreadtconfigt has_optiont getsectiont localevaltevaltgetconfR tuitinfo(tselft reposnametaccount((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR#s         cCsz|j}|sdSt|_td|jjdd|jd||jf|_|jjd|jj dS(Nttargettnames Keep alive targsi( t getkeepaliveRRRRt keepalivetgetnameRt setDaemontstart(Rt keepalivetime((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytstartkeepalive:s  cCs6|jdkrdS|jjd|_d|_dS(N(RR tsetR(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt stopkeepaliveEs   cCs|js|jndS(N(tgetholdconnectionopentdropconnections(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytholdordropconnectionsMs cCs|jjdS(N(Rtclose(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR/QscCsg|jdkrZ|jj|jdrK|jj|jd|_qZd|_n|j|S(s6Return a list of UIDs to not copy for this foldername.RcSsdS(N(R (tx((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt]tN(RR RRRRRR(Rt foldername((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytget_copy_ignore_UIDsTs  cCs |jrtS|jdtS(Ntholdconnectionopen(tgetidlefolderstTruetgetconfbooleantFalse(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR.as cCs2|jdd}|dkr.|jr.dS|S(NR&iii<i(t getconfintR8(Rtnum((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR%fscCs,|jjdks"td||jjS(sReturn the folder separator for the IMAP repository This requires that self.imapserver has been initialized with an acquireconnection() or it will still be `None`sW'%s' repository called getsep() before the folder separator was queried from the serverN(RtdelimR tAssertionError(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetsepls cCs|jr|jS|jj|jdr|jd}y|jj|}WnFtk r}tj t t d||ft j j t dnX|r||_|jSn|jdd}|dkr||_|jSt d|t j j dS(sfReturn the configured hostname to connect to :returns: hostname as string or throws Exceptiontremotehostevals4remotehosteval option for repository '%s' failed: %sit remotehosts-No remote host for repository '%s' specified.N(RRRRRRRt ExceptiontsixtreraiseRtERRORtREPORR (Rthostte((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgethostvs,        cCs7|jddd}|dkr3|jd}n|S(sRemote identity is used for certain SASL mechanisms (currently -- PLAIN) to inform server about the ID we want to authorize as instead of our login name.tremote_identitytdefaultsUTF-8N(RR tencode(Rtidentity((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytget_remote_identitys cCsdddddg}dddddg}|jdd|}x>|D]6}||krFtd|d |tjjqFqFW|jjd d ||S( NtGSSAPItXOAUTH2sCRAM-MD5tPLAINtLOGINtauth_mechanismss,\s*sRepository %s: s%unknown authentication mechanism '%s'timaps"Using authentication mechanisms %s(t getconflistRRFRGRtdebug(Rt supportedRLtmechstm((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytget_auth_mechanismss     cCsad}|j}|jj|jdr^|jd}|dkr^|j|jdSn|jj|jdr|jd}|dkr|Snytjj |j }Wn+t k r}|j t j krqnX|r|dSy"tjdj |j }Wn4t k rN}|j t j t jfkr]q]nX|r]|dSdS(NtremoteuserevalsUTF-8t remoteuseris /etc/netrc(R RRRRRRRMtnetrctauthenticatorsRJtIOErrorterrnotENOENTtEACCES(RtuserRt netrcentrytinst((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetusers0    " cCs_d}|jj|jdr3|jd}n|dkrO|jj|S|jddS(Ntremoteportevalt remoteport(R RRRRRRR<(Rtport((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetports  cCs|jddS(Ntipv6(R:R (R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetipv6scCs|jdtS(Ntssl(R:R9(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetsslscCs4tjjtjjtjjg}|jd|dS(Nt sslclientcert(tostpatht expandusert expandvarstabspatht getconf_xformR (Rtxforms((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetsslclientcerts!cCs4tjjtjjtjjg}|jd|dS(Nt sslclientkey(RqRrRsRtRuRvR (RRw((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetsslclientkeys!cCstjjtjjtjjg}|jd|d}|jdddkrt}|dkrt }|rddj |}nd}t |t j j qn|dkrdStjj|sd|j|f}t |t j j n|S(sDetermines CA bundle. Returns path to the CA bundle. It is either explicitely specified or requested via "OS-DEFAULT" value (and we will search known locations for the current OS and distribution). If search via "OS-DEFAULT" route yields nothing, we will throw an exception to make our callers distinguish between not specified value and non-existent default CA bundle. It is also an error to specify non-existent file via configuration: it will error out later, but, perhaps, with less verbose explanation, so we will also throw an exception. It is consistent with the above behaviour, so any explicitely-requested configuration that doesn't result in an existing file will give an exception. t sslcacertfiles OS-DEFAULTsPDefault CA bundle was requested, but no existing locations available. Tried %s.s, sdDefault CA bundle was requested, but OfflineIMAP doesn't know any for your current operating system.sFCA certfile for repository '%s' couldn't be found. No such file: '%s'N(RqRrRsRtRuRvR RRR tjoinRRFRGtisfileR#(RRwt cacertfilet searchpathtreason((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetsslcacertfiles$!    cCs|jddS(Nt tls_levelt tls_compat(R(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt gettlslevelscCs|jddS(Nt ssl_version(RR (R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt getsslversionscCs|jdtS(Ntstarttls(R:R9(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt getstarttlsscCsP|jdd}g|jdD]*}|r"|jjjdd^q"S(sReturn array of possible certificate fingerprints. Configuration item cert_fingerprint can contain multiple comma-separated fingerprints in hex form.tcert_fingerprintR4t,t:(Rtsplittstriptlowertreplace(Rtvaluetf((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytget_ssl_fingerprint!scCs ||_dS(N(R(Rturl((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytsetoauth2_request_url*scCs6|jdk r|jS|j|jdd|jS(NR(RR RR(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetoauth2_request_url-scCsa|jdd}|dkr]|jj|jdd}|dk r]|jd}q]n|S(Ntoauth2_refresh_tokentoauth2_refresh_token_evalR s (RR RRR(Rt refresh_token((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetoauth2_refresh_token4s   cCsa|jdd}|dkr]|jj|jdd}|dk r]|jd}q]n|S(Ntoauth2_access_tokentoauth2_access_token_evalR s (RR RRR(Rt access_token((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetoauth2_access_token>s   cCsa|jdd}|dkr]|jj|jdd}|dk r]|jd}q]n|S(Ntoauth2_client_idtoauth2_client_id_evalR s (RR RRR(Rt client_id((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetoauth2_client_idHs   cCsa|jdd}|dkr]|jj|jdd}|dk r]|jd}q]n|S(Ntoauth2_client_secrettoauth2_client_secret_evalR s (RR RRR(Rt client_secret((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetoauth2_client_secretRs   cCs|jddS(Nt preauthtunnel(RR (R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetpreauthtunnel\scCs|jddS(Nttransporttunnel(RR (R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgettransporttunnel_scCs|jddS(Nt referenceR4(R(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt getreferencebscCs|jdtS(Ntdecodefoldernames(R:R;(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetdecodefoldernamesescCs:|jdkr3|jj|jdd|_n|jS(NRs[](RR RRR(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR8hs cCs1t|j}|jdd}t||S(Ntmaxconnectionsi(tlenR8R<tmax(Rtnum1tnum2((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytgetmaxconnectionsoscCs|jdtS(Ntexpunge(R:R9(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt getexpungetscCs|jdd }|d k r7|jj|jdS|jdd }|d k rY|S|jdd }|d k rtjtjj |dd}|j j }|j |jdSyt j j|j}Wn+tk r }|jtjkrGqGn:X|rG|j}|d ks<||dkrG|dSny"t j dj|j}Wn4tk r}|jtjtjfkrqn:X|r|j}|d ks||dkr|dSnd S( sReturn the IMAP password for this repository. It tries to get passwords in the following order: 1. evaluate Repository 'remotepasseval' 2. read password from Repository 'remotepass' 3. read password from file specified in Repository 'remotepassfile' 4. read password from ~/.netrc 5. read password from /etc/netrc On success we return the password. If all strategies fail we return None.tremotepassevalsUTF-8t remotepasstremotepassfiletriis /etc/netrcN(RR RRRMtcodecstopenRqRrRstreadlineRR1R^R_RJR`RaRbRgRc(RtpasswdtpasswordtpassfiletfdReRfRd((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt getpasswordws>   !     "   cCs|j|j|||S(s5Return instance of OfflineIMAP representative folder.(t getfoldertypeR(RR5tdecode((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt getfolderscCs tjjS(N(RtIMAPt IMAPFolder(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyRscCs#|jj}|jj|dS(N(Rtacquireconnectiontreleaseconnection(Rtimapobj((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pytconnectscCs d|_dS(N(R R(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt forgetfoldersscCs|jdk r|jSg}|jj}|j}|jdtrR|j}nzY|d|jj\}}|dkrt d|j |t |ft j j nWd|jj|Xx|D]}|dkst|t r|dkrqnytj|\}}} Wn(tk r?|jjd|nXgtj|D]} | j^qP} d| krzqn|j|j|j| |qWt|jr|jj}zx|jD]} y |jtj| d tWnNt k rA} | jt j j krn|jj| td d qnX|j|j|j| |d tqWWd|jj|Xn|j dkr|j!d dn"d}|j!d ||j ||_|jS(s@Return a list of instances of OfflineIMAP representative folder.tsubscribedonlyt directorytOKsBCould not list the folders for repository %s. Server responded: %sNR4s2could not correctly parse server response; got: %ss \noselecttreadonlyisInvalid folderinclude:RtkeycSstj|jS(N(tstrRtgetvisiblename(R2((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR3R4cs dtffdY}|S(svConverts a cmp= function into a key= function We need to keep cmp functions for backward compatibilitytKcs eZdZfdZRS(cWs ||_dS(N(tobj(RRR$((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyRscs|jj|jjS(N(RR(Rtother(tmycmp(s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt__cmp__s(t__name__t __module__RR((R(s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyRs (tobject(RR((Rs5/usr/share/offlineimap/offlineimap/repository/IMAP.pytcmp2keys("RR RRtlistR:R;tlsubRRR#RRFtFOLDERRt isinstanceRt imapsplitt ValueErrorRterrort flagsplitRtappendRRtfolderincludestselectt utf8_IMAPR9tseverityRt foldersorttsort(RtretvalRt listfunctiontresultt listresulttstflagsR>R#R2tflaglistR5RIR((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt getfolderssd        (  !  cCs|jjrtj|}n|jj}zN|j|}|ddkrztd||t|ftj j nWd|jj |XdS(s#Delete a folder on the IMAP server.iRs:Folder '%s'[%s] could not be deleted. Server responded: %sN( R!t utf_8_supportRRRRtdeleteRRRFRR(RR5RR((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyt deletefolder s cCs|dkrdS|jr9|j|j|}n|sN|j}n|jj|||jjrqdS|jj}zl|jjrt j |}n|j |}|ddkrt d||t |ft jjnWd|jj|XdS(s*Create a folder on the IMAP server This will not update the list cached in :meth:`getfolders`. You will need to invoke :meth:`forgetfolders` to force new caching when you are done creating folders yourself. :param foldername: Full path of the folder to be created.R4NiRs:Folder '%s'[%s] could not be created. Server responded: %s(RR@Rt makefolderR!tdryrunRRRRRtcreateRRRFRR(RR5RR((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyRs&    (/RRRR+R-R0R/R6R.R%R@RJROR[RgRkRmRoRxRzRRRRRRRRRRRRRRRR8RRRR9RRRRRRR(((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR "sX        "     *             8     N tMappedIMAPRepositorycBseZdZRS(cCs tjjS(N(RtUIDMapstMappedIMAPFolder(R((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR<s(RRR(((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyR;s(t__doc__RqR^RaRtsysRt threadingRRDt offlineimapRRRRtofflineimap.repository.BaseRtofflineimap.threadutilRtofflineimap.utils.distroRR R R(((s5/usr/share/offlineimap/offlineimap/repository/IMAP.pyts     "