`i(dZddlZddlZddlmZddlmZddlm Z ej j dj Z Gdde Zd Zejdd kr.ejd d krdd lmZd dlmZddZee_gdZdSddZee_gdZdS)z7Reference implementation for reflection in gRPC Python.N)reflection_pb2)reflection_pb2_grpc)BaseReflectionServicerServerReflectionceZdZdZdZdS)ReflectionServicerz,Servicer handling RPCs for service statuses.c#K|D]}|dr|||jV6|dr|||jVi|dr.|||jj|jjV|dr| ||j V|dr| |V tj tjtjjjdtjjjd| VdS) Nfile_by_filenamefile_containing_symbolfile_containing_extensionall_extension_numbers_of_type list_servicesr) error_code error_message)error_responseoriginal_request)HasField_file_by_filenamer _file_containing_symbolr _file_containing_extensionr containing_typeextension_number_all_extension_numbers_of_typer _list_services_reflection_pb2ServerReflectionResponse ErrorResponsegrpc StatusCodeINVALID_ARGUMENTvalueencode)selfrequest_iteratorcontextrequests v/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/grpc_reflection/v1alpha/reflection.pyServerReflectionInfoz'ReflectionServicer.ServerReflectionInfos'  G 233 ,,Wg6NOOOOOO!!":;; 22W;!!"=>> 555E5F !!"ABB 99WB!!/22 ))'222222%>#2#@#'?#C#I!#L&*o&F&L' &(( $$$ &-)  N)__name__ __module__ __qualname____doc__r)r*r(rrs)66r*raEnables server reflection on a server. Args: service_names: Iterable of fully-qualified service names available. server: grpc.Server to which reflection service will be added. pool: DescriptorPool object to use (descriptor_pool.Default() if None). r)aio)_asyncct|tjr+tjt j|||dStjt |||dSN)pool) isinstancegrpc_aioServer_reflection_pb2_grpc&add_ServerReflectionServicer_to_serverr2r service_namesserverr6s r(enable_server_reflectionr?Ps} fho . .  G&}4@@@&      ! G"=t<<rMs[>= EEEEEEOOOOOO@@@@@@):  !!!!!/!!!H!A! 0 3q 8 8211111 (E$GGG    (E$GGGr*