[MON] Fixes notifier bug during alarm triggering 21/6321/1
authorBenjamin Diaz <bdiaz@whitestack.com>
Fri, 6 Jul 2018 19:04:19 +0000 (16:04 -0300)
committerBenjamin Diaz <bdiaz@whitestack.com>
Fri, 6 Jul 2018 19:05:03 +0000 (16:05 -0300)
Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>
osm_mon/plugins/OpenStack/Aodh/notifier.py
osm_mon/test/OpenStack/unit/test_notifier.py

index 377404a..8f3f0fe 100644 (file)
@@ -72,11 +72,11 @@ class NotifierHandler(BaseHTTPRequestHandler):
             post_data = post_data.decode()
         except AttributeError:
             pass
-        log.info("This alarm was triggered: %s", json.dumps(post_data))
+        log.info("This alarm was triggered: %s", post_data)
 
         # Send alarm notification to message bus
         try:
-            self.notify_alarm(json.dumps(post_data))
+            self.notify_alarm(json.loads(post_data))
         except Exception:
             log.exception("Error notifying alarm")
 
index 951bf10..a135cec 100644 (file)
@@ -52,7 +52,7 @@ class Response(object):
 
 class RFile():
     def read(self, content_length):
-        return post_data
+        return json.dumps(post_data, sort_keys=True)
 
 
 class MockNotifierHandler(NotifierHandler):
@@ -98,7 +98,7 @@ class TestNotifier(unittest.TestCase):
         self.handler.do_POST()
 
         set_head.assert_called_once()
-        notify.assert_called_with(json.dumps(post_data))
+        notify.assert_called_with(post_data)
 
     @mock.patch.object(KafkaProducer, "notify_alarm")
     @mock.patch.object(DatabaseManager, "get_alarm")