o
    0=j‹  ã                
   @  sÞ   U d Z ddlmZ ddlmZmZ ddlmZ ddlmZ z+ddl	m
Z
 ddlmZ eƒ  ¡ Ze
j ¡ D ]\ZZe d¡sFeevrFeeƒ e< q4W n eyY Z zed	ƒe‚d
Z[ww dZded< dddd„ZG dd„ dƒZd
S )zÚCloud Firestore Async module.

This module contains utilities for asynchronusly accessing the Google Cloud Firestore databases
associated with Firebase apps. This requires the ``google-cloud-firestore`` Python module.
é    )Úannotations)ÚOptionalÚDict)ÚApp)Ú_utils)Ú	firestore)ÚDEFAULT_DATABASEÚ_zrFailed to import the Cloud Firestore library for Python. Make sure to install the "google-cloud-firestore" module.NZ_firestore_asyncÚstrÚ_FIRESTORE_ASYNC_ATTRIBUTEÚappúOptional[App]Údatabase_idúOptional[str]Úreturnúfirestore.AsyncClientc                 C  s:   |durt |tƒstd|› d�ƒ‚t | tt¡}| |¡S )aP  Returns an async client that can be used to interact with Google Cloud Firestore.

    Args:
        app: An App instance (optional).
        database_id: The database ID of the Google Cloud Firestore database to be used.
            Defaults to the default Firestore database ID if not specified or an empty string
            (optional).

    Returns:
        google.cloud.firestore.Firestore_Async: A `Firestore Async Client`_.

    Raises:
        ValueError: If the specified database ID is not a valid string, or if a project ID is not
            specified either via options, credentials or environment variables, or if the specified
            project ID is not a valid string.

    .. _Firestore Async Client: https://cloud.google.com/python/docs/reference/firestore/latest/        google.cloud.firestore_v1.async_client.AsyncClient
    Nzdatabase_id "z" must be a string or None.)Ú
isinstancer
   Ú
ValueErrorr   Zget_app_servicer   Ú_FirestoreAsyncServiceÚ
get_client)r   r   Z
fs_service© r   úhC:\Users\psant\Downloads\Anu Raj Backend\school\venv\Lib\site-packages\firebase_admin/firestore_async.pyÚclient)   s   
r   c                   @  s$   e Zd ZdZddd„Zddd„ZdS )r   z?Service that maintains a collection of firestore async clients.r   r   r   ÚNonec                 C  s   || _ i | _d S )N)Ú_appÚ_clients)Úselfr   r   r   r   Ú__init__G   s   
z_FirestoreAsyncService.__init__r   r   r   c                 C  sV   |pt }|| jvr&| jj ¡ }| jj}|stdƒ‚tj|||d�}|| j|< | j| S )zKCreates an async client based on the database_id. These clients are cached.z²Project ID is required to access Firestore. Either set the projectId option, or use service account credentials. Alternatively, set the GOOGLE_CLOUD_PROJECT environment variable.)ÚcredentialsÚprojectZdatabaseN)	r   r   r   Z
credentialÚget_credentialZ
project_idr   r   ZAsyncClient)r   r   r   r   Z	fs_clientr   r   r   r   K   s   
ÿÿ

z!_FirestoreAsyncService.get_clientN)r   r   r   r   )r   r   r   r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   r   r   r   r   D   s    
r   )NN)r   r   r   r   r   r   )r$   Ú
__future__r   Útypingr   r   Zfirebase_adminr   r   Zgoogle.cloudr   Z%google.cloud.firestore_v1.base_clientr   ÚglobalsÚkeysÚexistingÚ__dict__ÚitemsÚkeyÚvalueÚ
startswithÚImportErrorÚerrorr   Ú__annotations__r   r   r   r   r   r   Ú<module>   s.   

€þÿ€ÿ