feat(core): add progress

yjl9903 · Sep 26, 2023 · c79737d · c79737d
1 parent cb8971d
commit c79737d
Show file tree

Hide file tree

Showing 4 changed files with 39 additions and 33 deletions.
diff --git a/packages/core/package.json b/packages/core/package.json
@@ -43,9 +43,9 @@
   "dependencies": {
     "@breadc/color": "^0.9.6",
     "@breadc/death": "^0.9.6",
-    "@breadfs/webdav": "^0.0.6",
+    "@breadfs/webdav": "^0.0.7",
     "anitomy": "^0.0.27",
-    "breadfs": "^0.0.6",
+    "breadfs": "^0.0.7",
     "consola": "^3.1.0",
     "date-fns": "^2.30.0",
     "debug": "^4.3.4",

diff --git a/packages/core/src/anime/anime.ts b/packages/core/src/anime/anime.ts
@@ -265,7 +265,7 @@ export class Anime {
   private async addVideo(
     localSrc: string,
     newVideo: LocalVideo,
-    { copy = false }: { copy?: boolean } = {}
+    { copy = false, onProgress }: { copy?: boolean } & AddVideoOptions = {}
   ): Promise<LocalVideoDelta | undefined> {
     await this.library();
 
@@ -282,16 +282,16 @@ export class Anime {
         // }
 
         if (copy) {
-          await src.copyTo(dst, { overwrite: true });
-          // await fs.copy(src, dst, {
-          //   overwrite: true,
-          // });
+          await src.copyTo(dst, {
+            overwrite: true,
+            fallback: { file: { write: { onProgress } } }
+          });
           delta = { operation: 'copy', video: newVideo };
         } else {
-          await src.moveTo(dst, { overwrite: true });
-          // await fs.move(src, dst, {
-          //   overwrite: true,
-          // });
+          await src.moveTo(dst, {
+            overwrite: true,
+            fallback: { file: { write: { onProgress } } }
+          });
           delta = { operation: 'move', video: newVideo };
         }
         this._delta.push(delta);
@@ -315,7 +315,8 @@ export class Anime {
    */
   public async addVideoByCopy(
     src: string,
-    video: LocalVideo
+    video: LocalVideo,
+    options: AddVideoOptions = {}
   ): Promise<LocalVideoDelta | undefined> {
     return this.addVideo(src, video, { copy: true });
   }
@@ -329,7 +330,8 @@ export class Anime {
    */
   public async addVideoByMove(
     src: string,
-    video: LocalVideo
+    video: LocalVideo,
+    options: AddVideoOptions = {}
   ): Promise<LocalVideoDelta | undefined> {
     return this.addVideo(src, video, { copy: false });
   }
@@ -442,3 +444,7 @@ interface LocalVideoDelta {
 
   log?: string;
 }
+
+interface AddVideoOptions {
+  onProgress?: (payload: { current: number; total: number }) => void;
+}
diff --git a/packages/local/package.json b/packages/local/package.json
@@ -44,7 +44,7 @@
     "@animespace/core": "workspace:*",
     "@breadc/color": "^0.9.6",
     "anitomy": "^0.0.27",
-    "breadfs": "^0.0.6",
+    "breadfs": "^0.0.7",
     "memofunc": "^0.0.6"
   },
   "engines": {

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml