VSf 'dZddlmZddlmZddlmZmZddlm Z m Z m Z ddl m Z ddlmZddlmZmZmZdd lmZGd d ee j*Zy ) zHClasses for representing collections for the Google Cloud Firestore API.)gapic_v1) retry_async)BaseCollectionReference_item_to_document_ref) async_queryasync_documentasync_aggregation)DocumentReference) AsyncIterator)AnyAsyncGeneratorTuple) Transactionc >eZdZdZdfd Zdej fdZdejfdZ de fdZ de jjdfd ed ed ej&d edeeeff d Z dd edej2ffd Zde jjdfde d ej&d edeedffdZde jjdfded ej&d edefdZ de jjdfded ej&d ede!ejDfdZ#xZ$S)AsyncCollectionReferencea A reference to a collection in a Firestore database. The collection may already exist or this class can facilitate creation of documents within the collection. Args: path (Tuple[str, ...]): The components in the collection path. This is a series of strings representing each collection and sub-collection ID, as well as the document IDs for any documents that contain a sub-collection. kwargs (dict): The keyword arguments for the constructor. The only supported keyword is ``client`` and it must be a :class:`~google.cloud.firestore_v1.client.Client` if provided. It represents the client that created this collection reference. Raises: ValueError: if * the ``path`` is empty * there are an even number of elements * a collection ID in ``path`` is not a string * a document ID in ``path`` is not a string TypeError: If a keyword other than ``client`` is used. returnNc,tt| |i|yN)superr__init__)selfpathkwargs __class__s iC:\Users\user\Documents\project_loop\venv\Lib\site-packages\google/cloud/firestore_v1/async_collection.pyrz!AsyncCollectionReference.__init__=s &6GGc,tj|S)zeQuery factory. Returns: :class:`~google.cloud.firestore_v1.query.Query` )r AsyncQueryrs r_queryzAsyncCollectionReference._query@s %%d++rcHtj|jS)zAsyncAggregationQuery factory. Returns: :class:`~google.cloud.firestore_v1.async_aggregation.AsyncAggregationQuery )r AsyncAggregationQueryr rs r_aggregation_queryz+AsyncCollectionReference._aggregation_queryHs !66t{{}EEr chunk_sizecnK|jj|23d{}|7 6ywr)r _chunkify)rr$pages rr&z"AsyncCollectionReference._chunkifyPs4++-11*=  $J =s 5313535 document_data document_idretrytimeoutcK|j||||\}}|j|fi|d{}|j|fS7w)a Create a document in the Firestore database with the provided data. Args: document_data (dict): Property names and values to use for creating the document. document_id (Optional[str]): The document identifier within the current collection. If not provided, an ID will be automatically assigned by the server (the assigned ID will be a random 20 character string composed of digits, uppercase and lowercase letters). retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. Defaults to a system-specified policy. timeout (float): The timeout for this request. Defaults to a system-specified value. Returns: Tuple[:class:`google.protobuf.timestamp_pb2.Timestamp`, :class:`~google.cloud.firestore_v1.async_document.AsyncDocumentReference`]: Pair of * The ``update_time`` when the document was created/overwritten. * A document reference for the created document. Raises: :class:`google.cloud.exceptions.Conflict`: If ``document_id`` is provided and the document already exists. N) _prep_addcreate update_time)rr(r)r*r+ document_refr write_results raddzAsyncCollectionReference.addTs[D $~~       f 1\00I&II ''55Js.AAAc*tt| |S)aCreate a sub-document underneath the current collection. Args: document_id (Optional[str]): The document identifier within the current collection. If not provided, will default to a random 20 character string composed of digits, uppercase and lowercase and letters. Returns: :class:`~google.cloud.firestore_v1.document.async_document.AsyncDocumentReference`: The child document. )rrdocument)rr)rs rr4z!AsyncCollectionReference.documents-t=kJJr page_sizecK|j|||\}}|jjjd||jjd|d{}|23d{}t ||776yw)a`List all subdocuments of the current collection. Args: page_size (Optional[int]]): The maximum number of documents in each page of results from this request. Non-positive values are ignored. Defaults to a sensible value set by the API. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. Defaults to a system-specified policy. timeout (float): The timeout for this request. Defaults to a system-specified value. Returns: Sequence[:class:`~google.cloud.firestore_v1.collection.DocumentReference`]: iterator of subdocuments of the current collection. If the collection does not exist at the time of `snapshot`, the iterator will be empty )requestmetadataN)_prep_list_documents_client_firestore_apilist_documents _rpc_metadatar)rr5r*r+r7riteratoris rr=z'AsyncCollectionReference.list_documentss.33IugNC44CC \\//      1 1!'a0 0   1xs6AA?A9A? A=$A;%A=(A?;A==A? transactioncpK|j||\}}|jdd|i|d{S7w)aRead the documents in this collection. This sends a ``RunQuery`` RPC and returns a list of documents returned in the stream of ``RunQueryResponse`` messages. Args: transaction (Optional[:class:`~google.cloud.firestore_v1.transaction.Transaction`]): An existing transaction that this query will run in. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. Defaults to a system-specified policy. timeout (float): The timeout for this request. Defaults to a system-specified value. If a ``transaction`` is used and it already has write operations added, this method cannot be used (i.e. read-after-write is not allowed). Returns: list: The documents in this collection that match the query. rANr9)_prep_get_or_streamget)rrAr*r+queryrs rrDzAsyncCollectionReference.gets=600@ vUYYA;A&AAAAs -646cK|j||\}}|jdd|i|23d{}|7 6yw)a Read the documents in this collection. This sends a ``RunQuery`` RPC and then returns an iterator which consumes each document returned in the stream of ``RunQueryResponse`` messages. .. note:: The underlying stream of responses will time out after the ``max_rpc_timeout_millis`` value set in the GAPIC client configuration for the ``RunQuery`` API. Snapshots not consumed from the iterator before that point will be lost. If a ``transaction`` is used and it already has write operations added, this method cannot be used (i.e. read-after-write is not allowed). Args: transaction (Optional[:class:`~google.cloud.firestore_v1.transaction. Transaction`]): An existing transaction that the query will run in. retry (google.api_core.retry.Retry): Designation of what errors, if any, should be retried. Defaults to a system-specified policy. timeout (float): The timeout for this request. Defaults to a system-specified value. Yields: :class:`~google.cloud.firestore_v1.document.DocumentSnapshot`: The next document that fulfills the query. rANr9)rCstream)rrAr*r+rErds rrGzAsyncCollectionReference.streamsOH00@ v#u||F FvF  !G Fs*?=;=?=?)rNr)%__name__ __module__ __qualname____doc__rrrr r r"r#intr&rmethodDEFAULTdictstrretries AsyncRetryfloatrr r2rAsyncDocumentReferencer4r r r=rlistrDr DocumentSnapshotrG __classcell__)rs@rrr#s2H, ..,F$5$K$KF# $,OO$;$; )6)6)6!! )6  )6 sCx )6X"&KK  . .K&$,OO$;$; 11!!1 1 )4/ 0 1F$($,OO$;$; B B!!B B  BB$($,OO$;$; ' '!!' ' ~66 7 'rrN)rLgoogle.api_corerrrR)google.cloud.firestore_v1.base_collectionrrgoogle.cloud.firestore_v1rrr "google.cloud.firestore_v1.documentr typingr r r r%google.cloud.firestore_v1.transactionrrrr9rrr_sJO$2UT@ -->T6{7M7MNTr