10 files changed, 695 insertions, 22 deletions

diff --git a/moon_manager/tests/functional_pod/conftest.py b/moon_manager/tests/functional_pod/conftest.py
new file mode 100644
index 00000000..b5811755
--- /dev/null
+++ b/moon_manager/tests/functional_pod/conftest.py
@@ -0,0 +1,12 @@
+import pytest
+
+print("ANALYSING CONFTEST")
+
+
+@pytest.fixture
+def context():
+    print("CREATING CONTEXT")
+    yield {
+        "hostname": "manager",
+        "port": 8082,
+    }
diff --git a/moon_manager/tests/functional_pod/run_functional_tests.sh b/moon_manager/tests/functional_pod/run_functional_tests.sh
index c80bf15d..7a95a491 100644
--- a/moon_manager/tests/functional_pod/run_functional_tests.sh
+++ b/moon_manager/tests/functional_pod/run_functional_tests.sh
@@ -1,11 +1,4 @@
 #!/usr/bin/env bash
 
-set -x
-
-kubectl create -n moon -f tools/moon_kubernetes/templates/moon_forming.yaml
-
-echo Waiting for jobs forming
-sleep 5
-kubectl get jobs -n moon
-kubectl logs -n moon jobs/forming
-
+cd /data/tests/functional_pod
+pytest .
diff --git a/moon_manager/tests/functional_pod/test_manager.py b/moon_manager/tests/functional_pod/test_manager.py
new file mode 100644
index 00000000..aab5fba4
--- /dev/null
+++ b/moon_manager/tests/functional_pod/test_manager.py
@@ -0,0 +1,77 @@
+import json
+import requests
+
+
+def get_json(data):
+    return json.loads(data.decode("utf-8"))
+
+
+def get_pdp(context):
+    req = requests.get("http://{}:{}/pdp".format(
+        context.get("hostname"),
+        context.get("port")),
+        timeout=3)
+    pdp = req.json()
+    return req, pdp
+
+
+def add_pdp(context, data):
+    req = requests.post("http://{}:{}/pdp".format(
+        context.get("hostname"),
+        context.get("port")),
+        data=json.dumps(data),
+        headers={'Content-Type': 'application/json'},
+        timeout=3)
+    pdp = req.json()
+    return req, pdp
+
+
+def delete_pdp(context, key):
+    req = requests.delete("http://{}:{}/pdp/{}".format(
+        context.get("hostname"),
+        context.get("port"), key),
+        timeout=3)
+    return req
+
+
+def delete_pdp_without_id(context):
+    req = requests.delete("http://{}:{}/pdp/{}".format(
+        context.get("hostname"),
+        context.get("port"), ""),
+        timeout=3)
+    return req
+
+
+def test_get_pdp(context):
+    req, pdp = get_pdp(context)
+    assert req.status_code == 200
+    assert isinstance(pdp, dict)
+    assert "pdps" in pdp
+
+
+def test_add_pdp(context):
+    data = {
+        "name": "testuser",
+        "security_pipeline": ["policy_id_1", "policy_id_2"],
+        "keystone_project_id": "keystone_project_id",
+        "description": "description of testuser"
+    }
+    req, pdp = add_pdp(context, data)
+    assert req.status_code == 200
+    assert isinstance(pdp, dict)
+    value = list(pdp["pdps"].values())[0]
+    assert "pdps" in pdp
+    assert value['name'] == "testuser"
+    assert value["description"] == "description of {}".format("testuser")
+    assert value["keystone_project_id"] == "keystone_project_id"
+
+
+def test_delete_pdp(context):
+    request, pdp = get_pdp(context)
+    success_req = None
+    for key, value in pdp['pdps'].items():
+        if value['name'] == "testuser":
+            success_req = delete_pdp(context, key)
+            break
+    assert success_req
+    assert success_req.status_code == 200
diff --git a/moon_manager/tests/functional_pod/test_models.py b/moon_manager/tests/functional_pod/test_models.py
new file mode 100644
index 00000000..dcda9f32
--- /dev/null
+++ b/moon_manager/tests/functional_pod/test_models.py
@@ -0,0 +1,78 @@
+import json
+import requests
+
+
+def get_models(context):
+    req = requests.get("http://{}:{}/models".format(
+        context.get("hostname"),
+        context.get("port")),
+        timeout=3)
+    models = req.json()
+    return req, models
+
+
+def add_models(context, name):
+    data = {
+        "name": name,
+        "description": "description of {}".format(name),
+        "meta_rules": ["meta_rule_id1", "meta_rule_id2"]
+    }
+    req = requests.post("http://{}:{}/models".format(
+        context.get("hostname"),
+        context.get("port")),
+        data=json.dumps(data),
+        headers={'Content-Type': 'application/json'},
+        timeout=3)
+    models = req.json()
+    return req, models
+
+
+def delete_models(context, name):
+    _, models = get_models(context)
+    request = None
+    for key, value in models['models'].items():
+        if value['name'] == name:
+            request = requests.delete("http://{}:{}/models/{}".format(key,
+                                      context.get("hostname"),
+                                      context.get("port")),
+                                      timeout=3)
+            break
+    return request
+
+
+def delete_models_without_id(context):
+    req = requests.delete("http://{}:{}/models/{}".format(
+                          context.get("hostname"),
+                          context.get("port"),
+                          ""),
+                          timeout=3)
+    return req
+
+
+def test_get_models(context):
+    req, models = get_models(context)
+    assert req.status_code == 200
+    assert isinstance(models, dict)
+    assert "models" in models
+
+
+def test_add_models(context):
+    req, models = add_models(context, "testuser")
+    assert req.status_code == 200
+    assert isinstance(models, dict)
+    value = list(models["models"].values())[0]
+    assert "models" in models
+    assert value['name'] == "testuser"
+    assert value["description"] == "description of {}".format("testuser")
+    assert value["meta_rules"][0] == "meta_rule_id1"
+
+
+def test_delete_models(context):
+    req = delete_models(context, "testuser")
+    assert req.status_code == 200
+
+
+def test_delete_models_without_id(context):
+    req = delete_models_without_id(context)
+    assert req.status_code == 500
+
diff --git a/moon_manager/tests/unit_python/api/test_assignemnt.py b/moon_manager/tests/unit_python/api/test_assignemnt.py
new file mode 100644
index 00000000..08688e04
--- /dev/null
+++ b/moon_manager/tests/unit_python/api/test_assignemnt.py
@@ -0,0 +1,174 @@
+import api.utilities as utilities
+import json
+
+
+# subject_categories_test
+
+
+def get_subject_assignment(client, policy_id):
+    req = client.get("/policies/{}/subject_assignments".format(policy_id))
+    subject_assignment = utilities.get_json(req.data)
+    return req, subject_assignment
+
+
+def add_subject_assignment(client, policy_id, category_id):
+    data = {
+        "id": "id1",
+        "category_id": category_id,
+        "data_id": "data_id1"
+    }
+    req = client.post("/policies/{}/subject_assignments/{}".format(policy_id, category_id), data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    subject_assignment = utilities.get_json(req.data)
+    return req, subject_assignment
+
+
+def delete_subject_assignment(client, policy_id):
+    req = client.delete("/policies/{}/subject_assignments".format(policy_id))
+    return req
+
+
+def test_get_subject_assignment():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, subject_assignment = get_subject_assignment(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(subject_assignment, dict)
+    assert "subject_assignments" in subject_assignment
+
+
+def test_add_subject_assignment():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, subject_assignment = add_subject_assignment(client, policy_id, "111")
+    assert req.status_code == 200
+    assert isinstance(subject_assignment, dict)
+    value = subject_assignment["subject_assignments"]
+    assert "subject_assignments" in subject_assignment
+    id = list(value.keys())[0]
+    assert value[id]['policy_id'] == policy_id
+    assert value[id]['category_id'] == "111"
+    assert value[id]['subject_id'] == "id1"
+
+
+def test_delete_subject_assignment():
+    client = utilities.register_client()
+    policy_id = utilities.get_policy_id()
+    success_req = delete_subject_assignment(client, policy_id)
+    assert success_req.status_code == 200
+
+# ---------------------------------------------------------------------------
+
+# object_categories_test
+
+
+def get_object_assignment(client, policy_id):
+    req = client.get("/policies/{}/object_assignments".format(policy_id))
+    object_assignment = utilities.get_json(req.data)
+    return req, object_assignment
+
+
+def add_object_assignment(client, policy_id, category_id):
+    data = {
+        "id": "id1",
+        "category_id": category_id,
+        "data_id": "data_id1"
+    }
+    req = client.post("/policies/{}/object_assignments/{}".format(policy_id, category_id), data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    object_assignment = utilities.get_json(req.data)
+    return req, object_assignment
+
+
+def delete_object_assignment(client, policy_id):
+    req = client.delete("/policies/{}/object_assignments".format(policy_id))
+    return req
+
+
+def test_get_object_assignment():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, object_assignment = get_object_assignment(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(object_assignment, dict)
+    assert "object_assignments" in object_assignment
+
+
+def test_add_object_assignment():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, object_assignment = add_object_assignment(client, policy_id, "111")
+    assert req.status_code == 200
+    assert isinstance(object_assignment, dict)
+    value = object_assignment["object_assignments"]
+    assert "object_assignments" in object_assignment
+    id = list(value.keys())[0]
+    assert value[id]['policy_id'] == policy_id
+    assert value[id]['category_id'] == "111"
+    assert value[id]['object_id'] == "id1"
+
+
+def test_delete_object_assignment():
+    client = utilities.register_client()
+    policy_id = utilities.get_policy_id()
+    success_req = delete_object_assignment(client, policy_id)
+    assert success_req.status_code == 200
+
+# ---------------------------------------------------------------------------
+
+# action_categories_test
+
+
+def get_action_assignment(client, policy_id):
+    req = client.get("/policies/{}/action_assignments".format(policy_id))
+    action_assignment = utilities.get_json(req.data)
+    return req, action_assignment
+
+
+def add_action_assignment(client, policy_id, category_id):
+    data = {
+        "id": "id1",
+        "category_id": category_id,
+        "data_id": "data_id1"
+    }
+    req = client.post("/policies/{}/action_assignments/{}".format(policy_id, category_id), data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    action_assignment = utilities.get_json(req.data)
+    return req, action_assignment
+
+
+def delete_action_assignment(client, policy_id):
+    req = client.delete("/policies/{}/action_assignments".format(policy_id))
+    return req
+
+
+def test_get_action_assignment():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, action_assignment = get_action_assignment(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(action_assignment, dict)
+    assert "action_assignments" in action_assignment
+
+
+def test_add_action_assignment():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, action_assignment = add_action_assignment(client, policy_id, "111")
+    assert req.status_code == 200
+    assert isinstance(action_assignment, dict)
+    value = action_assignment["action_assignments"]
+    assert "action_assignments" in action_assignment
+    id = list(value.keys())[0]
+    assert value[id]['policy_id'] == policy_id
+    assert value[id]['category_id'] == "111"
+    assert value[id]['action_id'] == "id1"
+
+
+def test_delete_action_assignment():
+    client = utilities.register_client()
+    policy_id = utilities.get_policy_id()
+    success_req = delete_action_assignment(client, policy_id)
+    assert success_req.status_code == 200
+
+# ---------------------------------------------------------------------------
\ No newline at end of file
diff --git a/moon_manager/tests/unit_python/api/test_data.py b/moon_manager/tests/unit_python/api/test_data.py
new file mode 100644
index 00000000..87a80c69
--- /dev/null
+++ b/moon_manager/tests/unit_python/api/test_data.py
@@ -0,0 +1,168 @@
+import api.utilities as utilities
+import json
+
+
+# subject_categories_test
+
+
+def get_subject_data(client, policy_id):
+    req = client.get("/policies/{}/subject_data".format(policy_id))
+    subject_data = utilities.get_json(req.data)
+    return req, subject_data
+
+
+def add_subject_data(client, name, policy_id, category_id):
+    data = {
+        "name": name,
+        "description": "description of {}".format(name)
+    }
+    req = client.post("/policies/{}/subject_data/{}".format(policy_id, category_id), data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    subject_data = utilities.get_json(req.data)
+    return req, subject_data
+
+
+def delete_subject_data(client, policy_id):
+    req = client.delete("/policies/{}/subject_data".format(policy_id))
+    return req
+
+
+def test_get_subject_data():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, subject_data = get_subject_data(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(subject_data, dict)
+    assert "subject_data" in subject_data
+
+
+def test_add_subject_data():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, subject_data = add_subject_data(client, "testuser", policy_id, "111")
+    assert req.status_code == 200
+    assert isinstance(subject_data, dict)
+    value = subject_data["subject_data"]['data']
+    assert "subject_data" in subject_data
+    id = list(value.keys())[0]
+    assert value[id]['name'] == "testuser"
+    assert value[id]['description'] == "description of {}".format("testuser")
+
+
+def test_delete_subject_data():
+    client = utilities.register_client()
+    policy_id = utilities.get_policy_id()
+    success_req = delete_subject_data(client, policy_id)
+    assert success_req.status_code == 200
+
+# ---------------------------------------------------------------------------
+
+# object_categories_test
+
+
+def get_object_data(client, policy_id):
+    req = client.get("/policies/{}/object_data".format(policy_id))
+    object_data = utilities.get_json(req.data)
+    return req, object_data
+
+
+def add_object_data(client, name, policy_id, category_id):
+    data = {
+        "name": name,
+        "description": "description of {}".format(name)
+    }
+    req = client.post("/policies/{}/object_data/{}".format(policy_id, category_id), data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    object_data = utilities.get_json(req.data)
+    return req, object_data
+
+
+def delete_object_data(client, policy_id):
+    req = client.delete("/policies/{}/object_data".format(policy_id))
+    return req
+
+
+def test_get_object_data():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, object_data = get_object_data(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(object_data, dict)
+    assert "object_data" in object_data
+
+
+def test_add_object_data():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, object_data = add_object_data(client, "testuser", policy_id, "111")
+    assert req.status_code == 200
+    assert isinstance(object_data, dict)
+    value = object_data["object_data"]['data']
+    assert "object_data" in object_data
+    id = list(value.keys())[0]
+    assert value[id]['value']['name'] == "testuser"
+    assert value[id]['value']['description'] == "description of {}".format("testuser")
+
+
+def test_delete_object_data():
+    client = utilities.register_client()
+    policy_id = utilities.get_policy_id()
+    success_req = delete_object_data(client, policy_id)
+    assert success_req.status_code == 200
+
+# ---------------------------------------------------------------------------
+
+# action_categories_test
+
+
+def get_action_data(client, policy_id):
+    req = client.get("/policies/{}/action_data".format(policy_id))
+    action_data = utilities.get_json(req.data)
+    return req, action_data
+
+
+def add_action_data(client, name, policy_id, category_id):
+    data = {
+        "name": name,
+        "description": "description of {}".format(name)
+    }
+    req = client.post("/policies/{}/action_data/{}".format(policy_id, category_id), data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    action_data = utilities.get_json(req.data)
+    return req, action_data
+
+
+def delete_action_data(client, policy_id):
+    req = client.delete("/policies/{}/action_data".format(policy_id))
+    return req
+
+
+def test_get_action_data():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, action_data = get_action_data(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(action_data, dict)
+    assert "action_data" in action_data
+
+
+def test_add_action_data():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, action_data = add_action_data(client, "testuser", policy_id, "111")
+    assert req.status_code == 200
+    assert isinstance(action_data, dict)
+    value = action_data["action_data"]['data']
+    assert "action_data" in action_data
+    id = list(value.keys())[0]
+    assert value[id]['value']['name'] == "testuser"
+    assert value[id]['value']['description'] == "description of {}".format("testuser")
+
+
+def test_delete_action_data():
+    client = utilities.register_client()
+    policy_id = utilities.get_policy_id()
+    success_req = delete_action_data(client, policy_id)
+    assert success_req.status_code == 200
+
+# ---------------------------------------------------------------------------
\ No newline at end of file
diff --git a/moon_manager/tests/unit_python/api/test_pdp.py b/moon_manager/tests/unit_python/api/test_pdp.py
new file mode 100644
index 00000000..a2d0cb5a
--- /dev/null
+++ b/moon_manager/tests/unit_python/api/test_pdp.py
@@ -0,0 +1,62 @@
+import json
+import api.utilities as utilities
+import pytest
+
+
+def get_pdp(client):
+    req = client.get("/pdp")
+    pdp = utilities.get_json(req.data)
+    return req, pdp
+
+
+def add_pdp(client, data):
+    req = client.post("/pdp", data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    pdp = utilities.get_json(req.data)
+    return req, pdp
+
+
+def delete_pdp(client, key):
+    req = client.delete("/pdp/{}".format(key))
+    return req
+
+
+def delete_pdp_without_id(client):
+    req = client.delete("/pdp/{}".format(""))
+    return req
+
+
+def test_get_pdp():
+    client = utilities.register_client()
+    req, pdp = get_pdp(client)
+    assert req.status_code == 200
+    assert isinstance(pdp, dict)
+    assert "pdps" in pdp
+
+
+def test_add_pdp():
+    data = {
+        "name": "testuser",
+        "security_pipeline": ["policy_id_1", "policy_id_2"],
+        "keystone_project_id": "keystone_project_id",
+        "description": "description of testuser"
+    }
+    client = utilities.register_client()
+    req, pdp = add_pdp(client, data)
+    assert req.status_code == 200
+    assert isinstance(pdp, dict)
+    value = list(pdp["pdps"].values())[0]
+    assert "pdps" in pdp
+    assert value['name'] == "testuser"
+    assert value["description"] == "description of {}".format("testuser")
+    assert value["keystone_project_id"] == "keystone_project_id"
+
+
+def test_delete_pdp():
+    client = utilities.register_client()
+    request, pdp = get_pdp(client)
+    for key, value in pdp['pdps'].items():
+        if value['name'] == "testuser":
+            success_req = delete_pdp(client, key)
+            break
+    assert success_req.status_code == 200
diff --git a/moon_manager/tests/unit_python/api/test_rules.py b/moon_manager/tests/unit_python/api/test_rules.py
new file mode 100644
index 00000000..86a3d390
--- /dev/null
+++ b/moon_manager/tests/unit_python/api/test_rules.py
@@ -0,0 +1,58 @@
+import api.utilities as utilities
+import json
+
+
+def get_rules(client, policy_id):
+    req = client.get("/policies/{}/rules".format(policy_id))
+    rules = utilities.get_json(req.data)
+    return req, rules
+
+
+def add_rules(client, policy_id):
+    data = {
+        "meta_rule_id": "meta_rule_id1",
+        "rule": ["subject_data_id2", "object_data_id2", "action_data_id2"],
+        "instructions": (
+            {"decision": "grant"},
+        ),
+        "enabled": True
+    }
+    req = client.post("/policies/{}/rules".format(policy_id), data=json.dumps(data),
+                      headers={'Content-Type': 'application/json'})
+    rules = utilities.get_json(req.data)
+    return req, rules
+
+
+def delete_rules(client, policy_id, meta_rule_id):
+    req = client.delete("/policies/{}/rules/{}".format(policy_id, meta_rule_id))
+    return req
+
+
+def test_get_rules():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, rules = get_rules(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(rules, dict)
+    assert "rules" in rules
+
+
+def test_add_rules():
+    policy_id = utilities.get_policy_id()
+    client = utilities.register_client()
+    req, rules = add_rules(client, policy_id)
+    assert req.status_code == 200
+    assert isinstance(rules, dict)
+    value = rules["rules"]
+    assert "rules" in rules
+    id = list(value.keys())[0]
+    assert value[id]["meta_rule_id"] == "meta_rule_id1"
+
+
+def test_delete_rules():
+    client = utilities.register_client()
+    policy_id = utilities.get_policy_id()
+    req, added_rules = get_rules(client, policy_id)
+    id = added_rules["rules"]['rules'][0]['id']
+    rules = delete_rules(client, policy_id, id)
+    assert rules.status_code == 200
diff --git a/moon_manager/tests/unit_python/api/utilities.py b/moon_manager/tests/unit_python/api/utilities.py
index a2b0689b..66ca30c5 100644
--- a/moon_manager/tests/unit_python/api/utilities.py
+++ b/moon_manager/tests/unit_python/api/utilities.py
@@ -9,4 +9,18 @@ def register_client():
     import moon_manager.server
     server = moon_manager.server.create_server()
     client = server.app.test_client()
-    return client
\ No newline at end of file
+    return client
+
+
+def get_policy_id():
+    import api.test_policies as policies
+    client = register_client()
+    policy_id = ''
+    req, policy = policies.get_policies(client)
+    for id in policy['policies']:
+        if id:
+            policy_id = id
+            break
+    if not policy_id:
+        policies.add_policies(client, "testuser")
+    return policy_id
diff --git a/moon_manager/tests/unit_python/conftest.py b/moon_manager/tests/unit_python/conftest.py
index 3f73f2da..902a41a2 100644
--- a/moon_manager/tests/unit_python/conftest.py
+++ b/moon_manager/tests/unit_python/conftest.py
@@ -35,7 +35,7 @@ CONF = {
             "bind": "0.0.0.0",
             "port": 8083,
             "container": "wukongsun/moon_orchestrator:v4.3",
-            "hostname": "interface"
+            "hostname": "orchestrator"
         },
         "pipeline": {
             "interface": {
@@ -114,7 +114,7 @@ CONF = {
     },
     "messenger": {
         "url": "rabbit://moon:p4sswOrd1@messenger:5672/moon"
-    }
+    },
 }
 
 COMPONENTS = (
@@ -123,22 +123,50 @@ COMPONENTS = (
     "database",
     "slave",
     "components/manager",
+    "components/orchestrator"
 )
 
+PODS = {
+    "pods": {
+        "721760dd-de5f-11e7-8001-3863bbb766f3": [
+            {
+                "pdp_id": "b3d3e18abf3340e8b635fd49e6634ccd",
+                "port": 8080,
+                "genre": "interface",
+                "name": "interface-paltry",
+                "keystone_project_id": "a64beb1cc224474fb4badd43173e7101",
+                "namespace": "moon",
+                "container": "wukongsun/moon_interface:v4.3"
+            },
+            {
+                "pdp_id": "b3d3e18abf3340e8b635fd49e6634ccd",
+                "meta_rule_id": "f8f49a779ceb47b3ac810f01ef71b4e0",
+                "port": 8081,
+                "genre": "authz",
+                "name": "authz-economic",
+                "policy_id": "f8f49a779ceb47b3ac810f01ef71b4e0",
+                "keystone_project_id": "a64beb1cc224474fb4badd43173e7101",
+                "namespace": "moon",
+                "container": "wukongsun/moon_authz:v4.3"
+            }
+        ]
+    }
+}
+
 
 def get_b64_conf(component=None):
     if component in CONF:
         return base64.b64encode(
             json.dumps(
-                CONF[component]).encode('utf-8')+b"\n").decode('utf-8')
+                CONF[component]).encode('utf-8') + b"\n").decode('utf-8')
     elif "/" in component:
         key1, _, key2 = component.partition("/")
         return base64.b64encode(
             json.dumps(
-                CONF[key1][key2]).encode('utf-8')+b"\n").decode('utf-8')
+                CONF[key1][key2]).encode('utf-8') + b"\n").decode('utf-8')
     else:
         return base64.b64encode(
-            json.dumps(CONF).encode('utf-8')+b"\n").decode('utf-8')
+            json.dumps(CONF).encode('utf-8') + b"\n").decode('utf-8')
 
 
 @pytest.fixture(autouse=True)
@@ -150,7 +178,7 @@ def no_requests(monkeypatch):
             m.register_uri(
                 'GET', 'http://consul:8500/v1/kv/{}'.format(component),
                 json=[{'Key': component, 'Value': get_b64_conf(component)}]
-                )
+            )
         m.register_uri(
             'POST', 'http://keystone:5000/v3/auth/tokens',
             headers={'X-Subject-Token': "111111111"}
@@ -169,10 +197,22 @@ def no_requests(monkeypatch):
         )
         m.register_uri(
             'POST', 'http://keystone:5000/v3/users/',
-            json={"users": [{
-                "id": "1111111111111"
-            }]}
+            json={"users": [{"id": "1111111111111"}]}
         )
+        m.register_uri(
+            'POST', 'http://orchestrator:8083/pods',
+            json=PODS,
+            headers={"content-type": "application/json"}
+        )
+        m.register_uri(
+            'GET', 'http://orchestrator:8083/pods',
+            json=PODS
+        )
+        m.register_uri(
+            'DELETE', 'http://orchestrator:8083/pods/{}'.format(list([PODS['pods'].keys()])[0]),
+            headers={"content-type": "application/json"}
+        )
+
         print("Start populating the DB.")
         from python_moondb.db_manager import init_engine, main
         engine = init_engine()
@@ -181,7 +221,6 @@ def no_requests(monkeypatch):
         print("End populating the DB.")
         yield m
 
-
 # @pytest.fixture(autouse=True, scope="session")
 # def manage_database():
 #     from moon_db.db_manager import init_engine, run
@@ -189,5 +228,3 @@ def no_requests(monkeypatch):
 #     run("upgrade", logging.getLogger("db_manager"), engine)
 #     yield
 #     print("Will close the DB")
-
-