feat: import workspace from json files

TeeWrath · TeeWrath · commit 7a5990eaef12 · 2025-09-05T02:16:35.000+05:30
diff --git a/lib/core/helpers/file_helper.dart b/lib/core/helpers/file_helper.dart
@@ -1,12 +1,10 @@
 import 'dart:convert';
-import 'package:file_selector_platform_interface/file_selector_platform_interface.dart';
 import 'package:cookethflow/core/helpers/platform_file_helper.dart';
+import 'package:file_selector_platform_interface/file_selector_platform_interface.dart';
 import 'package:flutter/foundation.dart';
 import 'package:universal_html/html.dart' as html;
 
 class FileServices {
-  final FileSelectorPlatform fileSelector = FileSelectorPlatform.instance;
-
   Future<String> exportFile({
     required String defaultName,
     required String jsonString,
@@ -35,7 +33,7 @@ class FileServices {
           mimeTypes: ['application/json'],
         );
 
-        final String? path = await fileSelector.getSavePath(
+        final String? path = await PlatformFileService.getSavePath(
           acceptedTypeGroups: [typeGroup],
           suggestedName: sanitizedName,
         );
@@ -89,7 +87,7 @@ class FileServices {
           mimeTypes: ['image/png'],
         );
 
-        final String? path = await fileSelector.getSavePath(
+        final String? path = await PlatformFileService.getSavePath(
           acceptedTypeGroups: [typeGroup],
           suggestedName: sanitizedName,
         );
@@ -144,7 +142,7 @@ class FileServices {
           mimeTypes: ['image/svg+xml'],
         );
 
-        final String? path = await fileSelector.getSavePath(
+        final String? path = await PlatformFileService.getSavePath(
           acceptedTypeGroups: [typeGroup],
           suggestedName: sanitizedName,
         );
@@ -188,7 +186,7 @@ class FileServices {
 
     try {
       final XFile? file =
-          await fileSelector.openFile(acceptedTypeGroups: [typeGroup]);
+          await PlatformFileService.openFile(acceptedTypeGroups: [typeGroup]);
 
       if (file != null) {
         print('Selected file: ${file.path}');
@@ -201,22 +199,35 @@ class FileServices {
   }
 
   Future<XFile?> importJsonFiles() async {
-    const XTypeGroup typeGroup = XTypeGroup(
-      label: 'JSON',
-      mimeTypes: ['application/json'],
-      extensions: ['json'],
-    );
-
     try {
-      final XFile? file =
-          await fileSelector.openFile(acceptedTypeGroups: [typeGroup]);
-      if (file != null) {
-        print('Selected file: ${file.path}');
+      final result = await PlatformFileService.pickJSONFile();
+      if (result == null) {
+        return null; // User cancelled the operation
       }
-      return file;
+      final fileName = result['name'] as String;
+      final bytes = result['bytes'] as Uint8List;
+      return XFile.fromData(
+        bytes,
+        mimeType: 'application/json',
+        name: fileName,
+      );
     } catch (e) {
       print('Error in selecting file: $e');
       return null;
     }
   }
+
+  Future<Map<String, dynamic>?> importJsonFileFromUser() async {
+    try {
+      final file = await importJsonFiles();
+      if (file == null) {
+        return null; // User cancelled the operation
+      }
+      final bytes = await file.readAsBytes();
+      return PlatformFileService.parseJSONFile(bytes);
+    } catch (e) {
+      print('Error importing JSON file: $e');
+      return null;
+    }
+  }
 }
diff --git a/lib/core/helpers/platform_file_helper.dart b/lib/core/helpers/platform_file_helper.dart
@@ -1,5 +1,6 @@
 import 'dart:convert';
 import 'dart:io';
+import 'package:file_selector_platform_interface/file_selector_platform_interface.dart';
 import 'package:flutter/foundation.dart';
 import 'package:flutter_document_picker/flutter_document_picker.dart';
 import 'package:universal_html/html.dart' as html;
@@ -80,4 +81,48 @@ class PlatformFileService {
       return null;
     }
   }
+
+  // Added methods to replace file_selector usage
+  static Future<String?> getSavePath({
+    required List<XTypeGroup> acceptedTypeGroups,
+    required String suggestedName,
+  }) async {
+    try {
+      if (kIsWeb) {
+        // Web platform does not need a save path; handled via Blob
+        return null;
+      } else {
+        final path = await FlutterDocumentPicker.openDocument(
+          params: FlutterDocumentPickerParams(
+            allowedFileExtensions:
+                acceptedTypeGroups.first.extensions ?? ['json'],
+            invalidFileNameSymbols: ['/'],
+          ),
+        );
+        return path;
+      }
+    } catch (e) {
+      print("Error getting save path: $e");
+      return null;
+    }
+  }
+
+  static Future<XFile?> openFile({
+    required List<XTypeGroup> acceptedTypeGroups,
+  }) async {
+    try {
+      final result = await pickJSONFile();
+      if (result == null) return null;
+      final fileName = result['name'] as String;
+      final bytes = result['bytes'] as Uint8List;
+      return XFile.fromData(
+        bytes,
+        mimeType: acceptedTypeGroups.first.mimeTypes?.first ?? 'application/json',
+        name: fileName,
+      );
+    } catch (e) {
+      print("Error opening file: $e");
+      return null;
+    }
+  }
 }
diff --git a/lib/features/dashboard/providers/dashboard_provider.dart b/lib/features/dashboard/providers/dashboard_provider.dart
@@ -5,10 +5,13 @@ import 'package:flutter/material.dart';
 import 'package:phosphor_flutter/phosphor_flutter.dart';
 import 'package:supabase_flutter/supabase_flutter.dart';
 import 'package:uuid/uuid.dart';
+import 'package:cookethflow/core/helpers/file_helper.dart';
 
 class DashboardProvider extends StateHandler {
   late SupabaseClient? supabase;
   late SupabaseService supabaseService;
+  final FileServices _fileServices = FileServices();
+
   DashboardProvider(this.supabase, this.supabaseService) : super() {
     initialize();
   }
@@ -151,7 +154,7 @@ class DashboardProvider extends StateHandler {
     }
   }
 
-  Future<String> createNewProject(BuildContext context) async {
+  Future<String> createNewProject() async {
     _isLoading = true;
     try {
       var res = supabase?.auth.currentUser;
@@ -188,7 +191,87 @@ class DashboardProvider extends StateHandler {
     }
   }
 
-  void importExistingProject(BuildContext context) {}
+  Future<String> importExistingProject() async {
+    _isLoading = true;
+    notifyListeners();
+    try {
+      final jsonContent = await _fileServices.importJsonFileFromUser();
+      if (jsonContent == null) {
+        return 'Import operation cancelled or failed.';
+      }
+
+      if (jsonContent['workspace'] == null || jsonContent['canvasObjects'] == null) {
+        return 'Invalid file format. Missing "workspace" or "canvasObjects" data.';
+      }
+
+      final currentUser = supabase?.auth.currentUser;
+      if (currentUser == null) {
+        return 'User not authenticated.';
+      }
+
+      final oldWorkspaceId = jsonContent['workspace']['id'];
+      final newWorkspaceId = Uuid().v4();
+
+      final newWorkspace = Map<String, dynamic>.from(jsonContent['workspace']);
+      newWorkspace['id'] = newWorkspaceId;
+      newWorkspace['owner'] = currentUser.id;
+      newWorkspace['name'] = '${newWorkspace['name']} (Imported)';
+      newWorkspace.remove('created_at');
+      newWorkspace.remove('lastEdited');
+
+      final oldToNewIdMap = <String, String>{};
+      final newCanvasObjects = <Map<String, dynamic>>[];
+
+      for (var obj in (jsonContent['canvasObjects'] as List)) {
+        final newId = Uuid().v4();
+        final oldId = obj['id'];
+        oldToNewIdMap[oldId] = newId;
+
+        final newObj = Map<String, dynamic>.from(obj);
+        newObj['id'] = newId;
+        newCanvasObjects.add(newObj);
+      }
+
+      for (var obj in newCanvasObjects) {
+        if (obj['object_type'] == 'connector') {
+          final sourceId = obj['source_id'];
+          final targetId = obj['target_id'];
+          if (sourceId != null && oldToNewIdMap.containsKey(sourceId)) {
+            obj['source_id'] = oldToNewIdMap[sourceId];
+          }
+          if (targetId != null && oldToNewIdMap.containsKey(targetId)) {
+            obj['target_id'] = oldToNewIdMap[targetId];
+          }
+        }
+      }
+
+      await supabase!.from('workspace').insert(newWorkspace);
+
+      if (newCanvasObjects.isNotEmpty) {
+        final objectsToInsert = newCanvasObjects.map((obj) {
+          return {
+            'id': obj['id'],
+            'object': obj,
+            'workspace_id': newWorkspaceId,
+          };
+        }).toList();
+        await supabase!.from('canvas_objects').insert(objectsToInsert);
+      }
+
+      await refreshDashboard();
+      return 'Workspace imported successfully!';
+    } catch (e) {
+      print("Error importing project: $e");
+      String output = 'An error occurred during import.';
+      if (e.toString().contains('maximum limit of 10 workspaces')) {
+        output = 'Maximum limit of workspaces reached. Upgrade your plan for more!';
+      }
+      return output;
+    } finally {
+      _isLoading = false;
+      notifyListeners();
+    }
+  }
 
   Future<void> syncWithDb() async {
     if (supabase == null) {
@@ -249,4 +332,4 @@ class DashboardProvider extends StateHandler {
       await refreshDashboard();
     }
   }
-}
+}
diff --git a/lib/features/dashboard/widgets/add_project_dialogue.dart b/lib/features/dashboard/widgets/add_project_dialogue.dart
@@ -33,7 +33,7 @@ class AddProject extends StatelessWidget {
                 icon: PhosphorIconsRegular.plus,
                 label: 'Start Blank Project',
                 onTap: () async {
-                  String output = await provider.createNewProject(context);
+                  String output = await provider.createNewProject();
                   if (output != 'Workspace created successfully!!') {
                     ScaffoldMessenger.of(context).showSnackBar(
                       SnackBar(
@@ -54,7 +54,14 @@ class AddProject extends StatelessWidget {
                 label: 'Import Existing Project',
                 onTap: () async {
                   context.pop();
-                  provider.importExistingProject(context);
+                  String output = await provider.importExistingProject();
+                  ScaffoldMessenger.of(context).showSnackBar(
+                    SnackBar(
+                      content: Text(output),
+                      backgroundColor: Colors.lightGreen,
+                      duration: const Duration(seconds: 3),
+                    ),
+                  );
                 },
                 txtColor: suprovider.isDark ? Colors.white : Colors.black,
                 borderColor: suprovider.isDark ? Colors.white : Colors.black,
@@ -65,4 +72,4 @@ class AddProject extends StatelessWidget {
       },
     );
   }
-}
+}
diff --git a/lib/features/workspace/providers/workspace_provider.dart b/lib/features/workspace/providers/workspace_provider.dart
@@ -127,11 +127,9 @@ class WorkspaceProvider extends StateHandler {
       final canvasObjectsData =
           _canvasObjects.values.map((obj) => obj.toJson()).toList();
 
+      // ** FIX: Ensure the full workspace object is exported **
       final exportData = {
-        'workspace': {
-          'name': workspaceData["name"],
-          'data': workspaceData["data"],
-        },
+        'workspace': workspaceData,
         'canvasObjects': canvasObjectsData,
       };
 
