feat: Node 环境支持为同步配置设置独立的 cron

Author: xream

backend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "sub-store",
-  "version": "2.23.17",
+  "version": "2.23.18",
   "description": "Advanced Subscription Manager for QX, Loon, Surge, Stash and Shadowrocket.",
   "main": "src/main.js",
   "packageManager": "pnpm@11.0.9",

backend/src/restful/artifacts.js

@@ -20,6 +20,10 @@ import {
 } from '@/restful/errors';
 import Gist from '@/utils/gist';
 import { archiveArtifact } from '@/utils/archive';
+import {
+    normalizeArtifactCron,
+    refreshArtifactCronJobs,
+} from '@/utils/artifact-cron';
 
 const ARTIFACT_GIST_PLACEHOLDER_FILENAME = '.sub-store-placeholder';
 const ARTIFACT_GIST_PLACEHOLDER_CONTENT = [
@@ -109,6 +113,7 @@ async function restoreArtifacts(_, res) {
                 }
             });
             $.write(allArtifacts, ARTIFACTS_KEY);
+            refreshArtifactCronJobs();
         } catch (err) {
             $.error(`查找 Sub-Store Gist 时发生错误: ${err.message ?? err}`);
             throw err;
@@ -133,9 +138,15 @@ function getAllArtifacts(req, res) {
 }
 
 function replaceArtifact(req, res) {
-    const allArtifacts = req.body;
-    $.write(allArtifacts, ARTIFACTS_KEY);
-    success(res);
+    try {
+        const allArtifacts = req.body;
+        allArtifacts.forEach(normalizeArtifactCron);
+        $.write(allArtifacts, ARTIFACTS_KEY);
+        refreshArtifactCronJobs();
+        success(res);
+    } catch (error) {
+        failed(res, error);
+    }
 }
 
 async function getArtifact(req, res) {
@@ -188,8 +199,15 @@ function updateArtifact(req, res) {
             );
             return;
         }
+        try {
+            normalizeArtifactCron(newArtifact);
+        } catch (error) {
+            failed(res, error);
+            return;
+        }
         updateByName(allArtifacts, oldName, newArtifact);
         $.write(allArtifacts, ARTIFACTS_KEY);
+        refreshArtifactCronJobs();
         success(res, newArtifact);
     } else {
         failed(
@@ -244,6 +262,7 @@ function createArtifactItem(artifact) {
     }
 
     $.info(`正在创建远程配置：${artifact.name}`);
+    normalizeArtifactCron(artifact);
     const allArtifacts = $.read(ARTIFACTS_KEY);
     if (findByName(allArtifacts, artifact.name)) {
         throw new RequestInvalidError(
@@ -253,6 +272,7 @@ function createArtifactItem(artifact) {
     }
     insertByPosition(allArtifacts, artifact, getCreateItemPosition());
     $.write(allArtifacts, ARTIFACTS_KEY);
+    refreshArtifactCronJobs();
     return artifact;
 }
 
@@ -299,6 +319,7 @@ async function deleteArtifactItem(name) {
     }
     deleteByName(allArtifacts, name);
     $.write(allArtifacts, ARTIFACTS_KEY);
+    refreshArtifactCronJobs();
     return {
         artifact,
         remote,

backend/src/restful/index.js

@@ -4,9 +4,14 @@ import express from '@/vendor/express';
 import $ from '@/core/app';
 import migrate from '@/utils/migration';
 import download, { downloadFile } from '@/utils/download';
-import { syncArtifacts, produceArtifact } from '@/restful/sync';
+import {
+    syncArtifacts,
+    produceArtifact,
+    syncArtifactItem,
+} from '@/restful/sync';
 import { gistBackupAction } from '@/restful/miscs';
 import { TOKENS_KEY, SETTINGS_KEY } from '@/constants';
+import { startArtifactCronJobs } from '@/utils/artifact-cron';
 
 import registerSubscriptionRoutes from './subscriptions';
 import registerCollectionRoutes from './collections';
@@ -145,6 +150,8 @@ export default function serve() {
     $app.start();
 
     if ($.env.isNode) {
+        startArtifactCronJobs(syncArtifactItem);
+
         // Deprecated: SUB_STORE_BACKEND_CRON, SUB_STORE_CRON
         const backend_sync_cron = eval(
             'process.env.SUB_STORE_BACKEND_SYNC_CRON',
@@ -158,7 +165,7 @@ export default function serve() {
                 async function () {
                     try {
                         $.info(`[SYNC CRON] ${backend_sync_cron} started`);
-                        await syncArtifacts();
+                        await syncArtifacts({ skipCronArtifacts: true });
                         $.info(`[SYNC CRON] ${backend_sync_cron} finished`);
                     } catch (e) {
                         $.error(