mxi  dZddlZddlZddlmZddlZddlmZddlmZGddejdd ejZ d Z d Z d d gZejddk\r+ejddk\rddlmZej'dyyy)z;Reference implementation for status mapping in gRPC Python.N) status_pb2)GRPC_DETAILS_METADATA_KEY)code_to_grpc_status_codec eZdZy)_StatusN)__name__ __module__ __qualname__M/home/htdocs/ttos/venv/lib/python3.12/site-packages/grpc_status/rpc_status.pyrrs r rcodedetailstrailing_metadatac|jy|jD]\}}|tk(stjj |}|j j d|j k7r3tdt|j d|j d|j|jk7r*td|jd|jd|cSy)aReturns a google.rpc.status.Status message corresponding to a given grpc.Call. This is an EXPERIMENTAL API. Args: call: A grpc.Call instance. Returns: A google.rpc.status.Status message representing the status of the RPC. Raises: ValueError: If the gRPC call's code or details are inconsistent with the status code and message inside of the google.rpc.status.Status. NrzCode in Status proto (z) doesn't match status code ()zMessage in Status proto (z ) doesn't match status details () rrrStatus FromStringrvalue ValueErrorrrmessage)callkeyr rich_statuss r from_callr!s ',,.  U + +$++66u=Kyy{  #{'7'77 / 0@0@A499;P||~!4!44 *22DLLND   r ctt|j|jt|j ffS)adConvert a google.rpc.status.Status message to grpc.Status. This is an EXPERIMENTAL API. Args: status: a google.rpc.status.Status message representing the non-OK status to terminate the RPC with and communicate it to the client. Returns: A grpc.Status instance representing the input google.rpc.status.Status message. r)rrrrrSerializeToString)statuss r to_statusr!Cs:  %fkk 2 &(@(@(B C  r rr!)_asyncaio)__doc__ collectionssys google.rpcrgrpc_commonrr namedtuplerrrr!__all__ version_infor$r%appendr r rr1sB ! .- K9&NOKK D,  A! 0 0 3q 8 NN5!9r