s-j&ddlmZddlZddlmZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZgdZd eDZd6dZd7dZd8dZd9dZd:dZd;dZdd3Z"d?d5Z#dS)@) annotationsN)datetime)Any)urlparse) ActionDescriptor ActionMode AttentionItem DisplayPolicyKpiItemModuleIdModuleSnapshot ModuleStatus SensitivitySeverity SourceHealth SourceTypeutcnow)assert_safe_module_snapshot) amount_chfcash_value_chftotal_value_chfportfolio_value_chfbalancesaldorevenueexpensezbudget[_\s-]*amountzaccount[_\s-]*nameiban transactioncsvxlsxpdfz db[_\s-]*pathzruntime[_\s-]*pathlocal_original_path drive_web_urltokensecretpasswordapi_keyz /home/agentzfinance\.sqlitecLg|]!}tj|tj"S)recompile IGNORECASE).0patterns Y/home/agent/projects/Jarvis/apps/api-gateway/jarvis_gateway/adapters/finance_sanitizer.py r04s& Z Z ZGRZ / / Z Z Zurl str | NonereturnboolcP|sdSt|}|jdko|jdvS)NFhttp> 127.0.0.1 localhost)rschemehostname)r2parseds r/_is_safe_local_urlr=7s4 u c]]F =F " Tv:T'TTr1payloaddict[str, Any]keysstr bool | Nonec|D]^}||}t|tr|cSt|trt |dddd}||cS_dS)Nok connected reachablehealthy)get isinstancer5dict _bool_from)r>r@keyvaluenesteds r/rKrK>sy C   eT " " LLL eT " " t[+yQQF! 4r1datetime | NonecdD]}||ttr[tfdtDs; t jddcS#t$rYwxYwdS)N)last_success_atlast_successful_sync_at last_sync_at generated_atc3BK|]}|VdSN)search)r-r.rMs r/ z"_safe_timestamp..Ms/-]-]gnnU.C.C-]-]-]-]-]-]r1Zz+00:00) rHrIrAany _COMPILEDr fromisoformatreplace ValueError)r>rLrMs @r/_safe_timestampr_Js] C   eS ! ! #-]-]-]-]S\-]-]-]*]*]  -emmC.J.JKKKKK     4s'A;; BBrMr int | Nonec<t|trd|cxkrdkrnn|St|trtt |dSt|t r-dD]*}t ||}||cS+dS)Nr') review_items review_countpending_reviewscount)rIintlistminlenrJ _count_valuerH)rMrLfounds r/rkrkUs%!u"4"4"4"4"4"4"4"4"4 %%3u::t$$$%O  C 300E  ! 4r1key_namergcVt|trbd}|D]I\}}|kr+t|trd|cxkrdkr nn||z }6|t |z }J|St|t rt fd|DSdS)Nrrbc38K|]}t|VdSrV)_sum_key)r-itemrms r/rXz_sum_key..ls->>8D(++>>>>>>r1)rIrJitemsrgrprhsum)rMrmtotalrLrNs ` r/rprpbs% ;;== 4 4KCh:fc#:#:qF?R?R?R?Rd?R?R?R?R?R&(333 %?>>>>>>>>>> 1r1provider_payloadct|trHd|D}|sdStd|DrdStd|DrdSdSt|trt |dddSdS) Ncg|]L}t|tt|ddMS)status)rIrJrArHlower)r-rqs r/r0z'_provider_connected..rsLoooDXbcgimXnXnoC2..//5577ooor1c3K|]}|dvV dS)>rDreadyrGrENr)r-rxs r/rXz&_provider_connected..us(XXVv@@XXXXXXr1Tc3K|]}|dvV dS)>errorofflinedegradedNr)r}s r/rXz&_provider_connected..ws(QQfv99QQQQQQr1FrErDrF)rIrhrZrJrK)rustatusess r/_provider_connectedrps"D))ooDTooo 4 XXxXXX X X 4 QQQQQ Q Q 5t"D))L*K{KKK 4r1 provider_ok runtime_ok audit_statusrcb|dur tjS|dus|dvr tjStjS)NF>rwarning)rDEGRADED ATTENTIONOK)rrrs r/_status_from_sourcesrs=U$$e|/CCC%% ?r1nowrtitlemessageseverityrdeduper ctd|tj|||tj|t ddt jtjddddd| S)N att_finance_uFinance prüfen/financeFlabelhrefmode sensitivityblocked_reasonpreview_requiredconfirm_requiredaudit_requiredzfinance.) id module_idrrrr created_ataction dedupe_key)r r FINANCEr SENSITIVErr LINK_ONLY)rrrrrs r/ _attentionrsy  "& " "")#%#-""     'f&&%   r1)legacy_dashboard_urllast_attempt_atrawrrr c |rt|std|p t}t|dt r|dn|di}t|dt r|dn|di}t|dt r|dn|di}t|dt r|dn|d i}|}t|t r|ni}t|t r|ni}t|t r|ni}t|t r|ni}t |} t|d d d } t|d d d } | d uo| d u} |dp+|dp|dpd } t|  dvr!t|  nd }t|p3t|dp#t|dpd}t|p#t|pt|p| r|nd}t| | |}tdd|d|r tjn tjt$jt(jdtdd| rdn| d urdndd| r tjn tjt$jt(jdtd d!| rdndd| r tjn tjt$jt(jd"g}g}|r0|t3|d#d$tjd%| d ur0|t3|d&d'tjd|d(vr0|t3|d)d*tjd+| s0|t3|d,d-tjdt5d.d/t6jt$jdd d d 0}|g}|r>|t5d1|t6jt$jdd d d 0t;t<jd2|t$jt(j||d3|t@j!t@j"hvrdnd4tG| dtHj%d5d6|d| 7||dd8||d69}|&d:;}tO|tQ||S)rDrr review_neededreviewsrrcz Review ItemsrrzCount only; no amounts.)rLrrMunitrrdisplay_policy help_textprovider_connectedzProvider verbundenJaNein Unbekanntz Status only.runtime_reachablezRuntime erreichbarzReachability only.u Review nötigu2FinanceManager meldet Review-Bedarf ohne Beträge.reviewzProvider degradiertz%Finance Provider ist nicht verbunden.>rruImport Audit prüfenz.Import Audit meldet einen sicheren Warnstatus.auditzRuntime offlinez,FinanceManager Runtime ist nicht erreichbar.z Open FinancerrzLegacy Finance DashboardFinanceManageri,finance_source_degradedzfinance-readonly-v1zjarvis.module_snapshot.v1)rF latency_ms source_typeversioncontract_versionrQlast_error_redactedstale)rrrxrrrQrstale_after_secondsdegraded_reason source_healthkpisattention_itemslinksprimary_actionrjson)r))r=r^rrIrHrJrrKrArzrkrpr_rr rWARNINGSUCCESSrrr SUMMARYINTERNALERRORappendrrrrr r rrrrrrHTTP_API model_dump"assert_no_sensitive_finance_outputr)rrrrrrrrrurr health_okrFaudit_status_rawrrd last_successrxr attentionprimaryrsnapshotr>s r/sanitize_finance_payloadrs[8$67K$L$L86777  %VXXC&01D1Dd&K&Koswwz"""QTQXQXYjlnQoQoH$.swwy/A/A4$H$Hkcggi   cggVfhjNkNkG",SWWX->->"E"E aSWWX   377S\^`KaKaF",SWWX->->"E"E tSWWX   377SoqsKtKtF%h55=xx2H#GT22:ggG!&$// 7VVRF!&$// 7VVRF%&677KG[$ BBJ64K@@I%'BIU,BIzz(++ovzz./I/IoVZZXfMgMgoko478H4I4I4O4O4Q4QUo4o4o3'((..000uyL''u8FO+L+LuP\]`]d]den]o]oPpPputuL"6**~og.F.F~/Z]J^J^~jsc}cfcfy}L !+z< H HFN. SZzFf\emeueuLTL\jujP]PeqJ K K K(0DT_MUDDozDpDpDekekJU\`Jk`ksk{k{PXP`nynBS`ShtB C C C'/CS\Kh44bhosS\pGOObjbp~I~RcpcxDX Y Y Y D &(IMC:npxqACKLL M M MeC)>@giqiy|FGG H H H+++C)?Aqs{tDFMNN O O O HC):textr.s r/rrsT w<>$   JHII I JJJr1)r2r3r4r5)r>r?r@rAr4rB)r>r?r4rO)rMrr4r`)rMrrmrAr4rg)rurr4rB)rrBrrBrrAr4r) rrrrArrArrrrAr4r )rr?rr3rrOr4r )r>rr4r)$ __future__rr*rtypingr urllib.parserjarvis_gateway.contractsrrr r r r r rrrrrrjarvis_gateway.redactionrFORBIDDEN_FINANCE_PATTERNSr[r=rKr_rkrprrrrrr)r1r/rs"""""" !!!!!!A@@@@@6 [ Z?Y Z Z Z UUUU                 .Y]BF<<<<<<~JJJJJJr1