�
��Vc@s
dd
lm
Z
mZmZmZ
ddlmZ
ddlZddlZddl	Z	ddl
Z
ddlZddlm
Z

ddlmZ
ddlZddd��YZddd	��YZd
dd��YZdef
d
��YZdejf
d��YZde
efd��YZdS(i����(tRLockt
currentThreadtLocktEvent(
tdequeN(
tUIBase(
tExitNotifyThreadt
CursesUtilcBsSeZ
d�Zd
�Zd�Zed�
Zd�Zd�Zd�Z	d�Z
RS(c
Os%t�|_
t�|_i|_dS(
N(Rtiolockttframe_locktcolormap(tselftargstkwargs((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt__init__ s
	
cCstj
|j|
�
S(
s<Return the curses color pair, that corresponds to the color.(tcursest
color_pairR
(Rtcol_name((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytcurses_colorpair)sc
	Cs�d
|jd<t
jdt
jt
j�
d|jd<t
j}
dt
jtfdt
jtfdt
jtfdt
jtfd	t
j	tfd
t
j
tfdt
jtff}d}xA|D]9\}}}|d7}||j|<t
j|||
�
q�WdS(
s,Initialize the curses color pairs available.itwhitei
tbannertblacktbluetredtpurpletcyantgreentorangeN(R
Rt	init_pairtCOLOR_WHITEt
COLOR_BLUEtCOLOR_BLACKtFalset	COLOR_REDt
COLOR_MAGENTAt
COLOR_CYANtCOLOR_GREENtCOLOR_YELLOW(Rtbcoltcolorst
itnametfcoltbold((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytinit_colorpairs.s 



	











cCs|jj
|
�
S(
s�Locks the Curses ui thread.

        Can be invoked multiple times from the owning thread. Invoking
        from a non-owning thread blocks and waits until it has been
        unlocked by the owning thread.(Rtacquire(Rtblock((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytlockFsc


Cs|jj
�
d
S(s
Unlocks the Curses ui thread.

        Decrease the lock counter by one and unlock the ui thread if the
        counter reaches 0.  Only call this method when the calling
        thread owns the lock. A RuntimeError is raised if this method is
        called when the lock is unlocked.N(Rtrelease(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytunlockOscOs-|j�
z|
||�
Wd
|j
�
Xd
S(s'Perform an operation with full locking.N(R/R1(RttargetRR
((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytexec_lockedYs


c
Csd
�}
|j|
�

dS(Nc
Sstj
j�
tj�
dS(
N(Rtpanelt
update_panelstdoupdate(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytlockedstuffcs


(
R3(RR7((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytrefreshbs
	c

Cs
t|d
�S(Ntstdscr(
thasattr(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytisactivehs
(t__name__t
__module__RRR,tTrueR/R1R3R8R;(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRs
						
			tCursesAccountFramecBsGeZ
dZd
�Zdd�
Zd�Zd�Zd�Zd�ZRS(s�Notable instance variables:

    - account: corresponding Account()
    - children
    - ui
    - key
    - window: curses window associated with an account
    cCsFg|_|r|nd
|_
|
|_d|_d|_d|_dS(sG
        :param account: An Account() or None (for eg SyncrunnerThread)s*ControliN(tchildrentaccounttuitNonetwindowtacc_numtlocation(RRBRA((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRvs	

	
		icCso|
rd
|
d|
dfnd}d|j||j
f}|jj|jjdd|�
t|�
|_dS(sVDraw the account status string.

        secs tells us how long we are going to sleep.s%3d:%02di<tactives%s: [%s] %12.12s: iN(RERARBR3RDtaddstrtlenRF(Rtsecstsleepstrtaccstr((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytdrawleadstr�s$

cCsY|
|_||_
|j�
x6|jD]+}|j|
|jd
�
|jd7_q&WdS(s�Register an curses win and a hotkey as Account window.

        :param curses_win: the curses window associated with an account
        :param acc_num: int denoting the hotkey associated with this account.ii
N(RDRERMR@tupdateRF(Rt
curses_winREtchild((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt	setwindow�s	
	



c
CsAt|j
|j|jd
�}
|jd7_|jj|
�

|
S(s_Create a new ThreadFrame and append it to self.children.

        :returns: The new ThreadFrameii
(tCursesThreadFrameRBRDRFR@tappend(Rttf((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytget_new_tframe�s


cCs=|j|�

|j
j|jj�

tj|
�

|jj�S(
smShow how long we are going to sleep and sleep.

        :returns: Boolean, whether we want to abort the sleep(	RMRBR3RDR8ttimetsleepRAtget_abort_event(Rt	sleepsecst
remainingsecs((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytsleeping�s




c

CsYt|j
tjj�rU|jjd
|j
�

|j
jjd|j
j	dd�
ndS(s8Request that we stop sleeping asap and continue to sync.s%Requested synchronization for acc: %ss
Account %st	skipsleept
1N(
t
isinstanceRAtofflineimaptaccountstAccountRBtinfotconfigtsetR)(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytsyncnow�s


(	R<R=t__doc__RRMRQRUR[Re(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR?ls			
	
RRcBs>eZ
dZd
�Zdd�
Zd�Zd�Zd�ZRS(s-curses_color: current color pair for logging.cCs:|
|_||_
||_||_tjd
�
|_dS(s_
        :param ui: is a Blinkenlights() instance
        :param acc_win: curses Account windowiN(RBRDt
xt
yRRtcurses_color(RRBtacc_winRgRh((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�s
	
	
	
	
icCs0||jj
|
�
B|_|
|_|j�
d
S(s{Draw the thread symbol '@' in the specified color

        :param modifier: Curses modified, such as curses.A_BOLD
        N(RBRRit	colornametdisplay(Rtcolortmodifier((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytsetcolor�s
	
c
s#�f
d
�}
�jj
|
�

dS(Ncs3�jj
�j�jd
�j�
�jj�
dS(Nt
@(RDtaddchRhRgRiR8((
R(s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytlocked_display�s
"
(RBR3(RRr((
Rs9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRl�s
cCs)|
|_||_
||_|j�
d
S(s<Update the xy position of the '.' (and possibly the aframe).N(RDRhRgRl(RRjRgRh((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRN�s	
	
	
c

Cs|jd
�

dS(NR(
Ro(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt	std_color�s
(R<R=RfRRoRlRNRs(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRR�s
	
		tInputHandlerc
BsDeZ
dZd
�Zd�Zd�Zd�Zd�Zd�ZRS(s+Listens for input via the curses interfacescCsKtt
|�j�
d|_|
|_t�|_t�|_	|j
�
dS(
N(tsuperRtRRCtchar_handlerRBRtenabledRt	inputlocktstart(RRB((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�s

	
	
c
cs]|jj
�
xI|jj�rX|j�
|jjj�}
Wd
QX|
dkr|
V
qqWd
S(s�Return the key pressed or -1.

        Wait until `enabled` and loop internally every stdscr.timeout()
        msecs, releasing the inputlock.
        :returns: char or None if disabled while in hereNi����(Rwtwaittis_setRxRBR9tgetch(Rtchar((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt
get_next_char�s





c
Cs;x4tr6|j
�}
x|
D]}|j|�

qWqWdS(
N(R>R~Rv(Rtchar_genR}((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytrun
s
	



cCsF|j�7
|
|_
|
d
kr/|jj�
n
|jj�
Wd
QXd
S(s
Sets a character callback handler.

        If a key is pressed it will be passed to this handler. Keys
        include the curses.KEY_RESIZE key.

        callback is a function taking a single arg -- the char pressed.
        If callback is None, input will be ignored.N(RxRvRCRwtclearRd(Rtcallback((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt
set_char_hdlr
s
	

	
c


Cs|jj
�
|jj�
d
S(s�Call this method when you want exclusive input control.

        Make sure to call input_release afterwards! While this lockis
        held, input can go to e.g. the getpass input.N(RwR�RxR-(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt
input_acquire
s

c


Cs|jj
�
|jj�
d
S(s1Call this method when you are done getting input.N(RxR0RwRd(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt
input_release%
s

(	R<R=RfRR~R�R�R�R�(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRt�s
	
	
				tCursesLogHandlerc
BseZ
dZd
�ZRS(s?self.ui has been set to the UI class before anything is invokedcCs�tj
j||
�}|jj�j}|jjj�
|jj�
zT|jj	j
�\}}|sk|r�|jj	jd
�

n|jj	j||�
Wd|jj
�
|jjj�
X|jj	j�
|jjj�
dS(Ni
(tloggingt
StreamHandlertformatRBtgettfRiR	R-R/tlogwintgetyxRqRHR1R0tnoutrefreshR9R8(Rtrecordtlog_strRmRhRg((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytemit/
s











(R<R=RfR�(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�,
s
t
BlinkenlightscBs.
eZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zdd�
Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd!d�
Zed�
Zd�Zd�Z d�Z!d�Z"d �Z#RS("s�
Curses-cased fancy UI.

    Notable instance variables self. ....:

       - stdscr: THe curses std screen
       - bannerwin: The top line banner window
       - width|height: The total curses screen dimensions
       - logheight: Available height for the logging part
       - log_con_handler: The CursesLogHandler()
       - threadframes:
       - accframes[account]: 'Accountframe'c
Os*tt
|�j|
|�
tj|�

dS(
N(RuR�RR(RRR
((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRP
s

c
Cs?t�}
t
jd
�
|_|
j|j�

|jj|
�

|
S(s�Backend specific console handler.

        Sets up things and adds them to self.logger.
        :returns: The logging.Handler() for console outputs%(message)s(R�R�t	Formattert	formattertsetFormattertloggert
addHandler(Rtch((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytsetup_consolehandlerU
s
	
c

Cs�tj
j�r#tjj�r#tStjjd
d�s<tStj	dd!dkshtj	dd!dkr�yt
j�
t
j�
Wq�


tSXnt
S(	s6Returns true if the backend is usable ie Curses works.tTERMiiiiN(ii(iii(tsyststdouttisattytstdinR tostenvirontgetRCtversion_infoRtinitscrtendwinR>(
t
s((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytisusableg
s

,






c

Cs 
i|_i|_
i|_t�|_tj�|_tj�
tj	�
|jj
d
�

|jjd�

tj�
d|_ytjd�
|_Wn


n
X|jj�
|jj�
|j�
||j_|j�
t|�
|_|jj|j�

|j�jd�

|jtj�

dS(Ni
i�iR(tavailablethreadframestthreadframest	accframesRtaflockRR�R9tnoechotcbreaktkeypadttimeouttstart_colorRCt	oldcursortcurs_setR�R8R,t_log_con_handlerRBtsetupwindowsRttinputhandlerR�t
on_keypressedR�RoRbR_R(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytinit_banner{
s0
	
	
	




	












c
Gs-|j�j
d
�

tt|�j|
�
dS(s=Output that we start syncing an account (and start counting).RN(R�RoRuR�tacct(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s
c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�t
connecting(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�tsyncfolders(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�t
syncingfolder(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�tskippingfolder(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�tloadmessagelist(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�tsyncingmessages(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�tcopyingmessage(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�tdeletingmessages(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�taddingflags(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�t
deletingflags(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

c
Gs-|j�j
d
�

tt|�j|
�
dS(NR(R�RoRuR�tcallhook(RR((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

icCs3|j�j
d
tj�
tt|�j|
�

dS(NR(R�RoRtA_BOLDRuR�twarn(Rtmsgtminor((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s

cCs�|j|
�
}|j
�[
|
|j|kro|j||
}|jd
�

|j|j|�

|j||
=nWdQXtt|�j|
�

dS(NR(	tgetthreadaccountR	R�RoR�RSRuR�tthreadExited(RtthreadtaccRT((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s









c
	Cs�t�}
|j
�}|j��
y&|
|j|krD|j||
SWn.tk
ru


i|j|<t�|j|<n
Xt|j|�
r�|j|j�}|j	�
n|j
|�
j�}||j||
<Wd
QX|S(s/Return the ThreadFrame() of the current thread.N(R
R�R	R�tKeyErrorRR�RItpopleftRstgetaccountframeRU(Rt
cur_threadR�RT((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s	












cCs�|
tj
kr|j�
n|
d
ks4|
dkr8dSt|
�
dkrs|jd�

tjjj|j	d�
nyt
t|
�
�
}Wntk
r�


dSX|t|j
�
kr�dS|j|j
|�
j�
dS(Ni
i�t
qsRequested shutdown via 'q'i(Rt
KEY_RESIZEt
resizetermtchrR�R_R`Ratset_abort_eventRctintt
ValueErrorRIthotkeysR�Re(Rtkeytindex((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��
s











cCsK|j�j
d
�

|jd|
d|
df�

tt|�j|
|�S(NRsNext sync in %d:%02di<(R�RoRbRuR�RW(RRYRA((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyRWs


cCsA|
s|j�j
d
�

n|j|j��
}|j|
|�S(NR(R�RoR�R�R[(RRYRZtaccframe((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR[s


c

Cs|j|j
t�
d
S(sResize the current windows.N(R3R�R>(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�sc

Cstj
|�

dS(
N(Rt
mainException(
R((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�s
cCst|jj
�
|j�
z>|jd
�

|jd|
�

|jj�
|jj�}Wd|j�
|jj�
X|S(Ns *** Input Requireds+ *** Please enter password for account %s: (	R�R�R/R�R�R8tgetstrR1R�(RtaccountnameRcterrmsgtpassword((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pytgetpass"s




	






cCs�
|jj
�\|_|_|jt|j�
d
|_|
r�tj|j|j�
|j	j
d
|j�
|jj
|j|j�
n?tjd
|jdd�|_	tj|j|jd
d�|_|j
�
|jjt�

|jjt�

|j�
tt|jj��
�
|_|jd
}d}g|_xg|jD]\}tjd
|j|d�}|j|j||�
|jj|�

|d
7}|d
8}q=
Wtj�
dS(s�Setup and draw bannerwin and logwin.

        If `resize`, don't create new windows, just adapt size. This
        function should be invoked with CursesUtils.locked().i
iN(R9tgetmaxyxtheighttwidthRIR�t	logheightRR�t	bannerwintresizeR�tnewwintdraw_bannerwintidlokR>tscrolloktdraw_logwintreversedtsortedtkeysR`R�RQRSR6(RR�tposR�RARj((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�4s.





!









	







c
Cs�tj
�r%tj|jd
�
B}
n	tj}
|jj�
|jjd|
�
dtj	tj
f}|jjdd||
�
|jjd|jt
tj�
dtj|
�
|jj�
dS(sDraw the top-line banner line.Rt
 s%s %sii
N(Rt
has_colorsR�Rt	A_REVERSER�R�tbkgdR_t__productname__t__version__RHR�RIt
__copyright__R�(RRmtstring((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�Ts
	



	



#


c
Cs^tj
�rtjd
�
}
n	tj}
|jjd
d
�
|jj�
|jjd|
�
dS(s(Re)draw the current logwindow.iR�N(RR�RtA_NORMALR�tmoveteraseR�(RRm((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�ds
	



cCs[|j�E
|
|j
kr$|j
|
St||
�|j
|
<|jd
t�

WdQX|j
|
S(spReturn an AccountFrame() corresponding to acc_name.

        Note that the *control thread uses acc_name `None`.R�N(R�R�R?R�R>(Rtacc_name((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�os


c
Os�tj
�
|jjd
�

tj�
tj�
|jj|j�

t	j
|�

tt|�j
|_
tt|�j|
|�
dS(Ni(RtnocbreakR9R�techoR�R�t
removeHandlerR�RR�RuR�R�t	terminate(RRR
((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�|s








cCstj
||
�
dS(
N(RtthreadException(RR�((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR��sN($R<R=RfRR�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�R�RWR[R�R�RCR�R R�R�R�R�R�R�(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyR�C
s@				$													
						 			
	((((t	threadingRR
RRtcollectionsRRVR�R�RR�tofflineimap.ui.UIBaseRtofflineimap.threadutilRR_RR?RRRtR�R�R�(((s9/usr/lib/python2.7/site-packages/offlineimap/ui/Curses.pyt<module>s"







MO+F