a !f@s(dZGdddeZGdddeZdS)aUIterators for paging through API responses. These iterators simplify the process of paging through API responses where the response is a list of results with a ``nextPageToken``. To make an iterator work, just override the ``get_items_from_response`` method so that given a response (containing a page of results) it parses those results into an iterable of the actual objects you want:: class MyIterator(Iterator): def get_items_from_response(self, response): items = response.get('items', []) for item in items: my_item = MyItemClass(other_arg=True) my_item._set_properties(item) yield my_item You then can use this to get **all** the results from a resource:: >>> iterator = MyIterator(...) >>> list(iterator) # Convert to a list (consumes all values). Or you can walk your way through items and call off the search early if you find what you're looking for (resulting in possibly fewer requests):: >>> for item in MyIterator(...): >>> print item.name >>> if not item.is_valid: >>> break c@sXeZdZdZdZeegZdddZddZdd Z d d Z d d Z ddZ ddZ dS)IteratoraA generic class for iterating through Cloud JSON APIs list responses. :type client: :class:`gcloud.client.Client` :param client: The client, which owns a connection to make requests. :type path: string :param path: The path to query for the list of items. :type extra_params: dict or None :param extra_params: Extra query string parameters for the API call. Z pageTokenNcCsD||_||_d|_d|_|pi|_|j|j}|r@td|fdS)NzUsing a reserved parameter)clientpath page_numbernext_page_token extra_paramsRESERVED_PARAMS intersection ValueError)selfrrrZreserved_in_user P/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/iterator.py__init__@s zIterator.__init__ccs,|r(|}||D] }|VqqdS)z"Iterate through the list of items.N) has_next_pageget_next_page_responseget_items_from_response)r responseitemr r r __iter__LszIterator.__iter__cCs|jdkrdS|jduS)zDetermines whether or not this iterator has more pages. :rtype: boolean :returns: Whether the iterator has more pages or not. rTNrrr r r r rSs zIterator.has_next_pagecCs&|jr|j|jini}||j|S)zGetter for query parameters for the next request. :rtype: dict :returns: A dictionary of query parameters. )r PAGE_TOKENupdater)r resultr r r get_query_params^s  zIterator.get_query_paramscCsH|std|jjjd|j|d}|jd7_|d|_ |S)zRequests the next page from the path provided. :rtype: dict :returns: The parsed JSON response of the next page's contents. z*No more pages. Try resetting the iterator.GET)methodrZ query_paramsZ nextPageToken) r RuntimeErrorr connectionZ api_requestrrrgetrr rr r r ris  zIterator.get_next_page_responsecCsd|_d|_dS)z%Resets the iterator to the beginning.rNrrr r r resetzszIterator.resetcCstdS)aFactory method called while iterating. This should be overriden. This method should be overridden by a subclass. It should accept the API response of a request for the next page of items, and return a list (or other iterable) of items. Typically this method will construct a Bucket or a Blob from the page of results in the response. :type response: dict :param response: The response of asking for the next page of items. N)NotImplementedErrorr!r r r rs z Iterator.get_items_from_response)N)__name__ __module__ __qualname____doc__r frozensetrrrrrrr"rr r r r r0s     rc@s"eZdZdZdddZddZdS)MethodIteratoraMethod-based iterator iterating through Cloud JSON APIs list responses. :type method: instance method :param method: ``list_foo`` method of a domain object, taking as arguments ``page_token``, ``page_size``, and optional additional keyword arguments. :type page_token: string or ``NoneType`` :param page_token: Initial page token to pass. if ``None``, fetch the first page from the ``method`` API call. :type page_size: integer or ``NoneType`` :param page_size: Maximum number of items to return from the ``method`` API call; if ``None``, uses the default for the API. :type max_calls: integer or ``NoneType`` :param max_calls: Maximum number of times to make the ``method`` API call; if ``None``, applies no limit. :type kw: dict :param kw: optional keyword argments to be passed to ``method``. NcKs(||_||_||_||_||_d|_dS)Nr)_method_token _page_size_kw _max_calls _page_num)r r page_token page_sizeZ max_callskwr r r rs zMethodIterator.__init__ccsl|jdus|j|jkrh|jf|j|jd|j\}}|D] }|Vq:|durRdS|jd7_||_qdS)N)r0r1r)r.r/r*r+r,r-)r itemsZ new_tokenrr r r rs zMethodIterator.__iter__)NNN)r$r%r&r'rrr r r r r)s  r)N)r'objectrr)r r r r s!_