X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Ftest%2FOpenStack%2Fintegration%2Ftest_notify_alarm.py;h=8aa2c9fec1adcd15f4d5ddc69e916b3bfa26295b;hb=93699898c51364cde193d8d441f4aed45670e7bf;hp=6fedf69bd2491d411519b4abeee3833b25c91cf8;hpb=e80db311a29dc8562dc84ae3336af167bac2ec5b;p=osm%2FMON.git

diff --git a/osm_mon/test/OpenStack/integration/test_notify_alarm.py b/osm_mon/test/OpenStack/integration/test_notify_alarm.py
index 6fedf69..8aa2c9f 100644
--- a/osm_mon/test/OpenStack/integration/test_notify_alarm.py
+++ b/osm_mon/test/OpenStack/integration/test_notify_alarm.py
@@ -21,7 +21,6 @@
 ##
 """Tests for all common OpenStack methods."""
 
-
 from __future__ import unicode_literals
 import json
 import logging
@@ -31,14 +30,14 @@ from threading import Thread
 
 import mock
 import requests
+from kafka import KafkaProducer
 from six.moves.BaseHTTPServer import BaseHTTPRequestHandler
 from six.moves.BaseHTTPServer import HTTPServer
 
-from osm_mon.core.message_bus.producer import KafkaProducer
 from osm_mon.core.settings import Config
-from osm_mon.plugins.OpenStack.Aodh.alarming import Alarming
+from osm_mon.plugins.OpenStack.Aodh.alarm_handler import OpenstackAlarmHandler
 from osm_mon.plugins.OpenStack.common import Common
-from osm_mon.plugins.OpenStack.response import OpenStack_Response
+from osm_mon.plugins.OpenStack.response import OpenStackResponseBuilder
 
 log = logging.getLogger(__name__)
 
@@ -86,12 +85,10 @@ class MockNotifierHandler(BaseHTTPRequestHandler):
 
     def notify_alarm(self, values):
         """Mock the notify_alarm functionality to generate a valid response."""
-        config = Config.instance()
-        config.read_environ()
-        self._alarming = Alarming()
+        cfg = Config.instance()
+        self._alarming = OpenstackAlarmHandler()
         self._common = Common()
-        self._response = OpenStack_Response()
-        self._producer = KafkaProducer('alarm_response')
+        self._response = OpenStackResponseBuilder()
         alarm_id = values['alarm_id']
 
         auth_token = Common.get_auth_token('test_id')
@@ -120,10 +117,8 @@ class MockNotifierHandler(BaseHTTPRequestHandler):
                         resource_id=resource_id,
                         sev=values['severity'], date=a_date,
                         state=values['current'], vim_type="OpenStack")
-                    self._producer.publish_alarm_response(
-                        'notify_alarm', resp_message)
                 except Exception:
-                    pass
+                    log.exception("Error generating response")
 
 
 def get_free_port():
@@ -155,12 +150,11 @@ def test_do_get():
 
 
 class AlarmNotificationTest(unittest.TestCase):
-    @mock.patch.object(KafkaProducer, "publish_alarm_response")
-    @mock.patch.object(OpenStack_Response, "generate_response")
+    @mock.patch.object(OpenStackResponseBuilder, "generate_response")
     @mock.patch.object(Common, "perform_request")
     @mock.patch.object(Common, "get_endpoint")
     @mock.patch.object(Common, "get_auth_token")
-    def test_post_notify_alarm(self, auth, endpoint, perf_req, resp, notify):
+    def test_post_notify_alarm(self, auth, endpoint, perf_req, resp):
         """Integration test for notify_alarm."""
         url = 'http://localhost:{port}/users'.format(port=mock_server_port)
         payload = {"severity": "critical",
@@ -187,6 +181,3 @@ class AlarmNotificationTest(unittest.TestCase):
             "notify_alarm", alarm_id="my_alarm_id", resource_id="my_resource_id",
             sev="critical", date='dd-mm-yyyy 00:00', state="current_state",
             vim_type="OpenStack")
-
-        # Response message is sent back to the SO via MON's producer
-        notify.assert_called_with("notify_alarm", mock.ANY)