diff --git a/backend/src/utils/download.js b/backend/src/utils/download.js index 5274c72..9b59459 100644 --- a/backend/src/utils/download.js +++ b/backend/src/utils/download.js @@ -9,9 +9,11 @@ import $ from '@/core/app'; const tasks = new Map(); -export default async function download(url, ua, timeout) { +export default async function download(rawUrl, ua, timeout) { let $arguments = {}; + let url = rawUrl.replace(/#noFlow$/, ''); const rawArgs = url.split('#'); + url = url.split('#')[0]; if (rawArgs.length > 1) { try { // 支持 `#${encodeURIComponent(JSON.stringify({arg1: "1"}))}` diff --git a/backend/src/utils/flow.js b/backend/src/utils/flow.js index c0195ac..125abe8 100644 --- a/backend/src/utils/flow.js +++ b/backend/src/utils/flow.js @@ -9,12 +9,11 @@ export function getFlowField(headers) { )[0]; return headers[subkey]; } -export async function getFlowHeaders(url, ua, timeout) { - if (url.endsWith('#noFlow')) { - return; - } +export async function getFlowHeaders(rawUrl, ua, timeout) { + let url = rawUrl; let $arguments = {}; const rawArgs = url.split('#'); + url = url.split('#')[0]; if (rawArgs.length > 1) { try { // 支持 `#${encodeURIComponent(JSON.stringify({arg1: "1"}))}` @@ -31,6 +30,9 @@ export async function getFlowHeaders(url, ua, timeout) { } } } + if ($arguments?.noFlow) { + return; + } const cached = headersResourceCache.get(url); let flowInfo; if (!$arguments?.noCache && cached) {