create migration

Author: Thomasr

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/authentication/util/AdvancedMapUtils.java

@@ -1,5 +1,8 @@
 package org.lowcoder.api.authentication.util;
 
+import org.bson.Document;
+
+import java.util.HashMap;
 import java.util.Map;
 
 public class AdvancedMapUtils {
@@ -52,4 +55,23 @@ public static String getString(Map<String, Object> map, String key) {
 
         return current!=null?current.toString():null;
     }
+
+    public static Map<String, Object> documentToMap(Document document) {
+        if (document == null) {
+            return new HashMap<>();
+        }
+
+        Map<String, Object> map = new HashMap<>();
+        for (Map.Entry<String, Object> entry : document.entrySet()) {
+            Object value = entry.getValue();
+            if (value instanceof Document) {
+                // Recursively convert nested Document
+                map.put(entry.getKey(), documentToMap((Document) value));
+            } else {
+                map.put(entry.getKey(), value);
+            }
+        }
+        return map;
+    }
+
 }

server/api-service/lowcoder-server/src/main/java/org/lowcoder/runner/migrations/DatabaseChangelog.java

@@ -9,9 +9,11 @@
 import com.mongodb.client.result.DeleteResult;
 import lombok.extern.slf4j.Slf4j;
 import org.bson.Document;
+import org.bson.types.ObjectId;
 import org.lowcoder.domain.application.model.Application;
 import org.lowcoder.domain.application.model.ApplicationHistorySnapshot;
 import org.lowcoder.domain.application.model.ApplicationHistorySnapshotTS;
+import org.lowcoder.domain.application.model.ApplicationRecord;
 import org.lowcoder.domain.bundle.model.Bundle;
 import org.lowcoder.domain.datasource.model.Datasource;
 import org.lowcoder.domain.datasource.model.DatasourceStructureDO;
@@ -49,8 +51,10 @@
 import java.time.temporal.ChronoUnit;
 import java.util.Arrays;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 
+import static org.lowcoder.api.authentication.util.AdvancedMapUtils.documentToMap;
 import static org.lowcoder.domain.util.QueryDslUtils.fieldName;
 import static org.lowcoder.sdk.util.IDUtils.generate;
 
@@ -422,6 +426,31 @@ public void populateEmailInUserConnections(MongockTemplate mongoTemplate, Common
 
     }
 
+    @ChangeSet(order = "028", id = "published-to-record", author = "Thomas")
+    public void publishedToRecord(MongockTemplate mongoTemplate, CommonConfig commonConfig) {
+        Query query = new Query(Criteria.where("publishedApplicationDSL").exists(true));
+
+        MongoCursor<Document> cursor = mongoTemplate.getCollection("application").find(query.getQueryObject()).iterator();
+
+        while (cursor.hasNext()) {
+            Document document = cursor.next();
+            Document dsl = (Document) document.get("publishedApplicationDSL");
+            ObjectId id = document.getObjectId("_id");
+            String createdBy = document.getString("createdBy");
+            Map<String, Object> dslMap = documentToMap(dsl);
+            ApplicationRecord record = ApplicationRecord.builder()
+                    .applicationId(id.toHexString())
+                    .applicationDSL(dslMap)
+                    .commitMessage("")
+                    .tag("1.0.0")
+                    .createdBy(createdBy)
+                    .modifiedBy(createdBy)
+                    .createdAt(Instant.now())
+                    .updatedAt(Instant.now())
+                    .build();
+            mongoTemplate.insert(record);
+        }
+    }
 
     private void addGidField(MongockTemplate mongoTemplate, String collectionName) {
         // Create a query to match all documents