fix: allow to deserialize multi-resource json documents (#855)

Signed-off-by: Andre Dietisheim <[email protected]>

Author: adietish

Diff for: src/main/kotlin/com/redhat/devtools/intellij/kubernetes/editor/EditorResourceSerialization.kt

@@ -10,6 +10,8 @@
  ******************************************************************************/
 package com.redhat.devtools.intellij.kubernetes.editor
 
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.databind.node.ArrayNode
 import com.intellij.json.JsonFileType
 import com.intellij.openapi.fileTypes.FileType
 import com.redhat.devtools.intellij.kubernetes.model.util.ResourceException
@@ -22,7 +24,6 @@ import org.jetbrains.yaml.YAMLFileType
 object EditorResourceSerialization {
 
     const val RESOURCE_SEPARATOR_YAML = "\n---"
-    private const val RESOURCE_SEPARATOR_JSON = ",\n"
 
     /**
      * Returns a list of [HasMetadata] for a given yaml or json string.
@@ -41,27 +42,49 @@ object EditorResourceSerialization {
      * @see JsonFileType.INSTANCE
      */
     fun deserialize(jsonYaml: String?, fileType: FileType?, currentNamespace: String?): List<HasMetadata> {
-        return if (jsonYaml == null
-            || !isSupported(fileType)) {
-            emptyList()
-        } else {
-            val resources = jsonYaml
-                .split(RESOURCE_SEPARATOR_YAML)
-                .filter { jsonYaml -> jsonYaml.isNotBlank() }
-            if (resources.size > 1
-                && YAMLFileType.YML != fileType) {
-                throw ResourceException(
-                    "${fileType?.name ?: "File type"} is not supported for multi-resource documents. Only ${YAMLFileType.YML.name} is.")
+        return try {
+            when {
+                jsonYaml == null ->
+                    emptyList()
+
+                YAMLFileType.YML == fileType ->
+                    yaml2Resources(jsonYaml, currentNamespace)
+
+                JsonFileType.INSTANCE == fileType ->
+                    json2Resources(jsonYaml, currentNamespace)
+
+                else ->
+                    emptyList()
+            }
+        } catch (e: RuntimeException) {
+            throw ResourceException("Invalid kubernetes yaml/json", e.cause ?: e)
+        }
+    }
+
+    private fun yaml2Resources(yaml: String, currentNamespace: String?): List<HasMetadata> {
+        val resources = yaml
+            .split(RESOURCE_SEPARATOR_YAML)
+            .filter { yaml ->
+                yaml.isNotBlank()
             }
-            try {
-                resources
-                    .map { jsonYaml ->
-                        setMissingNamespace(currentNamespace, createResource<GenericKubernetesResource>(jsonYaml))
-                    }
-                    .toList()
-            } catch (e: RuntimeException) {
-                throw ResourceException("Invalid kubernetes yaml/json", e.cause ?: e)
+        return resources
+            .map { yaml ->
+                setMissingNamespace(currentNamespace, createResource<GenericKubernetesResource>(yaml))
             }
+            .toList()
+    }
+
+    private fun json2Resources(json: String?, currentNamespace: String?): List<HasMetadata> {
+        val mapper = ObjectMapper()
+        val rootNode = mapper.readTree(json)
+        return if (rootNode.isArray) {
+            (rootNode as ArrayNode)
+                .mapNotNull { node ->
+                    setMissingNamespace(currentNamespace, mapper.treeToValue(node, GenericKubernetesResource::class.java))
+                }
+                .toList()
+        } else {
+            emptyList()
         }
     }