a $j%@sddlmZddlZddlZddlmZddlmZddlm Z Gddde Z Gd d d ej Z eGd d d ZeGd ddZeGdddZeGdddZdddddZddddddZd+ddddddd Zddd!d"d#d$d%Zd,dd&d&dd'd(d)d*ZdS)-) annotationsN) dataclass) T_JSON_DICT)storagecsBeZdZdZddddZedddddZfd d ZZS) CacheIdz&Unique identifier of the Cache object.strreturncCs|SNselfr r 9E:\soccer\ml_env\Lib\site-packages\mycdp/cache_storage.pyto_jsonszCacheId.to_jsonjsonr cCs||Sr r clsrr r r from_jsonszCacheId.from_jsoncsdtS)Nz CacheId({}))formatsuper__repr__r  __class__r rrszCacheId.__repr__) __name__ __module__ __qualname____doc__r classmethodrr __classcell__r r rrrs rc@sJeZdZdZdZdZdZdZdZdZ dd d d Z e ddd d dZ dS)CachedResponseTypezType of HTTP response cached.basicZcorsdefaulterrorZopaqueResponseZopaqueRedirectrr cCs|jSr )valuer r r rr'szCachedResponseType.to_jsonrcCs||Sr r rr r rr*szCachedResponseType.from_jsonN) rrrrZBASICZCORSDEFAULTERRORZOPAQUE_RESPONSEZOPAQUE_REDIRECTrrrr r r rr!sr!c@steZdZUdZded<ded<ded<ded<d ed <ded <d ed <ded<ddddZedddddZdS) DataEntryz Data entry.r request_urlrequest_methodtyping.List[Header]request_headersfloat response_timeintresponse_statusresponse_status_textr! response_typeresponse_headersrr cCsrt}|j|d<|j|d<dd|jD|d<|j|d<|j|d<|j|d<|j|d <d d|j D|d <|S) N requestURL requestMethodcSsg|] }|qSr r.0ir r r Gz%DataEntry.to_json..requestHeaders responseTimeresponseStatusresponseStatusText responseTypecSsg|] }|qSr r6r7r r rr:Lr;responseHeaders) dictr)r*r,r.r0r1r2rr3rrr r rrCs     zDataEntry.to_jsonrc Csr|t|dt|ddd|dDt|dt|dt|dt|d d d|d Dd S) Nr4r5cSsg|]}t|qSr Headerrr7r r rr:Tsz'DataEntry.from_json..r<r=r>r?r@cSsg|]}t|qSr rDr7r r rr:]srA)r)r*r,r.r0r1r2r3)rgetr-r/r!rrr r rrOs      zDataEntry.from_jsonNrrrr__annotations__rrrr r r rr(/s  r(c@s`eZdZUdZded<ded<ded<ded<dZd ed <d d d dZed ddddZdS)CachezCache identifier.rcache_idrsecurity_origin storage_key cache_nameN&typing.Optional[storage.StorageBucket]storage_bucketrr cCsNt}|j|d<|j|d<|j|d<|j|d<|jdurJ|j|d<|S)NcacheIdsecurityOrigin storageKey cacheName storageBucket)rBrJrrKrLrMrOrCr r rrqs    z Cache.to_jsonrc Cs^|t|dt|dt|dt|d|dddurVtj|dnddS)NrPrQrRrSrT)rJrKrLrMrO)rrrFrrZ StorageBucketrr r rr{s   zCache.from_json) rrrrrHrOrrrr r r rrIcs   rIc@s@eZdZUded<ded<ddddZedddd d Zd S) rErnamer%rr cCst}|j|d<|j|d<|S)NrUr%)rBrUr%rCr r rrs  zHeader.to_jsonrcCs |t|dt|ddS)NrUr%)rUr%rrFrr r rrs  zHeader.from_jsonN)rrrrHrrrr r r rrEs rEc@s<eZdZUdZded<ddddZedddd d Zd S) CachedResponsezCached response.rbodyrr cCst}|j|d<|S)NrX)rBrXrCr r rrs zCachedResponse.to_jsonrcCs|t|ddS)NrX)rXrVrr r rrs zCachedResponse.from_jsonNrGr r r rrWs rWz0typing.Generator[T_JSON_DICT, T_JSON_DICT, None])rJr ccs&t}||d<d|d}|V}dS)zI Deletes a cache. :param cache_id: Id of cache for deletion. rPzCacheStorage.deleteCachemethodparamsNrBr)rJr[cmd_dictrr r r delete_caches  r^r)rJrequestr ccs.t}||d<||d<d|d}|V}dS)z Deletes a cache entry. :param cache_id: Id of cache where the entry will be deleted. :param request: URL spec of the request. rPr_zCacheStorage.deleteEntryrYNr\)rJr_r[r]rr r r delete_entrys r`ztyping.Optional[str]rNz>typing.Generator[T_JSON_DICT, T_JSON_DICT, typing.List[Cache]])rKrLrOr ccs\t}|dur||d<|dur&||d<|dur:||d<d|d}|V}dd|d DS) a Requests cache names. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey, storageBucket must be specified. Security origin. :param storage_key: *(Optional)* Storage key. :param storage_bucket: *(Optional)* Storage bucket. If not specified, it uses the default bucket. :returns: Caches for the security origin. NrQrRrTzCacheStorage.requestCacheNamesrYcSsg|]}t|qSr )rIrr7r r rr:r;z'request_cache_names..cachesr\)rKrLrOr[r]rr r rrequest_cache_namess rbr+z:typing.Generator[T_JSON_DICT, T_JSON_DICT, CachedResponse])rJr)r,r ccsLt}||d<||d<dd|D|d<d|d}|V}t|dS) z Fetches cache entry. :param cache_id: Id of cache that contains the entry. :param request_url: URL spec of the request. :param request_headers: headers of the request. :returns: Response read from the cache. rPr4cSsg|] }|qSr r6r7r r rr:r;z+request_cached_response..r<z"CacheStorage.requestCachedResponserYresponse)rBrrWrrF)rJr)r,r[r]rr r rrequest_cached_responses  rdztyping.Optional[int]zWtyping.Generator[T_JSON_DICT, T_JSON_DICT, typing.Tuple[typing.List[DataEntry], float]])rJ skip_count page_size path_filterr ccsrt}||d<|dur"||d<|dur2||d<|durB||d<d|d}|V}dd |d Dt|d fS) a] Requests data from cache. :param cache_id: ID of cache to get entries from. :param skip_count: *(Optional)* Number of records to skip. :param page_size: *(Optional)* Number of records to fetch. :param path_filter: *(Optional)* If present, only return the entries containing this substring in the path :returns: A tuple with the following items: 0. **cacheDataEntries** - Array of object store data entries. 1. **returnCount** - Count of returned entries from this storage. If pathFilter is empty, it is the count of all entries from this storage. rPNZ skipCountZpageSizeZ pathFilterzCacheStorage.requestEntriesrYcSsg|]}t|qSr )r(rr7r r rr:(r;z#request_entries..ZcacheDataEntriesZ returnCount)rBrr-rF)rJrerfrgr[r]rr r rrequest_entriess  rh)NNN)NNN) __future__renumtyping dataclassesrutilrrrrEnumr!r(rIrErWr^r`rbrdrhr r r rs4    3&