feat(bulk-model-sync): handle concept changes

Author: mhuster23

bulk-model-sync-lib/src/commonMain/kotlin/org/modelix/model/sync/bulk/ModelImporter.kt

@@ -159,9 +159,10 @@ class ModelImporter(
         currentNodeProgress += 1
         progressReporter.step(currentNodeProgress.toULong())
         doAndPotentiallyContinueOnErrors {
-            syncProperties(node, data)
-            syncChildren(node, data, progressReporter)
-            syncReferences(node, data)
+            val conceptCorrectedNode = checkAndHandleConceptChange(node, data)
+            syncProperties(conceptCorrectedNode, data)
+            syncChildren(conceptCorrectedNode, data, progressReporter)
+            syncReferences(conceptCorrectedNode, data)
         }
     }
 
@@ -197,7 +198,9 @@ class ModelImporter(
             // optimization for when there is no change in the child list
             // size check first to avoid querying the original ID
             if (expectedNodes.size == existingNodes.size && expectedNodes.map { it.originalId() } == existingNodes.map { it.originalId() }) {
-                existingNodes.zip(expectedNodes).forEach { syncNode(it.first, it.second, progressReporter) }
+                existingNodes.zip(expectedNodes).forEach {
+                    syncNode(it.first, it.second, progressReporter)
+                }
                 continue
             }
 
@@ -252,8 +255,6 @@ class ModelImporter(
                 } else {
                     nodeAtIndex
                 }
-                check(childNode.getConceptReference() == expectedConcept) { "Unexpected concept change from $expectedConcept to ${childNode.getConceptReference()}" }
-
                 syncNode(childNode, expected, progressReporter)
             }
 
@@ -267,6 +268,15 @@ class ModelImporter(
         }
     }
 
+    private fun checkAndHandleConceptChange(existingNode: INode, expectedNode: NodeData): INode {
+        val newConcept = expectedNode.concept?.let { ConceptReference(it) }
+        if (existingNode.getConceptReference() == newConcept) {
+            return existingNode
+        }
+        requireNotNull(newConcept) { "Unexpected null concept" }
+        return existingNode.replaceNode(newConcept)
+    }
+
     private fun buildExistingIndex(): MutableMap<String, INodeReference> {
         val localOriginalIdToExisting = createMemoryEfficientMap<String, INodeReference>()
         root.getDescendants(true).forEach { node ->