From 932826aecafa65264c69ef7a1b0cf001583f3dc7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=8F=B2=E6=82=A6?= Date: Wed, 14 Jan 2026 17:33:07 +0800 Subject: [PATCH] =?UTF-8?q?sync-server/server.js=EF=BC=9A=E5=9C=A8=20type?= =?UTF-8?q?=3Durl=20=E7=9A=84=20JSON=20=E8=A7=A3=E6=9E=90=E9=87=8C?= =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=A4=9A=E7=A7=8D=20URL=20=E7=BB=93=E6=9E=84?= =?UTF-8?q?=E8=AF=86=E5=88=AB=EF=BC=8C=E6=8B=BF=E5=88=B0=E9=93=BE=E6=8E=A5?= =?UTF-8?q?=E5=90=8E=E7=BB=A7=E7=BB=AD=E6=9C=8D=E5=8A=A1=E7=AB=AF=E8=B7=9F?= =?UTF-8?q?=E9=9A=8F=E9=87=8D=E5=AE=9A=E5=90=91=E5=B9=B6=E7=9B=B4=E9=80=9A?= =?UTF-8?q?=E6=B5=81=E5=AA=92=20=20=20=20=20=E4=BD=93=EF=BC=8C=E9=81=BF?= =?UTF-8?q?=E5=85=8D=E6=8A=8A=20JSON=20=E8=BF=94=E5=9B=9E=E7=BB=99=20=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sync-server/server.js | 20 ++++++++++++++++++-- 1 file changed, 18 insertions(+), 2 deletions(-) diff --git a/sync-server/server.js b/sync-server/server.js index 49c454f..0e5926f 100644 --- a/sync-server/server.js +++ b/sync-server/server.js @@ -400,8 +400,24 @@ function proxyRequest(targetUrl, req, res) { proxyRes.on('end', () => { try { const parsedBody = JSON.parse(body); - if (parsedBody && parsedBody.url) { - requestStream(parsedBody.url, 1); + const extractUrl = (payload) => { + if (!payload || typeof payload !== 'object') return null; + if (typeof payload.url === 'string') return payload.url; + if (typeof payload.data === 'string') return payload.data; + if (payload.data && typeof payload.data === 'object') { + if (typeof payload.data.url === 'string') return payload.data.url; + if (typeof payload.data.link === 'string') return payload.data.link; + if (payload.data.data && typeof payload.data.data.url === 'string') return payload.data.data.url; + if (Array.isArray(payload.data) && payload.data[0] && typeof payload.data[0].url === 'string') { + return payload.data[0].url; + } + } + if (payload.result && typeof payload.result.url === 'string') return payload.result.url; + return null; + }; + const resolvedUrl = extractUrl(parsedBody); + if (resolvedUrl) { + requestStream(url.resolve(targetUrl, resolvedUrl), 1); return; } } catch (e) {