feat(StatsView): Add local files report.

Author: walkthunder

src/baseTypes.ts

@@ -143,6 +143,7 @@ export type DecisionType =
 export type TSyncStatus =
   | "pending"
   | "syncing"
+  | "sync-done"
   | "publishing"
   | "done"
   | "fail"
@@ -167,6 +168,7 @@ export interface FileOrFolderMixedState {
   decisionBranch?: number;
   remoteEncryptedKey?: string;
 
+  syncType?: `TOREMOTE` | `TOLOCAL`; // upload to remote OR download to local
   syncStatus?: TSyncStatus;
   remoteLink?: string;
   syncError?: string;

src/components/StatsView.tsx

@@ -62,7 +62,7 @@ export const StatsViewComponent = (props: { plugin: InvioPlugin }) => {
     if (url) {
       open(url);
     } else {
-      new Notice('This page has been deleted online', 3000);
+      new Notice('Link not found', 3000);
     }
   }
   const openFile = async (key: string) => {

src/components/store.ts

@@ -67,6 +67,10 @@ const useStore = create<State>()((set, get) => ({
     if (!(obj && obj[key])) {
         return;
     }
+    // For ToLocal files, sync done means ready
+    if ((update.syncStatus === 'sync-done') && (obj[key].syncType === 'TOLOCAL')) {
+      update.syncStatus = 'done';
+    }
     // Once failed, then all process failed.
     if (obj[key].syncStatus === 'fail') {
       update.syncStatus = 'fail';

src/exporter.ts

@@ -69,7 +69,7 @@ export const publishFiles = async (
 ) => {
     const htmlPath = AssetHandler.initHtmlPath();
 
-    if (allFiles.length > 100000 || allFiles.length <= 0)
+    if (allFiles.length > 100000 || allFiles.length < 0)
     {
         new Notice(`❗Invalid number of files to export: ${allFiles.length}.`, 0);
         return {success: false, exportedPath: htmlPath, fileNumber: allFiles.length};

src/main.ts

@@ -337,7 +337,7 @@ export default class InvioPlugin extends Plugin {
         return;
       }
 
-      const { toRemoteFiles } = TouchedPlanModel.getTouchedFilesGroup(touchedFileMap)
+      const { toRemoteFiles, toLocalFiles } = TouchedPlanModel.getTouchedFilesGroup(touchedFileMap)
 
 
       // The operations above are almost read only and kind of safe.
@@ -359,14 +359,14 @@ export default class InvioPlugin extends Plugin {
         log.info('init stats view: ', view);
         if (view) {
           const initData: Record<string, FileOrFolderMixedState> = {};
-          let changingFiles = toRemoteFiles;
+          let remoteChangingFiles = toRemoteFiles;
           if (triggerSource === 'force') {
-            changingFiles = allFiles.map(f => {
+            remoteChangingFiles = allFiles.map(f => {
               const fState: FileOrFolderMixedState = { key: f.path, syncStatus: 'syncing' }
               return fState;
             })
           }
-          changingFiles.forEach(f => {
+          [ ...remoteChangingFiles, ...toLocalFiles ].forEach(f => {
             initData[f.key] = f;
           })
           view.info('Stats data init...');
@@ -422,6 +422,18 @@ export default class InvioPlugin extends Plugin {
               log.info('ignore decision ', decision, pathName);
             } 
           },
+          async (i: number, totalCount: number, pathName: string, decision: string, err?: any) => {
+            if (err) {
+              log.info('sync failed ', pathName, decision);
+              view?.update(pathName, { syncStatus: 'fail' });
+              view?.error(`${i}/${totalCount} - file ${pathName} sync failed`);
+              return;
+            }
+            log.info('sync done ', pathName, decision);
+            // TODO: Get remote link, but need remote domain first
+            view?.update(pathName, { syncStatus: 'sync-done', remoteLink: '' });
+            view?.info(`${i}/${totalCount} - file ${pathName} sync done`);
+          },
           (key: string) => {
             log.warn('Remote files conflicts when syncing ... ', key);
             view?.warn(`Remote file ${key} conflicts when syncing ...`);

src/sync.ts

@@ -1454,6 +1454,7 @@ export const doActualSync = async (
   concurrency: number = 1,
   callbackSizesGoWrong?: any,
   callbackSyncProcess?: any,
+  callbackSyncDone?: any,
   callbackConflictSync?: any
 ) => {
   const mixedStates = syncPlan.mixedStates;
@@ -1572,8 +1573,30 @@ export const doActualSync = async (
             vault,
             localDeleteFunc,
             password
-          );
+          ).catch((err) => {
+            if (callbackSyncDone !== undefined) {
+              callbackSyncDone(
+                realCounter,
+                realTotalCount,
+                key,
+                val.decision,
+                err
+              );
+  
+              realCounter += 1;
+            }
+            throw err;
+          })
+          if (callbackSyncDone !== undefined) {
+            await callbackSyncDone(
+              realCounter,
+              realTotalCount,
+              key,
+              val.decision
+            );
 
+            realCounter += 1;
+          }
           log.debug(`finished ${key}`);
         };
 

src/touchedPlanModel.ts

@@ -28,15 +28,19 @@ export class TouchedPlanModel extends Modal {
     [ ...Object.keys(files) ].forEach(key => {
       const f = files[key];
       if ((f.decision === 'uploadLocalDelHistToRemote') && f.existRemote) {
+        f.syncType = 'TOREMOTE';
         toRemoteFiles.push(f);
       }
       if (f.decision === 'uploadLocalToRemote') {
+        f.syncType = 'TOREMOTE';
         toRemoteFiles.push(f);
       }
       if (f.decision === 'downloadRemoteToLocal') {
+        f.syncType = 'TOLOCAL';
         toLocalFiles.push(f);
       }
       if ((f.decision === 'keepRemoteDelHist') && f.existLocal) {
+        f.syncType = 'TOLOCAL';
         toLocalFiles.push(f);
       }
       if (f.remoteUnsync) {