fix watcher await

server/src/domain/library/library.service.ts

@@ -46,7 +46,7 @@ export class LibraryService extends EventEmitter {
   private configCore: SystemConfigCore;
   private watchLibraries = false;
   private watchLock = false;
-  private watchers: Record<string, () => void> = {};
+  private watchers: Record<string, () => Promise<void>> = {};
 
   constructor(
     @Inject(IAccessRepository) accessRepository: IAccessRepository,
@@ -175,7 +175,7 @@ export class LibraryService extends EventEmitter {
 
   async unwatch(id: string) {
     if (this.watchers[id]) {
-      this.watchers[id]();
+      await this.watchers[id]();
       delete this.watchers[id];
     }
   }

server/src/domain/repositories/storage.repository.ts

@@ -55,6 +55,6 @@ export interface IStorageRepository {
   crawl(crawlOptions: CrawlOptionsDto): Promise<string[]>;
   copyFile(source: string, target: string): Promise<void>;
   rename(source: string, target: string): Promise<void>;
-  watch(paths: string[], options: WatchOptions, events: Partial<WatchEvents>): () => void;
+  watch(paths: string[], options: WatchOptions, events: Partial<WatchEvents>): () => Promise<void>;
   utimes(filepath: string, atime: Date, mtime: Date): Promise<void>;
 }

server/src/infra/repositories/filesystem.provider.ts

@@ -148,6 +148,6 @@ export class FilesystemProvider implements IStorageRepository {
     watcher.on(StorageEventType.UNLINK, (path) => events.onUnlink?.(path));
     watcher.on(StorageEventType.ERROR, (error) => events.onError?.(error));
 
-    return () => watcher.close();
+    return async () => await watcher.close();
   }
 }