config: Transformer for old version of config

Refs: lfn-cnti#2130
- The transformer transforms the old config according to the
structure proposed in lfn-cnti#2129.

Signed-off-by: svteb <[email protected]>

Author: svteb

src/tasks/utils/cnf_installation/config_transformer.cr

@@ -0,0 +1,131 @@
+require "yaml"
+
+module CNFInstall
+  class ConfigTransformer
+    # Initialize with the original configuration hash
+    def initialize(@old_config : Hash)
+    end
+
+    # Perform the transformation to the new config format
+    def transform : Hash
+      transformed_config = {
+        "config_version" => "2.0", # New version identifier
+        "common_parameters" => transform_common_parameters,
+        "dynamic_parameters" => transform_dynamic_parameters,
+        "deployments" => transform_deployments
+      }
+
+      transformed_config
+    end    
+
+    private def transform_common_parameters : Hash
+      {
+        "service_name" => @old_config["service_name"]?.as_s,
+        "rolling_update_tag" => @old_config["rolling_update_tag"]?.as_s,
+        "white_list_container_names" => @old_config["white_list_container_names"]?.as_a.map(&.as_s),
+        "docker_insecure_registries" => @old_config["docker_insecure_registries"]?.as_a.map(&.as_s),
+        "image_registry_fqdns" => @old_config["image_registry_fqdns"]?.as_h(String, String),
+        "container_names" => transform_container_names(@old_config["container_names"]?.as_a),
+        "five_g_parameters" => transform_five_g_parameters
+      }
+    end
+
+    private def transform_dynamic_parameters : Hash
+      {
+        "source_cnf_dir" => @old_config["source_cnf_dir"]?.as_s,
+        "yml_file_path" => @old_config["yml_file_path"]?.as_s,
+        "destination_cnf_dir" => @old_config["destination_cnf_dir"]?.as_s,
+        "install_method" => transform_install_method(@old_config["install_method"])
+      }
+    end
+
+    private def transform_deployment : Hash
+      case
+      when @old_config.has_key?("manifest_directory")
+        transform_manifests
+      when @old_config.has_key?("helm_directory")
+        transform_helm_directories
+      else
+        transform_helm_charts
+      end
+    end
+
+    private def transform_container_names(container_names : Array(Hash)?) : Array(Hash)
+      return nil unless container_names
+        
+      container_names.map do |container|
+        {
+          "name" => container["name"]?.as_s,
+          "rolling_update_test_tag" => container["rolling_update_test_tag"]?.as_s,
+          "rolling_downgrade_test_tag" => container["rolling_downgrade_test_tag"]?.as_s,
+          "rolling_version_change_test_tag" => container["rolling_version_change_test_tag"]?.as_s,
+          "rollback_from_tag" => container["rollback_from_tag"]?.as_s
+        }
+      end
+    end
+
+    private def transform_five_g_parameters : Hash
+      {
+        "amf_label" => @old_config["amf_label"]?.as_s,
+        "smf_label" => @old_config["smf_label"]?.as_s,
+        "upf_label" => @old_config["upf_label"]?.as_s,
+        "ric_label" => @old_config["ric_label"]?.as_s,
+        "amf_service_name" => @old_config["amf_service_name"]?.as_s,
+        "mmc" => @old_config["mmc"]?.as_s,
+        "mnc" => @old_config["mnc"]?.as_s,
+        "sst" => @old_config["sst"]?.as_s,
+        "sd" => @old_config["sd"]?.as_s,
+        "tac" => @old_config["tac"]?.as_s,
+        "protectionScheme" => @old_config["protectionScheme"]?.as_s,
+        "publicKey" => @old_config["publicKey"]?.as_s,
+        "publicKeyId" => @old_config["publicKeyId"]?.as_s,
+        "routingIndicator" => @old_config["routingIndicator"]?.as_s,
+        "enabled" => @old_config["enabled"]?.as_s,
+        "count" => @old_config["count"]?.as_s,
+        "initialMSISDN" => @old_config["initialMSISDN"]?.as_s,
+        "key" => @old_config["key"]?.as_s,
+        "op" => @old_config["op"]?.as_s,
+        "opType" => @old_config["opType"]?.as_s,
+        "type" => @old_config["type"]?.as_s,
+        "apn" => @old_config["apn"]?.as_s,
+        "emergency" => @old_config["emergency"]?.as_s
+      }
+    end
+
+    private def transform_install_method(install_method : Tuple?) : Hash(String, String | Nil)
+      return nil unless install_method
+    
+      # Not sure about this one
+      {
+        "type" => install_method[0]?.as_s,
+        "description" => install_method[1]?.as_s
+      }
+    end
+
+    private def transform_helm_charts : Array
+      [{
+        "name" => @old_config["release_name"]?.as_s,
+        "helm_repo_name" => @old_config["release_name"]?.as_s,
+        "helm_repo_url" => @old_config["release_name"]?.as_s,
+        "helm_chart_name" => @old_config["release_name"]?.as_s,
+        "helm_values" => @old_config["release_name"]?.as_s,
+        "namespace" => @old_config["release_name"]?.as_s
+      }]
+    end
+
+    private def transform_helm_directories : Array
+      [{
+        "name" => @old_config["release_name"]?.as_s,
+        "helm_directory" => @old_config["helm_directory"]?.as_s,
+        "namespace" => @old_config["namespace"]?.as_s
+      }]
+    end
+
+    private def transform_manifests : Array
+      [{
+        "name" => @old_config["release_name"]?.as_s,
+        "manifest_directory" => @old_config["manifest_directory"]?.as_s
+      }]
+    end
+  end
+end