+ lHj8ba0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t ^RI H t H t ^RIHt^RIHtHtHtHtHt^RIHt^RIHt^R IHtHt^R IHtHt]P@!]!4t".R;Ot#RR)R*lt?R+R,lt@R-R.ltAR/R0ltBR1R2ltCR3R4ltDR5R6ltER7R8ltFR9R:ltGR#)=aFile inputs and outputs of connector tools. The model passes a local path wherever a tool takes a file. Before execute, each path is checked with the media-delivery rule (the one that guards ``MEDIA:`` attachments), staged through the tool gateway, and PUT to the presigned storage URL; the gateway's descriptor replaces the path. Files a tool returns are downloaded at once into the profile's connector downloads folder, and the model sees ``{name, mimetype, path}``. Storage URLs and keys never reach the model or the logs. ) annotationsN)replace)UTCdatetime)Path)AnyIteratorMappingOptionalSequence)ToolGatewayError) PlannedCall)parse_connector_namevendor_slug_candidates)CONNECTOR_FILE_MAX_BYTESexecute_error_familyFileInputErrorzPass a local file path.*localdockerz[\x00-\x1f\x7f<>:\"|?*\\/].zdict[str, tuple[Path_, ...]] _FILE_INPUTSc]tRt^5tRtRtR#)_Stagedz`A descriptor this dispatch staged; a second file-input path over the same value leaves it alone.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rC/home/ubuntu/.hermes/hermes-agent/tools/connectors/gateway/files.pyrr5sjr rcFa]tRt^9tRtRR/RV3RllltRRltRtV;t#) rzBA file input refused before the call reached execute; nothing ran.hintNc(V^8dQhRRRRRRRR/#)codestrmessager# Optional[str]returnNoner)formats"r! __annotate__FileInputError.__annotate__<s)S3RVr c ><\SV`V4WnW0nR#N)super__init__r&r#)selfr&r(r# __class__s&&&$r!r2FileInputError.__init__<s !  r cV^8dQhRR/#)r%r*dict[str, Any]r)r,s"r!r-r.As...r c RVPR\V4R\VP4/pVP'dVPVR&RRRV/#)zGThe call's error entry, in the shape the gateway's execute errors take.r&r(familyr#dataNerror)r&r'rr#)r3r;s& r!resultFileInputError.resultAsN!'Is4y(ThimirirTs t 999 IIE&Mgu--r )r&r#) rrrrrr2r<r __classcell__)r4s@r!rr9s!L ..r c$V^8dQhRRRRRR/#)r%namer' input_schemarr*r7r)r,s"r!r-r-Ns!**3*c*n*r c \V\4'g/#\\P\ WR^444\ V&\ V4#)zThe tool's parameters as the model sees them (file inputs become path strings); records the file-input argument paths for ``name`` so execute knows what to stage.r) isinstancedicttuplefromkeys _file_pathsr_as_model_schema)r@rAs&&r!model_parametersrINsD lD ) ) t}}[UWYZ-[\]L L ))r c V^8dQhRRRR/#)r%noderr*r)r,s"r!r-r-WsII3I3Ir c\V\4'dVUu.uFp\V4NK up#\V\4'gV#VP R4RJd9VP R4;'gR R\ 2P 4pRRRV/#VP4UUu/uFwr4V\V4bK upp#uupiuuppi)file_uploadableT description typestring)rClistrHrDgetFILE_INPUT_NOTEstripitems)rKitemrNkeyvalues& r!rHrHWs$37844 &488 dD ! !  xx!"d*-066B7q8IJPPR -==;?::< H%> #D /D xx!"d* -hhv&,,",F"6qyA A A-.,'J*d##$**,JC"5 $  eaiH H H-488G,d4Hd4HK4H%RS)TTT B ITs=A)D3,D3D- A$D3-D/.8D3&D1'D3/D31D3c$V^8dQhRRRRRR/#)r%clientrplanr r*ztuple[Path_, ...]r)r,s"r!r-r-vs"##s#+#:K#r caVP\9d\VP,#\VP4pVfR#\VPVP 4pVP \V44;'g/PR4;'g/o\T3RlT4/4p\TPTPR4;'g/4\TP,# \d8p\PRTPTP4RuRp?#Rp?ii;i)zOThe plan's file-input paths: recorded by search or describe, else fetched once.NschemaszQconnector %s: schema fetch for file inputs failed (%s); executing without stagingc3<"TF5p\SPV4\4'gK*SV,xK7 R#5ir0)rCrTrD).0slugrqs& r! %_known_file_inputs..s-_ZT:gkkRVFWY];^=74==Zs 'AArAr)r@rrr connectortoolrqrSrTr loggerwarningr&nextrI)rnroparsed candidatesexcschemarqs&& @r!_known_file_inputsrvs yyL DII&& !$)) ,F ~ '(8(8&++FJ>>$z"2399r>>yIOOR _Z_ac dFTYY > : @ @bA  "" jyy#(( , s** D D$D E,E:EEc(V^8dQhRRRRRRRR/#)r%rnrror task_idr)r*r)r,s"r!r-r-s( 8 8 8K 8] 8{ 8r caaa\SP4'gS#\SS4pV'gS#SPpVFp\WEVVV3Rl4pK \ SVR7#)z``plan`` with each file-input path replaced by a staged descriptor for ``plan.tool``. Raises ``FileInputError`` when a path is refused or a stage fails; nothing is executed then.c <\SSVS4#r0) _stage_one)rawrnrors&r!stage_inputs..sZPTVY[b=cr ) arguments) _has_textrr _substitutedataclass_replace)rnrorpathsrr]sffd r! stage_inputsrsZ T^^ $ $ vt ,E  I 1cd  TY 77r c V^8dQhRRRR/#)r%rZrr*boolr)r,s"r!r-r-sSTr c\V\4'dR#\V\4'dQ\;QJd*RVP 44F 'gK R# R#!RVP 444#\V\ \ 34'd5\;QJdRV4F 'gK R# R#!RV44#R#)zCA file input needs a string; a call with none has nothing to stage.Tc38"TFp\V4xK R#5ir0rrsrXs& r!ru_has_text..s>~t9T??~Fc38"TFp\V4xK R#5ir0rrs& r!rurs5ut9T??ur)rCr'r anyvaluesrSrErZs&r!rrs%%!!s>u||~>ss>s>s>u||~>>>%$''s5u5ss5s5s5u555 r c$V^8dQhRRRRRR/#)r%rZrr]z Sequence[str]r*r)r,s"r!r-r-s!s-3r cV'gb\V\4'd V!V4#\V\4'd,\V\4'gRV9d\ RRRR7hV#V^,VR,rCV\ 8Xd5\V\ 4'dVUu.uFp\WTV4NK up#T#\V\4'dW09d/VCV\W,WB4/C#V#uupi)zbA copy of ``value`` with the leaf at ``path`` staged; missing or non-path leaves stay as they are.s3keyFILE_NOT_ALLOWEDz=File inputs take a local file path, not a storage descriptor.z(Pass the path of the local file to send.r#:NN)rCr'r rrrirSr)rZr]stageheadrestrXs&&& r!rrs  eS ! !<  eW % %j.H.HWX]M] !35t&PR R a$r($ {EOPUW[E\E\5A54 D.5Agbgg%!!dmE%E{5;DEE LBs C0c ,V^8dQhRRRRRRRRR R /#) r%rnrror rr'rr)r*zdict[str, str]r)r,s"r!r-r-s0))s)+)C)-)Tb)r c ~\W#4p\W$4p\V4PR Rp\P !V4^,;'gRpVP VPP4VPVV\V4R7pTPTR,TR ,T4\!TR ,4# \d@p T PR8Xd\R\T 44T h\RRT RT 24T hRp ? ii;i \dp \RR T R T 24T hRp ? ii;i)Nzapplication/octet-stream)toolkitrxfilenamemimetypesizeTOOL_NOT_ALLOWEDFILE_UPLOAD_FAILEDz!The tool gateway could not stage z: upload_urlheadersz Uploading z to storage failed: descriptori)_readable_file _read_bytesrr@ mimetypes guess_type stage_filerwlowerrxlenr r&rr'put_filer) rnrorrr]r:r@rstagedr~s &&&& r!rrsD # 'D s !D :??45 !D##D)!,JJ0JHo""4>>+?+?+A \`,43t9#F j|,fY.?F 6,' (( o 88) ) !3SX>C G15VW[V\\^_b^c3deknno j1ZvEYZ]Y^3_`fiijs1AC !D D:DD D<$D77D<c$V^8dQhRRRRRR/#r%rr'rr)r*r)r,s"r!r-r-s&@@@m@@r c^RIHp^RIHp\ W4pV!WC!RR4R7pV'dV#\ V4P 4'g\RV R2RR 7h\R V R 2R R 7h) z`The host path of a file the model may send, by the media-delivery rule; else ``FileInputError``.)validate_media_delivery_path)get_session_envHERMES_SESSION_KEYrO) session_keyFILE_NOT_FOUNDz' is not a regular file on this machine.z"Pass the path of an existing file.rrz@ may not leave this machine: the file-sending policy refuses it.zyFiles under the Hermes downloads and cache folders, or a folder listed in gateway.media_delivery_allow_dirs, can be sent.)gateway.platforms.basergateway.session_contextr _backend_pathris_filer)rrrr candidatealloweds&& r!rrsC7c+I*9/RfhjBklG  ? " " $ $-#6]/^"FH H se#cd? @@r c$V^8dQhRRRRRR/#rr)r,s"r!r-r-s! 2 2s 2] 2s 2r c^RIHpHpT;'gRpV!V4pV\9d\ RRV R2RR7h\ V!W44#)z``raw`` as an absolute path in the terminal backend's namespace, resolved the way the file tools resolve it. Backends whose files live on another machine are refused, as ``MEDIA:`` is.)_resolve_path_for_task_terminal_env_type_for_taskdefaultrz Files in the z\ terminal backend are not on this machine, so they cannot be sent as a connector file input.zNUse a file on this machine, or switch to the local or Docker terminal backend.r)tools.file_tools_pathsrr_HOST_READABLE_BACKENDSrr')rrrrtaskbackends&& r!rrsb[   iD)$/G-- -y9@!@ac c %c0 11r c$V^8dQhRRRRRR/#)r%rr'r]r*bytesr)r,s"r!r-r-s!  S   r c ~\PPV4pV\8d(\ RV RVR , R\R , R24h\ V4P 4pT'g\ RT R24hT# \d-p\ RT RTP;'gT R24ThRp?ii;i) FILE_TOO_LARGEz is z+ MiB; connector file inputs are limited to z MiB.rz could not be read: .Nz is empty.i) osr]getsizerrr read_bytesOSErrorstrerror)rr]rr:r~s&& r!rrslwwt$ * * !1$'5Tk-B,CCn$<$M#Ne"UV VDz$$& -#j/ABB K l-#6J3<>>c>c>r c\V\4'd'VPR4fVPR4fV#/VCR\WR,4/C#)zA successful result with each ``{name, mimetype, url}`` replaced by ``{name, mimetype, path}``, or ``{name, mimetype, error}`` when the download failed. Errors and replays pass through.r;r:)rCr rT_saved)rnr<s&&r! save_outputsrsN fg & &&**W*=*IVZZX^M_Mg =f =ffVF^< ==r c$V^8dQhRRRRRR/#)r%rnrrZr*r)r,s"r!r-r- s&FF3FsFsFr c >\V\4'dVUu.uFp\W4NK up#\V\4'gV#\ V4'd \ W4#VP 4UUu/uFwr2V\W4bK upp#uupiuuppir0)rCrSrr _is_file_output _downloadrW)rnrZrXrYs&& r!rr s%167v$77 eW % % u''7<{{} E})#C% %} EE 8 Fs B9Bc V^8dQhRRRR/#)r%rZMapping[str, Any]r*rr)r,s"r!r-r-s99,99r ca\;QJdV3RlR4F 'dK RM RM!V3RlR44;'dSR,PR4#)c3b<"TF$p\SPV4\4xK& R#5ir0)rCrTr')rsrYrZs& r!ru"_is_file_output..s%V:U3z%))C.#..:Us,/urlFT)r@rr)zhttps://zhttp://)all startswithrsfr!rrsE 3V:UV333V:UV V 9 9 e  789r c$V^8dQhRRRRRR/#)r%rnrfilerr*r7r)r,s"r!r-r-s"c!2~r chVP4UUu/uFwr#VR9gKW#bK ppp\WR,VR,4VR&V#uuppi \\3dNp\P R\ TR,4\T4P4RT 2TR&Rp?T#Rp?ii;i)rr@r]z(connector file download of %s failed: %szdownload failed: r;N)r expiresAt) rW_fetch_to_downloadsr rryrz _safe_namerQr)rnrrYrXkeptr~s&& r!rrs'+zz| W|)#sBV7VICI|D W2*6;V MV  K X g &2A:dSYlC[]abe]f]o]op+C51W K2s" A A AB1$AB,,B1c(V^8dQhRRRRRRRR/#)r%rnrrr'r@r*r)r,s"r!r-r-"s(222#2S2S2r c ^RIHpHpHpV!V!4V, 4p\P !VRRR7pV;_uu_4VP WP\R7RRR4\V\V44p\P!VPV4\V4\VP4P!RR7# +'giLv;i \TP4P!RR7i;i) zStream ``url`` into a temp file, then link it under a fresh name: a cut download never leaves a partial file under the final name, and an existing file is never replaced.)CONNECTOR_DOWNLOADS_SUBDIRget_hermes_homemkdir_under_hermes_homez .partial-F)dirprefixdelete) max_bytesNT) missing_ok)hermes_constantsrrrtempfileNamedTemporaryFileget_filewriteDOWNLOAD_MAX_BYTES _reserve_namerrrr@r'runlink) rnrr@rrrfolderhandletargets &&& r!rr"sfe $_%69S%S TF  ( (VKPU VF2 V OOC9KO Lvz$'78 6;;'6{ V[[  D 1 V V[[  D 1s$ C&"C%AC& C# C&&'D c$V^8dQhRRRRRR/#)r%rrr@r'r*r)r,s"r!r-r-3s! 6 6$ 6c 6d 6r c~\P!\4PR4p\P P V4wr4\R4FEpY^8XdV RV 2M V RV RV V 2, pVPR4P4Vu# \RV 24h \dKei;i)zYCreate an empty file under a fresh ``-``; the download then replaces it.z%Y%m%dT%H%M%SZi-xbzno free name for ) rnowrstrftimerr]splitextrangeopencloseFileExistsError)rr@stampstemsuffixattemptrs&& r!rr3s LL  & &'7 8E77##D)LD;1 eWAdV,UG1TFRST[S\]c\dBef  KK  # # %  -dV4 55   s:B-- B<;B<c V^8dQhRRRR/#)r%r@r'r*r)r,s"r!r-r-As00S0S0r c\P!RV4R,p\PRV4P 4P R4pV\ )R;'gR#)zPA basename safe on every OS: no separators, control characters, or ``.``/``..``.z[\\/]_rNr)resplit_UNSAFE_NAME_CHARSsubrV_MAX_NAME_CHARS)r@basecleaneds& r!rrAsV 88Hd #B 'D $$S$/557==cBG O#$ % / //r )rrrIrri )H__conditional_annotations__r __future__rloggingrrrr dataclassesrrrrpathlibrtypingrrr r r tools.connectors.gateway.errorsr tools.connectors.gateway.merger tools.connectors.gateway.namesrrtools.connectors.gateway.wirerr getLoggerrry__all__rrUrirh frozensetrcompilerrrEr'r^r__annotations__rDr ExceptionrrIrHrGrrrrrrrrrrrrrrr)r s@r!r0s # 4"==<6WX   8 $ &+ $Wh$78ZZ => c3h-/ */kdk .Y .**IU(#0 8")&@$ 2 (>F9 2" 60r