Fixes bugs for integration with policy module

[osm/MON.git] / osm_mon / test / integration / test_vim_account.py

diff --git a/osm_mon/test/integration/test_vim_account.py b/osm_mon/test/integration/test_vim_account.py
deleted file mode 100644 (file)
index e84b3cb..0000000
--- a/osm_mon/test/integration/test_vim_account.py
+++ /dev/null
@@ -1,115 +0,0 @@
-# -*- coding: utf-8 -*-
-
-# Copyright 2018 Whitestack, LLC
-# *************************************************************
-
-# This file is part of OSM Monitoring module
-# All Rights Reserved to Whitestack, LLC
-
-# Licensed under the Apache License, Version 2.0 (the "License"); you may
-# not use this file except in compliance with the License. You may obtain
-# a copy of the License at
-
-#         http://www.apache.org/licenses/LICENSE-2.0
-
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-# License for the specific language governing permissions and limitations
-# under the License.
-
-# For those usages not covered by the Apache License, Version 2.0 please
-# contact: bdiaz@whitestack.com or glavado@whitestack.com
-##
-
-"""Test an end to end Openstack vim_account requests."""
-
-import json
-import logging
-import time
-import unittest
-
-from kafka import KafkaConsumer
-from kafka import KafkaProducer
-from kafka.errors import KafkaError
-
-from osm_mon.core.auth import AuthManager
-
-log = logging.getLogger(__name__)
-
-
-class VimAccountTest(unittest.TestCase):
-    def setUp(self):
-        try:
-            self.producer = KafkaProducer(bootstrap_servers='localhost:9092')
-            self.consumer = KafkaConsumer(bootstrap_servers='localhost:9092',
-                                          group_id='osm_mon')
-            self.consumer.subscribe(['vim_account'])
-            self.auth_manager = AuthManager()
-        except KafkaError:
-            self.skipTest('Kafka server not present.')
-
-    # TODO: REFACTOR. This test requires common_consumer running. Needs to be changed so it does not.
-    @unittest.skip("Needs refactoring.")
-    def test_create_edit_delete_vim_account(self):
-        """Test vim_account creation message from KafkaProducer."""
-        # Set-up message, producer and consumer for tests
-        create_payload = {
-            "_id": "test_id",
-            "name": "test_name",
-            "vim_type": "openstack",
-            "vim_url": "auth_url",
-            "vim_user": "user",
-            "vim_password": "password",
-            "vim_tenant_name": "tenant",
-            "config":
-                {
-                    "foo": "bar"
-                }
-        }
-
-        self.producer.send('vim_account', key=b'create', value=json.dumps(create_payload))
-
-        self.producer.flush()
-
-        time.sleep(1)
-        creds = self.auth_manager.get_credentials(create_payload['_id'])
-        self.assertIsNotNone(creds)
-        self.assertEqual(creds.name, create_payload['name'])
-        self.assertEqual(json.loads(creds.config), create_payload['config'])
-
-        # Set-up message, producer and consumer for tests
-        edit_payload = {
-            "_id": "test_id",
-            "name": "test_name_edited",
-            "vim_type": "openstack",
-            "vim_url": "auth_url",
-            "vim_user": "user",
-            "vim_password": "password",
-            "vim_tenant_name": "tenant",
-            "config":
-                {
-                    "foo_edited": "bar_edited"
-                }
-        }
-
-        self.producer.send('vim_account', key=b'edit', value=json.dumps(edit_payload))
-
-        self.producer.flush()
-
-        time.sleep(1)
-        creds = self.auth_manager.get_credentials(edit_payload['_id'])
-        self.assertEqual(creds.name, edit_payload['name'])
-        self.assertEqual(json.loads(creds.config), edit_payload['config'])
-
-        delete_payload = {
-            "_id": "test_id"
-        }
-
-        self.producer.send('vim_account', key=b'delete', value=json.dumps(delete_payload))
-
-        self.producer.flush()
-
-        time.sleep(1)
-        creds = self.auth_manager.get_credentials(delete_payload['_id'])
-        self.assertIsNone(creds)