o ưi?@sdZddlmZmZmZmZddlmZmZm Z m Z ddl m Z m Z ddlmZmZddlmZeZdeded eeeffd d Zejd d geege de ddde dddde ddde ddde ddde ddde ddde ddde ddde ddde ddde ddde d d!df d"ed#ed$eed%eed&eed'eed(eed)eed*eed+eed,eed-eed.efd/d0Zejd1d geege d2d3id2d4id5d6eefd7ed8efd9d:ZdS);z AUDIT LOGGING All /audit logging endpoints. Attempting to write these as CRUD endpoints. GET - /audit/{id} - Get audit log by id GET - /audit - Get all audit logs )AnyDictListOptional) APIRouterDepends HTTPExceptionQuery)AuditLogResponsePaginatedAuditLogResponse)CommonProxyErrorsUserAPIKeyAuth)user_api_key_authjson_keyvaluereturncCs$dd|g|did|g|digiS)a Build an OR condition that matches a value inside a JSON column at the given key, checking both before_value and updated_values. Uses Prisma's JSON path filtering (PostgreSQL only). Example result (team_id="t1"): {"OR": [ {"before_value": {"path": ["team_id"], "string_contains": "t1"}}, {"updated_values": {"path": ["team_id"], "string_contains": "t1"}}, ]} ORZ before_value)pathZstring_containsZupdated_values)rrrrg/home/app/Keep/.python/lib/python3.10/site-packages/litellm_enterprise/proxy/audit_logging_endpoints.py_build_json_field_or_conditions rz/auditz Audit Logging)tags dependenciesresponse_model)ge d)rleNz2Filter by user or system that performed the action) descriptionz0Filter by API key hash that performed the actionz.Filter by action type (create, update, delete)z&Filter by table name that was modifiedz,Filter by ID of the object that was modifiedzFilter logs after this datezFilter logs before this datezRFilter by team_id present in before_value or updated_values JSON (PostgreSQL only)z[Filter by token (key hash) present in before_value or updated_values JSON (PostgreSQL only)z=Column to sort by (e.g. 'updated_at', 'action', 'table_name')ZdesczSort order ('asc' or 'desc')page page_size changed_bychanged_by_api_keyaction table_name object_id start_dateend_dateobject_team_idobject_key_hashsort_by sort_orderc sdddlm} | durtddtjjidi}|r||d<|r#||d<|r)||d <|r/||d <|r5||d <|s9|rKi}|rA||d <|rG||d <||d<| r[|dgtd| g|d<| rk|dgtd| g|d<i}| ryt| t ry| || <n| |d<| j j j |||d||dIdH}| j j j |dIdH}| | }t|rdd|Dng||||dS)z Get all audit logs with filtering and pagination. Returns a paginated response of audit logs matching the specified filters. Note: object_team_id and object_key_hash use Prisma JSON path filtering, which requires PostgreSQL. r prisma_clientNmessage status_codedetailr"r#r$r%r&ZgteZlteZ updated_atANDZteam_idtokenr)whereorderskipZtaker6cSsg|] }tdi|qS)r)r model_dump).0 audit_logrrr sz"get_audit_logs..) audit_logstotalr r! total_pages)litellm.proxy.proxy_serverr.rr db_not_connected_errorrgetr isinstancestrdblitellm_auditlogZ find_manycountr )r r!r"r#r$r%r&r'r(r)r*r+r,r.Zwhere_conditionsZ date_filterZorder_byr>Z total_countr@rrrget_audit_logs.sp 2         rIz /audit/{id}rzAudit log not foundzDatabase connection error)r/)rrr responsesiduser_api_key_dictcsvddlm}|durtddtjjid|jjjd|idIdH}|dur2td dd |d idt d i| S) a[ Get detailed information about a specific audit log entry by its ID. Args: id (str): The unique identifier of the audit log entry Returns: AuditLogResponse: Detailed information about the audit log entry Raises: HTTPException: If the audit log is not found or if there's a database connection error rr-Nr/r0r1rLr9rJzAudit log with ID z not foundr) rAr.rr rBrrFrGZ find_uniquer r:)rLrMr.r<rrrget_audit_log_by_ids  rN)__doc__typingrrrrZfastapirrrr Z6litellm_enterprise.types.proxy.audit_logging_endpointsr r Zlitellm.proxy._typesr r Z$litellm.proxy.auth.user_api_key_authrZrouterrErrCintrIrNrrrrs         " t