&g/ ddlZddlZddlZddlmcmZejeZ GddZ Gddej Z dS)Nc0eZdZdZdZdZdZdZdZdS)RefreshThreadManagerzD Organizes exactly one background job that refresh a token. cDd|_tj|_dS)zInitializes the manager.N)_worker threadingLock_lockselfs M/var/www/api/venv/lib/python3.11/site-packages/google/auth/_refresh_worker.py__init__zRefreshThreadManager.__init__s ^%% cx||tjd|j5|j|jj ddddS|j|jsAt |tj||_|j dddn #1swxYwYdS)auStarts a refresh thread for the given credentials. The credentials are refreshed using the request parameter. request and cred MUST not be None Returns True if a background refresh was kicked off. False otherwise. Args: cred: A credentials object. request: A request object. Returns: bool NzQUnable to start refresh. cred and request must be valid and instantiated objects.F)credrequestT) e InvalidValuer r _error_infois_alive RefreshThreadcopydeepcopystart)r rrs r start_refreshz"RefreshThreadManager.start_refresh#s <7?.c Z % %|'DL,D,P % % % % % % % %|#4<+@+@+B+B#,$ g@V@VWWW  ""$$$  % % % % % % % % % % % % % % %tsB/A!B//B36B3cl|j5|jr d|j_ddddS#1swxYwYdS)zU Removes any errors that were stored from previous background refreshes. N)r rrr s r clear_errorz RefreshThreadManager.clear_error>sZ 0 0| 0+/ ( 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s )--cB|j}d|d<|S)z2Pickle helper that serializes the _lock attribute.Nr )__dict__rr states r __getstate__z!RefreshThreadManager.__getstate__Fs# ""$$g rcftj|d<|j|dS)z4Pickle helper that deserializes the _lock attribute.r N)rrrupdaters r __setstate__z!RefreshThreadManager.__setstate__Ls/"))g U#####rN) __name__ __module__ __qualname____doc__r rrr!r$rr rrsi&&& 6000 $$$$$rrc(eZdZdZfdZdZxZS)rz, Thread that refreshes credentials. c dtjdi|||_||_d|_dS)zInitializes the thread. Args: cred: A Credential object to refresh. request: A Request object used to perform a credential refresh. **kwargs: Additional keyword arguments. Nr))superr _cred_requestr)r rrkwargs __class__s r r zRefreshThread.__init__Ws> ""6"""  rc |j|jdS#t$r/}td|||_Yd}~dSd}~wwxYw)z1 Perform the credential refresh. z"Background refresh failed due to: N)r-refreshr. Exception_LOGGERerrorr)r errs r runzRefreshThread.runesy # J  t} - - - - - # # # MMDsDD E E E"D        #s# A$AA)r%r&r'r(r r7 __classcell__)r0s@r rrRsQ      #######rr) rloggingrgoogle.auth.exceptionsauth exceptionsr getLoggerr%r4rThreadrr)rr r?s """"""""" ' H % %7$7$7$7$7$7$7$7$t#####I$#####r