a ù!fŸ-ã@s¸dZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z dZ e  e¡ZiZe ¡Zdd„Zd d „Zd d „ZGd d„deƒZdd„ZGdd„de jƒZdS)a’ Multiprocess file credential storage. This module provides file-based storage that supports multiple credentials and cross-thread and process access. This module supersedes the functionality previously found in `multistore_file`. This module provides :class:`MultiprocessFileStorage` which: * Is tied to a single credential via a user-specified key. This key can be used to distinguish between multiple users, client ids, and/or scopes. * Can be safely accessed and refreshed across threads and processes. Process & thread safety guarantees the following behavior: * If one thread or process refreshes a credential, subsequent refreshes from other processes will re-fetch the credentials from the file instead of performing an http request. * If two processes or threads attempt to refresh concurrently, only one will be able to acquire the lock and refresh, with the deadlock caveat below. * The interprocess lock will not deadlock, instead, the if a process can not acquire the interprocess lock within ``INTERPROCESS_LOCK_DEADLINE`` it will allow refreshing the credential but will not write the updated credential to disk, This logic happens during every lock cycle - if the credentials are refreshed again it will retry locking and writing as normal. Usage ===== Before using the storage, you need to decide how you want to key the credentials. A few common strategies include: * If you're storing credentials for multiple users in a single file, use a unique identifier for each user as the key. * If you're storing credentials for multiple client IDs in a single file, use the client ID as the key. * If you're storing multiple credentials for one user, use the scopes as the key. * If you have a complicated setup, use a compound key. For example, you can use a combination of the client ID and scopes as the key. Create an instance of :class:`MultiprocessFileStorage` for each credential you want to store, for example:: filename = 'credentials' key = '{}-{}'.format(client_id, user_id) storage = MultiprocessFileStorage(filename, key) To store the credentials:: storage.put(credentials) If you're going to continue to use the credentials after storing them, be sure to call :func:`set_store`:: credentials.set_store(storage) To retrieve the credentials:: storage.get(credentials) éN)Ú iteritems)Ú_helpers)ÚclientécCs6tj |¡rdSt|dƒ ¡t d |¡¡dSdS)zCreates the an empty file if it does not already exist. Returns: True if the file was created, False otherwise. Fza+bzCredential file {0} createdTN)ÚosÚpathÚexistsÚopenÚcloseÚloggerÚinfoÚformat©Úfilename©rúo/var/www/html/python-backend/venv/lib/python3.9/site-packages/oauth2client/contrib/multiprocess_file_storage.pyÚ_create_file_if_neededds  rc Cs¸z| d¡t |¡}Wn ty8t d¡iYS0| d¡dkrVt d¡iSi}t| di¡ƒD]H\}}z"t  |¡}t j   |¡}|||<Wqjt d  |¡¡Yqj0qj|S)a$Load credentials from the given file handle. The file is expected to be in this format: { "file_version": 2, "credentials": { "key": "base64 encoded json representation of credentials." } } This function will warn and return empty credentials instead of raising exceptions. Args: credentials_file: An open file handle. Returns: A dictionary mapping user-defined keys to an instance of :class:`oauth2client.client.Credentials`. rz@Credentials file could not be loaded, will ignore and overwrite.Ú file_versionéz=Credentials file is not version 2, will ignore and overwrite.Ú credentialsz)Invalid credential {0} in file, ignoring.)ÚseekÚjsonÚloadÚ Exceptionr ÚwarningÚgetrÚbase64Ú b64decoderÚ CredentialsZ new_from_jsonr )Úcredentials_fileÚdatarÚkeyÚencoded_credentialÚcredential_jsonÚ credentialrrrÚ_load_credentials_filess0  ÿ ÿ   ÿ r%cCshdidœ}t|ƒD]2\}}| ¡}t t t |¡¡¡}||d|<q| d¡t  ||¡|  ¡dS)a1Writes credentials to a file. Refer to :func:`_load_credentials_file` for the format. Args: credentials_file: An open file handle, must be read/write. credentials: A dictionary mapping user-defined keys to an instance of :class:`oauth2client.client.Credentials`. r)rrrrN) rÚto_jsonrZ _from_bytesrÚ b64encodeÚ _to_bytesrrÚdumpÚtruncate)rrr r!r$r#r"rrrÚ_write_credentials_file¦s ÿ  r+c@sXeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dS)Ú_MultiprocessStorageBackendaThread-local backend for multiprocess storage. Each process has only one instance of this backend per file. All threads share a single instance of this backend. This ensures that all threads use the same thread lock and process lock when accessing the file. cCs8d|_||_t d |¡¡|_t ¡|_d|_ i|_ dS)Nz{0}.lockF) Ú_fileÚ _filenameÚ fastenersZInterProcessLockr Ú _process_lockÚ threadingÚLockÚ _thread_lockÚ _read_onlyÚ _credentials)ÚselfrrrrÚ__init__Åsÿ z$_MultiprocessStorageBackend.__init__cCs.|js dSt|jƒ}|j |¡t d¡dS)z)(Re-)loads the credentials from the file.NzRead credential file)r-r%r5Úupdater Údebug)r6Zloaded_credentialsrrrÚ_load_credentialsÎs   z-_MultiprocessStorageBackend._load_credentialscCs8|jrt d¡dSt|j|jƒt d |j¡¡dS)Nz+In read-only mode, not writing credentials.zWrote credential file {0}.)r4r r9r+r-r5r r.©r6rrrÚ_write_credentialsØs  z._MultiprocessStorageBackend._write_credentialscCs||j ¡|jjtd}|rs&?    3g