⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.23
Server IP:
178.33.27.10
Server:
Linux cpanel.dev-unit.com 3.10.0-1160.108.1.el7.x86_64 #1 SMP Thu Jan 25 16:17:31 UTC 2024 x86_64
Server Software:
Apache/2.4.57 (Unix) OpenSSL/1.0.2k-fips
PHP Version:
8.2.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib
/
python2.7
/
site-packages
/
offlineimap
/
View File Name :
accounts.pyo
� ��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( ��