[Th dddlZddlZddlZddlZddlZddlmZmZmZddl m Z ddl m Z ddl m Z ddl mZddl mZdd l mZdd l mZdd lmZmZej0d Z d d eeeefefdeeeefdeeeffdZ d d eeeefefdeeeefdeeeffdZ d d eeeefefdeeeefdeeeffdZ d d eeeefefdeeeefdeeeffdZ d d eeeefefdeeeefdeeeffdZ! d d eeeefefdeeeefdeeeffdZ" d d eeeefefdeeeefdeeeffdZ# d d eeeefefdeeeefdeeeffdZ$ d d eeeefefdeeeefdeeeffdZ% d d eeeefefdeeeefdeeeffdZ& d d eeeefefdeeeefdeeeffdZ' d d eeeefefdeeeefdeeeffdZ(Gdde jRZ*Gdde jRZ+y)!N)AnyOptionalUnion) urlencode) _api_module)_common) _transformers)types)get_value_by_path)set_value_by_path) AsyncPagerPagerzgoogle_genai.files from_object parent_objectreturnci}t|dgt|ddgt|dgt|dgt|ddgt|dg|S)N page_size_querypageSize page_token pageTokengetvsetvrr to_objects W/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/google/genai/files.py_ListFilesConfig_to_mldevr&sm!) + }%1*-tK+/O + ~&2 ; [<.) c ji}t|dg#t|dgtt|dg||S)Nconfig)rrrrs r_ListFilesParameters_to_mldevr#;sC!) +z".  !${XJ"?K r ci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|SNdetailsmessagecoderrs r_FileStatus_to_mldevr)J!) + {#/YKkI;!?@ + {#/YKkI;!?@ +x ,VHd;9: r c Fi}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|d gt|dgt|d gt|d gt|d gt|d gt|d gt|d gt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg#t|dgtt|dg||S)Nname display_name displayName mime_typemimeType size_bytes sizeBytes create_time createTimeexpiration_timeexpirationTime update_time updateTime sha256_hash sha256Hashuri download_uri downloadUristatesourcevideo_metadata videoMetadataerror)rrr)rs r_File_to_mldevrC[s@!) +x ,VHd;9: +'(4]OT+7G%HI + }%1ZL${[M"BC + ~&2[M4 l^#DE + '3\ND}o$FG +)*+7%&[;L:M(NO + '3\ND}o$FG + '3\ND}o$FG +w+UGT+w78 +'(4]OT+7G%HI +y!-WItK';< +z".XJ[8* => +()*6_%tK:J9K'LM +y!-  T+y99E r c i}t|dg#t|dgtt|dg|t|dgt|dgt|dg|S)Nfiler")rrrCrs r_CreateFileParameters_to_mldevrFsi!) +x , tK&2I>  +z".XJ[8* => r c i}t|dg-t|ddgtjt|dgt|dgt|dgt|dg|SNr,_urlrEr"rrt t_file_namers r_GetFileParameters_to_mldevrMl!) +x ,FF#Q]]4 fX3N%O +z".XJ[8* => r c i}t|dg-t|ddgtjt|dgt|dgt|dgt|dg|SrHrJrs r_DeleteFileParameters_to_mldevrPrNr ci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|Sr%rrs r_FileStatus_from_mldevrRr*r c Fi}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|d gt|dgt|d gt|d gt|d gt|d gt|d gt|d gt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg#t|dgtt|dg||S)Nr,r.r-r0r/r2r1r4r3r6r5r8r7r:r9r;r=r<r>r?rAr@rB)rrrRrs r_File_from_mldevrTs=!) +x ,VHd;9: + '3^$d;&HI + |$0[M4 j\#BC + }%1\ND{m$DE + ~&2]OT+ ~%FG +()*6&'k +()5%&[?:K(LM +y!-  tK';YG r c (i}t|dgt|dgt|dgt|dgt|dgt|dgt|dg1t|dgt|dgDcgc]}t||c}|Scc}w)NsdkHttpResponsesdk_http_response nextPageTokennext_page_tokenfiles)rrrT)rrritems r_ListFilesResponse_from_mldevr\ s!) +)*+7'(${=Nd| jFj>vr tId| jFj>d} t |tjr*|jjK|| |j(|} n)|jjK| |j(|} tjjMtO| jPd|r|jSSiS)aCalls the API to upload a file using a supported file service. Args: file: A path to the file or an `IOBase` object to be uploaded. If it's an IOBase object, it must be opened in blocking (the default) mode and binary mode. In other words, do not use non-blocking mode or text mode. The given stream must be seekable, that is, it must be able to call `seek()` on 'path'. config: Optional parameters to set `diplay_name`, `mime_type`, and `name`. rgr/r,r-files/zfUnknown mime type: Could not determine the mimetype for your file please set the `mime_type` argumentmodeb'The file must be opened in binary mode.r is not a valid file path.iUnknown mime type: Could not determine the mimetype for your file please set the `mime_type` argumentrjapplication/json resumablestartz Content-TypezX-Goog-Upload-ProtocolzX-Goog-Upload-Commandz#X-Goog-Upload-Header-Content-Lengthz!X-Goog-Upload-Header-Content-Type api_versionroTrvrrx-goog-upload-urlPFailed to create file. Upload URL did not returned from the create file request.rvrErk)*rqrrrsr UploadFileConfig isinstancedictrr/r,r- startswithioIOBasehasattrrtellseekosSEEK_ENDr1SEEK_SETfspathrisfileFileNotFoundErrorgetsize mimetypes guess_typervrro HttpOptionsrCreateFileConfigrWKeyError upload_filer~rTr{r rrEr" config_modelfile_objoffsetfs_path_rvrl upload_url return_files ruploadz Files.uploadOs     I ))+L FD !--77   **  #00h h}} )A)A()Kx}}o.hm$ "    # :   v  dii DE Eyy{f ii2;; IIK&0h ii $ $g BGGNN734&(B CDDGGOOG4h    # ) 4 4W =A    # =   11!..l!#l,$/#*4<4G4G3H2:2D2D1E l&&0(3'.8@8K8K7L6>6H6H5I   l|| %%%4 H ""*  % % - - 5 h&@&@&H&H H   ++334GHJ$ "$$00  H//l1k$$00 :x221k :: $ $!+"2"26":;,2|&&( % 8: % r cRtd|j|j||SNrZre)rrrr"s rlistz Files.lists,   & !  r c|jjr tdd}|r(t|trt j d i|}n|}t|t jr|j tdtj|}d|d}ddi}|dt|}d}t|d g t|d g}|jj|| }t|t jr ||_|St|t j r|j"||j"_|S) arDownloads a file's data from storage. Files created by `upload` can't be downloaded. You can tell which files are downloadable by checking the `source` or `download_uri` property. Note: This method returns the data as bytes. For `Video` and `GeneratedVideo` objects there is an additional side effect, that it also sets the `video_bytes` property on the `Video` object. Args: file (str): A file name, uri, or file object. Identifying which file to download. config (DownloadFileConfigOrDict): Optional, configuration for the get method. Returns: File: The file data as bytes. Usage: .. code-block:: python for file client.files.list(): if file.download_uri is not None: break else: raise ValueError('No files found with a `download_uri`.') data = client.files.download(file=file) # data = client.files.download(file=file.name) # data = client.files.download(file=file.download_uri) video = types.Video(uri=file.uri) video_bytes = client.files.download(file=video) video.video_bytes rgNzOnly generated files can be downloaded, uploaded files can't be downloaded. You can tell which files are downloadable by checking the `source` or `download_uri` property.r :downloadaltmediarhrvrr)rqrrrsrrr DownloadFileConfigrr<rKrLrr download_fileVideo video_bytesGeneratedVideovideo) rrEr"rr,rrrvdatas rdownloadzFiles.downloadsIR    I L FD !//9&9  $ #(9(9(A  5  == D D6 #D7#LV1Y|,- .DL L>*+7,(89l    ) ) ! * D $ $d K D%.. /DJJ4J#djj Kr )!__name__ __module__ __qualname__rr ListFilesConfigOrDictr}r FileOrDictCreateFileConfigOrDictrrstrGetFileConfigOrDictrriDeleteFileConfigOrDictrrrrPathLikerrUploadFileConfigOrDictrrrrrDownloadFileConfigOrDictbytesrrr rrdrd>s@DC ; ;<C CR8< =   =u334 =   =@IMBB"*5+D+D"EB zzBJLPEE"*5+G+G"HE EV8< r #r{{3'2 3ru334 r  zz rj@D ; ;< UZZ:> O #uzz5;;0D0DD EOu556 O  Or rdcZeZdZdddeej dej fdZdddejdeejdejfdZ ddde deejdejfd Zddde deej dej"fd Zdddee ej*e ej.fdeej0dejfd Zdddeej deejfd Zdddee ejfdeej8defd Zy) AsyncFilesNrer"rcKtj|}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{}|j sd nt#j$|j } |jjs t'| } tj(j+| |j- } tj.|j0 | _|jj5| | S7íw) akLists all files from the service. Args: config (ListFilesConfig): Optional, configuration for the list method. Returns: ListFilesResponse: The response for the list method. Usage: .. code-block:: python pager = await client.aio.files.list(config={'page_size': 10}) for file in pager.page: print(file.name) rergrIrZrrhr"Nrirjrkrn)r rprqrrrsr#rirtrrur"rvr rwrx async_requestrzr{r|r\r}r~rrrorWrrs rrzAsyncFiles._list!s(00O     I 3?Cl%))&1 !!"23##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33 t\<H'mmBHMM1JM    $ $3MBm**99'A'A'C:L&+%7%7  &L" %%l3 !sD$G,&G*'CG,rEcKtj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||d{} |@t!|d dr3tj"| } |jj%| | S| j&sd nt)j*| j&} |jjs t-| } tj"j/| |j1 } |jj%| | S7wr)r rrqrrrsrFrirtrrur"rvr rwrxrrrrrzr{r|r_r~rrs rrzAsyncFiles._createhs 11 O     I 4ODl%))&1 $//0@A$##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33lLHg-t--Il '' 5 &mmBHMM1JM    $ $4]Cm++::'A'A'C;L %%l3 +sD%H 'H(C!H r,cKtj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} | j sd nt#j$| j } |jjs t'| } tj(j+| |j- } |jj/| | S7w) asRetrieves the file information from the service. Args: name (str): The name identifier for the file to retrieve. config (GetFileConfig): Optional, configuration for the get method. Returns: File: The file information. Usage: .. code-block:: python file = await client.aio.files.get(name='files/...') print(file.uri) rrgrIrrrhr"Nrirjrk)r rrqrrrsrMrirtrrur"rvr rwrxrrzr{r|rTrr~rrrs rrizAsyncFiles.gets(.. O     I 1Al%))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33 t\<H'mmBHMM1JM    $ $&}5m::,,'A'A'C-L %%l3 sD%G'G(BGcKtj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} | j sd nt#j$| j } |jjs t'| } tj(j+| |j- } tj.| j0 | _|jj5| | S7íw) agDeletes a remotely stored file. Args: name (str): The name identifier for the file to delete. config (DeleteFileConfig): Optional, configuration for the delete method. Returns: DeleteFileResponse: The response for the delete method Usage: .. code-block:: python await client.aio.files.delete(name='files/...') rrgrIrrrhr"Nrrjrkrn)r rrqrrrsrPrirtrrur"rvr rwrxrrzr{r|rbrr~rrrorWrrs rrzAsyncFiles.deletes&11 O     I 4ODl%))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33$ lH'mmBHMM1JM    $ $4]Cm++::'A'A'C;L&+%7%7  &L" %%l3 !sD%G-'G+(CG-c K|jjr tdtj}|r_t |t rtjdi|}n|}tj|j|j|j}ntj}|j/|jjdsd|j|_ t |tjr|j tdt|drd|jvr td|j!}|j#d t$j&|j!|z |_|j#|t$j*nt%j,|}|rt$j.j1|st3|d t$j.j5||_|jt7j8|\|_}|j td|rC|j:r7|j:}d |_d d d|j(|jd|_n3tj@d d d d|j(|jd}|jC|tjD|dd{} | jFF| jFj>0d| jFj>vr#d| jFj>vr tIdd| jFj>vr| jFj>d} n| jFj>d} t |tjr2|jjK|| |j(|d{} n1|jjK| |j(|d{} tjjMtO| jPd|r|jSSiS7x77Ww)aCalls the API to upload a file asynchronously using a supported file service. Args: file: A path to the file or an `IOBase` object to be uploaded. If it's an IOBase object, it must be opened in blocking (the default) mode and binary mode. In other words, do not use non-blocking mode or text mode. The given stream must be seekable, that is, it must be able to call `seek()` on 'path'. config: Optional parameters to set `diplay_name`, `mime_type`, and `name`. rgrNrrrrrrrrjrrrrrTrrrzX-Goog-Upload-URLrrrErkr)*rqrrrsr rrrrr/r,r-rrrrrrrrrr1rrrrrrrrrvrrorrrrWrasync_upload_filer~rTr{rrs rrzAsyncFiles.upload4s     I ))+L FD !--77   **  #00h h}} )A)A()Kx}}o.hm$ "    # =   v  dii DE Eyy{f ii2;; IIK&0h ii $ $g BGGNN734&(B CDDGGOOG4h    # ) 4 4W =A    # =   11!..l!#l,$/#*4<4G4G3H2:2D2D1E l&&0(3'.8@8K8K7L6>6H6H5I   l\\ %%%4 "H ""*  % % - - 5 x'A'A'I'I I#8+E+E+M+MM     : : B B B--556IJj--556IJj$ "**<<  H//l=k**<< :x22=k :: $ $!+"2"26":;,2|&&( % 8: % A0s8K0Q12Q*3C2Q1%Q-&1Q1Q/AQ1-Q1/Q1cnKtd|j|j|d{|S7 wr)rrrs rrzAsyncFiles.lists8  jjj''   (s '53 5cK|jjr tdd}|r(t|trt j d i|}n|}tj|}d|d}d}t|dg t|dg}ddi}|r|dt|}|jj|| d{}|S7w) atDownloads a file's data from the file service. The Vertex-AI implementation of the API foes not include the file service. Files created by `upload` can't be downloaded. You can tell which files are downloadable by checking the `download_uri` property. Args: File (str): A file name, uri, or file object. Identifying which file to download. config (DownloadFileConfigOrDict): Optional, configuration for the get method. Returns: File: The file data as bytes. Usage: .. code-block:: python for file client.files.list(): if file.download_uri is not None: break else: raise ValueError('No files found with a `download_uri`.') data = client.files.download(file=file) # data = client.files.download(file=file.name) # data = client.files.download(file=file.uri) rgNrrrvrrrhrr) rqrrrsrrr rrKrLrrasync_download_file) rrEr"rr,rrvrrs rrzAsyncFiles.downloadsF    I L FD !//9&9  == D D6 #DL L>*+7,(89l7#LvQy./ 0d!!55 !6 D K  sB;C=C>C)rrrrr rr}rrrrrrrrrirrrrrrrrrrrrrrrrr rrrs@DE ; ;<E EV8< =   =u334 =   =@IMDD"*5+D+D"ED zzDNLPEE"*5+G+G"HE EV8< w #r{{3'2 3wu334 w  zz wt@D ; ;<%**:> @ #uzz/ "@u556 @  @r r)N),rr{loggingrrtypingrrr urllib.parserrjrr r rKr r rr rpagersrr getLoggerloggerrrobjectrr#r)rCrFrMrPrRrTr\r_rb BaseModulerdrrr rrs$  ''" ..%   / 0 /3tCH~v-.DcN+ #s(^./3 tCH~v-. DcN+  #s(^ "/3tCH~v-.DcN+ #s(^&/33tCH~v-.3DcN+3 #s(^3p/3tCH~v-.DcN+ #s(^(/3 tCH~v-. DcN+  #s(^ $/3 tCH~v-. DcN+  #s(^ $/3tCH~v-.DcN+ #s(^&/33tCH~v-.3DcN+3 #s(^3p/3tCH~v-.DcN+ #s(^8/3 tCH~v-. DcN+  #s(^ /3 tCH~v-. DcN+  #s(^ ^K " "^BX''Xr