a $j%I @sddlmZddlZddlmZddlmZddlmZddlm Z eGdd d Z eGd d d Z eGd d d Z eGdddZ eGdddZeGdddZeGdddZd8dddddddddZd9ddddddddZd:dddddddd d!d"Zdd#d$d%Zdd#d&d'Zd;dddd(d(dddd)d*d+ d,d-Zddddd4d5d6d7ZdS)?) annotationsN) dataclass) T_JSON_DICT)runtime)storagec@sLeZdZUdZded<ded<ded<dd d d Zeddd d dZdS)DatabaseWithObjectStoresz(Database with an array of object stores.strnamefloatversionztyping.List[ObjectStore] object_storesrreturncCs2t}|j|d<|j|d<dd|jD|d<|S)Nr r cSsg|] }|qSto_json.0irr6E:\soccer\ml_env\Lib\site-packages\mycdp/indexed_db.py z4DatabaseWithObjectStores.to_json.. objectStores)dictr r r selfjsonrrrrs   z DatabaseWithObjectStores.to_jsonrrcCs0|t|dt|ddd|dDdS)Nr r cSsg|]}t|qSr) ObjectStore from_jsonrrrrr'sz6DatabaseWithObjectStores.from_json..r)r r r r getr clsrrrrr "s  z"DatabaseWithObjectStores.from_jsonN__name__ __module__ __qualname____doc____annotations__r classmethodr rrrrrs rc@sTeZdZUdZded<ded<ded<ded <d d d d Zed ddddZdS)rz Object store.r r KeyPathkey_pathboolauto_incrementztyping.List[ObjectStoreIndex]indexesrrcCs@t}|j|d<|j|d<|j|d<dd|jD|d<|S)Nr keyPath autoIncrementcSsg|] }|qSrrrrrrr>rz'ObjectStore.to_json..r0)rr r-rr/r0rrrrr9s   zObjectStore.to_jsonrcCs>|t|dt|dt|ddd|dDdS)Nr r1r2cSsg|]}t|qSr)ObjectStoreIndexr rrrrrGrz)ObjectStore.from_json..r0)r r-r/r0r r"r,r r.r#rrrr As   zObjectStore.from_jsonNr%rrrrr-s rc@sTeZdZUdZded<ded<ded<ded<d d d d Zed dd ddZdS)r3zObject store index.r r r,r-r.unique multi_entryrrcCs6t}|j|d<|j|d<|j|d<|j|d<|S)Nr r1r5 multiEntry)rr r-rr5r6rrrrrWs    zObjectStoreIndex.to_jsonrcCs:|t|dt|dt|dt|ddS)Nr r1r5r7)r r-r5r6r4r#rrrr _s    zObjectStoreIndex.from_jsonNr%rrrrr3Ks r3c@sleZdZUdZded<dZded<dZded<dZded <dZd ed <d d ddZ e d ddddZ dS)KeyzKey.r type_Nztyping.Optional[float]numbertyping.Optional[str]stringdatez!typing.Optional[typing.List[Key]]arrayrrcCsnt}|j|d<|jdur$|j|d<|jdur8|j|d<|jdurL|j|d<|jdurjdd|jD|d<|S)Ntyper:r<r=cSsg|] }|qSrrrrrrrrzKey.to_json..r>)rr9r:r<r=r>rrrrrws        z Key.to_jsonrc Cs|t|d|dddur,t|dnd|dddurLt|dnd|dddurlt|dnd|dddurdd|dDnddS) Nr?r:r<r=r>cSsg|]}t|qSr)r8r rrrrrrz!Key.from_json..)r9r:r<r=r>r!r#rrrr s z Key.from_json) r&r'r(r)r*r:r<r=r>rr+r rrrrr8is      r8c@s\eZdZUdZded<ded<dZded<dZded<d d d d Zed dd ddZ dS)KeyRangez Key range.r. lower_open upper_openNztyping.Optional[Key]lowerupperrrcCsNt}|j|d<|j|d<|jdur2|j|d<|jdurJ|j|d<|S)N lowerOpen upperOpenrCrD)rrArBrCrrDrrrrrs    zKeyRange.to_jsonrc Csd|t|dt|d|dddur:t|dnd|dddur\t|dnddS)NrErFrCrD)rArBrCrD)r.r"r8r r#rrrr s  zKeyRange.from_json) r&r'r(r)r*rCrDrr+r rrrrr@s    r@c@sLeZdZUdZded<ded<ded<dddd Zeddd d d Zd S) DataEntryz Data entry.zruntime.RemoteObjectkey primary_keyvaluerrcCs4t}|j|d<|j|d<|j|d<|S)NrH primaryKeyrJ)rrHrrIrJrrrrrs zDataEntry.to_jsonrcCs8|tj|dtj|dtj|ddS)NrHrKrJ)rHrIrJ)rZ RemoteObjectr r"r#rrrr s zDataEntry.from_jsonNr%rrrrrGs rGc@sTeZdZUdZded<dZded<dZded<d d d d Zed dd ddZ dS)r,z Key path.r r9Nr;r<z!typing.Optional[typing.List[str]]r>rrcCsFt}|j|d<|jdur$|j|d<|jdurBdd|jD|d<|S)Nr?r<cSsg|]}|qSrrrrrrrrz#KeyPath.to_json..r>)rr9r<r>rrrrrs    zKeyPath.to_jsonrcCsX|t|d|dddur,t|dnd|dddurPdd|dDnddS)Nr?r<r>cSsg|] }t|qSrr rrrrrrz%KeyPath.from_json..)r9r<r>)r r"r#rrrr s zKeyPath.from_json) r&r'r(r)r*r<r>rr+r rrrrr,s    r,r r;z&typing.Optional[storage.StorageBucket]z0typing.Generator[T_JSON_DICT, T_JSON_DICT, None]) database_nameobject_store_namesecurity_origin storage_keystorage_bucketrccs^t}|dur||d<|dur&||d<|dur:||d<||d<||d<d|d}|V}dS) a Clears all entries from an object store. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey, or 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. :param database_name: Database name. :param object_store_name: Object store name. NsecurityOrigin storageKey storageBucket databaseNameobjectStoreNamezIndexedDB.clearObjectStoremethodparamsrrrMrNrOrPrQrYcmd_dictrrrrclear_object_stores r])rMrOrPrQrccsVt}|dur||d<|dur&||d<|dur:||d<||d<d|d}|V}dS)a Deletes a database. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey, or 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. :param database_name: Database name. NrRrSrTrUzIndexedDB.deleteDatabaserWrZrMrOrPrQrYr\rrrrdelete_database's r_)rMrN key_rangerOrPrQrc csjt}|dur||d<|dur&||d<|dur:||d<||d<||d<||d<d|d }|V}dS) a Delete a range of entries from an object store :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey, or 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. :param database_name: :param object_store_name: :param key_range: Range of entry keys to delete NrRrSrTrUrVkeyRangez"IndexedDB.deleteObjectStoreEntriesrWrZ) rMrNr`rOrPrQrYr\rrrrdelete_object_store_entriesFs  rbrccsddi}|V}dS)zDisables events from backend.rXzIndexedDB.disableNrr\rrrrdisableksrdccsddi}|V}dS)zEnables events from backend.rXzIndexedDB.enableNrrcrrrenablessreintztyping.Optional[KeyRange]zVtyping.Generator[T_JSON_DICT, T_JSON_DICT, typing.Tuple[typing.List[DataEntry], bool]]) rMrN index_name skip_count page_sizerOrPrQr`rc cst} |dur|| d<|dur&|| d<|dur:|| d<|| d<|| d<|| d<|| d<|| d <|durv|| d <d | d } | V} d d| dDt| dfS)a Requests data from object store or index. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey, or 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. :param database_name: Database name. :param object_store_name: Object store name. :param index_name: Index name, empty string for object store data requests. :param skip_count: Number of records to skip. :param page_size: Number of records to fetch. :param key_range: *(Optional)* Key range. :returns: A tuple with the following items: 0. **objectStoreDataEntries** - Array of object store data entries. 1. **hasMore** - If true, there are more entries to fetch in the given range. NrRrSrTrUrVZ indexNameZ skipCountZpageSizerazIndexedDB.requestDatarWcSsg|]}t|qSr)rGr rrrrrrz request_data..ZobjectStoreDataEntriesZhasMore)rrr.r") rMrNrgrhrirOrPrQr`rYr\rrrr request_data{s*    rjzFtyping.Generator[T_JSON_DICT, T_JSON_DICT, typing.Tuple[float, float]]ccsvt}|dur||d<|dur&||d<|dur:||d<||d<||d<d|d}|V}t|d t|d fS) a Gets metadata of an object store. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey, or 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. :param database_name: Database name. :param object_store_name: Object store name. :returns: A tuple with the following items: 0. **entriesCount** - the entries count 1. **keyGeneratorValue** - the current value of key generator, to become the next inserted key into the object store. Valid if objectStore.autoIncrement is true. NrRrSrTrUrVzIndexedDB.getMetadatarWZ entriesCountZkeyGeneratorValue)rrr r"r[rrr get_metadatas    rkzDtyping.Generator[T_JSON_DICT, T_JSON_DICT, DatabaseWithObjectStores]ccsbt}|dur||d<|dur&||d<|dur:||d<||d<d|d}|V}t|dS) a Requests database with given name in given frame. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey, or 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. :param database_name: Database name. :returns: Database with an array of object stores. NrRrSrTrUzIndexedDB.requestDatabaserWZdatabaseWithObjectStores)rrrr r"r^rrrrequest_databases rlz.Z databaseNamesrZ)rOrPrQrYr\rrrrrequest_database_namess rm)NNN)NNN)NNN)NNNN)NNN)NNN)NNN) __future__rtyping dataclassesrutilrrrrrr3r8r@rGr,r]r_rbrdrerjrkrlrmrrrrsd     5'&$#%"<-$