Spaces:
Sleeping
Sleeping
File size: 4,226 Bytes
4bea261 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 | import { txasupabase } from '../../../lib/txasupabase.js';
export const POST = async ({ request, cookies }) => {
const token = cookies.get('auth_token')?.value;
if (!token) return new Response(JSON.stringify({ error: 'Chưa đăng nhập' }), { status: 401 });
try {
const { movieSlug, movieName, movieThumb, episodeName, currentTime, duration } = await request.json();
const userData = JSON.parse(Buffer.from(token, 'base64').toString('utf-8'));
// Tìm người dùng trên Supabase dựa vào ID
const user = await txasupabase.getUserById(userData.id);
if (!user) return new Response(JSON.stringify({ error: 'User not found' }), { status: 404 });
const history = user.history || [];
// Xóa mục lịch sử cũ của phim này nếu đã có để đưa lên đầu danh sách
const historyIndex = history.findIndex(h => h.slug === movieSlug);
if (historyIndex !== -1) {
history.splice(historyIndex, 1);
}
// Thêm lịch sử xem phim mới lên đầu mảng
history.unshift({
slug: movieSlug,
name: movieName,
thumb: movieThumb,
episode: episodeName,
currentTime: currentTime || 0,
duration: duration || 0,
watchedAt: new Date().toISOString()
});
// Giới hạn tối đa 50 lượt xem phim gần nhất
const limitedHistory = history.slice(0, 50);
// Cập nhật lại lịch sử xem phim lên Supabase
await txasupabase.saveUser({
...user,
history: limitedHistory
});
return new Response(JSON.stringify({ success: true }), { status: 200 });
} catch (err) {
console.error('[History POST Error]:', err);
return new Response(JSON.stringify({ error: 'System error' }), { status: 500 });
}
};
export const GET = async ({ cookies, url }) => {
const token = cookies.get('auth_token')?.value;
if (!token) return new Response(JSON.stringify({ history: [] }), { status: 200 });
try {
const userData = JSON.parse(Buffer.from(token, 'base64').toString('utf-8'));
const user = await txasupabase.getUserById(userData.id);
if (!user) return new Response(JSON.stringify({ history: [] }), { status: 200 });
const slug = url.searchParams.get('slug');
if (slug) {
const item = user.history?.find(h => h.slug === slug);
if (item) {
return new Response(JSON.stringify({
movieSlug: item.slug,
currentTime: item.currentTime,
duration: item.duration,
episodeName: item.episode,
watchedAt: item.watchedAt,
// Hỗ trợ tham số cũ cho trình phát TXAPlayer
current_time: item.currentTime,
episode_name: item.episode
}), { status: 200 });
}
return new Response(JSON.stringify({ error: 'Not found' }), { status: 404 });
}
return new Response(JSON.stringify({ history: user.history || [] }), { status: 200 });
} catch (err) {
console.error('[History GET Error]:', err);
return new Response(JSON.stringify({ history: [] }), { status: 200 });
}
};
export const DELETE = async ({ request, cookies }) => {
const token = cookies.get('auth_token')?.value;
if (!token) return new Response(JSON.stringify({ error: 'Chưa đăng nhập' }), { status: 401 });
try {
const { movieSlugs, clearAll } = await request.json();
const userData = JSON.parse(Buffer.from(token, 'base64').toString('utf-8'));
const user = await txasupabase.getUserById(userData.id);
if (!user) return new Response(JSON.stringify({ error: 'User not found' }), { status: 404 });
let history = user.history || [];
if (clearAll) {
history = [];
} else if (movieSlugs && Array.isArray(movieSlugs)) {
history = history.filter(h => !movieSlugs.includes(h.slug));
}
// Cập nhật lại lịch sử đã lọc lên Supabase
await txasupabase.saveUser({
...user,
history
});
return new Response(JSON.stringify({ success: true, message: 'Đã xóa lịch sử xem!' }), { status: 200 });
} catch (err) {
console.error('[History DELETE Error]:', err);
return new Response(JSON.stringify({ error: 'System error' }), { status: 500 });
}
};
|