feat: check csars for inputs

Author: jaydesl

micado_eec/micado.py

@@ -8,7 +8,7 @@
 from werkzeug.exceptions import BadRequest, NotFound
 
 from .handle_micado import HandleMicado
-from .utils import base64_to_yaml, is_valid_adt, get_adt_inputs, file_to_json
+from .utils import base64_to_yaml, is_valid_adt, get_adt_inputs, get_csar_inputs, file_to_json
 
 r = redis.StrictRedis("redis", decode_responses=True)
 if not r.ping():
@@ -131,7 +131,8 @@ def _get_artefact_ports(artefact_data):
     """
     free_inputs, free_outputs, parameters = [], [], []
     if artefact_data["downloadUrl"].endswith(".csar"):
-        return [], [], []
+        params = get_csar_inputs(artefact_data["downloadUrl_content"])
+        return [], [], params
 
     try:
         artefact_content = base64_to_yaml(artefact_data["downloadUrl_content"])

micado_eec/utils.py

@@ -1,5 +1,7 @@
 import base64
+import io
 import json
+import zipfile
 
 import ruamel.yaml as yaml
 
@@ -59,3 +61,30 @@ def get_adt_inputs(adt):
         }
         for key, details in adt.get("topology_template", {}).get("inputs", {}).items()
     ]
+
+def get_csar_inputs(b64_csar):
+
+    file_content = base64.b64decode(b64_csar)
+
+    file_like_object = io.BytesIO(file_content)
+    zip_file = zipfile.ZipFile(file_like_object)
+
+    params = []
+
+    for file in zip_file.namelist():
+
+        if not file.endswith('.yaml') or file.startswith('__'):
+            continue
+
+        yaml_file = zip_file.open(file)
+        adt = yaml.safe_load(yaml_file)
+        
+        params.extend([
+            {
+                "key": key,
+                "description": details.get("description", "n/a").rstrip(),
+            }
+            for key, details in adt.get("topology_template", {}).get("inputs", {}).items()
+        ])
+
+    return params