Li?{ PddlZddlZddlZddlZddlmZmZmZddlm Z ddl m Z ddl m Z ddl m Z ddl mZdd l mZdd l mZdd l mZdd lmZmZej0d Z ddeeeefefdeeeefdeeeffdZ ddeeeefefdeeeefdeeeffdZ ddeeeefefdeeeefdeeeffdZ ddeeeefefdeeeefdeeeffdZ ddeeeefefdeeeefdeeeffdZ! ddeeeefefdeeeefdeeeffdZ" ddeeeefefdeeeefdeeeffdZ# ddeeeefefdeeeefdeeeffdZ$Gdde jJZ&Gdde jJZ'y)N)AnyOptionalUnion) urlencode) _api_module)_common) _extra_utils) _transformers)types)get_value_by_path)set_value_by_path) AsyncPagerPagerzgoogle_genai.files from_object parent_objectreturncVi}t|dgt|dgt|dg|S)Nfilegetvsetvrr to_objects P/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/google/genai/files.py_CreateFileParameters_to_mldevr&s5!) +x ,VHd;9: cVi}t|dgt|dgt|dg|SNsdkHttpResponsesdk_http_responserrs r_CreateFileResponse_from_mldevr"1@!) +)*+7'(${=NF!) +x ,FF#Q]]4 fX3N%O rcVi}t|dgt|dgt|dg|Srrrs r_DeleteFileResponse_from_mldevr.Kr#rc ~i}t|dg-t|ddgtjt|dg|Sr%r(rs r_GetFileParameters_to_mldevr0Xr,rci}t|dgt|ddgt|dgt|dgt|ddgt|dg|S)N page_size_querypageSize page_token pageTokenrrs r_ListFilesConfig_to_mldevr7esm!) + }%1*-tK+/O + ~&2 ; [<.) rcRi}t|dgtt|dg||S)Nconfig)rr7rs r_ListFilesParameters_to_mldevr:zs1!) +z".d; ;YG rci}t|dgt|dgt|dgt|dgt|dgt|dgt|dg't|dgt|dgDcgc]}|c}|Scc}w)Nr r! nextPageTokennext_page_tokenfilesr)rrritems r_ListFilesResponse_from_mldevr@s!) +)*+7'(${=Nr3?r9Ngetresponsekwargsheaders)r _ListFilesParameters _api_clientvertexai ValueErrorr:rG format_maprpopr9 http_optionsr convert_to_dictencode_unserializable_typesrequestbodyjsonloadsr@ListFilesResponse_from_response model_dump HttpResponserLr!_verify_response selfr9parameter_model request_dictrequest_url_dictpath query_paramsrSrI response_dict return_values r_listz Files._lists(00O     I 3?Cl%))&1 !!"23##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''t\<PH&mmBHMM1JM    $ $3MBm**99'A'A'C:L&+%7%7  &L" %%l3 rrctj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||} |@t!|d dr3tj"| } |jj%| | S| j&sint)j*| j&} |jjs t-| } tj"j/| |j1 } |jj%| | S Nrr9rEr'zupload/v1beta/filesr3rFr9postshould_return_http_response)r!rH)r _CreateFileParametersrNrOrPrrGrQrrRr9rSr rTrUrVgetattrCreateFileResponser^rWrXrYr"r[r\ r`rr9rarbrcrdrerSrIrgrfs r_createz Files._creates 11 O     I 4ODl%))&1 $//0@A$##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''lLHg-t--Il '' 5 &mmBHMM1JM    $ $4]Cm++::'A'A'C;L %%l3 rr&c6tj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||} | j sint#j$| j } tj&j)| |j+ } |jj-| | S) aiRetrieves 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 = client.files.get(name='files/...') print(file.uri) r&r9rEr' files/{file}r3rFr9NrGrH)r _GetFileParametersrNrOrPr0rGrQrrRr9rSr rTrUrVrWrXrYFiler[r\r^ r`r&r9rarbrcrdrerSrIrfrgs rrGz Files.getsw(.. O     I 1Al%))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''t\<PH&mmBHMM1JM::,,'A'A'C-L %%l3 rctj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||} | j sint#j$| j } |jjs t'| } tj(j+| |j- } tj.| j0 | _|jj5| | S) a]Deletes 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 client.files.delete(name='files/...') rtrEr'rur3rFr9NdeleterHrK)r _DeleteFileParametersrNrOrPr+rGrQrrRr9rSr rTrUrVrWrXrYr.DeleteFileResponser[r\r]rLr!r^rxs rrzz Files.delete_s&11 O     I 4ODl%))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL''$ lH'mmBHMM1JM    $ $4]Cm++::'A'A'C;L&+%7%7  &L" %%l3 rc|jjr tdtj}|r_t |t rtjd i|}n|}tj|j|j|j}ntj}|j/|jjdsd|j|_ tj||j|j\}}}||_||_|j!|tj"|d}|j$.|j$j&d|j$j&vr t)d |j$j&d} t |t*j,r*|jj/|| |j| } n>t1j2|} |jj/| | |j| } tjj5| j6d |r|j9 Si S)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`. rE mime_typer& display_namefiles/user_http_optionsuser_mime_typeTrSrmrkx-goog-upload-urlPFailed to create file. Upload URL did not returned from the create file request.rSrrH)rNrOrPr UploadFileConfig isinstancedictrwrr&r startswithr prepare_resumable_uploadrS size_bytesrrCreateFileConfigr!rLKeyErrorioIOBase upload_fileosfspathr[rXr\ r`rr9 config_modelfile_objrSrrrI upload_url return_filefs_paths ruploadz Files.uploads>     I ))+L FD !--77   **  #00h h}} )A)A()Kx}}o.hm*6*O*O &33#--+'L*i %H"H|| %%%4 H ""*  % % - - 5 h&@&@&H&H H   ++334GHJ$ "$$00  H//l1k $g$$00 :x221k :: $ $!!&),2|&&( % 8: % rcRtd|j|j||SNr>rC)rrhr`r9s rlistz Files.lists,   & !  rc|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 rENzOnly 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 :downloadaltmediarFrSrr)rNrOrPrrr DownloadFileConfigrw download_urir)r*rr download_fileVideo video_bytesGeneratedVideovideo) r`rr9rr&rdrerSdatas 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 ListFilesConfigOrDictrZrh FileOrDictCreateFileConfigOrDictrprrstrGetFileConfigOrDictrwrGDeleteFileConfigOrDictr|rzrrPathLikerrUploadFileConfigOrDictrrrrrDownloadFileConfigOrDictbytesrrrrrBrBs@DC ; ;<C CR8< =   =u334 =   =@IM??"*5+D+D"E? zz?DLPEE"*5+G+G"HE EV8< J #r{{3'2 3Ju334 J  zz JZ@D ; ;< UZZ:> O #uzz5;;0D0DD EOu556 O  OrrBcZeZdZdddeej dej fdZdddejdeejdejfdZ ddde deejdejfd Zddde deej dej"fd Zdddee ej*e ej.fdeej0dejfd Zdddeej deejfd Zdddee ejfdeej8defd Zy) AsyncFilesNrCr9rcKtj|}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{}|j sint#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) rCrEr'r>r3rFr9NrGrHrK)r rMrNrOrPr:rGrQrrRr9rSr rTrU async_requestrWrXrYr@rZr[r\r]rLr!r^r_s rrhzAsyncFiles._listPs(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,rcKtj||}|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&sint)j*| j&} |jjs t-| } tj"j/| |j1 } |jj%| | S7wrj)r rnrNrOrPrrGrQrrRr9rSr rTrUrrorpr^rWrXrYr"r[r\rqs rrrzAsyncFiles._creates 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&cRKtj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} | j sint#j$| j } tj&j)| |j+ } |jj-| | S7}w) 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) rtrEr'rur3rFr9NrGrH)r rvrNrOrPr0rGrQrrRr9rSr rTrUrrWrXrYrwr[r\r^rxs rrGzAsyncFiles.gets(.. O     I 1Al%))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL%%33 t\<H'mmBHMM1JM::,,'A'A'C-L %%l3 sD%F''F%(A>F'cKtj||}|jjr t dt |}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} | j sint#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/...') rtrEr'rur3rFr9NrzrHrK)r r{rNrOrPr+rGrQrrRr9rSr rTrUrrWrXrYr.r|r[r\r]rLr!r^rxs rrzzAsyncFiles.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-cK|jjr tdtj}|r_t |t rtjdi|}n|}tj|j|j|j}ntj}|j/|jjdsd|j|_ tj||j|j\}}}||_||_|j!|tj"|dd{}|j$F|j$j&0d |j$j&vr#d |j$j&vr t)d d |j$j&vr|j$j&d } n|j$j&d } t |t*j,r2|jj/|| |j| d{} nFt1j2|} |jj/| | |j| d{} tjj5| j6d |r|j9SiS777Nw)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`. rEr~NrrTrrkrzX-Goog-Upload-URLrrrrHr)rNrOrPr rrrrwrr&rrr rrSrrrrr!rLrrrasync_upload_filerrr[rXr\rs rrzAsyncFiles.upload`s     I ))+L FD !--77   **  #00h h}} )A)A()Kx}}o.hm*6*O*O &33#--+'L*i %H"H\\ %%%4 "H ""*  % % - - 5 x'A'A'I'I I#8+E+E+M+MM     : : B B B--556IJj--556IJj$ "**<<  H//l=k $g**<< :x22=k :: $ $!!&),2|&&( % 8: % C0 s9EKKC2KKAK K A KKKcnKtd|j|j|d{|S7 wr)rrhrs 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) rENrrrSrrrFrr) rNrOrPrrr rr)r*rrasync_download_file) r`rr9rr&rdrSrers rrzAsyncFiles.downloadsF    I L FD !//9&9  == D D6 #DL L>*+7,(89l7#LvQy./ 0d!!55 !6 D K  sB;C=C>C)rrrrr rrZrhrrrprrrrrwrGrr|rzrrrrrrrrrrrrrrrrrNs@DE ; ;<E EV8< =   =u334 =   =@IMAA"*5+D+D"EA zzAHLPEE"*5+G+G"HE EV8< O #r{{3'2 3Ou334 O  zz Od@D ; ;<%**:> @ #uzz/ "@u556 @  @rr)N)(rrXloggingrtypingrrr urllib.parserrr r r r)r r rrrpagersrr getLoggerloggerrrobjectrr"r+r.r0r7r:r@ BaseModulerBrrrrrs$  ''" ..%   / 0 /3tCH~v-.DcN+ #s(^/3 tCH~v-. DcN+  #s(^ /3 tCH~v-. DcN+  #s(^ /3 tCH~v-. DcN+  #s(^ /3 tCH~v-. DcN+  #s(^ /3tCH~v-.DcN+ #s(^./3tCH~v-.DcN+ #s(^/3tCH~v-.DcN+ #s(^&sK " "sl m''mr