uPjE UddlZddlmZmZddlmZddlmZmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZmZmZmZdd lmZdd lmZer dd lmZdd lmZdZ e e!d<dZ"e e!d<eddZ#e e!d<dZ$e e!d<eddZ%e e!d<eddZ&e e!d<dee'de'fdZ(de'de'de'fd Z)d!e'de'de*e'e'ffd"Z+d!e'de'de'de,e'e'ffd#Z-d$e.de'dzfd%Z/d$ede,e'e.ffd&Z0d6d'Z1 d7d$e.d(e'de'fd)Z2 d8d$e.d*ede'dzddfd+Z3d$e.d*ede'de.fd,Z4de'de'de'dzfd-Z5de'de'de'dzfd.Z6d!e'd*ede'de*e'e'ffd/Z7d$e.dee.dzfd0Z8d9d$ed1e9e.d2e:de.fd3Z;d*edee'fd4Ztjt|S)uJSON-encode the sorted scope list — using a separator like ``|`` would collide for any tenant whose user_id / team_id / org_id / api_key happens to contain the separator. JSON quoting escapes every separator that matters.)jsondumpssorted)r!s p/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/proxy/container_endpoints/ownership.py _allowed_container_ids_cache_keyr(2s ::f\* ++original_container_idcustom_llm_providerctd|d|S)N:)r)r*r+s r'_container_model_object_idr.:s& 'q)<(=Q?T>U VVr) container_idctj|}|jd|}|jd}|r|dk(r|}||fS)N response_idr+openai)r_decode_container_idget)r/r+decodedr*decoded_providers r'!decode_container_id_for_ownershipr7>sP-BB<PG#*;;}l#K%kk*?@/8;. "5 55r)cdK||d}tj|}|jd}t|tr|sUt ||d{}|r?||k7r:tj|}|jd}t|tr|r|}t|tr|r||d<|S7^w)N)r/r+model_id)rr3r4 isinstancestr_get_stored_container_id) r/r*r+paramsr5r9 stored_idstored_decodedstored_model_ids r'get_container_forwarding_paramsrAGs.2F.BB<PG{{:&H x %( "::OQd!ee l2$<$Q$QR[$\N%3%7%7 %CO/3/O*(C X%z MfsA B0B.AB0responsec|yt|tr|jd}n t|dd}t|tr|SdS)Nidr:dictr4getattrr;)rBvalues r'_get_response_idrIasE(D! T"$-uc*544r)ct|tr t|St|dr|jSt|dr|jSdt |iS)N model_dumprFrD)r:rFhasattrrKrI)rBs r'_dump_responserMksV(D!H~x&""$$x }} "8, --r)cKddlm}|Sw)Nr prisma_client)litellm.proxy.proxy_serverrPrOs r'_get_prisma_clientrRus8 s defaultci}t|tr|jdxsi}nt|ddxsi}|jd}t|tr|r|S|S)N_hidden_paramsr+rE)rBrS hidden_paramsproviders r',_custom_llm_provider_from_responses_responserX{sb+-M(D! %56<" *:DAGR #''(=>H(C X Nr)user_api_key_dictcKtj|}|sy|xs t|}|D]} t|dd||d{y7#t$r!}t j d||Yd}~Gd}~wwxYww)zITrack containers created implicitly by code interpreter in /v1/responses.Nr)rDobject)rBrYr+zRFailed to record container ownership from responses output for container_id=%s: %s)r-collect_container_ids_from_responses_responserXrecord_container_owner Exceptionr exception)rBrYr+ container_idsresolved_providerr/es r'/record_container_owners_from_responses_responsercs 4aabjkM 2l6bck6l%  ( , D"3$5      ! * *d   s@-A;AA A A; A A8A3.A;3A88A;c Kt|}|tjd|St|}| t ddt ||\}}t ||}t|}||d<||d<tj|} td{} | tjd|St| j} | jd|i d{} | gt| d dtk7r t d d t!t| d d|s t dd| j#d|i|| |dd{n%| j%||| t||dd{t&j)||t*j)||t-|} | rt.j1t3| |S76777dw)NzISkipping container ownership tracking because provider response has no idzCUnable to record container ownership: caller has no identity scope. status_codedetailr+provider_container_idzCSkipping container ownership tracking because prisma_client is Nonemodel_object_idwhere file_purposeizUnable to track container created_by Forbidden)unified_object_id file_object updated_by)rldata)rprjrqrmrnrr)rs)rIr warningr r r7r.rMr$r%rRrtable find_uniquerGrrupdatecreater set_cacherrr delete_cacher()rBrYr+r/ownerr*rarjrqfile_object_jsonrPruexisting caller_scopess r'r]r]s +84L$$%pq34EFE }X  0QQ]_r/s,,78MO`aO'1K):K%&+@K'(#'::k#:!3!55M$$%jk*=9??E!--5F4X-YYH 8^T 26N NC8ST T-gh d.SUfgC D Dll$o6%1/#   ll%1#2/ 8##   $$_e<((,G 55FGM$112RS`2ab OS6 Z   sKBGG A GG A'GG%G+G,AG GGGcKt||}tj|}|tk(ry||St d{}|yt |j }|j|tdd{}| t|ddnd}tj|||nt| t|ddnd}tj|t|tr |r||St|S77|w)Nrjrmrkrnrp)r.r get_cacherrRrru find_firstrrGryrr:r;r) r*r+rjcachedrPrurowr{r>s r'_get_container_ownerrs78MObcO*44_EF ))  !3!55M*=9??EHMHXHX.4 IYICC DG?wsL$?X\E$$_u?PeVnoNQo730CT#JcgI(( C0Y LEa L%6 Cs#=C7C38C78C59A;C75C7cKt||}tj|}|tk(ryt |t r|r|St d{}|yt|j}|j|tdd{}| t|ddnd}tj|t |t r|r|ntt |t r|r|SdS77[w)aTReturn the ``unified_object_id`` stored at create time, if any. Used by :func:`get_container_forwarding_params` to recover the deployment ``model_id`` for native upstream container IDs: the stored value is the encoded form produced by ``encode_container_id_in_response`` when the router selected a specific deployment. Nrrkrp) r.rrrr:r;rRrrurrrGry)r*r+rjrrPrurr>s r'r<r<s88MObcO.88IF --&#6 !3!55M*=9??EHMHXHX.4 IYICC ORo730CT#JcgI(( C0YD`#9c2y9JdJ!6 Cs%A C&C"8C&C$ AC&$C&cKt||\}}t|r||fSt||d{}t||s t dd||fS7!w)Nrerorf)r7rrrr )r/rYr+r*rar{s r' assert_user_can_access_containerr6sp 0QQ]_r/s,,'($&777 ..CEVWWE )%1B CK@@ "3 33 Xs.AA"Ac|yt|tr|jd}n t|dd}t|tr|SdS)Nrs)r:rFr4rGlist)rBrss r'_get_container_list_datarJsE(D!||F#x.dD)43t3r)rsremoved_filtered_itemscht|trB||d<|r#t|d|d<t|d|d<nd|d<d|d<d|d<|rd|d<|S||_|rt|dnd|_|rt|dnd|_|st |drd|_|rt |drd|_|S)Nrsrfirst_idlast_idFhas_more)r:rFrIrsrrrLr)rBrsrs r'_set_container_list_datarTs(D! #3DG#s#N_aeAfAr#--sKs!**9d;6GH !6 G ts=AC.C%AC.C'C.!C)4C)$C.'C.)C.c>Kt|r|St|}||St|d{}g}|D]?}t|}|t ||\}} t || |vs/|j |At||t|t|k7S7mw)N)r) rrrrIr7r.appendrlen) rBrYr+rsallowed_container_idsfiltereditemr/r*ras r'filter_container_list_responsers '(*84D |)CDU)V#V$&H"'-   3TUacv3w00 %&;=N OSh h OOD ! " $HhsS[}`cdh`iOi jj$Ws+BB6B%7B)r"zPrismaClient | None)r2)N)F)>r$collections.abcrrr AbstractSettypingrrrfastapir litellm._loggingr litellm.caching.in_memory_cacher litellm.proxy._typesr -litellm.proxy.common_utils.resource_ownershipr rrr'litellm.repositories.table_repositoriesrlitellm.responses.utilsrprismar prisma_modelslitellm.proxy.utilsrr__annotations__rrrrr r;r(r.tupler7rFrAr[rIrMrRrXrcr]rr<rrrboolrrrr)r'rs -.,,!19/ L<.0#.%- #C%B -TV WW 'KeJ$1UXZ$[E['4tY[&\e\,8C=,S,WcWPSWX[W6C6c6V[\_ad\dVe6.1HK #s(^45v5#*5.S.T#v+%6.      &'+%t >HH%HH HVcPSX[^bXb< K# KTW K\_bf\f KF44%44 38_ 4(4v4(62BT2I4s$v,X\io0%>kk%kk kr)