vjudge: trigger weekly sync

packages/vjudge/src/index.ts

@@ -14,6 +14,7 @@ const syncing = {};
 class AccountService {
     api: IBasicProvider;
     problemLists: Set<string>;
+    syncing = false;
     listUpdated = false;
     working = false;
     error = '';
@@ -120,13 +121,11 @@ class AccountService {
         return false;
     }
 
-    async main() {
-        const res = await this.login();
-        if (!res) return;
-        setInterval(() => this.login(), Time.hour);
-        TaskModel.consume({ type: 'remotejudge', subType: this.account.type.split('.')[0] }, this.judge.bind(this), false);
+    async handleSync() {
+        if (this.syncing) return;
+        this.syncing = true;
+        try {
             const ddocs = await DomainModel.getMulti({ mount: this.account.type.split('.')[0] }).toArray();
-        this.working = true;
             do {
                 this.listUpdated = false;
                 for (const listName of this.problemLists) {
@@ -143,6 +142,21 @@ class AccountService {
                     }
                 }
             } while (this.listUpdated);
+        } catch (e) {
+            this.error = e;
+            logger.error('%s sync failed', this.account.handle);
+            logger.error(e);
+        }
+        this.syncing = false;
+    }
+
+    async main() {
+        const res = await this.login();
+        if (!res) return;
+        setInterval(() => this.login(), Time.hour);
+        TaskModel.consume({ type: 'remotejudge', subType: this.account.type.split('.')[0] }, this.judge.bind(this), false);
+        this.working = true;
+        this.handleSync();
     }
 }
 
@@ -159,9 +173,10 @@ class VJudgeService extends Service {
 
     accounts: RemoteAccount[];
     private providers: Record<string, any> = {};
-    private pool: Record<string, any> = {};
+    private pool: Record<string, AccountService> = {};
     async start() {
         this.accounts = await coll.find().toArray();
+        this.ctx.setInterval(this.sync.bind(this), Time.week);
     }
 
     addProvider(type: string, provider: BasicProvider, override = false) {
@@ -177,13 +192,21 @@ class VJudgeService extends Service {
         });
     }
 
+    async sync() {
+        for (const key in this.pool) {
+            const account = this.pool[key];
+            if (!account.working) continue;
+            await account.handleSync();
+        }
+    }
+
     async checkStatus(onCheckFunc = false) {
         const res: Record<string, { working: boolean, error?: string, status?: any }> = {};
         for (const [k, v] of Object.entries(this.pool)) {
             res[k] = {
                 working: v.working,
                 error: v.error,
-                status: v.api.checkStatus ? await v.api.checkStatus(onCheckFunc) : null,
+                status: 'checkStatus' in v.api ? await v.api.checkStatus(onCheckFunc) : null,
             };
         }
         return res;

packages/vjudge/src/interface.ts

@@ -39,6 +39,7 @@ export interface IBasicProvider {
     listProblem(page: number, resync: boolean, listId: string): Promise<string[]>;
     submitProblem(id: string, lang: string, code: string, info: any, next: NextFunction, end: NextFunction): Promise<string | void>;
     waitForSubmission(id: string, next: NextFunction, end: NextFunction): Promise<void>;
+    checkStatus?: (onCheckFunc: boolean) => Promise<void>;
 }
 
 export interface BasicProvider {