X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=multivimbroker%2Fmultivimbroker%2Ftests%2Ftest_syscomm.py;h=e28c2c762cb6831913730e915d0c59311ca1874a;hb=3a5ab188980db59049c9b0318fd6facddccce366;hp=bed857dc5c8674dfc7e8ae54d8dc361fcb2e116e;hpb=02d164d5aea5bf6a8d3077f05217328a6f12a6ef;p=multicloud%2Fframework.git diff --git a/multivimbroker/multivimbroker/tests/test_syscomm.py b/multivimbroker/multivimbroker/tests/test_syscomm.py index bed857d..e28c2c7 100644 --- a/multivimbroker/multivimbroker/tests/test_syscomm.py +++ b/multivimbroker/multivimbroker/tests/test_syscomm.py @@ -8,8 +8,11 @@ # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +import mock import unittest +from multivimbroker.pub import exceptions +from multivimbroker.pub.msapi import extsys from multivimbroker.pub.utils import syscomm @@ -24,3 +27,54 @@ class TestSyscomm(unittest.TestCase): for item in ret: for v in item['versions']: self.assertIn(v, expected_body[item['vim_type']]) + + @mock.patch.object(extsys, "get_vim_by_id") + def test_getMultivimDriver(self, mock_get_vim): + mock_get_vim.return_value = { + "type": "openstack", + "version": "ocata" + } + full_path = "multicloud/v0/openstack_regionone/identity" + expect_path = "multicloud-ocata/v0/openstack_regionone/identity" + ret_path = syscomm.getMultivimDriver("openstack_regionone", full_path) + self.assertEqual(expect_path, ret_path) + + def test_findMultivimDriver_no_type(self): + vim = {"type": "wrong type"} + self.assertRaises(exceptions.NotFound, syscomm.findMultivimDriver, vim) + + def test_findMultivimDriver_no_version(self): + vim = {"type": "openstack"} + ret = syscomm.findMultivimDriver(vim) + self.assertEqual("multicloud-ocata", ret) + + def test_findMultivimDriver_with_version(self): + vim = {"type": "openstack", "version": "titanium_cloud"} + ret = syscomm.findMultivimDriver(vim) + self.assertEqual("multicloud-titanium_cloud", ret) + + def test_originHeaders(self): + req = mock.Mock() + req.META = { + "HTTP_X_AUTH_TOKEN": "token_1", + "NOT_STARTSWITH_HTTP": "value_1" + } + expect_headers = { + "X-AUTH-TOKEN": "token_1" + } + ret_headers = syscomm.originHeaders(req) + self.assertDictEqual(expect_headers, ret_headers) + + def test_getHeadersKeys_no_connection(self): + resp = {} + self.assertEqual([], syscomm.getHeadersKeys(resp)) + + def test_getHeadersKeys_with_connection(self): + resp = { + "connection": "aa,bb", + "keep-alive": "yes", + "aa": "vaa", + "bb": "vbb", + "cc": "vcc" + } + self.assertEqual(["cc"], syscomm.getHeadersKeys(resp))