Fix concurrent file system operation

Author: CodeDoctorDE

packages/lw_file_system/lib/src/api/file_system_base.dart

@@ -6,6 +6,7 @@ import 'package:flutter/foundation.dart';
 import 'package:lw_file_system/lw_file_system.dart';
 import 'package:path/path.dart' as p;
 import 'package:rxdart/rxdart.dart';
+import 'package:synchronized/synchronized.dart';
 
 import 'file_system_dav.dart';
 import 'file_system_io.dart';
@@ -31,11 +32,15 @@ abstract class GeneralFileSystem {
 
   Future<void> reset();
 
+  final _initializeLock = Lock();
+
   Future<void> initialize({bool force = false}) async {
-    if (force) await reset();
-    if (force || !await isInitialized()) {
-      await runInitialize();
-    }
+    return _initializeLock.synchronized(() async {
+      if (force) await reset();
+      if (force || !await isInitialized()) {
+        await runInitialize();
+      }
+    });
   }
 
   @protected

packages/lw_file_system/lib/src/api/file_system_io.dart

@@ -4,12 +4,15 @@ import 'dart:io';
 import 'package:flutter/foundation.dart';
 import 'package:lw_file_system/lw_file_system.dart';
 import 'package:path/path.dart' as p;
+import 'package:synchronized/synchronized.dart';
 
 class IODirectoryFileSystem extends DirectoryFileSystem {
   @override
   final LocalStorage? storage;
   final bool useIsolates;
 
+  final _lock = Lock();
+
   IODirectoryFileSystem({
     this.storage,
     required super.config,
@@ -62,21 +65,25 @@ class IODirectoryFileSystem extends DirectoryFileSystem {
   @override
   Future<RawFileSystemDirectory> createDirectory(String path) async {
     path = normalizePath(path);
-    final directory = Directory(await getAbsolutePath(path));
-    if (!await directory.exists()) {
-      await directory.create(recursive: true);
-    }
-    return RawFileSystemDirectory(
-      AssetLocation(path: path, remote: remoteName),
-      assets: [],
-    );
+    return _lock.synchronized(() async {
+      final directory = Directory(await getAbsolutePath(path));
+      if (!await directory.exists()) {
+        await directory.create(recursive: true);
+      }
+      return RawFileSystemDirectory(
+        AssetLocation(path: path, remote: remoteName),
+        assets: [],
+      );
+    });
   }
 
   @override
   Future<void> deleteAsset(String path) async {
     path = normalizePath(path);
-    // This removes all types of entities
-    await Directory(await getAbsolutePath(path)).delete(recursive: true);
+    return _lock.synchronized(() async {
+      // This removes all types of entities
+      await Directory(await getAbsolutePath(path)).delete(recursive: true);
+    });
   }
 
   @override
@@ -87,11 +94,13 @@ class IODirectoryFileSystem extends DirectoryFileSystem {
   }) async {
     path = normalizePath(path);
     path = await getAbsolutePath(path);
-    if (useIsolates) {
-      await compute(_updateFile, (path, data));
-    } else {
-      await _updateFile((path, data));
-    }
+    return _lock.synchronized(() async {
+      if (useIsolates) {
+        await compute(_updateFile, (path, data));
+      } else {
+        await _updateFile((path, data));
+      }
+    });
   }
 
   Future<void> _updateFile((String, Uint8List) e) async {

packages/lw_file_system/pubspec.yaml

@@ -26,6 +26,7 @@ dependencies:
       path: packages/lw_file_system_api
       ref: ddd0761c3ed5a48108bddd0448df76d77eeb9da0
   async: ^2.12.0
+  synchronized: ^3.4.0
   # path: ^1.8.0
 
 dev_dependencies: