`i 8ddlZddlZddlZddlZddlZddlmZmZmZddl m Z ddl m Z ddl m Z ddl mZddl mZdd lmZdd l mZdd l mZdd lmZmZej4d Z d"dedeeefdeedefdZ d"dedeeefdeedefdZ d"dedeeefdeedefdZ d"dedeeefdeedefdZ! d"dedeeefdeedefdZ" d"dedeeefdeedefdZ# d"dedeeefdeedefdZ$ d"dedeeefdeedefdZ% d"dedeeefdeedefdZ& d"dedeeefdeedefdZ' d"dedeeefdeedefdZ( d"dedeeefdeedefdZ)Gdde jTZ+Gd d!e jTZ,y)#N)AnyOptionalUnion) urlencode) _api_module)_common) _transformers)types) BaseApiClient)get_value_by_path)set_value_by_path) AsyncPagerPagerzgoogle_genai.files api_client from_object parent_objectreturnci}t|dgt|ddgt|dgt|dgt|ddgt|dg|S)N page_size_querypageSize page_token pageTokengetvsetvrrr to_objects W/var/www/html/ts-aiml.yecor.com/venv/lib/python3.12/site-packages/google/genai/files.py_ListFilesConfig_to_mldevr!%sm !) + }%1*-tK+/O + ~&2 ; [<.) c li}t|dg$t|dgt|t|dg||S)Nconfig)rrr!rs r _ListFilesParameters_to_mldevr%;sH !) +z".  ! [8*5y  r"ci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|SNdetailsmessagecoderrs r _FileStatus_to_mldevr+M !) + {#/YKkI;!?@ + {#/YKkI;!?@ +x ,VHd;9: r"c Hi}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|dgt|t|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_mldevrE_sE !) +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!-   [7)4i  r"c i}t|dg$t|dgt|t|dg|t|dgt|dgt|dg|S)Nfiler$)rrrErs r _CreateFileParameters_to_mldevrHsk !) +x , z4 fX#> J  +z".XJ[8* => r"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SNr._urlrGr$rrt t_file_namers r _GetFileParameters_to_mldevrOp !) +x ,  j${VH"=>  +z".XJ[8* => r"c i}t|dg.t|ddgtj|t|dgt|dgt|dgt|dg|SrJrLrs r _DeleteFileParameters_to_mldevrRrPr"ci}t|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dgt|dg|Sr'rrs r _FileStatus_from_mldevrTr,r"c Hi}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|dgt|t|dg||S)Nr.r0r/r2r1r4r3r6r5r8r7r:r9r<r;r=r?r>r@rArCrBrD)rrrTrs r _File_from_mldevrVsB !) +x ,VHd;9: + '3^$d;&HI + |$0[M4 j\#BC + }%1\ND{m$DE + ~&2]OT+ ~%FG +()*6&'k +()5%&[?:K(LM +y!-   [7)4i  r"c i}t|dgt|dgt|dgt|dg2t|dgt|dgDcgc]}t|||c}|Scc}w)N nextPageTokennext_page_tokenfiles)rrrV)rrrritems r _ListFilesResponse_from_mldevr\s !) +()5&'kO;L)MN +y!-  [7)4  Zy 9    s A* cVi}t|dgt|dgt|dg|S)N httpHeaders http_headersrrs r _CreateFileResponse_from_mldevr`2s6 !) + '3^$d;&HI r"c i}|SNrs r _DeleteFileResponse_from_mldevrd>s !) r"ceZdZdddeej dej fdZdddejdeejdejfdZ ddde deejdejfd Zddde deej dej"fd Zdddee ej*ej.ej2fdeej4dejfd Zdddeej deejfd Zdddee ejej<ej>fdeej@de!fd Z"y)FilesNr$r$rcHtj|}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||}|jjst!|j|}tj"j%||j' } |jj)| | S) aaLists 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 = client.files.list(config={'page_size': 10}) for file in pager.page: print(file.name) rg=This method is only supported in the Gemini Developer client.rKrZr?r$Ngetresponsekwargs)r _ListFilesParameters _api_clientvertexai ValueErrorr%rk format_maprpopr$ http_optionsr convert_to_dictencode_unserializable_typesrequestr\ListFilesResponse_from_response model_dump_verify_response selfr$parameter_model request_dictrequest_url_dictpath query_paramsru response_dict return_values r _listz Files._listJs(00O     I 3   Ol&))&1 !!"23##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL$$,, t\<M    $ $3   Mm**99'A'A'C:L %%l3 r"rGcJtj||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||} |jjst!|j| } tj"j%| |j' } |jj)| | S NrGr$rirKzupload/v1beta/filesrrjr$postrl)r _CreateFileParametersrprqrrrHrkrsrrtr$rur rvrwrxr`CreateFileResponserzr{r| r~rGr$rrrrrrurrs r _createz Files._creates 11 O     I 4   Ol&))&1 $//0@A$##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL$$,,lLM    $ $4   Mm++::'A'A'C;L %%l3 r"r.cJtj||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||} |jjst!|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.r$rirK files/{file}rrjr$Nrkrl)r _GetFileParametersrprqrrrOrkrsrrtr$rur rvrwrxrVFilerzr{r| r~r.r$rrrrrrurrs r rkz Files.gets(.. O     I 1   Ol&))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL$$,, t\<M    $ $&t'7'7Gm::,,'A'A'C-L %%l3 r"cJtj||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||} |jjst!|j| } tj"j%| |j' } |jj)| | 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/...') rrirKrrrjr$Ndeleterl)r _DeleteFileParametersrprqrrrRrkrsrrtr$rur rvrwrxrdDeleteFileResponserzr{r|rs r rz Files.deletes&11 O     I 4   Ol&))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL$$,,$ lM    $ $4   Mm++::'A'A'C;L %%l3 r"c |jjr tdtj}|r_t |t rtjdi|}n|}tj|j|j|j}ntj}|j/|jjdsd|j|_ t |tjr|j tdt|drd|jvr td|j!}|j#dt$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|} | jFd| jFvr tId| jFd} t |tjr*|jjK|| |j(|} n)|jjK| |j(|} tjjMtO|j| 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`. rir1r.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` argumentapplication/json resumablestartz Content-TypezX-Goog-Upload-ProtocolzX-Goog-Upload-Commandz#X-Goog-Upload-Header-Content-Lengthz!X-Goog-Upload-Header-Content-Type api_versionheadersrurx-goog-upload-urlPFailed to create file. Upload URL did not returned from the create file request.rGrlrc)*rprqrrr UploadFileConfig isinstancedictrr1r.r/ startswithioIOBasehasattrrtellseekosSEEK_ENDr3SEEK_SETfspathrisfileFileNotFoundErrorgetsize mimetypes guess_typerurr HttpOptionsrCreateFileConfigr_KeyError upload_filerzrVjsonr{ r~rGr$ config_modelfile_objoffsetfs_path_rurm upload_url return_files r uploadz Files.uploadTs     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|| e44,OH % h&;&; ;   &&':;J$ "$$00  H//l1k$$00 :x221k :: $ $!$"2"2K4D4DV4LM,2|&&( % 8: % r"cRtd|j|j||SNrZrg)rrr~r$s r listz Files.lists,   & !  r"c|jjr tdd}|r(t|trt j d i|}n|}t|t jr|j tdtj|j|}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 riNzOnly 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 :downloadaltmediarjrurrc)rprqrrrrr DownloadFileConfigrr>rMrNrr download_fileVideo video_bytesGeneratedVideovideo) r~rGr$rr.rrrudatas r downloadzFiles.downloadsQR    I L FD !//9&9  $ #(9(9(A  5  ==))4 0D D6 #D7#LV1Y|,- .DL L>*+7,(89l    ) ) ! * D $ $d K D%.. /DJJ4J#djj Kr")#__name__ __module__ __qualname__rr ListFilesConfigOrDictryr FileOrDictCreateFileConfigOrDictrrstrGetFileConfigOrDictrrkDeleteFileConfigOrDictrrrpathlibPathrPathLikerrUploadFileConfigOrDictrrrrrDownloadFileConfigOrDictbytesrrcr"r rfrfHs@DD ; ;<D DT8< 7   7u334 7   7tIMCC"*5+D+D"EC zzCLLPDD"*5+G+G"HD DT8< n #w||R[[")); <nu334 n  zz nb@D ; ;< UZZ:> O #uzz5;;0D0DD EOu556 O  Or"rfcjeZdZdddeej dej fdZdddejdeejdejfdZ ddde deejdejfd Zddde deej dej"fd Zdddee ej*ej.ej2fdeej4dejfd Zdddeej deejfd Zdddee ejfdeej<defd Z y) AsyncFilesNrgr$rcdKtj|}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{}|jjst!|j|}tj"j%||j' } |jj)| | 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) rgrirKrZrrjr$Nrkrl)r rorprqrrr%rkrsrrtr$rur rvrw async_requestr\ryrzr{r|r}s r rzAsyncFiles._list"s(00O     I 3   Ol&))&1 !!"23##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL**88 t\<M    $ $3   Mm**99'A'A'C:L %%l3 sD/F01F.2A=F0rGcfKtj||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd|||d{} |jjst!|j| } tj"j%| |j' } |jj)| | S7|wr)r rrprqrrrHrkrsrrtr$rur rvrwrr`rrzr{r|rs r rzAsyncFiles._createhs 11 O     I 4   Ol&))&1 $//0@A$##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL**88lLM    $ $4   Mm++::'A'A'C;L %%l3 D0F12F/3A=F1r.cfKtj||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} |jjst!|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) rrirKrrrjr$Nrkrl)r rrprqrrrOrkrsrrtr$rur rvrwrrVrrzr{r|rs r rkzAsyncFiles.gets(.. O     I 1   Ol&))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL**88 t\<M    $ $&t'7'7Gm::,,'A'A'C-L %%l3 rcfKtj||}|jjr t dt |j|}|j d}|rdj|}nd}|j d}|r|dt|}|jddd}|j,|jj|jj}tj|}tj|}|jjd |||d{} |jjst!|j| } tj"j%| |j' } |jj)| | 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/...') rrirKrrrjr$Nrrl)r rrprqrrrRrkrsrrtr$rur rvrwrrdrrzr{r|rs r rzAsyncFiles.deletes&11 O     I 4   Ol&))&1 (()9:##H-LvQy./ 0dXt$04L*  " " / / ;$++88l**<8L66|DL**88$ lM    $ $4   Mm++::'A'A'C;L %%l3 rc 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|d{} | jFd| jFvr tId| jFd} t |tjr2|jjK|| |j(|d{} n1|jjK| |j(|d{} tjjMtO|j| jPd|r|jSSiS777bw)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`. rirNrrrrrrrrrrrrrrrrrrGrlrc)*rprqrrr rrrrr1r.r/rrrrrrrrrr3rrrrrrrrrurrrrrr_rasync_upload_filerzrVrr{rs r rzAsyncFiles.upload,s     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\\ e44,O"H % h&;&; ;   &&':;J$ "**<<  H//l=k**<< :x22=k :: $ $!$"2"2K4D4DV4LM,2|&&( % 8: % -s8K/P1P2A>P0P11P"P#APPPcnKtd|j|j|d{|S7 wr)rrrs r rzAsyncFiles.lists8  jjj''   (s '53 5cK|jjr tdd}|r(t|trt j d i|}n|}tj|j|}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) riNrrrurrrjrrc) rprqrrrrr rrMrNrrasync_download_file) r~rGr$rr.rrurrs r rzAsyncFiles.downloadsF    I L FD !//9&9  ==))4 0D D6 #DL L>*+7,(89l7#LvQy./ 0d!!55 !6 D K  sCCC C)!rrrrr rryrrrrrrrrrkrrrrrrrrrrrrrrrrrrcr"r rr s@DD ; ;<D DT8< 7   7u334 7   7tIMCC"*5+D+D"EC zzCLLPDD"*5+G+G"HD DT8< m #w||R[[")); <mu334 m  zz m`@D ; ;<%**:> @ #uzz/ "@u556 @  @r"rrb)-rloggingrrrtypingrrr urllib.parserrrr r rMr rpr r rrrpagersrr getLoggerloggerrobjectr!r%r+rErHrOrRrTrVr\r`rd BaseModulerfrrcr"r rs9$  ''" &..%   / 0 %)tV|$D> 2%)tV|$D> *%)tV|$D> *%)66tV|$6D>6 6x%)tV|$D> ,%)tV|$D> ,%)tV|$D> ,%)tV|$D> *%)66tV|$6D>6 6x%)tV|$D> 2%)  tV|$ D>  %)tV|$D> UK " "UpE''Er"