@@ -154,15 +154,15 @@ def auth(self, request: Request) -> bool:
154154 ts = request .headers .get ("glts" , None )
155155
156156 if not pk :
157- self .logger .warn (f"Missing public key header" )
157+ self .logger .warning (f"Missing public key header: headers= { request . headers } " )
158158 return False
159159
160160 if not sig :
161- self .logger .warn (f"Missing signature header" )
161+ self .logger .warning (f"Missing signature header: headers= { request . headers } " )
162162 return False
163163
164164 if not ts :
165- self .logger .warn (f"Missing timestamp header" )
165+ self .logger .warning (f"Missing timestamp header: headers= { request . headers } " )
166166 return False
167167
168168 # TODO Check the signature.
@@ -212,12 +212,15 @@ def proxy(self, request: Request):
212212 )
213213
214214 try :
215+ self .logger .debug (f"Sending grpc request req={ req } , payload={ content } to url={ url } " )
215216 res = client .send (req )
216217 # Capture the error from header and send it in the body as well
217- if res .headers .get ("grpc-status" , "0" ) != "0" :
218- grpc_status = res .headers .get ("grpc-status" )
218+ status = res .headers .get ("grpc-status" , "0" )
219+ logging .debug (f"Server returned grpc-status={ status } " )
220+ if status != "0" :
219221 error_message = res .headers .get ("grpc-message" , "None" )
220- self .logger .warning (f"gRPC status code received: { grpc_status } " )
222+ self .logger .error (f"Received grpc-status={ status } , error={ error_message } " )
223+ self .logger .warning (f"gRPC status code received: { status } " )
221224 self .logger .warning (f"gRPC message received: { error_message } " )
222225 error = error_message .encode ("utf-8" )
223226 error_res = struct .pack ("!cI" , request .flags , len (error )) + error
0 commit comments