g} ddlZddlmZddlmZddlmZmZddl m Z m Z m Z m Z ddlmZddlmZmZddlmZmZdd lmZdd lmZdd lmZeZd Z d"d ede ede eefde eeffdZ d#de!de"de"defdZ#d e e$efdefdZ% d"dZ&defdZ'de(fdZ)dZ*de"fdZ+de"fdZ,edede dfdZ-ede dfd Z.ede dfd!Z/y)$N)contextmanager) import_module)escapesub)DictIterableSequenceUnion) ObjectProxy)contexttrace)"_SUPPRESS_HTTP_INSTRUMENTATION_KEY_SUPPRESS_INSTRUMENTATION_KEY)extract) StatusCode)TraceContextTextMapPropagatorsuppress_instrumentationobj attributesexistingreturnczi}|r|j||D] }t||d}|t|||<"|SN)updategetattrstr)rrr extractedattrvalues X/var/www/openai/venv/lib/python3.12/site-packages/opentelemetry/instrumentation/utils.pyextract_attributes_from_objectr!.sMI"T4(  !%jIdO statusallow_redirect server_spanct|tstjS|dkrtjS|dkrtjS|dkr|rtjS|dkr|rtjStjS)z}Converts an HTTP status code to an OpenTelemetry canonical status code Args: status (int): HTTP status code di+ii) isinstanceintrUNSETERROR)r#r$r%s r http_status_to_status_coder,;sv fc " | } } }   r"rct|tr. |jdd\}}t |} t ||}t ||d}|r6t|tr%t|d rt|||jyyyy#t$r}t d|d|d}~wwxYw#t$r}t d|d|d|d}~wwxYw) aMGiven a function that was wrapped by wrapt.wrap_function_wrapper, unwrap it The object containing the function to unwrap may be passed as dotted module path string. Args: obj: Object that holds a reference to the wrapped function or dotted import path as string attr (str): Name of the wrapped function .zCannot parse 'z' as dotted import pathNzCannot import 'z' from '' __wrapped__) r(rrsplit ValueError ImportErrorrrAttributeErrorr hasattrsetattrr1)rr module_path class_nameexcmodulefuncs r unwrapr=Ts#s &)jja&8 #K {+ &*-C 3d #D 4-'$ 2NT4++,3O-t  %<=   !*XfXQ?  s.B B& B#BB#& C/CCc`dx}x}}tjtjur=t||}t j |}tj j}n.t j}tj j}|j|||||} | |fS)aReturns internal or server span along with the token which can be used by caller to reset context Args: tracer : tracer in use by given instrumentation library span_name (string): name of the span start_time : start time of the span context_carrier : object which contains values that are used to construct a Context. This object must be paired with an appropriate getter which understands how to extract a value from it. context_getter : an object which contains a get function that can retrieve zero or more values from the carrier and a keys function that can get all the keys from carrier. N)getter)namer kind start_timer) r get_current_span INVALID_SPANrr attachSpanKindSERVER get_currentINTERNAL start_span) tracer span_namerBcontext_carriercontext_getterrtokenctx span_kindspans r _start_internal_or_server_spanrSqs0#"E"C) 5#5#55on=s#NN)) !!#NN++       D ;r"ct|ttfs|Stjj |}|j ddS)N%z%%)r(rbytesurllibparsequotereplace)squoteds r _url_quoter]s< a#u & \\   "F >>#t $$r"c4i}tj||S)zs Return the OpenTelemetry Trace and Span IDs if Span ID is set in the OpenTelemetry execution context. ) propagatorinject)_headerss r _get_opentelemetry_valuesrbs Hh Or"c8tt||dd|S)Nz(?!$))rr) python_path directorypath_separators r _python_path_without_directoryrhs*  9  ~.e4  r"cltjtxstjt Sr)r get_valuer#_SUPPRESS_INSTRUMENTATION_KEY_PLAINr"r is_instrumentation_enabledrms078 B   @ A r"cNtxrtjt Sr)rmr rjrrlr"r is_http_instrumentation_enabledros' % ' 0A0A*1-r"keysc'Ktj}|D]}tj|d|}tj|} dtj|y#tj|wxYww),Suppress instrumentation within the context.TN)r rH set_valuerEdetach)rprPkeyrOs r _suppress_instrumentationrvsb    CT3/ NN3 E uusAA? A%A?%A<<A?c#fKttt5ddddy#1swYyxYwwrrN)rvrrkrlr"r rrs* #%'J     s1% 1.1c#\Ktt5ddddy#1swYyxYwwrx)rvrrlr"r suppress_http_instrumentationrzs  ##E F  G F Fs,  ,),r)TF)0 urllib.parserW contextlibr importlibrrerrtypingrrr r wraptr opentelemetryr r opentelemetry.contextrropentelemetry.propagateropentelemetry.tracer,opentelemetry.trace.propagation.tracecontextrr_rkanyrr!r)boolr,objectr=rSr]dictrbrhrmrorvrrzrlr"r rsw%#22( ,*+ , $ EI   "3- 37S>  #s(^    2-fck"-#-F 'T%S%4D  S Xd^  (4.x~r"