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 @ sn d d l m Z m Z m Z m Z m Z d d l Z d d l Z d d l Z d d l Z d d l
Z
d d l Z d d l Z d d l Z d d l
m Z d d l m Z d d l m Z m Z d d l m Z m Z m Z m Z d d l Z d d l m Z y1 e Z d d l Z d e e � k r,e Z n Wn e k
r@n Xd f d
� � YZ! d e" f d � � YZ# d S(
i����( t Lockt BoundedSemaphoret Threadt Eventt
currentThreadN( t exc_info( t gaierror( t SSLErrort cert_time_to_seconds( t imaplibutilt imaputilt
threadutilt OfflineImapError( t getglobaluit authGSSClientWrapt
IMAPServerc B s� e Z d Z d Z d Z d � Z d � Z d � Z e d � Z d � Z
d � Z d � Z d
� Z
d � Z d � Z d
� Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s" Initializes all variables from an IMAPRepository() instance
Various functions, such as acquireconnection() return an IMAP4
object on which we can operate.
Public instance variables are: self.:
delim The server's folder delimiter. Only valid after acquireconnection()
i i c C s" t � | _ | | _ | j � | _ | j � | _ | j � | _ | j rt | j rt t d | d t j
j � � n | j r� | j n | j | _ | j r� d n | j � | _ | j � | _ | j � | _ d | _ d | _ d | _ | j � | _ | j � | _ | j t k r%t j | _ n* | j t k rCt j | _ n t j! | _ | j r^d n | j" � | _# | j$ � | _% | j% d k r�| j r�d n d | _% n | j& � | _' | j( � | _) | j* � | _+ | j+ d k r�d | _, n | j- � | _. | j/ � | _0 | j1 � | _2 | j3 � | _4 | j5 � | _6 | j7 � | _8 | j9 � | _: | j; � | _< d | _= d | _> | j? � | _@ g | _A g | _B i | _C tD | j@ � | _E tF � | _G | jH � | _I | jJ � | _K | jL | _M d | _N t | _O d | j jP jQ } | j jR | d � s3t j | _S n� | j jT | d � } y\ d d lU } | jV d � \ } } } tW | � } | jX tY | | � | | � | jZ | _S Wnw t[ k
r�| j j\ d � t j | _S nK t] t^ f k
r } | j j\ d
| | j jP jQ | f � t j | _S n Xd S( Ns %s: sM you must enable precisely one type of tunnel (preauth or transport), not bothi� i� s Account t proxyi����t :s- PySocks not installed, ignoring proxy option.s= Bad proxy option %s for account %s: %s Ignoring proxy option.(_ R
t uit repost getconfigt configt getpreauthtunnelt preauth_tunnelt gettransporttunnelt transport_tunnelR t ERRORt REPOt tunnelt Nonet getusert usernamet get_remote_identityt
user_identityt get_auth_mechanismst authmechst passwordt
passworderrort goodpasswordt getsslt usesslt getipv6t useipv6t Truet sockett AF_INET6t aft Falset AF_INETt AF_UNSPECt gethostt hostnamet getportt portt getsslclientcertt
sslclientcertt getsslclientkeyt sslclientkeyt getsslcacertfilet
sslcacertfilet _IMAPServer__verifycertt get_ssl_fingerprintt fingerprintt
getsslversiont
sslversiont gettlslevelt tlslevelt getoauth2_refresh_tokent oauth2_refresh_tokent getoauth2_access_tokent oauth2_access_tokent getoauth2_client_idt oauth2_client_idt getoauth2_client_secrett oauth2_client_secrett getoauth2_request_urlt oauth2_request_urlt delimt roott getmaxconnectionst maxconnectionst availableconnectionst assignedconnectionst lastownerR t semaphoreR t connectionlockt getreferencet referencet getidlefolderst idlefolderst GSS_STATE_STEPt gss_stept gss_vct gssapit accountt namet
has_optiont proxied_sockett gett sockst splitt intt setdefaultproxyt getattrt
socksockett ImportErrort warnt AttributeErrort
ValueError( t selfR t _account_sectionR Rc t
proxy_typet hostR5 t e( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __init__; s�
c C s� | j d k r | j S| j d k r; | j d k r; | j S| j j � pn | j j | j j � | j | j � | _ d | _ | j S( s# Returns the server password or NoneN(
R& R R$ R% R t getpasswordR t getpasst getnameR ( Rm ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt
__getpassword� s c C s | j S( sk Returns this server's folder root. Can only be called after one
or more calls to acquireconnection.( RN ( Rm ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt getroot� s c C sw | d k r d S| j j � | j j | � | j s< | rI | j � n | j j | � | j j � | j
j � d S( s� Releases a connection, returning it to the pool.
:param drop_conn: If True, the connection will be released and
not be reused. This can be used to indicate broken connections.N( R RU t acquireRR t removet Terminatet logoutRQ t appendt releaseRT ( Rm t
connectiont drop_conn( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt releaseconnection� s
c C sm | j � } | j j d d | � | j � } | j d t j | | � j � } | j j d d | � | S( Nt imaps __md5handler: got challenge %st s __md5handler: returning %s( t stripR t debugt _IMAPServer__getpasswordR t hmact newt hexdigest( Rm t responset challenget passwdt retval( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __md5handler� s #c C s0 | j j d d � | j | j | j � � d S( s( Basic authentication via LOGIN command.R� s$ Attempting IMAP LOGIN authenticationN( R R� t loginR R� ( Rm t imapobj( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __loginauth� s c C s� | j } | j � } d } | j d k r6 | j } n d } | j | | | f � j d � } | j | | d f � j d � } | j j d d | � | S( s\ Implements SASL PLAIN authentication, RFC 4616,
http://tools.ietf.org/html/rfc4616t u s utf-8s (passwd hidden for log)R� s __plainhandler: returning %sN( R R� R! R t joint encodeR R� ( Rm R� t authcR� t authzt NULLR� t logsafe_retval( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __plainhandler� s !!c C sd | j d k r" | j d k r" d S| j d k ri } | j | d <| j | d <| j | d <d | d <| j j d d | j � | j j d d | � t j } | j t _ z( t
j | j t
j | � � j
� } Wd | t _ Xt j | � } | j j d d | � | d | _ n | j j d d
| j � d | j | j f } | j j d d | � | S(
Nt client_idt
client_secrett
refresh_tokent
grant_typeR� s xoauth2handler: url "%s"s xoauth2handler: params "%s"s xoauth2handler: response "%s"t access_tokens! xoauth2handler: access_token "%s"s user=%sauth=Bearer %ss xoauth2handler: returning "%s"( RD R RF RH RJ R R� RL R, Ra t urllibt urlopent urlencodet readt jsont loadsR ( Rm R� t paramst original_sockett respt auth_string( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __xoauth2handler� s,
(
c C sd t j | � } y� | j | j k r� | j sa t j d | j � \ } | _ t j | j � } n t j | j | � } | t j
k r� | j | _ q� nW | j | j k r� t j | j | � } t j | j � } t j
| j | | j � } n t j | j � } WnD t j k
rG} | j j d d | d d | d d f � d SX| sWd } n t j | � S( Ns imap@R� s %s: %si i R� ( t base64t b64encodeR[ RZ R\ t kerberost authGSSClientInitR3 t authGSSClientResponset authGSSClientStept AUTH_GSS_CONTINUEt GSS_STATE_WRAPt authGSSClientUnwrapR R t GSSErrorR R� R t b64decode( Rm R� t datat rct err( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __gssauth� s, - c C s� d | j k r� | j r� | j j d d � y | j � Wq� | j k
r~ } t d t | � t j j d t � d � � q� Xn d S( Nt STARTTLSR� s Using STARTTLS connections" Failed to start TLS connection: %si ( t capabilitiesR( R R� t starttlst errorR t strR R R R ( Rm R� Rq ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __start_tls s
c C s� t s
t S| j j � zr y | j d | j � t SWn" | j k
rY } t | _ � n/ Xt | _ t j
| j � d | _ | j
| _ Wd | j j � Xd S( Nt GSSAPI( t have_gssR/ RU Rx t authenticatet _IMAPServer__gssauthR+ R� R] R� t authGSSClientCleanR\ R RZ R[ R} ( Rm R� Rq ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __authn_gssapi7 s
c C s | j d | j � t S( Ns CRAM-MD5( R� t _IMAPServer__md5handlerR+ ( Rm R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __authn_cram_md5J s c C s | j d | j � t S( Nt PLAIN( R� t _IMAPServer__plainhandlerR+ ( Rm R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt
__authn_plainN s c C s | j d | j � t S( Nt XOAUTH2( R� t _IMAPServer__xoauth2handlerR+ ( Rm R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __authn_xoauth2R s c C s< d | j k r' t d t j j � � n | j | � t Sd S( Nt
LOGINDISABLEDs3 IMAP LOGIN is disabled by server. Need to use SSL?( R� R R R t _IMAPServer__loginauthR+ ( Rm R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt
__authn_loginV s
c C sb i | j t t f d 6| j t t f d 6| j t t f d 6| j t t f d 6| j t t f d 6} g } t } t } | j } d | k r� | j d � | j d d � n x| D] } | | k r� t
d | � � n | | \ } } }
| r| rt } | j | � n |
r6d | } | | j k r6q� q6n t } | j
j d d
| � y | | � rfd SWq� | j t f k
r�} | j
j d | | f � | j | | f � q� Xq� Wt | � r�d
j t d � | � � }
t d |
t j j � � n | s^d j t d � t d � | j � � � } t d | j d j | j � | f t j j � � n d S( sg Authentication machinery for self.acquireconnection().
Raises OfflineImapError() of type ERROR.REPO when
there are either fatal problems or no authentications
succeeded.
If any authentication method succeeds, routine should exit:
warnings for failed methods are to be produced in the
respective except blocks.R� s CRAM-MD5R� R� t LOGINi s: Bad authentication method %s, please, file OfflineIMAP bugs AUTH=R� u Attempting %s authenticationNs %s authentication failed: %ss
c S s! d j | d t | d � f � S( Ns : i i ( R� R� ( t x( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt <lambda>� s s$ All authentication types failed:
%ss , c S s | d S( Ni ( ( R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR� � s c S s | d d !d k S( Ni i s AUTH=( ( R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR� � s u` Repository %s: no supported authentication mechanisms found; configured %s, server advertises %s( t _IMAPServer__authn_gssapiR/ R+ t _IMAPServer__authn_cram_md5t _IMAPServer__authn_xoauth2t _IMAPServer__authn_plaint _IMAPServer__authn_loginR# Ry t insertt Exceptiont _IMAPServer__start_tlsR� R R� R� R Rj R| t lenR� t mapR R t filterR ( Rm R� t auth_methodst exc_stackt tried_to_authnt tried_tlst mechst mt funct tryTLSt check_capt capRq t msgt methods( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __authn_helperb s`
c
C s� | j j � | j j � t � } d } t | j � r� d } x^ t t | j � d d d � D]= } | j | } | j | | j k r^ | } | j | =Pq^ q^ W| s� | j d } | j d =n | j
j | � | j | j | <| j j � | S| j j � d } y/x�| s�| j
r^| j j d | j
� t j | j
d t j � d | j �} d } n� | j r�| j j | j | j � t j | j | j | j | j | j | j | j d t j � d | j d | j d | j d | j �} nO | j j | j | j � t j! | j | j d t j � d | j d | j �} | j" s y# | j# | � | j$ | _% d } Wq�t& k
r�} t' | � | _( � q�Xq q W| j) j* d
d � r�| j+ � n | j, � \ } } | d g k r�t- | d j. � j/ � � | _0 n | j1 d k r�| j2 | j3 d � d } | d g k s;| d k rW| j2 | j3 d � d } n | d g k sr| d k r�d
| j) j4 � | j3 f }
| j j5 |
� t6 |
� � n t7 j8 | d � d \ | _1 | _9 t7 j: | j1 � | _1 t7 j: | j9 � | _9 n | j �% | j
j | � | j | j | <Wd QX| SWn�t6 k
r�} | j j � t& j; j< } t= | � t> k r�d | j | j) f } t& | | � d t? � d � n� t@ | tA � r%| jB tB jC k r%| j d k r�d | j | j f } n d | j | j) | f } t& | | � d t? � d � nc t@ | t jD � r�| jE d tB jF k r�d | j | j | j) f } t& | | � d t? � d � n t' | � d d k r�t& d | j | j) f t& j; j< � d t? � d � q�� n Xd S( s� Fetches a connection from the pool, making sure to create a new one
if needed, to obey the maximum connection limits, etc.
Opens a connection to the server and returns an appropriate
object.i i����i R t timeoutt
use_socketR> t tls_levelR. t usecompressions ""s "*"s' Server '%s' returned no folders in '%s'Ns� Could not resolve name '%s' for repository '%s'. Make sure you have configured the server name correctly and that you are online.i i� sz Could not connect via SSL to host '%s' and non-standard ssl port %d configured. Make sure you connect to the correct port.sW Unknown SSL protocol connecting to host '%s' for repository '%s'. OpenSSL responded:
%ss� Connection to host '%s:%d' for repository '%s' was refused. Make sure you have the right host and port configured and that you are actually able to access the network.i s can't open socket; errorsT Could not connect to remote server '%s' for repository '%s'. Remote does not answer.(G RT Rx RU R R R� RQ t rangeRS t identRR R| R} R R t
connectingR t IMAP4_TunnelR, t getdefaulttimeoutRa R( R3 R5 t WrappedIMAP4_SSLR9 R7 R; R< R@ R> RB R. t WrappedIMAP4R t _IMAPServer__authn_helperR$ R& R R� R% R t getconfbooleant enable_compressiont
capabilityt tuplet upperRd R� RM t listRW Ru Rj R� R
t imapsplitRN t dequoteR R t typeR R t
isinstanceR t errnot EPERMR� t argst ECONNREFUSED(
Rm t curThreadR� t it tryobjt successRq t typt datt listresR� t severityt reason( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt acquireconnection� s�
&
" #
! ( c C s | j j � | j j � d S( s� Waits until there is a connection available.
Note that between the time that a connection becomes available and the
time it is requested, another thread may have grabbed it. This function
is mainly present as a way to avoid spawning thousands of threads to
copy messages, then have them all wait for 3 available connections.
It's OK if we have maxconnections + 1 or 2 threads, which is what this
will help us do.N( RT Rx R} ( Rm ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt connectionwaitW s
c C s� | j �y t j | j | j � x" | j | j D] } | j � q1 Wg | _ g | _ i | _ | j | _
d | _ t
| _ Wd QXd S( N( RU R t semaphoreresetRT RP RR RQ R{ RS RZ R[ R R\ R/ R] ( Rm R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt closed s
c C si | j j d d � x<| j � sQ| j j � t | j � t | j � } | j j � g } x� t | � D]t } | j j d d | | f � t | j
� | k r� t | | j
| � } n t | � } | j � | j
| � qk W| j j d d � | j | � | j j d d � x" | D] } | j � | j � q W| j j d d � q W| j j d d � d S( s; Sends a NOOP to each connection recorded.
It will wait a maximum of timeout seconds between doing this, and will
continue to do so until the Event object as passed is true. This method
is expected to be invoked in a separate thread, which should be join()'d
after the event is set.R� s keepalive thread starteds) keepalive: processing connection %d of %ds keepalive: waiting for timeouts keepalive: after waits keepalive: all threads joineds keepalive: event is set; exitingN( R R� t isSetRU Rx R� RR RQ R} R� RY t
IdleThreadt startR| t waitt stopR� ( Rm R� t eventt numconnectionst threadsR t idler( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt keepalivew s.
c C sg d } | s d | S| j � } g } | j d � } | rd t j � t | � k rd d | | f Sn xL | j d g � D]8 } | d \ } } | d k rw | j | j � � qw qw Wt | � d k r� d | SxB | j d g � D]. \ } } | d
k r� | j | j � � q� q� WxJ | D]B }
|
| k sWd | k r|
d | j d d
� d
k rd SqWd | S( s� Verify that cert (in socket.getpeercert() format) matches hostname.
CRLs are not handled.
Returns error message if any problems are found and None on success.s CA Cert verifying failed: s %s no certificate receivedt notAfters %s certificate expired %st subjecti t
commonNames% %s no commonName found in certificatet subjectAltNamet DNSt .s *.i s/ %s no matching domain name found in certificateN( t lowerRb t timeR R| R� Rd R ( Rm t certR3 t errstrt dnsnamet certnamest notaftert st keyt valuet certname( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __verifycert� s.
,( t __name__t
__module__t __doc__RZ R� Rr R� Rw R/ R� R� R� R� R� R� R� R� R� R� R� R� R� R
R R R R< ( ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR / s0 [ ! T �
'R c B sJ e Z d d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C sw | | _ | | _ t � | _ t � | _ | d k rN t d | j � | _ n t d | j
� | _ | j j d � d S( s� If invoked without 'folder', perform a NOOP and wait for
self.stop() to be called. If invoked with folder, switch to IDLE
mode and synchronize once we have a new messaget targeti N( t parentt folderR t stop_sigR
R R R t noopt threadt _IdleThread__idlet setDaemon( Rm R1 R2 ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyRr � s c C s | j j � d S( N( R5 R ( Rm ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR � s c C s | j j � d S( N( R3 t set( Rm ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR � s c C s | j j � d S( N( R5 R� ( Rm ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR� � s c C s� | j j � } zY y | j � WnD | j k
rf | j j d | j � | j j | t � d } n XWd | r� | j j | � | j
j � n Xd S( Ns( Attempting NOOP on dropped connection %s( R1 R
R4 t abortR Rj t
identifierR� R+ R R3 R ( Rm R� ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR4 � s c C s� | j j } | j } | j } | j } | j } | j | j � } | j d d � } | j | � t
j j | | d t
�| j d d � } | j | � t � } | j t � � d S( Nt presynchookR� t quickt postsynchook( R1 R R^ t
localrepost remoterepost statusrepost getfolderR2 t getconft callhookt offlineimapt accountst
syncfolderR/ R
t unregisterthreadR ( Rm R? R^ R> R@ t remotefoldert hookR ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __dosync� s
c s� � f d � } x�� j j � s�t � _ t } x� | s� � j j � } y | j � j � Wn� t k
r� } | j t j
j k r� � j j
| t � d � � j j | t � q� | j t j
j k r� � j j
| t � d � q� � q3 Xt } q3 Wd | j k r| j d | � n! � j j d | j � | j � � j j � y | j � Wn> | j k
r�� j j d | j � � j j | t � n X� j j | � � j r � j j � � j � q q Wd S( s9 Invoke IDLE mode until timeout or self.stop() is invoked.c sH | \ } } } | d k r7 � j j � r7 t � _ n � j j � d S( s IDLE callback function invoked by imaplib2.
This is invoked when a) The IMAP server tells us something
while in IDLE mode, b) we get an Exception (e.g. on dropped
connections, or c) the standard imaplib IDLE timeout of 29
minutes kicks in.N( R R3 R R+ t needsyncR8 ( R t resultt cb_argt exc_data( Rm ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt callback s i t IDLERO sF IMAP IDLE not supported on server '%s'.Sleep until next refresh cycle.s( Attempting NOOP on dropped connection %sN( R3 R R/ RK R1 R
t selectR2 R R R t FOLDER_RETRYR R� R R� R+ t FOLDERR� t idleRj R: R4 R R9 t cleart _IdleThread__dosync( Rm RO R R� Rq ( ( Rm s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt __idle s@
N(
R- R. R Rr R R R� R4 RV R6 ( ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyR � s ($ t threadingR R R R R R� R, R� R� R� R" R t sysR R t sslR R RD R R
R R t offlineimap.accountst offlineimap.uiR
R/ R� R� t dirR+ Ri R t objectR ( ( ( s: /usr/lib/python2.7/site-packages/offlineimap/imapserver.pyt <module> s2 ( "
� � �