Merge "Docs: Enable O2 DMS by exposing k8s API endpoint"

[pti/o2.git] / o2dms / api / dms_lcm_view.py

diff --git a/o2dms/api/dms_lcm_view.py b/o2dms/api/dms_lcm_view.py
index 208636a..c9abac9 100644 (file)
--- a/o2dms/api/dms_lcm_view.py
+++ b/o2dms/api/dms_lcm_view.py
@@ -35,73 +35,46 @@ def deployment_managers(uow: unit_of_work.AbstractUnitOfWork):
 
 
 def deployment_manager_one(deploymentManagerId: str,
-                           uow: unit_of_work.AbstractUnitOfWork,
-                           profile: str = 'params'):
+                           uow: unit_of_work.AbstractUnitOfWork):
+
     # with uow:
     #     res = uow.session.execute(select(deploymentmanager).where(
     #         deploymentmanager.c.deploymentManagerId == deploymentManagerId))
     #     first = res.first()
-    # return None if first is None else dict(first)
-    # with uow:
-    # first = uow.deployment_managers.get(deploymentManagerId)
-    # return first.serialize() if first is not None else None
+    #     return None if first is None else dict(first)
     with uow:
         first = uow.deployment_managers.get(deploymentManagerId)
-        if first is None:
-            return first
-        result = first.serialize()
+        return first.serialize() if first is not None else None
+
+    # profile = profile.lower()
+    # with uow:
+    #     first = uow.deployment_managers.get(deploymentManagerId)
+    #     if first is None:
+    #         return first
+    #     result = first.serialize()
+
+    # profile_data = result.pop("profile", None)
+    # result['profileName'] = 'default'
 
-    if "params" == profile:
-        pass
-    elif "file" == profile and result.hasattr("profile"):
-        p = result.pop("profile", None)
-        result["profile"] = _gen_kube_config(deploymentManagerId, p)
-    else:
-        result.pop("profile", None)
+    # if "sol0018" == profile:
+    #     result['profileName'] = profile
+    #     result['profileData'] = profile_data
+    # elif "file" == profile and result.hasattr("profile"):
+    # p = result.pop("profile", None)
+    # result["profile"] = _gen_kube_config(deploymentManagerId, p)
 
-    return result
+    # return result
 
 
 def _gen_kube_config(dmId: str, kubeconfig: dict) -> dict:
 
-    # KUBECONFIG environment variable
-    # reference:
-    # https://kubernetes.io/docs/tasks/access-application-cluster/configure-access-multiple-clusters/
-    data = {
-        'apiVersion': 'v1',
-        'clusters': [
-            {
-                'cluster': {
-                    'server':
-                    kubeconfig.pop('cluster_api_endpoint', None),
-                    'certificate-authority-data':
-                    kubeconfig.pop('cluster_ca_cert', None),
-                },
-                'name': 'inf-cluster'
-            }],
-        'contexts': [
-            {
-                'context': {
-                    'cluster': 'inf-cluster',
-                    'user': 'kubernetes-admin'
-                },
-                'name': 'kubernetes-admin@inf-cluster'
-            }
-        ],
-        'current-context': 'kubernetes-admin@inf-cluster',
-        'kind': 'Config',
-        'preferences': {},
-        'users': [
-            {
-                'name': kubeconfig.pop('admin_user', None),
-                'user': {
-                    'client-certificate-data':
-                    kubeconfig.pop('admin_client_cert', None),
-                    'client-key-data':
-                    kubeconfig.pop('admin_client_key', None),
-                }
-            }]
-    }
+    data = config.gen_k8s_config_dict(
+        kubeconfig.pop('cluster_api_endpoint', None),
+        kubeconfig.pop('cluster_ca_cert', None),
+        kubeconfig.pop('admin_user', None),
+        kubeconfig.pop('admin_client_cert', None),
+        kubeconfig.pop('admin_client_key', None),
+    )
 
     # Generate a random key for tmp kube config file
     letters = string.ascii_uppercase