xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-26 11:30:23 +00:00
Code Issues Projects Releases Wiki Activity

Add serialization to ConfluentExceptions

Browse Source 
In the same manner that messages
are handled, handle non-messages
content.
This commit is contained in:
Jarrod Johnson 2020-01-21 11:28:08 -05:00
parent f1e1d9804a
commit 79afd174c9
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
confluent_server/confluent/exceptions.py
View File

@ -17,7 +17,15 @@
import base64
import json
import msgpack
def deserilaize_exc(msg):
excd = msgpack.unpackb(msg)
if excd[0] not in globals():
return False
if not issubclass(excd[0], ConfluentException):
return False
return globals(excd[0])(*excd[1])
class ConfluentException(Exception):
apierrorcode = 500
@ -27,6 +35,9 @@ class ConfluentException(Exception):
errstr = ' - '.join((self._apierrorstr, str(self)))
return json.dumps({'error': errstr })
def serialize(self):
return msgpack.packb([self.__class__.__name__, [str(self)]])
@property
def apierrorstr(self):
if str(self):
@ -104,6 +115,7 @@ class PubkeyInvalid(ConfluentException):
def __init__(self, text, certificate, fingerprint, attribname, event):
super(PubkeyInvalid, self).__init__(self, text)
self.myargs = (text, certificate, fingerprint, attribname, event)
self.fingerprint = fingerprint
self.attrname = attribname
self.message = text
@ -117,6 +129,9 @@ class PubkeyInvalid(ConfluentException):
'certificate': certtxt}
self.errorbody = json.dumps(bodydata)
def serialize(self):
return msgpack.packb([self.__class__.__name__, self.myargs])
def get_error_body(self):
return self.errorbody