apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-18 17:51:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix error responses in websockets

Browse source
This commit is contained in:
Cyber MacGeddon 2024-12-29 18:05:42 +00:00
parent 4672c6a0c7
commit f4fd7183dd
2 changed files with 15 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
trustgraph-flow/trustgraph/gateway/requestor.py
View file

@ -65,7 +65,10 @@ class ServiceRequestor:
raise RuntimeError("Timeout") raise RuntimeError("Timeout")
if resp.error: if resp.error:
return { "error": resp.error.message } err = { "error": resp.error.message }
if responder:
await responder(err, True)
return err
resp, fin = self.from_response(resp) resp, fin = self.from_response(resp)
@ -81,7 +84,10 @@ class ServiceRequestor:
logging.error(f"Exception: {e}") logging.error(f"Exception: {e}")
return { "error": str(e) } err = { "error": str(e) }
if responder:
await responder(err, True)
return err
finally: finally:
self.sub.unsubscribe(id) self.sub.unsubscribe(id)

8
trustgraph-flow/trustgraph/gateway/sender.py
View file

@ -46,5 +46,11 @@ class ServiceSender:
logging.error(f"Exception: {e}") logging.error(f"Exception: {e}")
return { "error": str(e) } err = { "error": str(e) }
if responder:
await responder(err, True)
return err