uPj&UdZddlZddlmZddlmZmZddlmZddl m Z m Z m Z ddl mZerddlmZehd Zeed <Gd d e eZy) z? User repository for database operations on LiteLLM_UserTable. N)Mapping) TYPE_CHECKINGFinalLiteLLM_UserTable)BaseRepositoryDbRecordrecord_to_dict) TableActions)models>metadata model_spendmodel_max_budget_JSON_ENCODED_COLUMNSc*eZdZdZededfdZedeefdZ de dzdedzfdZ d,d e d e dedzffd Z d e dedzfdZde dedzfdZde deefdZde deefdZdefdZ d-d e de dzde dzde dzde dzde dzdee dzde dzdedzd e dzdee dzdee efdzdedzdedzdedzd e dzd!ee dzd"ee dzd#e dzdef(d$Z d-d e de dzde dzde dzde dzde dzdee dzde dzdedzd e dzdee dzdee efdzdedzdedzdedzd e dzd!ee dzd"ee dzd#e dzdedzf(d%Zd e d e defd&Zd e dedzfd'Zd e d(ededzfd)Zd e de dedzfd*Zd e de dedzfd+ZxZS).UserRepositoryz(Repository for user database operations.returnzprisma_models.LiteLLM_UserTablecB|jjjSN) prisma_clientdblitellm_usertableselfs i/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/repositories/user_repository.pytablezUserRepository.tables!!$$666ctSrrrs r model_classzUserRepository.model_classs  rrecordNc |ytjt|jDcic]5\}}||tvr%t |t rtj|n|7c}}Scc}}w)z*Convert a database record to a User model.N) rmodel_validater itemsr isinstancestrjsonloads)rr columnvalues r _to_modelzUserRepository._to_modelsq > //&4F%;%A%A%C !FEV7L-LQ[\acfQg 5)mrr    s:A1 user_idid_valueid_fieldc@Kt|||d{S7wr)super find_by_id)rr,r- __class__s rr0zUserRepository.find_by_id*sW'(;;;;s  user_emailcXK|jd|id{}|r|dSdS7 w)zFind a user by email.r2whereNr find_many)rr2recordss r find_by_emailzUserRepository.find_by_email-s5#~~\:4N~OO$wqz.$.Ps *(* sso_user_idcDK|j|dd{S7w)zFind a user by SSO ID.r:r-N)r0)rr:s rfind_by_sso_idzUserRepository.find_by_sso_id2s__[=_IIII   organization_idcFK|jd|id{S7w)z"Find all users in an organization.r?r4Nr6)rr?s rfind_by_organization_idz&UserRepository.find_by_organization_id6s#^^+sZ !ZZ\)#'::Z=/eijoepAq4r:#ss 1ek)***ss!AA%AAAA user_aliaspasswordrD user_role max_budgetr r max_parallel_requests tpm_limit rpm_limitbudget_durationallowed_cache_controlspoliciesobject_permission_idcjKd|i}|||d<|||d<|||d<|||d<|||d<|||d<|||d <| | |d <| | |d <| | |d <| tj| |d <| | |d<|||d<|||d<|||d<|||d<|||d<|||d<|j|d{S7w)zCreate a new user.r+NrSrBr:r?rTrDrUrVr2r r rWrXrYrZr[r\r])r&dumpscreaterr+rSrBr:r?rTrDrUrVr2r r rWrXrYrZr[r\r]datas r create_userzUserRepository.create_userLsR.+4W)=  !!+D   %DO  ""-D   &&5D" #  'D   !DM  )D   !!+D   !!+D   #DN  #zz(3D  ,,AD( )  )D   )D   &&5D" # ! --CD) *  'D   ++?D' ([[&&&&sB*B3,B1-B3clKi}|||d<|||d<|||d<|||d<|||d<|||d<|||d<| | |d <| | |d <| | |d <| tj| |d <| | |d <|||d<|||d<|||d<|||d<|||d<|||d<|j||dd{S7w)zUpdate a user.NrSrBr:r?rTrDrUrVr2r r rWrXrYrZr[r\r]r+r<)r&r_updateras r update_userzUserRepository.update_usersS.*,  !!+D   %DO  ""-D   &&5D" #  'D   !DM  )D   !!+D   !!+D   #DN  #zz(3D  ,,AD( )  )D   )D   &&5D" # ! --CD) *  'D   ++?D' ([[$[CCCCsB+B4-B2.B4cfK|jj|ddd|id{}|S7w)zSet user_email only when the stored value is null, atomically at the database. Returns the number of rows updated: 0 means another writer already set an email. N)r+r2r2)r5rb)r update_many)rr+r2 updated_counts rbackfill_null_user_emailz'UserRepository.backfill_null_user_emailsD +/***@*@%T: ++A+ %  % s &1/1cDK|j|dd{S7w)zDelete a user.r+r<N)delete)rr+s r delete_userzUserRepository.delete_users[[9[====r>spendcJK|j|d|idd{S7w)zUpdate user spend.rnr+r<N)re)rr+rns r update_spendzUserRepository.update_spends&[[7E*:Y[OOOOrGcK|j|dd{sy|j|dd|iidd{S7%7w)z7Add a user to a team using atomic array push operation.r+r<NrDpush)existsre)rr+rBs r add_to_teamzUserRepository.add_to_teamsN[[9[===[[7VW4E*FQZ[[[[>\sA? AAAAcK|j|d{}|y|jDcgc] }||k7s | }}|j|d|idd{S7Dcc}w7 w)zRemove a user from a team. Note: Prisma doesn't support atomic array removal, so we use a read-modify-write pattern here. For high-concurrency scenarios, consider using raw SQL with array_remove(). NrDr+r<)r0rDre)rr+rBusertrDs rremove_from_teamzUserRepository.remove_from_teamsh!OOG44 <#'::>ag>>[[7E*:Y[OOO 5?Os0A%AA% AAA%A#A%A%)r+)NNNNNNNNNNNNNNNNNN) __name__ __module__ __qualname____doc__propertyr rtyperrr r*r%r0r9r=listrArFintrRfloatrobjectrcrfrjrmrprtrx __classcell__)r1s@rrrs2 7|$EF77!T"34!!  4  4E4L  <<>1BT1I>P#PeP@QTX@XP\\s\?PSW?W\ Pc PC PDUX\D\ Prr)r|r&collections.abcrtypingrrlitellm.models.userr$litellm.repositories.base_repositoryrr r %litellm.repositories.prisma_protocolsr rMr prisma_models frozensetr__annotations__rrrrsN #'1YY>.()XYuY]P^$56]Pr