bruno/remotely-save
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add hints for too many errors

Browse Source
This commit is contained in:
fyears 2022-04-08 09:32:36 +08:00
parent 8270a02246
commit 303f47f7c1
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/sync.ts
View File

@ -1158,6 +1158,7 @@ export const doActualSync = async (
const queue = new PQueue({ concurrency: concurrency, autoStart: true }); const queue = new PQueue({ concurrency: concurrency, autoStart: true });
const potentialErrors: Error[] = []; const potentialErrors: Error[] = [];
let tooManyErrors = false;
for (let k = 0; k < singleLevelOps.length; ++k) { for (let k = 0; k < singleLevelOps.length; ++k) {
const val: FileOrFolderMixedState = singleLevelOps[k]; const val: FileOrFolderMixedState = singleLevelOps[k];
@ -1194,12 +1195,22 @@ export const doActualSync = async (
queue.add(fn).catch((e) => { queue.add(fn).catch((e) => {
const msg = `${key}: ${e.message}`; const msg = `${key}: ${e.message}`;
potentialErrors.push(new Error(msg)); potentialErrors.push(new Error(msg));
if (potentialErrors.length >= 3) {
tooManyErrors = true;
queue.pause();
queue.clear();
}
}); });
} }
await queue.onIdle(); await queue.onIdle();
if (potentialErrors.length > 0) { if (potentialErrors.length > 0) {
if (tooManyErrors) {
potentialErrors.push(
new Error("too many errors, stop the remaining tasks")
);
}
throw new AggregateError(potentialErrors); throw new AggregateError(potentialErrors);
} }
} }