opensource/obsidian-douban
1
0
Fork 0
mirror of https://github.com/Wanxp/obsidian-douban.git synced 2026-04-04 08:38:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix sync terminate when item wrong

Browse Source
This commit is contained in:
wanxp 2024-05-16 18:34:38 +08:00
parent e1ae4cd88c
commit 910dbd30d9
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/org/wanxp/douban/sync/handler/DoubanAbstractSyncHandler.ts
View File

@ -8,6 +8,8 @@ import {sleepRange} from "../../../utils/TimeUtil";
import DoubanSubjectLoadHandler from "../../data/handler/DoubanSubjectLoadHandler";
import {DoubanListHandler} from "./list/DoubanListHandler";
import DoubanSubject from "../../data/model/DoubanSubject";
import {log} from "../../../utils/Logutil";
import {i18nHelper} from "../../../lang/helper";
export abstract class DoubanAbstractSyncHandler<T extends DoubanSubject> implements DoubanSyncHandler{
@ -71,11 +73,15 @@ export abstract class DoubanAbstractSyncHandler<T extends DoubanSubject> implem
if (!context.plugin.statusHolder.syncing()) {
return;
}
if(syncStatus.shouldSync(item.id)) {
let subject: DoubanSubject = await this.doubanSubjectLoadHandler.handle(item.id, context);
await sleepRange(BasicConst.CALL_DOUBAN_DELAY, BasicConst.CALL_DOUBAN_DELAY + BasicConst.CALL_DOUBAN_DELAY_RANGE);
}else {
syncStatus.unHandle(item.id, item.title);
try {
if(syncStatus.shouldSync(item.id)) {
let subject: DoubanSubject = await this.doubanSubjectLoadHandler.handle(item.id, context);
await sleepRange(BasicConst.CALL_DOUBAN_DELAY, BasicConst.CALL_DOUBAN_DELAY + BasicConst.CALL_DOUBAN_DELAY_RANGE);
}else {
syncStatus.unHandle(item.id, item.title);
}
}catch (e) {
log.notice(i18nHelper.getMessage('130120'))
}
}
}