e`ddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl Z ddl m Z ddddd adad Zd ZGd d Zy)N)Queue)deque)OfflineImapErrorz'Other offlineimap related sync messageszIMAP protocol debuggingzMaildir repository debuggingzThreading debugging)imapmaildirthreadc|ay)z0Set the global ui object to be used for logging.Nglobalui)newuis 0/usr/share/offlineimap3/offlineimap/ui/UIBase.py setglobaluir's HctS)zReturn the current ui object.r rr getglobaluir.s  Orc~eZdZejfdZdZdZdZdZ dZ d:dZ d;d Z d Z d ZdUIBasecV||_|jddd|_g|_i|_d|_i|_i|_d|_t|_ d|_ tjd|_|jj||j!|_y)Ngeneralzdry-runF OfflineImap)configgetdefaultbooleandryrun debuglist debugmessages debugmsglenthreadaccountsacct_startimeslogfiler exc_queueuidval_problemlogging getLoggerloggersetLevelsetup_consolehandler_log_con_handler)selfrloglevels r__init__zUIBase.__init__6s ..y)UK    #'' 6  X& $ 9 9 ;Irc>tjtj}tjd|_|j |j |jj||jjtj|S)zBackend specific console handler. Sets up things and adds them to self.logger. :returns: The logging.Handler() for console outputz %(message)s) r% StreamHandlersysstdout Formatter formatter setFormatterr' addHandlerinfo offlineimapbannerr+chs rr)zUIBase.setup_consolehandlerOsk " "3:: .!**=9 ' r" ++, rctjjd}tjd|_|j |j|j j|y)z Backend specific syslog handler.z/dev/logz%offlineimap[%(process)d]: %(message)sN)r%handlers SysLogHandlerr2r3r4r'r5r9s rsetup_sysloghandlerzUIBase.setup_sysloghandler`sO   + +J 7 **+RS ' r"rc :tj|d}tjdd}|j||jj |dj tjddDcgc] }t|c}}dtjd|d tjd d j tj}tjd tjt d |d d }|j#|y cc}w)z'Create file handler which logs to file.atz&%(asctime)s %(levelname)s: %(message)sz%Y-%m-%d %H:%M:%S.rz OfflineImap z starting... Python: z Platform: z Args:  rN)r% FileHandlerr2r4r'r5joinr0 version_infostrr7 __version__platformargv LogRecordINFO__file__emit)r+r"fhfile_formatterxp_vermsgrecords r setlogfilezUIBase.setlogfileks $ / **,9:MO ' r"#*:*:1Q*?@Q#a&@A'33UCLLHHSXX.0""=',,#'dD:  As9Dc&|j|yzDisplay a message.N)r6r+rSs r_msgz UIBase._msg}s #rc:|jj|yrWr'r6rXs rr6z UIBase.infos rc:|jj|yN)r'warning)r+rSminors rwarnz UIBase.warns C rNcF|r"|jjd|d|n|jjd|z|}|jsd}|jj |||f|r/|jjt j |yy)aLog a message at severity level ERROR. Log Exception 'exc' to error log, possibly prepended by a preceding error "msg", detailing at what point the error occurred. In debug mode, we also output the full traceback that occurred if one has been passed in via sys.info()[2]. Also save the Exception to a stack that can be output at the end of the sync run when offlineiamp exits. It is recommended to always pass in exceptions if possible, so we can give the user the best debugging info. We are always pushing tracebacks to the exception queue to make them to be output at the end of the run to allow users pass sensible diagnostics to the developers or to solve problems by themselves. One example of such a call might be: ui.error(exc, sys.exc_info()[2], msg="While syncing Folder %s in " "repo %s") ERROR:  ERROR: %sN)r'errorrr#put traceback format_tb)r+exc exc_tracebackrSinstant_tracebacks rrez UIBase.errors0  KK  3< = KK  kC/ 0)~~ $  Cm45  KK  i112CD E rc (tj}||jvr:|jdd|j d|j |d|dn'|jdd|j d|d||j|<y) zARegister current thread as being associated with an account name.r zRegister thread 'z' (previously 'z', now 'z')zRegister new thread 'z ' (account 'N) threading currentThreadr debuggetNamegetthreadaccount)r+account cur_threads rregisterthreadzUIBase.registerthreads,,. ,, , JJx,6,>,>,@,0,A,A*,Mw"X Y JJx"**,g"7 8*1J'rc||jvr |j|=|jdd|jzy)z=Unregister a thread as being associated with an account name.r zUnregister thread '%s'N)r rorpr+thrs runregisterthreadzUIBase.unregisterthreads: $%% %##C( 85 EFrcj|tj}||jvr|j|Sy)zxGet Account() for a thread (current if None) If no account has been registered with this thread, return 'None'.N)rmrnr rvs rrqzUIBase.getthreadaccounts9 ;))+C $%% %&&s+ +rctj}||jvrt|j|<|j|j |d|t |j||j kDr|j|j||jvr"|jjd|d|yy)N: [z]: ) rmrnrrappendlenrpopleftrr'ro)r+ debugtyperSrss rroz UIBase.debugs,,. T// /.3WD  z * :&--)S.IJ t!!*- .1A1A A   z * 2 2 4  & KK  Is; < 'rc|tvr<||jvr-|jj||j|yy|j |yr]) debugtypesrr} debugging invaliddebugr+rs r add_debugzUIBase.add_debugsI  ".%%i0y)/   i (rc||jvSr])rrs r is_debuggingzUIBase.is_debuggingsT^^+,rcT|jjd|dt|y)NzNow debugging for r{)r'rorrs rrzUIBase.debuggings%  8B98MO Prc,|jd|zy)NzInvalid debug type: %s)r`rs rrzUIBase.invaliddebugs *Y67rc|jjjdd}tjdd|S)z\Return the type of a repository or Folder as string. (IMAP, Gmail, Maildir, etc...)rAz(Folder|Repository)r) __class____name__splitresub)r+mobject prelimnames r getnicenamezUIBase.getnicenames9 &&//55c:2> vv+R< ? &&y2CD  +4++J7.EE Frc |jjddr|jjddry|jdt |d|j |d|dy)Nrrz'Attempted to modify flags for messages in folder r|zO], but that folder is read-only. No flags have been modified for that message.rrrr`rGr)r+ruidlistflagss rflagstoreadonlyzUIBase.flagstoreadonlyZ ;; ! !)-> ? &&y2CD  'lD$4$4Z$@*N Orc |jjddr|jjddry|jdt |d|j |d|dy)Nrrz(Attempted to modify labels for messages rr|zP], but that folder is read-only. No labels have been modified for that message.r)r+rrlabelss rlabelstoreadonlyzUIBase.labelstoreadonly"rrc |jjddr|jjddry|jdt |d|j |d|dy)NrrzAttempted to delete messages rr|zO], but that folder is read-only. No messages have been deleted in that folder.r)r+rrs rdeletereadonlyzUIBase.deletereadonly+sW ;; ! !)-> ? &&y2CD  "7|T-=-=j-I)+ ,rcy)zCalled when the UI starts. Must be called before any other UI call except isusable(). Displays the copyright banner. This is where the UI should do its setup -- TK, for instance, would create the application window here.Nrrs r init_bannerzUIBase.init_banner6s rc|jjtjsyd}|r|nd}|rd|znd}|rd|d|}|jj d|d|dy) z!Log 'Establishing connection to'.Nrz%s to :zEstablishing connectionz ())r' isEnabledForr%rLr6)r+ reposnamehostnameport displaystrs r connectingzUIBase.connecting=sa{{'' 5  '8R"td{ (0$7J $i1 2rctj|j|<|jjd|zy)z=Output that we start syncing an account (and start counting).z*** Processing account %sNtimer!r'r6)r+rrs racctz UIBase.acctKs2(,yy{G$ 4w>?rctj|j|z }|j|=|jjd||dz|dzfzy)z;Output that we finished syncing an account (in which time).z$*** Finished account '%s' in %d:%02d<Nr)r+rrsecs racctdonezUIBase.acctdoneQsYiikD//88    ( ?!3"9cBh78 9rc|jjtjr|j dd|d|yy)z"Log 'Copying folder structure...'.rzCopying folder structure from rN)r'rr%DEBUGro)r+src_repodst_repos r syncfolderszUIBase.syncfoldersYs7 ;; # #GMM 2 JJr (, - 3rch|jrdnd}|jdj|||y)z Called when a folder is created. [DRYRUN] rz{0}Creating folder {1}[{2}]Nrr6format)r+repo foldernameprefixs r makefolderzUIBase.makefolderas2!%  077 J& (rc |jjd|d|j|d|j|y)/Called when a folder sync operation is started.zSyncing r{ -> N)r'r6r)r+srcrepos srcfolder destreposrs r syncingfolderzUIBase.syncingfolderhs; 9373C3CH3M373C3CI3NP Qrc@|jjd|zy)rzSkipping %s (not changed)Nr[r+folders rskippingfolderzUIBase.skippingfolderos 4v=>rcd|_|jjd||j|j |j fzy)NTz~UID validity problem for folder %s (repo %s) (saved %d; got %d); skipping it. Please see FAQ and manual on how to handle this.)r$r'r^ getrepositoryget_saveduidvalidityget_uidvalidityrs rvalidityproblemzUIBase.validityproblemssV" @$V%9%9%;#88:F rr)r+srrdr dstfolders rsyncingmessageszUIBase.syncingmessagess9    R )   R )- .rc z|jjd|d|jd|d|jy)z3Output a log line stating which message is ignored.zIGNORED: Copy message UID rCrrNr'r6 repository)r+rsrcrs rignorecopyingmessagezUIBase.ignorecopyingmessages.  j&;&;= >rc v|jjd||||j||j|fzy)z0Output a log line stating which message we copy.z*Copy message UID %s (%d/%d) %s:%s -> %s:%sNr)r+rnum num_to_copyrrs rcopyingmessagezUIBase.copyingmessages> E k3>>3  ! !:I// 0rc |j|}|jrdnd}|jdj|t |t j j||y)Nrrz%{0}Deleting {1} messages ({2}) in {3})rrr6rr~r7imaputil uid_sequence)r+rdestlistdsrs rdeletingmessageszUIBase.deletingmessagessV __X & $  9@@ CL  - -g 6< =rcv|jjddj|t||fzy)Nz#Adding flag %s to %d messages on %srr'r6rEr~r+rrdests r addingflagszUIBase.addingflagss6 > IIe c'lDB22 3rcv|jjddj|t||fzy)Nz'Deleting flag %s from %d messages on %srrrs r deletingflagszUIBase.deletingflagss6 B IIe c'lDF22 3rcX|jjd|t||fzy)Nz$Adding label %s to %d messages on %sr'r6r~r+rlabelrs r addinglabelszUIBase.addinglabelss- ? 3w<C'' (rcX|jjd|t||fzy)Nz(Deleting label %s from %d messages on %sr r s rdeletinglabelszUIBase.deletinglabelss- C 3w<G'' (rc h|jjd||||dj|fzy)Nz1Setting labels to message %d on %s (%d of %d): %sr)r'r6rE)r+rr num_to_setrrs r settinglabelszUIBase.settinglabelss6 L sJ &(9P;; >#V%;%;=4$00888rc|j|j||j||jdy)z{Called when a thread has terminated with an exception. The argument is the ExitNotifyThread that has so terminated.dN)r`rBr? terminater>s rthreadExceptionzUIBase.threadException s5 $//78 v& src|jjs|jd|dk(rd}|jjs|jj\}}}dj t j t||}|r|jd|d|n|jd|z|r6|jddj t j|z|jjs|r|r|jd|d |d n|r|jd |z|jr|jd |dk(rd }tj|y)z$Called to terminate the application.z*ERROR: Exceptions occurred during the run!rrrbrcrdz Traceback: %sz r9z%s z7At least one folder skipped due to UID validity problemN) r#emptyr`getrErgformat_exception_onlytyperhr$r0exit)r+ exitstatus errortitleerrormsgrSrirjexc_strs rrEzUIBase.terminates6~~##% IIB CQ ..&&(&*nn&8&8&: #Cmggi==d3iMNG sG<= +/0 ,rww'' 60889..&&(  IIZB C  IIfx' (    IIO PQ  rcH|j||j|y)zRCalled when a thread has exited normally. Many UIs will just ignore this.N)r?rxr>s r threadExitedzUIBase.threadExited0s v& f%rc|jr!|jdj|y|j|y)Nz [DRYRUN] {0}rrXs rcallhookzUIBase.callhook:s+ ;; IIn++C0 1 IIcNrcd}|dkDr4|s2|jrd}n|jd|}|dz}|dkDr|s2|jdd|S)a@This function does not actually output anything, but handles the overall sleep, dealing with updates as necessary. It will, however, call sleeping() which DOES output something. :returns: 0/False if timeout expired, 1/2/True if there is a request to cancel the timer. FrT )get_abort_eventsleeping)r+ sleepsecsrr abortsleeps rsleepz UIBase.sleepBs] !mJ&&(! !]]2y9 R !mJ arc|dkDrD|dz||z dzk7r!|jjd|dz ztj|y)abSleep for sleepsecs, display remainingsecs to go. Does nothing if sleepsecs <= 0. Display a message on the screen if we pass a full minute. This implementation in UIBase does not support this, but some implementations return 0 for successful sleep and 1 for an 'abort', ie a request to sync immediately. rrzNext refresh in %.1f minutesgN@)r'rorr])r+r[ remainingsecss rrZzUIBase.sleepingUsS q="}y'@R&GG !!"@%,#./ JJy !r)r)NNr])rNN)=r __module__ __qualname__r%rLr-r)r>rUrYr6r`rertrxrqrorrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrr4r7r<r?rBrFrErTrVr]rZrrrrr5s/(/ J2" #$  !$FL 2G = )-P 8=:T FOO,  2@ 9-(Q?W 5 . > 0=33((<M3.j/+ :&&rr)r%logging.handlersrrr0rgrmqueuer collectionsrr7offlineimap.errorrrr rrrrrrrfsX$ .;/7-/ ppr