Server : Apache/2.4.62 (Unix) OpenSSL/1.0.2k-fips System : Linux server1.richineiserver.com 3.10.0-1160.119.1.el7.x86_64 #1 SMP Tue Jun 4 14:43:51 UTC 2024 x86_64 User : fdshops ( 1003) PHP Version : 8.2.21 Disable Function : NONE Directory : /lib/python2.7/site-packages/offlineimap/ |
�
��Vc @ s' d d l m Z m Z d d l m Z d d l Z d d l Z d d l m Z d d l Z d d l
m Z m Z m
Z
d d l
m Z d d l m Z d d l m Z d d l m Z y d d l Z Wn n Xd
� Z d � Z d � Z d
e j f d � � YZ d e f d � � YZ d � Z d S( i����( t Popent PIPE( t EventN( t exc_info( t mbnamest CustomConfigt OfflineImapError( t globals( t
Repository( t getglobalui( t InstanceLimitedThreadc C s
| j d � S( Nt Account( t getsectionlist( t customconfig( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt getaccountlist$ s c C s& g t | � D] } t | | � ^ q
S( sC Returns a list of instanciated Account class, one per account name.( R R ( R
t accountname( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt AccountListGenerator) s c C s1 i } x$ t | � D] } | | | j � <q W| S( sN Returns a dict of instanciated Account class with the account name as
key.( R t getname( R
t retvalt item( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt AccountHashGenerator0 s R c B s� e Z d Z e � Z e � Z d � Z d � Z d � Z d � Z d � Z
d � Z d � Z e
d � � Z d � Z d
� Z d � Z RS( s� Represents 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 C s� | | _ | | _ | j � | _ | j � | _ t � | _ | j d d � | _ | j j
d d � | _ d | _ | j d k r� d | _ n d S( s
: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.
t autorefreshg t generals dry-runi N( t configt namet getmetadatadirt metadatadirt getlocalevalt localevalR t uit getconffloatt
refreshperiodt
getbooleant dryrunt quicknumt None( t selfR R ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt __init__F s c C s | j S( N( R ( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyR \ s c C s | j S( N( R ( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt getconfig` s c C s | j S( N( R ( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyR c s c C s | j S( N( R ( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt __str__f s c C s t j j | j d | j � S( Ns Account-( t ost patht joinR R ( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt getaccountmetai s c C s d | j � S( Ns Account ( R ( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt
getsectionm s c C sy | d k r= xf t | � D] } | j d | d d � q Wn8 | d k rY | j j � n | d k ru | j j � n d S( sY Set 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.
i s Account t skipsleept 1i i N( R t sett abort_soon_signalt abort_NOW_signal( t clsR t signumt acctsection( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt set_abort_eventp s c C sY | j d d � } | r7 | j j | j � d d � n | pX t j j � pX t j j � S( sv Checks 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'.
R- i t 0( t getconfbooleanR R/ R, R R0 t is_setR1 ( R$ R- ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt get_abort_event� s
c C s� | j s
d Sg } t | d � r5 | j | j � n t | d � rW | j | j � n x | D] } | j � q^ Wt | j d � } | j j | | � } x | D] } | j � q� W| r� t
j j � s� t
j
j � r� d Sd | _ d Sd S( s� Sleep 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.
id t
localrepost remotereposi< i i i ( R t hasattrt appendR: R; t startkeepalivet intR t sleept
stopkeepaliveR R0 R8 R1 R" ( R$ t kaobjsR R t sleepresult( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt _sleeper� s(
c C sH t | d � } t | d � } | j j | d � | j j | d � d S( s1 Output diagnostics for all involved repositories.t remotet localt Remotet LocalN( R R t serverdiagnostics( R$ t remote_repot
local_repo( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyRI � s ( t __name__t
__module__t __doc__R R0 R1 R% R R& R R' R+ R, t classmethodR5 R9 RD RI ( ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyR : s $t SyncableAccountc B sM e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� A 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.c O sE t j | | | � d | _ t j j | j j � d | � | _ d S( Ns %s.lock(
R R% R# t _lockfdR( R) R* R R t
_lockfilepath( R$ t argst kwargs( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyR% � s c C s� t | j d � | _ y! t j | j t j t j B� WnT t k
rI nD t k
r� | j j � t
d | t
j j � d t � d � n Xd S( s@ Lock the account, throwing an exception if it is locked already.t wsB Could not lock account %s. Is another instance using this account?i N( t openRR RQ t fcntlt lockft LOCK_EXt LOCK_NBt NameErrort IOErrort closeR t ERRORt REPOR# R ( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt __lock� s !
c C sR | j rN | j j rN | j j � y t j | j � WqN t k
rJ qN Xn d S( s* Unlock the account, deleting the lock fileN( RQ t closedR] R( t unlinkRR t OSError( R$ ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt _unlock� s
c C s | j j | � yk | j � } t j j | � sD t j | d � n t | d � | _ t | d � | _ t | d � | _
WnI t k
r� } | j j | t
� d � | j t j j k r� � n d SXd } xL| r| j j | � z� y | j � | j � Wn� t t f k
r � n� t k
r�} | j t j j k rr| rT| d 8} n | j t j j k rr� qrn | j j | t
� d � nI t k
r�} | j j | t
� d d d | �n X| j r�d } n Wd | j j | � | j � | r| j � d k rd
} n Xq� Wd S( Ni� RE RF t statusi i i t msgs% While attempting to sync account '%s'i ( R t registerthreadR+ R( R) t existst mkdirR R; R: t statusreposR t errorR t severityR^ t CRITICALt acctt _SyncableAccount__lockt _SyncableAccount__synct KeyboardInterruptt
SystemExitR_ t ExceptionR t acctdoneRd RD ( R$ t accountmetadatat et looping( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt
syncrunner� sL
c C s4 | j j | j � j | j j � | j j � � � S( s? Return the corresponding local folder for a given remotefolder.( R: t getfoldert getvisiblenamet replaceR; t getsep( R$ t remotefolder( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt get_local_folder s c
C s� g } | j d d � } | j | � | j d d � } | d k rL t } n[ | d k r� | j d k sv | j | k r� d | _ t } q� | j d | _ t } n t } y�| j } | j } | j } | j � | j � | j
| | � | j d t � s| j j
| | � n x| j � D] } t j j � r7Pn | j sc| j j d d | | f � q n | j | � } | j s�| j j d d | | j f � q n t j j st d d | j j � d
t d d | j � | f d
| | | f � }
|
j � | j |
� q t | | | � q Wx | D] } | j � q)W| j sVt j! t � n | j" � | j" � Wn | j# � | j# � � n X| j$ � | j$ � | j d d � } | j | � d S( s� Synchronize 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.t presynchookt t quicki i t readonlys$ Not syncing filtered folder '%s'[%s]t instancenamet FOLDER_t targetR s Folder %s [acc: %s]RS t postsynchookN(% t getconft callhookt
getconfintt TrueR" t FalseR; R: Rj t
getfolderst sync_folder_structureR7 R t syncfoldersR R1 R8 t sync_thist debugR~ t
repositoryR t optionst singlethreadingR
R t
syncfoldert getexplainednamet startR= R* R! R t writet
forgetfolderst dropconnectionst holdordropconnections( R$ t
folderthreadst hookt quickconfigR� R; R: Rj R} t localfoldert threadt thr( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt __sync& sr
c C s� t j j � r d S| s d Sy� | j j d | � | j rA d St | d t d t d t d t d t �} | j � } | j j d | � | j j d | j
� WnL t t f k
r� � n3 t
k
r� } | j j | t � d d
d �n Xd S( Ns Calling hook: t shellt stdint stdoutt stderrt close_fdss Hook stdout: %s
Hook stderr:%s
s Hook return code: %di Rf s Calling hook( R R1 R8 R R� R! R R� R t communicatet
returncodeRq Rr Rs Rk R ( R$ t cmdt pt rRv ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyR� | s$ (
RL RM RN R% Ro Rd Rx R~ Rp R� ( ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyRP � s . Vc
sF � � f d � � d � � � � f d � } � f d � } | j } | j � | j } t � � � j | � z�y�| j | � } t j | j | j � � j
� � | j | j � j
| j � | j � � � � | j � d k r� � j � n � j � � j | | � | � | j � } | j � } | j � }
| d k | d k |
d k d k rt d t j j � d t � d � n | d k s�| s�|
r�| r�� j d � n | d k r�| | | | � n� | d k r�| | | | � � | | � � n� |
d k r*| | | |
� � | | � � nh | j � | rx| j � � rx| j � � rx� j | � � j � d Sn � | | � � | j � � j d
t � s�� j | | � | � | j! | � � n � j" d d � j � � | j d
t � s"� j � | | | � | j! | � � n � j" d
d | j � � � j# � � j � Wn� t$ t% f k
rm� n� t k
r�} | j& t j j' k r�� q � j( | t � d d d | | f �n? t) k
r�} � j( | d d | | j � t* j+ � f �n XWd x: d d d g D]) } | t, � k rt, � | j- � qqWXd S( s� Synchronizes given remote folder for the specified account.
Filtered folders on the remote side will not invoke this function.c s� | j � d k s$ | j � d k rx | j � sN � j | � | j j � d S| j � s� � j | � � j � d Sn | j � | j � d S( Ni ( t getmessagecountt check_uidvalidityt validityproblemR� t
restore_atimet save_uidvalidity( R� R} t statusfolder( R: R ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt check_uid_validity� s $
c S s@ | j � } t | d � } | j t | � d � | j � d S( Nt wts
( t get_min_uid_fileRV R� t strR] ( t foldert min_uidt uidfilet fd( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt save_min_uid� s c s� | j d | � � | | � � t d � | j � � } t | � d k rc | j d t | � � n& | j d t j t j | � d � � d S(
sC Returns messages with uid > min(uids of messages newer than date).t min_datec S s
| d k S( Ni ( ( t uid( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt <lambda>� s i R� i i< Ni� i�Q ( t cachemessagelistt filtert getmessageuidlistt lent mint timet gmtimet mktime( R� R} t datet
positive_uids( R� R� ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt cachemessagelists_upto_date� s c s� | j � | j � } | d k r� t | j � � d k rh t d | j j | j j f t j j � � q� | j d | � t
d � | j j � � } t | � d k r� t
| � } n d } � | | � n | j d | � d S( s� Retrieve 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.
i s> To use startdate on Repository %s, Repository %s must be emptyR� c S s
| d k S( Ni ( ( R� ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyR� � s i R� N( R� t retrieve_min_uidR# R� R� R R� R R^ t MESSAGER� t messagelistt keysR� ( t newt partialR� R� R� ( R� ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt cachemessagelists_startdate� s
i su You can set at most one of the following: maxage, startdate (for the local folder), startdate (for the remote folder)i sT Quick syncs (-q) not supported in conjunction with maxage or startdate; ignoring -q.NR� t imaps( Not syncing to read-only repository '%s'R� Rf s& Aborting sync, folder '%s' [acc: '%s']s( ERROR in syncfolder for %s folder %s: %sR� R� R} (. R; R: Rj R Rg R~ R t addR R t getlocalrootRy Rz R{ R| t get_uidvalidityR# t deletemessagelistR� t
syncingfoldert getmaxaget getstartdateR R^ R_ R t warnt quickchangedt skippingfolderR� R7 R� t syncingmessagest syncmessagestoR� t saveRq Rr Rl t FOLDERRk Rs t tracebackt
format_exct localst dropmessagelistcache(
t accountR} R� R� R� R; Rj R� t maxaget
localstartt remotestartRv R� ( ( R� R: R� R� R s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyR� � s� +
&
%( t
subprocessR R t threadingR R( R� t sysR R� t offlineimapR R R R t offlineimap.repositoryR t offlineimap.uiR t offlineimap.threadutilR
RW R R R t ConfigHelperMixinR RP R� ( ( ( s8 /usr/lib/python2.7/site-packages/offlineimap/accounts.pyt <module> s(
��