
    ^h/                     H    S SK Jr  S SKrS SKJrJr  S SKJr   " S S5      rg)    )OptionalN)print_verboseverbose_logger)StandardLoggingPayloadc                   @    \ rS rSr           SS jrS rS rSrg)S3Logger   Nc                    SS K n [        R                  " S[        R                   35        [        R                  Gb  [        R                  R                  5        HX  u  p[        U5      [        L d  M  UR                  S5      (       d  M1  [        R                  " U5      [        R                  U'   MZ     [        R                  R                  S5      n[        R                  R                  S5      n[        R                  R                  S5      n[        R                  R                  SS5      n[        R                  R                  S	5      n[        R                  R                  S
5      n[        R                  R                  S5      n[        R                  R                  S5      n	[        R                  R                  S5      n
[        R                  R                  S5      n[        R                  R                  S5      nXl        X l        [        R                  " SU 35        UR                  "  SUUUUUUU	U
US.	UD6U l        g ! [         a  n[!        S[        U5       35        UeS nAff = f)Nr   z'in init s3 logger - s3_callback_params zos.environ/s3_bucket_names3_region_names3_api_version
s3_use_sslT	s3_verifys3_endpoint_urls3_aws_access_key_ids3_aws_secret_access_keys3_aws_session_token	s3_configs3_pathzs3 logger using endpoint url )	region_nameendpoint_urlapi_versionuse_sslverifyaws_access_key_idaws_secret_access_keyaws_session_tokenconfigz Got exception on init s3 client )s3)boto3r   debuglitellms3_callback_paramsitemstypestr
startswith
get_secretgetbucket_namer   client	s3_client	Exceptionr   )selfr   r   r   r   r   r   r   r   r   r   r   kwargsr    keyvaluees                    Q/home/james-whalen/.local/lib/python3.13/site-packages/litellm/integrations/s3.py__init__S3Logger.__init__   s$    	1	  9':T:T9UV ))5")"<"<"B"B"DJCE{c)e.>.>}.M.M:A:L:LU:S2237 #E ")!;!;!?!?@P!Q!(!;!;!?!?@P!Q!(!;!;!?!?@P!Q$77;;L$O
#66::;G	")"<"<"@"@AR"S'.'A'A'E'E*($ ,3+E+E+I+I.,( (/'A'A'E'E*($ $66::;G	!4488C  ."L  #@@Q!RS"\\*,*" "6&>"6  DN  	<SVHEFG	s%   A,I 6I GI 
I?!I::I?c                 2   #    U R                  XX4U5        g 7f)N)	log_event)r.   r/   response_obj
start_timeend_timer   s         r3   _async_log_eventS3Logger._async_log_eventQ   s      	vZ=Qs   c           
          [         R                  " SU 35        UR                  S0 5      nUR                  S0 5      =(       d    0 n0 n[        U[        5      (       a%  UR                  5        H  u  pU	S;   a  M  XU	'   M     UR                  SS 5      nUc  g [        R                  R                  X;5      =(       d    SnU R                  (       a  U R                  R                  S5      S-   OSUR                  S5      -   S-   U-   nUS	-  nS
UR                  S5      -   S-   US   -   S	-   nSS KnUR                  U5      nU" SU 35        U R                  R                  U R                   UUSSSU S3SS9nU" S[#        U5       35        U" SU 35        U$ ! [$         a,  n[         R&                  " S[#        U5       35         S nAg S nAff = f)Nz/s3 Logging - Enters logging function for model litellm_paramsmetadata)headersendpointcaching_groupsprevious_modelsstandard_logging_object /z%Y-%m-%dz.jsonztime-z%Y-%m-%dT%H-%M-%S-%f_idr   z
s3 Logger - Logging payload = zapplication/jsonenzinline; filename=""z0private, immutable, max-age=31536000, s-maxage=0)BucketKeyBodyContentTypeContentLanguageContentDispositionCacheControlzResponse from s3:z*s3 Layer Logging - final response object: zs3 Layer Error - )r   r!   r)   
isinstancedictr$   r"   utilsget_logging_idr   rstripstrftimejsondumpsr,   
put_objectr*   r&   r-   	exception)r.   r/   r8   r9   r:   r   r>   r?   clean_metadatar0   r1   payloads3_file_names3_object_keys3_object_download_filenamerX   payload_strresponser2   s                      r3   r7   S3Logger.log_eventV   s   L	  A&J $ZZ(8"=N"":r28b   N(D))"*.."2JC   !.3s+ #3 9?

)49G "==77
LRPRL37<<$$S)C/R%%j12   W$M %%&<=> $-  	 ( **W-K<[MJK~~00''! . $%78S7TTU#VO 1 H -c(m_=>F|nUVO 	$$'8Q%AB	s   BF DF 
G("GG)r*   r,   r   )NNNNTNNNNNN)__name__
__module____qualname____firstlineno__r4   r;   r7   __static_attributes__     r3   r   r      s8     !!%!BHR
Mrj   r   )	typingr   r"   litellm._loggingr   r   litellm.types.utilsr   r   ri   rj   r3   <module>rn      s      : 6X Xrj   