
    `i                         d Z ddlmZ ddlmZ ddlZddlmZ ddlmZ	  ej
                    Zd Zd Zd	 Z G d
 de	j                  ZdgZdS )z+Base implementation of reflection servicer.    )descriptor_pb2)descriptor_poolN)reflection_pb2)reflection_pb2_grpcc                     t          j        t          j        t          j        j        j        d         t          j        j        j        d                                                   |           S )Nr      )
error_codeerror_message)error_responseoriginal_request)_reflection_pb2ServerReflectionResponseErrorResponsegrpc
StatusCode	NOT_FOUNDvalueencode)r   s    q/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/grpc_reflection/v1alpha/_base.py_not_found_errorr      sb    3&406q9/39!<CCEE
 
 
 *       c                     |                     | j        | i           | j        D ]}|j        |vrt          ||           d S N)updatenamedependencies _collect_transitive_dependencies)
descriptor
seen_files
dependencys      r   r   r   #   s[    z
3444 - E E
?*,,,ZDDDE Er   c                 H   i }t          | |           g }|                                D ]Q}t          j                    }|                    |           |                    |                                           Rt          j        t          j	        |          |          S )N)file_descriptor_proto)file_descriptor_responser   )
r   valuesr   FileDescriptorProtoCopyToProtoappendSerializeToStringr   r   FileDescriptorResponse)r   r   descriptorsserialized_proto_listd_valueprotos         r   _file_descriptor_responser.   +   s    K$Z=== %%'' @ @244E"""$$U%<%<%>%>????3!0!G#8"
 "
 "
 *	   r   c                   8    e Zd ZdZd	dZd Zd Zd Zd Zd Z	dS )
BaseReflectionServicerz#Base class for reflection servicer.Nc                 h    t          t          |                    | _        |t          n|| _        dS )zConstructor.

        Args:
            service_names: Iterable of fully-qualified service names available.
            pool: An optional DescriptorPool instance.
        N)tuplesorted_service_names_POOL_pool)selfservice_namespools      r   __init__zBaseReflectionServicer.__init__B   s/     $F=$9$9::"lUU


r   c                     	 | j                             |          }t          ||          S # t          $ r t	          |          cY S w xY wr   )r6   FindFileByNamer.   KeyErrorr   )r7   requestfilenamer   s       r   _file_by_filenamez(BaseReflectionServicer._file_by_filenameL   s`    	B228<<J -ZAAA  	- 	- 	-#G,,,,,	-   , AAc                     	 | j                             |          }t          ||          S # t          $ r t	          |          cY S w xY wr   )r6   FindFileContainingSymbolr.   r=   r   )r7   r>   fully_qualified_namer   s       r   _file_containing_symbolz.BaseReflectionServicer._file_containing_symbolT   se    	B<<$ J -ZAAA  	- 	- 	-#G,,,,,	-rA   c                 
   	 | j                             |          }| j                             ||          }| j                             |j                  }t          ||          S # t          $ r t          |          cY S w xY wr   )r6   FindMessageTypeByNameFindExtensionByNumberrC   	full_namer.   r=   r   )r7   r>   containing_typeextension_numbermessage_descriptorextension_descriptorr   s          r   _file_containing_extensionz1BaseReflectionServicer._file_containing_extension^   s    	B!%!A!A" " $(:#C#C"$4$ $  <<$. J -ZAAA  	- 	- 	-#G,,,,,	-s   AA& &BBc                 P   	 | j                             |          }t          t          d | j                             |          D                                 }t          j        t          j        |j        |          |          S # t          $ r t          |          cY S w xY w)Nc              3   $   K   | ]}|j         V  d S r   )number).0	extensions     r   	<genexpr>zHBaseReflectionServicer._all_extension_numbers_of_type.<locals>.<genexpr>v   s9        ! $     r   )base_type_namerK   )all_extension_numbers_responser   )r6   rG   r2   r3   FindAllExtensionsr   r   ExtensionNumberResponserI   r=   r   )r7   r>   rJ   rL   extension_numberss        r   _all_extension_numbers_of_typez5BaseReflectionServicer._all_extension_numbers_of_typep   s    	!%!A!A" " !&  %)Z%A%A*& &    ! ! #;/>/V#5#?%60 0 0 ")     	- 	- 	-#G,,,,,	-s   AB	 	B%$B%c                 r    t          j        t          j        d | j        D                       |          S )Nc                 8    g | ]}t          j        |           S ))r   )r   ServiceResponse)rR   service_names     r   
<listcomp>z9BaseReflectionServicer._list_services.<locals>.<listcomp>   s6       $ $3FFF  r   )service)list_services_responser   )r   r   ListServiceResponser4   )r7   r>   s     r   _list_servicesz%BaseReflectionServicer._list_services   sU    7#2#F (,(;  $ $ $ %
 
 
 	
r   r   )
__name__
__module____qualname____doc__r:   r@   rE   rN   rZ   rc    r   r   r0   r0   ?   s        --5 5 5 5B B BB B BB B B$  0	
 	
 	
 	
 	
r   r0   )rg   google.protobufr   r   r   grpc_reflection.v1alphar   r   r   _reflection_pb2_grpcDefaultr5   r   r   r.   ServerReflectionServicerr0   __all__rh   r   r   <module>ro      s    2 1 * * * * * * + + + + + +  E E E E E E O O O O O O!!  E E E  (R
 R
 R
 R
 R
1J R
 R
 R
j $
$r   