Move to k8s service names, exceptions

Issue-ID: DCAEGEN2-1537
Change-Id: Ibb7bd0233b5de9eb853f3516ba0907e148eae21d
Signed-off-by: Tommy Carpenter <tommy@research.att.com>

1 files changed, 83 insertions, 0 deletions

diff --git a/onap-dcae-cbs-docker-client/tests/conftest.py b/onap-dcae-cbs-docker-client/tests/conftest.py
new file mode 100644
index 0000000..05d2eb5
--- /dev/null
+++ b/onap-dcae-cbs-docker-client/tests/conftest.py
@@ -0,0 +1,83 @@
+# ================================================================================
+# Copyright (c) 2019 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# 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.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+import pytest
+from requests.exceptions import HTTPError, ConnectionError
+
+
+class FakeResponse:
+    def __init__(self, status_code, thejson):
+        self.status_code = status_code
+        self.thejson = thejson
+        self.text = ""
+
+    def raise_for_status(self):
+        if self.status_code > 299:
+            raise HTTPError
+
+    def json(self):
+        return self.thejson
+
+
+@pytest.fixture
+def monkeyed_requests_get():
+    """
+    mock for the CBS get
+    """
+
+    def _monkeyed_requests_get(url):
+        if url == "http://config_binding_service:10000/service_component_all/mybestfrienddotcom":
+            return FakeResponse(
+                status_code=200,
+                thejson={
+                    "config": {"key_to_your_heart": 666},
+                    "dti": {"some amazing": "dti stuff"},
+                    "policies": {"event": {"foo": "bar"}, "items": [{"foo2": "bar2"}]},
+                    "otherkey": {"foo3": "bar3"},
+                },
+            )
+
+        elif url == "http://config_binding_service:10000/service_component/mybestfrienddotcom":
+            return FakeResponse(status_code=200, thejson={"key_to_your_heart": 666})
+        else:
+            raise Exception("Unexpected URL {0}!".format(url))
+
+    return _monkeyed_requests_get
+
+
+@pytest.fixture
+def monkeyed_requests_get_404():
+    def _monkeyed_requests_get_404(url):
+        """
+        get that pretends that key doesnt exist
+        """
+        if url in [
+            "http://config_binding_service:10000/service_component_all/mybestfrienddotcom",
+            "http://config_binding_service:10000/service_component/mybestfrienddotcom",
+        ]:
+            return FakeResponse(status_code=404, thejson={})
+        raise Exception("Unexpected URL {0}!".format(url))
+
+    return _monkeyed_requests_get_404
+
+
+@pytest.fixture
+def monkeyed_requests_get_unreachable():
+    def _monkeyed_requests_get_unreachable(_url):
+        raise ConnectionError()
+
+    return _monkeyed_requests_get_unreachable