64 lines
1.7 KiB
TypeScript
64 lines
1.7 KiB
TypeScript
import i18n from 'i18next';
|
||
|
||
import { API_BASE_URL } from '@/src/constants/env';
|
||
import type { UserProfileV1_2 } from '@/src/features/userProfileScoring';
|
||
|
||
export type RecommendedItem = {
|
||
content_id: number;
|
||
text: string;
|
||
final_score: number;
|
||
fallback_level_final: number;
|
||
explanations?: Record<string, unknown> | null;
|
||
};
|
||
|
||
export type RecoMeta = Record<string, unknown>;
|
||
|
||
export type RecoEngineResult = {
|
||
items: RecommendedItem[];
|
||
meta: RecoMeta;
|
||
};
|
||
|
||
export type RecoRequest = {
|
||
k?: number;
|
||
user_profile: UserProfileV1_2;
|
||
already_recommended_ids?: Array<string | number>;
|
||
touched_or_viewed_ids?: Array<string | number>;
|
||
now?: string; // ISO8601（可选）
|
||
};
|
||
|
||
function withTimeout(ms: number): AbortController {
|
||
const controller = new AbortController();
|
||
setTimeout(() => controller.abort(), ms);
|
||
return controller;
|
||
}
|
||
|
||
export async function fetchRecoFeed(req: RecoRequest): Promise<RecoEngineResult> {
|
||
const controller = withTimeout(12_000);
|
||
const url = `${API_BASE_URL}/v1/reco/feed`;
|
||
|
||
const res = await fetch(url, {
|
||
method: 'POST',
|
||
headers: {
|
||
'Content-Type': 'application/json',
|
||
// 让后端做 locale 选择（目前后端只区分 en/tc）
|
||
'Accept-Language': i18n.language || 'en',
|
||
},
|
||
body: JSON.stringify({
|
||
k: req.k,
|
||
user_profile: req.user_profile,
|
||
already_recommended_ids: req.already_recommended_ids ?? [],
|
||
touched_or_viewed_ids: req.touched_or_viewed_ids ?? [],
|
||
now: req.now,
|
||
}),
|
||
signal: controller.signal,
|
||
});
|
||
|
||
if (!res.ok) {
|
||
const text = await res.text().catch(() => '');
|
||
throw new Error(`推荐接口请求失败：${res.status} ${res.statusText} ${text}`.trim());
|
||
}
|
||
|
||
return (await res.json()) as RecoEngineResult;
|
||
}
|
||
|