E g8;ddlmZddlmZmZddlmZddlZddlZddl m Z eGddZ eGd d Z eGd d Z eGd dZeGddZeGddZeGddZ d0d1dZ d2d3dZ d4d5d Zd6d!Zd6d"Z d7d8d)Z d0d9d+Z d2d:d-Z d;dz4DatabaseWithObjectStores.to_json.."s HHH HHH objectStores)dictr rrselfjsons rrz DatabaseWithObjectStores.to_jsonsAvvyV ,YHHT5GHHH^ rc|t|dt|dd|dDS)Nr rcBg|]}t|Sr) ObjectStore from_jsonrs rrz6DatabaseWithObjectStores.from_json..*s&RRR;0033RRRrr)r rrr r clsrs rr#z"DatabaseWithObjectStores.from_json%sOsT&\""$y/**RRT.=QRRR    rN__name__ __module__ __qualname____doc____annotations__r classmethodr#rrrr r snIIINNN,+++  [   rr cXeZdZUdZded<ded<ded<ded <d Zed Zd S) r"z Object store. r r KeyPathkey_pathboolauto_incrementztyping.List[ObjectStoreIndex]indexesct}|j|d<|j|d<|j|d<d|jD|d<|S)Nr keyPath autoIncrementc6g|]}|Srrrs rrz'ObjectStore.to_json..Ds ===1199;;===rr3)rr r0rr2r3rs rrzObjectStore.to_json?sXvvyV -//11Y $ 3_== ===Y rc|t|dt|dt|dd|dDS)Nr r5r6cBg|]}t|Sr)ObjectStoreIndexr#rs rrz)ObjectStore.from_json..Ms'LLLq%//22LLLrr3)r r0r2r3r r/r#r1r%s rr#zObjectStore.from_jsonGsdsT&\""&&tI77_ 566LLDOLLL     rNr'rrrr"r".sIII+***  [   rr"cXeZdZUdZded<ded<ded<ded<d Zed Zd S) r:z Object store index. r r r/r0r1unique multi_entryct}|j|d<|j|d<|j|d<|j|d<|S)Nr r5r= multiEntry)rr r0rr=r>rs rrzObjectStoreIndex.to_jsonbsJvvyV -//11YX!-\ rc |t|dt|dt|dt|dS)Nr r5r=r@)r r0r=r>r;r%s rr#zObjectStoreIndex.from_jsonjs^sT&\""&&tI77X''T,/00     rNr'rrrr:r:Qs|IIILLL  [   rr:creZdZUdZded<dZded<dZded<dZded <dZd ed <d Z e d Z dS)Keyz Key. r type_Nztyping.Optional[float]numbertyping.Optional[str]stringdatez!typing.Optional[typing.List[Key]]arrayct}|j|d<|j |j|d<|j |j|d<|j |j|d<|jd|jD|d<|S)NtyperErGrHc6g|]}|Srrrs rrzKey.to_json..s ===QQYY[[===rrI)rrDrErGrHrIrs rrz Key.to_jsonsuvvzV ; "![DN ; "![DN 9 9DL : !==$*===DM rc  |t|dd|vrt|dndd|vrt|dndd|vrt|dndd|vrd|dDndS)NrKrErGrHrIcBg|]}t|Sr)rCr#rs rrz!Key.from_json..s$;;;3==##;;;r)rDrErGrHrIr$r%s rr#z Key.from_jsonssd6l##,4,<,<5h((($*2d*:*:3tH~&&&(.$tF|$$$D?F$;;T'];;;;TX     r) r(r)r*r+r,rErGrHrIrr-r#rrrrCrCtsJJJ&*F))))$(F''''$(D''''04E3333     [   rrCc`eZdZUdZded<ded<dZded<dZded<d Zed Z dS) KeyRangez Key range. r1 lower_open upper_openNztyping.Optional[Key]lowerupperct}|j|d<|j|d<|j|j|d<|j|j|d<|S)N lowerOpen upperOpenrSrT)rrQrRrSrrTrs rrzKeyRange.to_jsonsfvv O[ O[ : ! J..00DM : ! J..00DM rc |t|dt|dd|vr t|dndd|vr t|dndS)NrVrWrSrT)rQrRrSrT)r1rCr#r%s rr#zKeyRange.from_jsons{sD-..D-..29T//#--W ...t29T//#--W ...t     r) r(r)r*r+r,rSrTrr-r#rrrrPrPs#'E&&&&#'E&&&&  [   rrPcNeZdZUdZded<ded<ded<dZedZdS) DataEntryz Data entry. zruntime.RemoteObjectkey primary_keyvaluect}|j|d<|j|d<|j|d<|S)Nr[ primaryKeyr])rr[rr\r]rs rrzDataEntry.to_jsonsWvvh&&((U !-5577\ **,,W  rc|tj|dtj|dtj|dS)Nr[r_r])r[r\r])r RemoteObjectr#r%s rr#zDataEntry.from_jsonsds$..tE{;;,66tL7IJJ&00g??    rNr'rrrrZrZst&%%%   [   rrZcVeZdZUdZded<dZded<dZded<d Zed Z dS) r/z Key path. r rDNrFrGz!typing.Optional[typing.List[str]]rIct}|j|d<|j |j|d<|jd|jD|d<|S)NrKrGcg|]}|Srrrs rrz#KeyPath.to_json..s3331Q333rrI)rrDrGrIrs rrzKeyPath.to_jsonsOvvzV ; "![DN : !33 333DM rc|t|dd|vrt|dndd|vrd|dDndS)NrKrGrIc,g|]}t|Srr rs rrz%KeyPath.from_json..s111a3q66111r)rDrGrIrgr%s rr#zKeyPath.from_jsonsksd6l##*2d*:*:3tH~&&&5<__114=1111$    r) r(r)r*r+r,rGrIrr-r#rrrr/r/s{JJJ$(F''''04E3333  [   rr/security_originrF storage_key database_namer object_store_namereturn0typing.Generator[T_JSON_DICT, T_JSON_DICT, None]c#hKt}|||d<|||d<||d<||d<d|d}|V}dS)aC Clears all entries from an object store. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey must be specified. Security origin. :param storage_key: *(Optional)* Storage key. :param database_name: Database name. :param object_store_name: Object store name. NsecurityOrigin storageKey databaseNameobjectStoreNamezIndexedDB.clearObjectStoremethodparamsrrhrirjrkrucmd_dictrs rclear_object_storerysh&&F"#2 *|*F> 1F .H>>DDDrc#^Kt}|||d<|||d<||d<d|d}|V}dS)z Deletes a database. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey must be specified. Security origin. :param storage_key: *(Optional)* Storage key. :param database_name: Database name. NrorprqzIndexedDB.deleteDatabasersrvrhrirjrurxrs rdelete_databaser|s]&&F"#2 *|*F>,H>>DDDr key_rangec#Kt}|||d<|||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 must be specified. Security origin. :param storage_key: *(Optional)* Storage key. :param database_name: :param object_store_name: :param key_range: Range of entry keys to delete NrorprqrrkeyRangez"IndexedDB.deleteObjectStoreEntriesrs)rr)rhrirjrkr}rurxrs rdelete_object_store_entriesr8s~ &&F"#2 *|*F> 1F "**,,F:6H>>DDDrc#Kddi}|V}dS)z' Disables events from backend. rtzIndexedDB.disableNrrxrs rdisablerWs$ %H>>DDDrc#Kddi}|V}dS)z& Enables events from backend. rtzIndexedDB.enableNrrs renableras$ $H>>DDDr index_name skip_countint page_sizetyping.Optional[KeyRange]Vtyping.Generator[T_JSON_DICT, T_JSON_DICT, typing.Tuple[typing.List[DataEntry], bool]]c#Kt}|||d<|||d<||d<||d<||d<||d<||d<|||d <d |d } | V} d | d Dt| dfS)a Requests data from object store or index. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey must be specified. Security origin. :param storage_key: *(Optional)* Storage key. :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. Nrorprqrr indexName skipCountpageSizerzIndexedDB.requestDatarscBg|]}t|Sr)rZr#rs rrz request_data..s&HHHA  Q  HHHrobjectStoreDataEntrieshasMore)rrr1) rhrirjrkrrrr}rurxrs r request_datarks4&&F"#2 *|*F> 1F $F;$F;"F:&..00z)H>>DHH.F)GHHH T)_ rFtyping.Generator[T_JSON_DICT, T_JSON_DICT, typing.Tuple[float, float]]c#Kt}|||d<|||d<||d<||d<d|d}|V}t|dt|d fS) aG Gets metadata of an object store. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey must be specified. Security origin. :param storage_key: *(Optional)* Storage key. :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. NrorprqrrzIndexedDB.getMetadatars entriesCountkeyGeneratorValue)rr rws r get_metadatars$&&F"#2 *|*F> 1F )H>>D d>"## d&'(( rDtyping.Generator[T_JSON_DICT, T_JSON_DICT, DatabaseWithObjectStores]c#Kt}|||d<|||d<||d<d|d}|V}t|dS)aR Requests database with given name in given frame. :param security_origin: *(Optional)* At least and at most one of securityOrigin, storageKey must be specified. Security origin. :param storage_key: *(Optional)* Storage key. :param database_name: Database name. :returns: Database with an array of object stores. NrorprqzIndexedDB.requestDatabasersdatabaseWithObjectStores)rr r#r{s rrequest_databaserss&&F"#2 *|*F>-H>>D # - -d3M.N O OOr.s 2 2 2qCFF 2 2 2r databaseNamesrv)rhrirurxrs rrequest_database_namesrsh&&F"#2 *|2H>>D 2 2D1 2 2 22r)NNNN) rhrFrirFrjr rkr rlrm)NNN)rhrFrirFrjr rlrm)NNNNN) rhrFrirFrjr rkr r}rPrlrm)rlrm)NNNNNNNN)rhrFrirFrjr rkr rr rrrrr}rrlr) rhrFrirFrjr rkr rlr)rhrFrirFrjr rlr)NN)rhrFrirFrlr) __future__rutilrr dataclassesrenumtypingrr r"r:rCrPrZr/ryr|rrrrrrrrrrrs%#"""""********!!!!!!           <          D          D ( ( ( ( ( ( (  ( V ! ! ! ! ! ! !  ! H          :          @15,0!!% :15,0!415,0!!%" >15,0!!%/3.....d15,0!!% !!!!!J15,0!PPPPP815,03333333r