mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/imputnet/cobalt.git synced 2025-07-13 08:48:26 +00:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

api/xiaohongshu: add support for new share links

Browse Source
This commit is contained in:
KwiatekMiki 2025-07-12 15:10:08 +02:00
parent 60f02b18e4
commit 9dafd8c8c8
No known key found for this signature in database
GPG Key ID: 91449EB0BBE1F17B
4 changed files with 21 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
api/src/processing/match.js
View File

@ -263,6 +263,7 @@ export default async function({ host, patternMatch, params, authType }) {
case "xiaohongshu":
r = await xiaohongshu({
...patternMatch,
shareType: url.pathname.split("/")[1],
h265: params.allowH265,
isAudioOnly,
dispatcher,

3
api/src/processing/service-config.js
View File

@ -207,7 +207,8 @@ export const services = {
patterns: [
"explore/:id?xsec_token=:token",
"discovery/item/:id?xsec_token=:token",
"a/:shareId"
"a/:shareId",
"m/:shareId"
],
altDomains: ["xhslink.com"],
},

20
api/src/processing/services/xiaohongshu.js
View File

@ -1,21 +1,35 @@
import { resolveRedirectingURL } from "../url.js";
import { resolveRedirectingURL, extract, normalizeURL } from "../url.js";
import { genericUserAgent } from "../../config.js";
import { createStream } from "../../stream/manage.js";
import { request } from "undici";
const https = (url) => {
return url.replace(/^http:/i, 'https:');
}
export default async function ({ id, token, shareId, h265, isAudioOnly, dispatcher }) {
export default async function ({ id, token, shareType, shareId, h265, isAudioOnly, dispatcher }) {
let noteId = id;
let xsecToken = token;
if (!noteId) {
if (!noteId && shareType === "a") {
const patternMatch = await resolveRedirectingURL(
`https://xhslink.com/a/${shareId}`,
dispatcher
);
noteId = patternMatch?.id;
xsecToken = patternMatch?.token;
} else if (!noteId && shareType === "m") {
const location = await request(`https://xhslink.com/m/${shareId}`, {
dispatcher,
redirect: 'manual'
}).then(r => {
if (r.statusCode === 302 && r.headers['location']) {
return r.headers['location'];
}
}).catch(() => null);
const { patternMatch } = extract(normalizeURL(location));
noteId = patternMatch?.id;
xsecToken = patternMatch?.token;
}

2
api/src/processing/url.js
View File

@ -99,7 +99,7 @@ function aliasURL(url) {
case "xhslink":
if (url.hostname === 'xhslink.com' && parts.length === 3) {
url = new URL(`https://www.xiaohongshu.com/a/${parts[2]}`);
url = new URL(`https://www.xiaohongshu.com/${parts[1]}/${parts[2]}`);
}
break;