feat: 订阅失败处理新增兜底通知和兜底静默

Author: xream

backend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "sub-store",
-  "version": "2.22.2",
+  "version": "2.22.3",
   "description": "Advanced Subscription Manager for QX, Loon, Surge, Stash and Shadowrocket.",
   "main": "src/main.js",
   "scripts": {

backend/src/restful/download.js

@@ -12,6 +12,18 @@ import { isIPv4, isIPv6 } from '@/utils';
 import { getISO } from '@/utils/geo';
 import env from '@/utils/env';
 
+function buildEmptyNezhaPayload() {
+    return JSON.stringify(
+        {
+            code: 0,
+            message: 'success',
+            result: [],
+        },
+        null,
+        2,
+    );
+}
+
 export default function register($app) {
     $app.get('/share/col/:name/:target', async (req, res) => {
         const { target } = req.params;
@@ -89,7 +101,10 @@ async function downloadSubscription(req, res) {
     const useMihomoExternal = req.query.target === 'SurgeMac';
 
     const platform =
-        req.query.target || getPlatformFromHeaders(req.headers) || 'JSON';
+        req.query.platform ||
+        req.query.target ||
+        getPlatformFromHeaders(req.headers) ||
+        'JSON';
     const reqUA = req.headers['user-agent'] || req.headers['User-Agent'];
     $.info(
         `正在下载订阅：${name}\n请求 User-Agent: ${reqUA}\n请求 target: ${req.query.target}\n实际输出: ${platform}`,
@@ -340,14 +355,18 @@ async function downloadSubscription(req, res) {
                 if (resultFormat === 'nezha') {
                     output = nezhaTransform(output);
                 } else if (resultFormat === 'nezha-monitor') {
-                    nezhaIndex = /^\d+$/.test(nezhaIndex)
-                        ? parseInt(nezhaIndex, 10)
-                        : output.findIndex((i) => i.name === nezhaIndex);
-                    output = await nezhaMonitor(
-                        output[nezhaIndex],
-                        nezhaIndex,
-                        req.query,
-                    );
+                    if (!Array.isArray(output) || output.length === 0) {
+                        output = buildEmptyNezhaPayload();
+                    } else {
+                        nezhaIndex = /^\d+$/.test(nezhaIndex)
+                            ? parseInt(nezhaIndex, 10)
+                            : output.findIndex((i) => i.name === nezhaIndex);
+                        output = await nezhaMonitor(
+                            output[nezhaIndex],
+                            nezhaIndex,
+                            req.query,
+                        );
+                    }
                 }
                 res.set('Content-Type', 'application/json;charset=utf-8');
             } else {
@@ -403,7 +422,10 @@ async function downloadCollection(req, res) {
     const useMihomoExternal = req.query.target === 'SurgeMac';
 
     const platform =
-        req.query.target || getPlatformFromHeaders(req.headers) || 'JSON';
+        req.query.platform ||
+        req.query.target ||
+        getPlatformFromHeaders(req.headers) ||
+        'JSON';
 
     const allCols = $.read(COLLECTIONS_KEY);
     const collection = findByName(allCols, name);
@@ -627,14 +649,18 @@ async function downloadCollection(req, res) {
                 if (resultFormat === 'nezha') {
                     output = nezhaTransform(output);
                 } else if (resultFormat === 'nezha-monitor') {
-                    nezhaIndex = /^\d+$/.test(nezhaIndex)
-                        ? parseInt(nezhaIndex, 10)
-                        : output.findIndex((i) => i.name === nezhaIndex);
-                    output = await nezhaMonitor(
-                        output[nezhaIndex],
-                        nezhaIndex,
-                        req.query,
-                    );
+                    if (!Array.isArray(output) || output.length === 0) {
+                        output = buildEmptyNezhaPayload();
+                    } else {
+                        nezhaIndex = /^\d+$/.test(nezhaIndex)
+                            ? parseInt(nezhaIndex, 10)
+                            : output.findIndex((i) => i.name === nezhaIndex);
+                        output = await nezhaMonitor(
+                            output[nezhaIndex],
+                            nezhaIndex,
+                            req.query,
+                        );
+                    }
                 }
                 res.set('Content-Type', 'application/json;charset=utf-8');
             } else {

backend/src/restful/ignore-failed-remote-sub.js

@@ -0,0 +1,80 @@
+import { ProxyUtils } from '@/core/proxy-utils';
+
+const IGNORE_FAILED_REMOTE_SUB_NOTIFY_MODES = new Set([
+    'enabled',
+    'fallbackNotify',
+]);
+const IGNORE_FAILED_REMOTE_SUB_FALLBACK_MODES = new Set([
+    'fallbackNotify',
+    'fallbackQuiet',
+]);
+
+function normalizeIgnoreFailedRemoteSub(mode) {
+    if (mode === true) return 'quiet';
+    if (mode === false || mode == null || mode === '') return 'disabled';
+    return mode;
+}
+
+function resolveIgnoreFailedRemoteSubMode(...values) {
+    for (const value of values) {
+        if (value != null && value !== '') {
+            return normalizeIgnoreFailedRemoteSub(value);
+        }
+    }
+
+    return 'disabled';
+}
+
+function shouldNotifyIgnoreFailedRemoteSub(mode) {
+    return IGNORE_FAILED_REMOTE_SUB_NOTIFY_MODES.has(
+        normalizeIgnoreFailedRemoteSub(mode),
+    );
+}
+
+function shouldFallbackIgnoreFailedRemoteSub(mode) {
+    return IGNORE_FAILED_REMOTE_SUB_FALLBACK_MODES.has(
+        normalizeIgnoreFailedRemoteSub(mode),
+    );
+}
+
+function handleIgnoreFailedRemoteSubError({ mode, message, notify }) {
+    const resolvedMode = normalizeIgnoreFailedRemoteSub(mode);
+
+    if (
+        resolvedMode === 'disabled' ||
+        shouldFallbackIgnoreFailedRemoteSub(resolvedMode)
+    ) {
+        throw new Error(message);
+    }
+
+    if (shouldNotifyIgnoreFailedRemoteSub(resolvedMode)) {
+        notify?.(message);
+    }
+}
+
+function notifyIgnoreFailedRemoteSubFallback({ mode, notify, error }) {
+    if (!shouldNotifyIgnoreFailedRemoteSub(mode)) return;
+    notify?.(error);
+}
+
+function buildEmptySubscriptionOutput({
+    platform = 'JSON',
+    produceType,
+    produceOpts = {},
+}) {
+    if (produceType === 'raw') {
+        return JSON.stringify([]);
+    }
+
+    return ProxyUtils.produce([], platform, produceType, produceOpts);
+}
+
+export {
+    buildEmptySubscriptionOutput,
+    handleIgnoreFailedRemoteSubError,
+    normalizeIgnoreFailedRemoteSub,
+    notifyIgnoreFailedRemoteSubFallback,
+    resolveIgnoreFailedRemoteSubMode,
+    shouldFallbackIgnoreFailedRemoteSub,
+    shouldNotifyIgnoreFailedRemoteSub,
+};