eo ddlmZmZddlmZmZddlZddlZddlm Z ddl Z ddl m Z m Z mZddl mZddlmZddlmZdd lmZd ZiZeZ ddlZd ZGd d e j8ZGddeZdZy# ddlZn#YnxYwY8xYw))PopenPIPE)EventLockN)exc_info)mbnames CustomConfigOfflineImapError)globals) Repository) getglobalui)InstanceLimitedThreadLIMITED_FOLDER_cf|jdDcgc]}|jc}Scc}w)NAccount)getsectionlistlstrip) customconfignames //usr/share/offlineimap3/offlineimap/accounts.pygetaccountlistr-s'&2&A&A)&L MdDKKM MM Ms.c~eZdZdZeZeZdZdZdZ dZ dZ dZ dZ ed Zd Zd Zd Zd Zy)rzRepresents an account (ie. 2 repositories) to sync. Most of the time you will actually want to use the derived :class:`accounts.SyncableAccount` which contains all functions used for syncing an account.c||_||_|j|_|j |_|j dd|_t|_ |jdd|_ |jjdd|_ d|_|jdkr%|jjd|zd|_ |jdk(rd |_ d |_d |_d |_y ) a :param config: Representing the offlineimap configuration file. :type config: :class:`offlineimap.CustomConfig.CustomConfigParser` :param name: A (str) string denoting the name of the Account as configured. utf8foldernamesF autorefreshggeneralzdry-runrz/autorefresh for %s is negative, fixing it to 0.N)configrgetmetadatadir metadatadir getlocaleval localevalgetconfboolean utf_8_supportr ui getconffloat refreshperiod getbooleandryrunquicknumwarn remoterepos localrepos statusrepos)selfrrs r__init__zAccount.__init__>s  !002,,.!001BEJ-!..}cBkk,,Y B     ! GGLLJ !$D     $!%D c|jSN)r!r.s rr zAccount.getlocaleval\s ~~r0c|jSr2)rr3s r getconfigzAccount.getconfig`s {{r0c|jSr2rr3s rgetnamezAccount.getnamec yyr0c|jSr2r7r3s r__str__zAccount.__str__fr9r0cptjj|jd|jzS)NzAccount-)ospathjoinrrr3s rgetaccountmetazAccount.getaccountmetais&ww||D,,j499.DEEr0c(d|jzS)NAccount )r8r3s r getsectionzAccount.getsectionmsDLLN**r0c|dk(r't|D]}|jd|zddy|dk(r|jjy|dk(r|jjyy)aYSet skip sleep/abort event for all accounts. If we want to skip a current (or the next) sleep, or if we want to abort an autorefresh loop, the main thread can use set_abort_event() to send the corresponding signal. Signum = 1 implies that we want all accounts to abort or skip the current or next sleep phase. Signum = 2 will end the autorefresh loop, ie all accounts will return after they finished a sync. signum=3 means, abort NOW, e.g. on SIGINT or SIGTERM. This is a class method, it will send the signal to all accounts. rB skipsleep1N)rsetabort_soon_signalabort_NOW_signal)clsrsignum acctsections rset_abort_eventzAccount.set_abort_eventpsm Q;-f5 G  : 3[#F G q[  ! ! % % ' q[  $ $ &r0c|jdd}|r+|jj|jdd|xs>tj j xstjj S)avChecks if an abort signal had been sent. If the 'skipsleep' config option for this account had been set, with `set_abort_event(config, 1)` it will get cleared in this function. Ie, we will only skip one sleep and not all. :returns: True, if the main thread had called :meth:`set_abort_event` earlier, otherwise 'False'. rFr0)r"rrJrCrrKis_setrL)r.rFs rget_abort_eventzAccount.get_abort_eventsi'' Q7  KKOODOO-{C @1G55<<>1''..0 1r0c|jsyg}t|dr|j|jt|dr|j|j|D]}|j t |jdz}|jj||}|D]}|j|rEtjjstjjryd|_yy)zSleep if the account is set to autorefresh. :returns: 0:timeout expired, 1: canceled the timer, 2:request to abort the program, 100: if configured to not sleep at all. dr,r+<rHrrE)r&hasattrappendr,r+startkeepaliveintr$sleep stopkeepaliverrKrSrLr))r.kaobjsitemr& sleepresults r_sleeperzAccount._sleepers!! 4 & MM$// * 4 ' MM$** + "D    ! "D..34 ggmmM48  !D     ! ((//1,,335DMr0ct|d}t|d}|jj|d|jj|dy)z1Output diagnostics for all involved repositories.remotelocalRemoteLocalN)r r$serverdiagnostics)r. remote_repo local_repos rrgzAccount.serverdiagnosticssD!x0 g.  !!+x8 !!*g6r0c<t|d} |jr#|jjd|d|dy|j ||jjd|zy#t $r%}|jj |Yd}~yd}~wwxYw)Nrczwould try to remove 'z' on remote of 'z ' accountzFolder '%s' deleted.rrE)r r(r$info deletefolder Exceptionerror)r. foldernamerhes rrlzAccount.deletefolders x0  {{ *4d<= ((4 3j@A  GGMM!  s.A-/A-- B6BBN)__name__ __module__ __qualname____doc__rrKrLr/r r5r8r;r@rC classmethodrPrTrargrlr0rrr2sfw <F+''21""H7 r0rc:eZdZdZdZdZdZdZdZdZ dZ y ) SyncableAccounta0A syncable email account connecting 2 repositories. Derives from :class:`accounts.Account` but contains the additional functions :meth:`syncrunner`, :meth:`sync`, :meth:`syncfolders`, used for syncing. In multi-threaded mode, one instance of this object is run per "account" thread.ctj|g|i|d|_tjj |j jd|z|_y)Nz%s.lock) rr/_lockfdr=r>r?rr _lockfilepath)r.argskwargss rr/zSyncableAccount.__init__sM/// WW\\ KK & & ()d*:<r0cvt|jd|_ tj|jtj y#t $r tj|jtj tjzYy#t $rYYyt$r4td|ztjjtdwxYwt$rN|jjtd|ztjjtdwxYw)z@Lock the account, throwing an exception if it is locked already.wzBCould not lock account %s. Is another instance using this account?rHN)openr{rz portalockerlockLOCK_EX NameErrorfcntllockfLOCK_NBIOErrorr ERRORREPOrcloser3s r__lockzSyncableAccount.__locksD..4     T\\;+>+> ? # # DLL%--%--*GH  #&359:$**//JqM ## #   LL   "/156 &&++ 1   s*.A D8?B C D8#existsmkdirr r+r,r-r rnrseverityrCRITICALacct_SyncableAccount__lock_SyncableAccount__syncr&KeyboardInterrupt SystemExitrrmacctdonerra)r.accountmetadatarploopings r syncrunnerzSyncableAccount.syncrunners! t$ "113O77>>/2%0)$9D (w7DO)$9D  GGLL    "%%G  & t}}!3G7   GGMM!XZ] +zz-33<<<   &z2 # 0::!1!7!7!j@smtCtD|j jtFd| jId|d|| |f} | jK|jM| n tG|| |d}|D]} | jO|dur tQjR|jTn5djW|}t|tjj|jY|jY|j[|j[|jdd}|j||rdydy#j]j]xYw)zSynchronize the account once, then return. Assumes that `self.remoterepos`, `self.localrepos`, and `self.statusrepos` has already been populated, so it should only be called from the :meth:`syncrunner` function.quickrTrEF presynchookfullz"Configuration mismatch in account z'%s'. z2 Account setting 'utf8foldernames' and repository z3setting 'decodefoldernames' may not be used at the z3same time. This account has not been synchronized. z1Please check the configuration and documentation.readonlyzNot syncing filtered folder 'z'[]zIgnoring folder 'z' due to unsupported 'z'' character serving as local separator.zFolder z [acc: )limitNamespacetargetrr|z3Account {}: no folder to sync (folderfilter issue?) postsynchookN)/ getconfintr)getconfcallhookr#r+getdecodefoldernamesr r8rrr,r- getfolderssync_folder_structurer"r$ syncfoldersrrLrS sync_thisdebugrr=r>sepr*r repositoryr optionssinglethreadingrFOLDER_NAMESPACE syncfoldergetexplainednamestartrYr?rwriteIntermediateFilerformat forgetfoldersholdordropconnectionsdropconnections)r. folderthreads quickconfigrhook startedThreadr+r,r-rr localfolderthreadthrrs r__synczSyncableAccount.__syncLs oogq1 ?E 1_}}!T]][%@ !  $  1 E||M2. duG&9   $"2"2"G"G"I"#G#+dlln#<$=#X$Y$Z$Z$Z $Z $W $W $4#9#9#>#> @ @N 0!M**KJ**K  " " $  ! ! #  - -j+ F,,Z?##K<!, 6 6 8) % ++224#--GGMM"0<0D0D0F 'UV !'')277;;&{1133|3355GGLL"."6"6"8*:K:K:M&OP"33LA ",,GGMM"0;0C0C0E{G]G]'_`662,d.>.>.F.F.H(J)(99;TC"L%8 FLLN!((0t\59 $ S) %V%   $--dii8KRRSWX&s,<,B,B,G,GHH  $ $ &  % % '  , , .  - - /||NB/ duG9&9   & & (  ' ' ) s 6LQ#Q5c tjjry|sy |jj d|z|j ryt jj}||d<t|dtttd|}|j\}}|jj d|jdd|jdd|jj d |jzy#ttf$rt $r3}|jj#|t%d d Yd}~yd}~wwxYw) NzCalling hook: OFFLINEIMAPSYNCMODET)shellstdinstdoutstderr close_fdsenvz Hook stdout: zutf-8z Hook stderr: zHook return code: %drHz Calling hookr)rrLrSr$rr(r=environcopyrr communicatedecode returncoderrrmrnr)r.cmdsyncmoderprrrps rrzSyncableAccount.callhooks  # # * * ,   @ GG  -3 4{{jjoo'G-5G) *c d $'3A]]_NFF GG  }}W-v}}W/EG H GG  3allB C!:.   @ GGMM!XZ]M ? ? @s*D B.acquire_mutexs( &224  F -5-/ \*L)--.>?G@Dv \*+;< F \"#34<<> F Fs A BBcrtjjjyr2)rr8rrelease)rrsr release_mutexz!syncfolder..release_mutexs)W__&' (?(?(ABJJLr0cpjdkDsjdkDrojs,jjj yjs"jj yyj j y)Nr)getmessagecountcheck_uidvalidityvalidityproblemr restore_atimesave_uidvalidity)rr,r statusfolderr$srcheck_uid_validityz&syncfolder..check_uid_validitys  & & (1 , 0L0L0NQR0R002"";/&&446113""<0((*4  ( ( *  ) ) +r0cRjtjtj|dzj }j t |dkDrGj jt|jt|yj|j }|Dcgc] }|dkDs | }}t |dkDr,j jt|yycc}w)zBReturns messages with uid > min(uids of messages newer than date).iQmin_datermin_uidN)cachemessagelisttimegmtimemktimegetmessageuidlistdropmessagelistcachelenmin)dateuidsuidrrs rcachemessagelists_upto_datez/syncfolder..cachemessagelists_upto_date s %%[[T!2\!AB & D--/((* t9q=  - - /  ) )#d) ) <  ( (T ( ;  ( ($ ( 7002D$(3C37C3D34y1}113--c$i-@4s  D$#D$c@|j|j}|t|jdkDrSt d|j j d|j j dtjj|j|t|jjDcgc] }|dkDs | }}t|dkDr t|}nd}|j|y|j|ycc}w) aRetrieve messagelists when startdate has been set for the folder 'partial'. Idea: suppose you want to clone the messages after date in one account (partial) to a new one (new). If new is empty, then copy messages in partial newer than date to new, and keep track of the min uid. On subsequent syncs, sync all the messages in new against those after that min uid in partial. This is a partial replacement for maxage in the IMAP-IMAP sync case, where maxage doesn't work: the UIDs of the messages in localfolder might not be in the same order as those of corresponding messages in remotefolder, so if L in local corresponds to R in remote, the ranges [L, ...] and [R, ...] might not correspond. But, if we're cloning a folder into a new one, [min_uid, ...] does correspond to [1, ...]. This is just for IMAP-IMAP. For Maildir-IMAP, use maxage instead.NrzTo use startdate on Repository z , Repository z must be emptyrrEr)rretrieve_min_uidrrr rrrMESSAGElist messagelistkeysr save_min_uid)newpartialrrr  positive_uidss rcachemessagelists_startdatez/syncfolder..cachemessagelists_startdate)s$ **, ?3((*+a/&(/(:(:(?(?ATAT(V(8'='='E'EGG (($(715W5H5H5M5M5O0P \TWZ[T[ \ \}%)!-0GG$$W-  $ $W $ 5!]s DDNrEzuYou can set at most one of the following: maxage, startdate (for the local folder), startdate (for the remote folder)rHzTQuick syncs (-q) not supported in conjunction with maxage or startdate; ignoring -q.)rrrrFrz(Not syncing to read-only repository '%s'zAborting sync, folder 'z ' [acc: 'z']rzERROR in syncfolder for z folder z: ),r+r,r-r rrraddr getlocalrootr8rrrr openfilesr syncingfolder getmaxage getstartdater rrrr* quickchangedskippingfolderrlocalsr closefilesr"syncingmessagessyncmessagestorsaverrrFOLDERrnrm traceback format_exc)rrrrrrr rr+r-maxage localstart remotestartfolderrprr,rr$s`` @@@@rrrs?"M,,(A8&6P%%K##J%%K Bg_..|<    GLL*"9"9";'') +#,,\-H-H-J-4W[5G5G5I;K]K]K_-`b  %%' lJ L&&( --/ "//1 $ :T#9 :kQU>U VYZ Z"$P$4#9#9#>#>#+:a= 2 2  *  GG= >   ' /   # ' k(2 4   $ ' \(3 5   ( ( *#00>(55lC%%l3,,.FF 8F! 557 8 !O   ) ) +((U;   {L*k R  ' ' \ B HHRC'')* +))*e<   z; \ R  & &|\ B HHRC ((*+ ,   "F 8F! 557 8 !% z * S ::(..55 5  HHQ 1 r3s"#! ??-&8$ F N dl,,dN@g@HYq     s$A<<B ?BB BB