o i!@sDddlZddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl m Z dd l mZdd l mZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlm Z ddl!m"Z"ddl!m#Z#ddl!m$Z$ddl%m&Z&ddl%m'Z'ddl%m(Z(ddl%m)Z)ddl%m*Z*ddl%m+Z+ddl%m,Z,ddl%m-Z-ej.Z/e/dkrdd l0m1Z1dd!l2m3Z3ne/d"krdd l4m1Z1dd!l5m3Z3n dd#l4m6Z1dd!l5m3Z3ee7Z8ed$Z9Gd%d&d&eZ:d'd(Z;d)d*Zd/d0Z?d1d2Z@d3d4ZAd5d6ZBd7d8ZCd9d:ZDejEd;d<ZFdS)=N) ObjectProxy)config)_SPAN_MEASURED_KEY) SPAN_KIND) trace_utils)SpanKind) SpanTypes)db)mongo) COMPONENT) get_logger)schematize_database_operation)schematize_service_name)get_argument_value)unwrap)wrap)tracer) parse_msg) parse_query) parse_spec)create_checkout_span) dbm_dispatch)is_query)process_server_message_result)process_server_operation_result)set_address_tags)set_query_metadata)setup_checkout_span_tags) ) Connection)Serverr) SocketInfopymongoc@s eZdZdS)TracedMongoClientN)__name__ __module__ __qualname__r+r+[/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/contrib/internal/pymongo/client.pyr';sr'cCvtdkr ttjtntdkrttjtnttjttdkr'ttjt nttj t tt j t tt jtdS)z"Patch synchronous pymongo modules. r/r r#N)VERSION_wr" run_operation-_trace_server_run_operation_and_with_responserun_operation_with_responsesend_message_with_response(_trace_server_send_message_with_responsecheckouttraced_get_socket get_socketr!command_trace_socket_command write_command_trace_socket_write_commandr+r+r+r,patch_pymongo_sync_modules?   r@cCr-)z$Unpatch synchronous pymongo modules.r.r1r#N)r2_ur"r4r5r6r7r8r9r:r;r!r<r=r>r?r+r+r+r,unpatch_pymongo_sync_modulesPrArCcCsd}t|rzt|}WntytdYnw|r tjs"dStjtdddt j t dt jd}|tt jj|ttj|td|tj|j|tj|j|tjtj||jt |||S)Nzerror parsing query pymongo.cmdmongodbdatabase_provider span_typeservicer)!rr Exceptionlog exceptionrenabledtracer rMONGODBr ext_servicerr& _set_tag_strr integration_namerrCLIENT set_metricrmongoxDBr COLLECTIONcollSYSTEMSERVICEset_tagstagsr) operationwrappedcmdspanr+r+r,datadog_trace_operationas.        rbcCst||dd}t||dd}t||}|dur||i|S|t|||\}}}||i|}t|||WdS1sAwYdS)Nrselfr^)rrbrrfuncargskwargsserver_instancer^raresultr+r+r,r5s  $r5cCs~t||dd}t||dd}t||}|dur||i|S|||i|}t|||WdS1s8wYdS)Nrrcrr^)rrbrrer+r+r,r8s  $r8cCs|t||dd}t||dd}t||dd}d}zt||}Wnty,tdYnw|r4|r4tjs6dS||_|||fS) z Parse socket command spec. Returns: tuple: (socket_instance, dbname, cmd) if parsing succeeds and tracing should proceed None: if parsing fails or tracing should be skipped rrcrdbnamerdspecNz"error parsing spec. skipping trace)rrrKrLrMrrNr )rgrhsocket_instancerkrlr`r+r+r,parse_socket_command_specs  rncCs|t||}|dur||i|S|\}}}t|||j}t|||\}}}||i|WdS1s7wYdS)N)rn trace_cmdaddressr)rfrgrhparsedrmrkr`sr+r+r,r=s   $r=cCs`t||dd}t||dd}d}zt|}Wnty$tdYnw|r*tjs,dS||fS)z Parse socket write command msg. Returns: tuple: (socket_instance, cmd) if parsing succeeds and tracing should proceed None: if parsing fails or tracing should be skipped rrcrdmsgNzerror parsing msg)rrrKrLrMrrN)rgrhrmrsr`r+r+r,parse_socket_write_command_msgs   rtcCst||}|dur||i|S|\}}t|||j}||i|}|r0|tj|dd|WdS1ssl                                %