commit 136f29577fd83028369c2c4fc4c60f738e0d26d3
author tierno <alfonso.tiernosepulveda@telefonica.com> Fri Oct 19 13:01:03 2018 +0200
committer tierno <alfonso.tiernosepulveda@telefonica.com> Mon Oct 22 23:37:48 2018 +0200
tree a81938a648c471f00ea4ee00678647c6858f1be2
parent 48b78e112662d927cad376d739e43fb94f108ff3

Bug 559 adding encrypt/decrypt methods
Fixing pytest and unittest. Adding to devops stage test

Change-Id: Idbeaa82dec736c4a8b2d2a26bd39aeecbc49b901
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>

osm_common/msglocal.py

diff --git a/osm_common/msglocal.py b/osm_common/msglocal.py
index f731e74..247de7b 100644
--- a/osm_common/msglocal.py
+++ b/osm_common/msglocal.py
@@ -21,6 +21,7 @@
 import asyncio
 from osm_common.msgbase import MsgBase, MsgException
 from time import sleep
+from http import HTTPStatus
 
 __author__ = "Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>"
 
@@ -54,7 +55,7 @@
         except MsgException:
             raise
         except Exception as e:  # TODO refine
-            raise MsgException(str(e))
+            raise MsgException(str(e), http_code=HTTPStatus.INTERNAL_SERVER_ERROR)
 
     def disconnect(self):
         for f in self.files_read.values():
@@ -82,7 +83,7 @@
             yaml.safe_dump({key: msg}, self.files_write[topic], default_flow_style=True, width=20000)
             self.files_write[topic].flush()
         except Exception as e:  # TODO refine
-            raise MsgException(str(e))
+            raise MsgException(str(e), HTTPStatus.INTERNAL_SERVER_ERROR)
 
     def read(self, topic, blocks=True):
         """
@@ -113,7 +114,7 @@
                     return None
                 sleep(2)
         except Exception as e:  # TODO refine
-            raise MsgException(str(e))
+            raise MsgException(str(e), HTTPStatus.INTERNAL_SERVER_ERROR)
 
     async def aioread(self, topic, loop):
         """
@@ -131,7 +132,7 @@
         except MsgException:
             raise
         except Exception as e:  # TODO refine
-            raise MsgException(str(e))
+            raise MsgException(str(e), HTTPStatus.INTERNAL_SERVER_ERROR)
 
     async def aiowrite(self, topic, key, msg, loop=None):
         """