g~ddlmZddlmZmZddlmZmZddlm Z ddl m Z m Z ddl mZdd lmZd gZGd d Zy ) ) annotations)AnyOptional)HTTPStatusErrorResponse)StorageApiError)CreateOrUpdateBucketOptions RequestMethod) AsyncClient) AsyncBucketAsyncStorageBucketAPIceZdZdZd dZ d d dZddZddZ d ddZ ddZ dd Z dd Z y)rzfThis class abstracts access to the endpoint to the Get, List, Empty, and Delete operations on a bucketc||_yN)_client)selfsessions K/var/www/openai/venv/lib/python3.12/site-packages/storage3/_async/bucket.py__init__zAsyncStorageBucketAPI.__init__s  NcK |jj|||d{}|j|S7#t$r5}|jj }t |d|d|dd}~wwxYww)Njsonmessageerror statusCode)rrequestraise_for_statusrresponserr )rmethodurlrr!excresps r_requestzAsyncStorageBucketAPI._requests  V!\\11&#D1IIH  % % '  J V<<$$&D!$y/4=$|BTU U Vs1A?!><>A?> A<0A77A<<A?cK|jddd{}|jDcgc] }tdi|c}S7+cc}ww)zHRetrieves the details of all storage buckets within an existing product.GET/bucketNr&rr)rresbuckets r list_bucketsz"AsyncStorageBucketAPI.list_buckets$sFMM%3347HHJ?J& %f%J??4?s A AA AA A c~K|jdd|d{}|j}tdi|S7w)zRetrieves the details of an existing storage bucket. Parameters ---------- id The unique identifier of the bucket you would like to retrieve. r(/bucket/Nr*r+)ridr,rs r get_bucketz AsyncStorageBucketAPI.get_bucket*s?MM%8B499xxz"T"":s =; =cK||xs|d}|r|jdi||jdd|d{}|jS7w)aCreates a new storage bucket. Parameters ---------- id A unique identifier for the bucket you are creating. name A name for the bucket you are creating. If not passed, the id is used as the name as well. options Extra options to send while creating the bucket. Valid options are `public`, `file_size_limit` and `allowed_mime_types`. r1namePOSTr)rNr*)updater&r)rr1r5optionsrr,s r create_bucketz#AsyncStorageBucketAPI.create_bucket6s^$')$*"=  DKK "' "MM  "   xxz  s5AA AczK||d|}|jdd||d{}|jS7w)a0Update a storage bucket. Parameters ---------- id The unique identifier of the bucket you would like to update. options The properties you want to update. Valid options are `public`, `file_size_limit` and `allowed_mime_types`. r4PUTr0rNr&r)rr1r8rr,s r update_bucketz#AsyncStorageBucketAPI.update_bucketRsF"00MM%8B4tMDDxxzEs ";9;cnK|jdd|did{}|jS7w)zRemoves all objects inside a single bucket. Parameters ---------- id The unique identifier of the bucket you would like to empty. r6r0z/emptyrNr<rr1r,s r empty_bucketz"AsyncStorageBucketAPI.empty_bucketcs:MM&HRD*?bMIIxxzJs 535clK|jdd|id{}|jS7w)aDeletes an existing bucket. Note that you cannot delete buckets with existing objects inside. You must first `empty()` the bucket. Parameters ---------- id The unique identifier of the bucket you would like to delete. DELETEr0rNr<r?s r delete_bucketz#AsyncStorageBucketAPI.delete_bucketns7MM(hrdO"MEExxzFs 424)rr returnNoner)r"r r#strrzOptional[dict[Any, Any]]rDr)rDzlist[AsyncBucket])r1rFrDr)NN)r1rFr5z Optional[str]r8z%Optional[CreateOrUpdateBucketOptions]rDdict[str, str])r1rFr8r rDrG)r1rFrDrG) __name__ __module__ __qualname____doc__rr&r.r2r9r=r@rCr*rrrrsp*.   '   @ ##9=  7   8 ; "  rN) __future__rtypingrrhttpxrr exceptionsr typesr r utilsr file_apir__all__rr*rrrTs." +(>! " #iir