Apply schema changes to CRUD UI workspace data

thingifier-crud-ui/src/main/java/uk/co/compendiumdev/thingifier/crudui/ActiveThingifierWorkspace.java

@@ -57,6 +57,21 @@ public synchronized WorkspaceSnapshot replaceWithYaml(final Path path) throws IO
         return replaceWithYaml(Files.readString(path));
     }
 
+    public synchronized WorkspaceSnapshot replaceWithMigratedThingifier(
+            final Thingifier newThingifier, final long expectedVersion) {
+        if (version != expectedVersion) {
+            throw new IllegalStateException(
+                    "Workspace changed; refresh schema preview before applying");
+        }
+        Thingifier oldThingifier = thingifier;
+        replaceWith(newThingifier);
+        version++;
+        if (oldThingifier != null) {
+            oldThingifier.close();
+        }
+        return snapshot();
+    }
+
     private void replaceWith(final Thingifier newThingifier) {
         thingifier = newThingifier;
         definition = modelExporter.export(newThingifier);

thingifier-crud-ui/src/main/java/uk/co/compendiumdev/thingifier/crudui/CrudUiController.java

@@ -11,6 +11,7 @@ public final class CrudUiController {
     private final WorkspaceDataExporter exporter;
     private final WorkspaceDataImporter importer;
     private final SchemaPreviewService schemaPreviewService;
+    private final WorkspaceSchemaUpgradeService schemaUpgradeService;
 
     public CrudUiController(final ActiveThingifierWorkspace workspace) {
         this.workspace = workspace;
@@ -19,6 +20,7 @@ public CrudUiController(final ActiveThingifierWorkspace workspace) {
         exporter = new WorkspaceDataExporter(workspace, apiProxy);
         importer = new WorkspaceDataImporter(workspace, apiProxy, metadataJson);
         schemaPreviewService = new SchemaPreviewService();
+        schemaUpgradeService = new WorkspaceSchemaUpgradeService(workspace, metadataJson);
     }
 
     public UiHttpResponse workspace() {
@@ -50,6 +52,26 @@ public UiHttpResponse previewSchema(final String schemaDraftJson) {
         }
     }
 
+    public UiHttpResponse previewSchemaUpgrade(final String upgradeRequestJson) {
+        try {
+            return schemaUpgradeService.preview(upgradeRequestJson);
+        } catch (CrudUiException e) {
+            return JsonSupport.error(e.statusCode(), e.getMessage());
+        } catch (IllegalArgumentException e) {
+            return JsonSupport.error(400, e.getMessage());
+        }
+    }
+
+    public UiHttpResponse applySchemaUpgrade(final String upgradeRequestJson) {
+        try {
+            return schemaUpgradeService.apply(upgradeRequestJson);
+        } catch (CrudUiException e) {
+            return JsonSupport.error(e.statusCode(), e.getMessage());
+        } catch (IllegalArgumentException e) {
+            return JsonSupport.error(400, e.getMessage());
+        }
+    }
+
     public UiHttpResponse exportData() {
         try {
             return exporter.exportData();