@@ -130,7 +130,15 @@ def _process_message(self, msg: Any) -> None:
130130 msg: The message body received
131131 """
132132 msg_dict = json .loads (msg )
133- msg_request_id = msg_dict .get ("request_id" )
133+ radas_response = msg_dict .get ("msg" )
134+ if not radas_response :
135+ self .log .info (
136+ "Message %s is not valid, ignoring" ,
137+ msg_dict
138+ )
139+ return
140+
141+ msg_request_id = radas_response .get ("request_id" )
134142 if msg_request_id != self .request_id :
135143 self .log .info (
136144 "Message request_id %s does not match the request_id %s from sender, ignoring" ,
@@ -143,10 +151,10 @@ def _process_message(self, msg: Any) -> None:
143151 self .log .info (
144152 "Start to process the sign event message, request_id %s is matched" , msg_request_id
145153 )
146- self .sign_result_status = msg_dict .get ("signing_status" )
147- self .sign_result_errors = msg_dict .get ("errors" , [])
154+ self .sign_result_status = radas_response .get ("signing_status" )
155+ self .sign_result_errors = radas_response .get ("errors" , [])
148156 if self .sign_result_status == "success" :
149- result_reference_url = msg_dict .get ("result_reference" )
157+ result_reference_url = radas_response .get ("result_reference" )
150158 if not result_reference_url :
151159 self .log .warning ("Not found result_reference in message,ignore." )
152160 return
0 commit comments