Dicken/dickendock
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

fix: xREL sauber – 1 Cache-Key/Film, Modal sofort, xREL async, Hindi-Filter, max5/≤1080p

Browse Source
This commit is contained in:
Dicken
2026-06-10 23:18:28 +02:00
parent 0d819b719c
commit 82ee05f902
2 changed files with 151 additions and 211 deletions
Download Patch File Download Diff File Expand all files Collapse all files

337
backend/src/tools/media/routes.js
View File

@@ -5,23 +5,25 @@ const { authenticate, requireAdmin } = require('../../middleware/auth');
const TMDB_BASE = 'https://api.themoviedb.org/3'; const TMDB_BASE = 'https://api.themoviedb.org/3';
const XREL_BASE = 'https://api.xrel.to/v2'; const XREL_BASE = 'https://api.xrel.to/v2';
const THIS_YEAR = new Date().getFullYear(); const THIS_YEAR = new Date().getFullYear();
const MIN_YEAR = THIS_YEAR - 1; const MIN_YEAR = THIS_YEAR - 1;
// ── SQLite Cache (12h für Treffer, 1h für Leer-Ergebnisse) ─────────────────── // Sprachen die wir NICHT wollen
function dbCacheGet(key) { const BLOCKED_LANGS = new Set(['tr', 'hi', 'te', 'ta', 'ml', 'kn', 'bn', 'mr', 'pa']);
// Genre-IDs die wir nicht wollen (nur wenn das der EINZIGE Genre ist)
// 16=Animation, 99=Documentary – aber nur rausfiltern wenn explizit kein Spielfilm-Genre dabei
const DOC_GENRE_ID = 99;
// ── SQLite Cache ──────────────────────────────────────────────────────────────
function cacheGet(key) {
const row = db.prepare('SELECT value, expires_at FROM xrel_cache WHERE cache_key=?').get(key); const row = db.prepare('SELECT value, expires_at FROM xrel_cache WHERE cache_key=?').get(key);
if (!row) return undefined; if (!row) return undefined;
if (Date.now() > row.expires_at) { if (Date.now() > row.expires_at) { db.prepare('DELETE FROM xrel_cache WHERE cache_key=?').run(key); return undefined; }
db.prepare('DELETE FROM xrel_cache WHERE cache_key=?').run(key);
return undefined;
}
try { return JSON.parse(row.value); } catch { return undefined; } try { return JSON.parse(row.value); } catch { return undefined; }
} }
function cacheSet(key, value, ttlMs = 12 * 60 * 60 * 1000) {
function dbCacheSet(key, value, ttlMs = 12 * 60 * 60 * 1000) { db.prepare('INSERT OR REPLACE INTO xrel_cache (cache_key,value,expires_at) VALUES (?,?,?)')
db.prepare('INSERT OR REPLACE INTO xrel_cache (cache_key, value, expires_at) VALUES (?,?,?)')
.run(key, JSON.stringify(value), Date.now() + ttlMs); .run(key, JSON.stringify(value), Date.now() + ttlMs);
} }
@@ -29,7 +31,6 @@ function dbCacheSet(key, value, ttlMs = 12 * 60 * 60 * 1000) {
function getToken() { function getToken() {
return db.prepare("SELECT value FROM admin_settings WHERE key='tmdb_token'").get()?.value || ''; return db.prepare("SELECT value FROM admin_settings WHERE key='tmdb_token'").get()?.value || '';
} }
async function tmdb(path, params = {}) { async function tmdb(path, params = {}) {
const token = getToken(); const token = getToken();
if (!token) throw new Error('Kein TMDb API-Token konfiguriert'); if (!token) throw new Error('Kein TMDb API-Token konfiguriert');
@@ -37,87 +38,72 @@ async function tmdb(path, params = {}) {
url.searchParams.set('language', 'de-DE'); url.searchParams.set('language', 'de-DE');
url.searchParams.set('region', 'DE'); url.searchParams.set('region', 'DE');
for (const [k, v] of Object.entries(params)) url.searchParams.set(k, v); for (const [k, v] of Object.entries(params)) url.searchParams.set(k, v);
const res = await fetch(url.toString(), { const res = await fetch(url.toString(), { headers: { Authorization: `Bearer ${token}`, Accept: 'application/json' } });
headers: { Authorization: `Bearer ${token}`, Accept: 'application/json' } if (!res.ok) throw new Error(`TMDb ${res.status}`);
});
if (!res.ok) throw new Error(`TMDb Fehler: ${res.status}`);
return res.json(); return res.json();
} }
let genreCache = null; let genreCache = null;
async function getGenreMap() { async function getGenreMap() {
if (genreCache) return genreCache; if (genreCache) return genreCache;
const data = await tmdb('/genre/movie/list'); const d = await tmdb('/genre/movie/list');
genreCache = {}; genreCache = {};
for (const g of data.genres) genreCache[g.id] = g.name; for (const g of d.genres) genreCache[g.id] = g.name;
return genreCache; return genreCache;
} }
function extractFSK(rd) {
function extractFSK(releaseDates) { const de = rd?.results?.find(r => r.iso_3166_1 === 'DE');
const de = releaseDates?.results?.find(r => r.iso_3166_1 === 'DE');
if (!de?.release_dates?.length) return null; if (!de?.release_dates?.length) return null;
const sorted = [...de.release_dates].sort((a, b) => (a.type === 3 ? -1 : 1)); const sorted = [...de.release_dates].sort((a, b) => a.type === 3 ? -1 : 1);
for (const r of sorted) { for (const r of sorted) { const c = (r.certification||'').trim(); if (c) return c; }
const c = (r.certification || '').trim();
if (c) return c;
}
return null; return null;
} }
async function fetchAllPages(path, maxPages = 3) { async function fetchAllPages(path, maxPages = 3) {
const first = await tmdb(path, { page: 1 }); const first = await tmdb(path, { page: 1 });
const total = Math.min(first.total_pages || 1, maxPages); const total = Math.min(first.total_pages || 1, maxPages);
let results = [...first.results]; let results = [...first.results];
if (total > 1) { if (total > 1) {
const extra = await Promise.all( const extra = await Promise.all(Array.from({ length: total-1 }, (_,i) => tmdb(path, { page: i+2 })));
Array.from({ length: total - 1 }, (_, i) => tmdb(path, { page: i + 2 }))
);
for (const p of extra) results = results.concat(p.results); for (const p of extra) results = results.concat(p.results);
} }
return results; return results;
} }
function filterMovies(list) { function filterMovies(list) {
const seen = new Set(); const seen = new Set();
return list.filter(m => { return list.filter(m => {
if (m.original_language === 'tr') return false; if (BLOCKED_LANGS.has(m.original_language)) return false;
const y = m.release_date ? parseInt(m.release_date.slice(0, 4)) : 0; const y = m.release_date ? parseInt(m.release_date.slice(0,4)) : 0;
if (y > 0 && y < MIN_YEAR) return false; if (y > 0 && y < MIN_YEAR) return false;
if (seen.has(m.id)) return false; if (seen.has(m.id)) return false;
seen.add(m.id); seen.add(m.id);
// Reine Dokus rausfiltern
const genres = m.genre_ids || [];
if (genres.length === 1 && genres[0] === DOC_GENRE_ID) return false;
if (genres.length === 0 && m.vote_count < 5) return false;
return true; return true;
}); });
} }
function enrichMovie(m, genreMap, fsk, rank) {
function enrichMovie(movie, genreMap, fsk, rank) {
return { return {
id: movie.id, id: m.id, title: m.title||m.original_title, original_title: m.original_title,
title: movie.title || movie.original_title, original_language: m.original_language, poster_path: m.poster_path,
original_title: movie.original_title, overview: m.overview, release_date: m.release_date, vote_average: m.vote_average,
original_language: movie.original_language, genres: (m.genre_ids||[]).map(id => genreMap[id]).filter(Boolean),
poster_path: movie.poster_path, fsk: fsk??null, rank: rank??null,
overview: movie.overview,
release_date: movie.release_date,
vote_average: movie.vote_average,
genres: (movie.genre_ids || []).map(id => genreMap[id]).filter(Boolean),
fsk: fsk ?? null,
rank: rank ?? null,
}; };
} }
// ── xREL ───────────────────────────────────────────────────────────────────── // ── xREL ─────────────────────────────────────────────────────────────────────
const QUALITY_BLOCKLIST = /\b(2160p|4k|uhd|uhdbluray|uhdbd)\b/i;
async function xrelFetch(path, params = {}, timeoutMs = 8000) { async function xrelFetch(path, params = {}) {
const url = new URL(XREL_BASE + path); const url = new URL(XREL_BASE + path);
for (const [k, v] of Object.entries(params)) url.searchParams.set(k, String(v)); for (const [k,v] of Object.entries(params)) url.searchParams.set(k, String(v));
const res = await fetch(url.toString(), { const res = await fetch(url.toString(), {
headers: { Accept: 'application/json' }, headers: { Accept: 'application/json' }, signal: AbortSignal.timeout(7000),
signal: AbortSignal.timeout(timeoutMs),
}); });
if (res.status === 429) { if (res.status === 429) {
const wait = parseInt(res.headers.get('Retry-After') || '15') * 1000; await new Promise(r => setTimeout(r, (parseInt(res.headers.get('Retry-After')||'10'))*1000));
await new Promise(r => setTimeout(r, wait)); const r2 = await fetch(url.toString(), { headers: { Accept: 'application/json' }, signal: AbortSignal.timeout(7000) });
const r2 = await fetch(url.toString(), { headers: { Accept: 'application/json' }, signal: AbortSignal.timeout(timeoutMs) });
if (!r2.ok) throw new Error(`xREL ${r2.status}`); if (!r2.ok) throw new Error(`xREL ${r2.status}`);
return r2.json(); return r2.json();
} }
@@ -125,209 +111,172 @@ async function xrelFetch(path, params = {}, timeoutMs = 8000) {
return res.json(); return res.json();
} }
function isGermanRelease(dirname, mainLang) { // Einzige Funktion für xREL: benutzt immer die ext_info_id und gibt max 5 deutsche ≤1080p Releases
if (mainLang === 'german') return true; // Cache-Key: tmdb_id (immer eindeutig, konsistent zwischen Badge und Modal)
return /\b(german|deutsch)(\.dl)?\b/i.test(dirname || ''); async function getXrelData(tmdbId, imdbId, title, originalTitle) {
} const cacheKey = `xrel:tmdb:${tmdbId}`;
const cached = cacheGet(cacheKey);
// Sucht xREL ext_info_id über IMDb-ID (exakter Match – keine falschen Treffer)
// Falls keine IMDb-ID: Titel-Suche mit strengem Titel-Vergleich als Fallback
async function findExtInfoId(imdbId, title, originalTitle) {
const cacheKey = `extinfoid:${imdbId || originalTitle || title}`.toLowerCase();
const cached = dbCacheGet(cacheKey);
if (cached !== undefined) return cached; if (cached !== undefined) return cached;
// Strategie 1: IMDb-ID Suche via ext_info search (xREL gibt uris zurück) let extInfoId = null;
// Suche ext_info_id via IMDb-URI (exakter Match)
if (imdbId) { if (imdbId) {
const queries = [originalTitle, title].filter(Boolean).filter((v, i, a) => a.indexOf(v) === i); const queries = [originalTitle, title].filter(Boolean).filter((v,i,a) => a.indexOf(v)===i);
for (const q of queries) { for (const q of queries) {
try { try {
const data = await xrelFetch('/search/ext_info.json', { q, type: 'movie', limit: 10 }); const data = await xrelFetch('/search/ext_info.json', { q: q.replace(/[*]/g,''), type:'movie', limit:10 });
const hits = Array.isArray(data.results) ? data.results : []; const hit = (data.results||[]).find(h => (h.uris||[]).includes(`imdb:${imdbId}`));
// Exakter Match über IMDb-URI if (hit?.id) { extInfoId = hit.id; break; }
const match = hits.find(h => } catch(_) {}
Array.isArray(h.uris) && h.uris.includes(`imdb:${imdbId}`)
);
if (match?.id) {
dbCacheSet(cacheKey, match.id);
return match.id;
}
} catch (_) {}
} }
} }
// Strategie 2: Titel-Suche mit strengem Vergleich (Fallback wenn keine IMDb-ID) // Fallback: exakter Titel-Match
const cleanQ = (t) => (t || '').replace(/[*#@!?:]/g, '').replace(/\s+/g, ' ').trim().toLowerCase(); if (!extInfoId) {
const queries = [originalTitle, title].filter(Boolean).filter((v, i, a) => a.indexOf(v) === i); const clean = (s) => (s||'').replace(/[*#!?:]/g,'').trim().toLowerCase();
const queries = [originalTitle, title].filter(Boolean).filter((v,i,a) => a.indexOf(v)===i);
for (const q of queries) { for (const q of queries) {
try { try {
const data = await xrelFetch('/search/ext_info.json', { q: q.replace(/[*#@!?:]/g, ''), type: 'movie', limit: 5 }); const data = await xrelFetch('/search/ext_info.json', { q: q.replace(/[*#!?:]/g,''), type:'movie', limit:5 });
const hits = Array.isArray(data.results) ? data.results : []; const hit = (data.results||[]).find(h => clean(h.title)===clean(q) || clean(h.alt_title)===clean(q));
// Nur exakter Titel-Match akzeptieren if (hit?.id) { extInfoId = hit.id; break; }
const match = hits.find(h => cleanQ(h.title) === cleanQ(q) || cleanQ(h.alt_title) === cleanQ(q)); } catch(_) {}
if (match?.id) {
dbCacheSet(cacheKey, match.id);
return match.id;
} }
} catch (_) {}
} }
dbCacheSet(cacheKey, null, 60 * 60 * 1000); // 1h für Nicht-Treffer if (!extInfoId) {
return null; cacheSet(cacheKey, [], 60*60*1000); // 1h für nicht gefunden
} return [];
}
// Holt alle deutschen Releases für eine ext_info_id
async function getGermanReleasesById(extInfoId) {
const cacheKey = `releases:${extInfoId}`;
const cached = dbCacheGet(cacheKey);
if (cached !== undefined) return cached;
// Releases holen: Scene + P2P parallel, nur german, nur ≤1080p, max 5
const [sceneData, p2pData] = await Promise.all([ const [sceneData, p2pData] = await Promise.all([
xrelFetch('/release/ext_info.json', { id: extInfoId, per_page: 100 }).catch(() => ({})), xrelFetch('/release/ext_info.json', { id: extInfoId, per_page: 50 }).catch(()=>({})),
xrelFetch('/p2p/releases.json', { ext_info_id: extInfoId, per_page: 100 }).catch(() => ({})), xrelFetch('/p2p/releases.json', { ext_info_id: extInfoId, per_page: 50 }).catch(()=>({})),
]); ]);
const results = []; const results = [];
for (const r of sceneData.list || []) { for (const r of sceneData.list||[]) {
if (!isGermanRelease(r.dirname, null)) continue; if (!/\b(german|deutsch)(\.dl)?\b/i.test(r.dirname||'')) continue;
if (QUALITY_BLOCKLIST.test(r.dirname||'')) continue;
results.push({ results.push({
dirname: r.dirname, dirname: r.dirname, size: r.size ? `${r.size.number} ${r.size.unit}` : null,
size: r.size ? `${r.size.number} ${r.size.unit}` : null, category: 'Scene', url: r.link_href,
category: 'Scene', date: r.time ? new Date(r.time*1000).toISOString().slice(0,10) : null, p2p: false,
url: r.link_href,
date: r.time ? new Date(r.time * 1000).toISOString().slice(0, 10) : null,
p2p: false,
}); });
} }
for (const r of p2pData.list||[]) {
// P2P: alle Seiten
const p2pPages = Math.min(p2pData.pagination?.total_pages || 1, 4);
const allP2P = [...(p2pData.list || [])];
if (p2pPages > 1) {
const extra = await Promise.all(
Array.from({ length: p2pPages - 1 }, (_, i) =>
xrelFetch('/p2p/releases.json', { ext_info_id: extInfoId, per_page: 100, page: i + 2 })
.then(d => d.list || []).catch(() => [])
)
);
for (const list of extra) allP2P.push(...list);
}
for (const r of allP2P) {
if (r.main_lang !== 'german') continue; if (r.main_lang !== 'german') continue;
if (QUALITY_BLOCKLIST.test(r.dirname||'')) continue;
results.push({ results.push({
dirname: r.dirname, dirname: r.dirname, size: r.size_mb ? `${(r.size_mb/1024).toFixed(1)} GB` : null,
size: r.size_mb ? `${(r.size_mb / 1024).toFixed(1)} GB` : null, category: r.category?.sub_cat||'P2P', url: r.link_href,
category: r.category?.sub_cat || 'P2P', date: r.pub_time ? new Date(r.pub_time*1000).toISOString().slice(0,10) : null, p2p: true,
url: r.link_href,
date: r.pub_time ? new Date(r.pub_time * 1000).toISOString().slice(0, 10) : null,
p2p: true,
}); });
} }
results.sort((a, b) => (b.date || '').localeCompare(a.date || '')); results.sort((a,b) => (b.date||'').localeCompare(a.date||''));
const ttl = results.length > 0 ? 12 * 60 * 60 * 1000 : 60 * 60 * 1000; const top5 = results.slice(0, 5);
dbCacheSet(cacheKey, results, ttl); cacheSet(cacheKey, top5, top5.length > 0 ? 12*60*60*1000 : 60*60*1000);
return results; return top5;
} }
// ── Routes ──────────────────────────────────────────────────────────────────── // ── Routes ────────────────────────────────────────────────────────────────────
router.get('/now-playing', authenticate, async (req, res) => { router.get('/now-playing', authenticate, async (req, res) => {
try { try {
const [pages, genreMap] = await Promise.all([fetchAllPages('/movie/now_playing', 3), getGenreMap()]); const [pages, genreMap] = await Promise.all([fetchAllPages('/movie/now_playing',3), getGenreMap()]);
const filtered = filterMovies(pages); const filtered = filterMovies(pages);
const top10raw = filtered.slice(0, 10); const top10raw = filtered.slice(0,10), restRaw = filtered.slice(10);
const restRaw = filtered.slice(10); const top10 = await Promise.all(top10raw.map(async (m,i) => {
const top10 = await Promise.all(top10raw.map(async (m, i) => {
let fsk = null; let fsk = null;
try { const d = await tmdb(`/movie/${m.id}/release_dates`); fsk = extractFSK(d); } catch (_) {} try { fsk = extractFSK(await tmdb(`/movie/${m.id}/release_dates`)); } catch(_) {}
return enrichMovie(m, genreMap, fsk, i + 1); return enrichMovie(m, genreMap, fsk, i+1);
})); }));
res.json([...top10, ...restRaw.map(m => enrichMovie(m, genreMap, null, null))]); res.json([...top10, ...restRaw.map(m => enrichMovie(m,genreMap,null,null))]);
} catch (e) { res.status(500).json({ error: e.message }); } } catch(e) { res.status(500).json({ error: e.message }); }
}); });
router.get('/upcoming', authenticate, async (req, res) => { router.get('/upcoming', authenticate, async (req, res) => {
try { try {
const [pages, genreMap] = await Promise.all([fetchAllPages('/movie/upcoming', 3), getGenreMap()]); const [pages, genreMap] = await Promise.all([fetchAllPages('/movie/upcoming',3), getGenreMap()]);
const filtered = filterMovies(pages).filter(m => m.release_date); const filtered = filterMovies(pages).filter(m => m.release_date);
filtered.sort((a, b) => a.release_date.localeCompare(b.release_date)); filtered.sort((a,b) => a.release_date.localeCompare(b.release_date));
const groups = {}; const groups = {};
for (const m of filtered) { for (const m of filtered) {
const d = new Date(m.release_date); const d = new Date(m.release_date), dow = d.getDay();
const dow = d.getDay(); const mon = new Date(d); mon.setDate(d.getDate()+(dow===0?-6:1-dow));
const mon = new Date(d); const key = mon.toISOString().slice(0,10);
mon.setDate(d.getDate() + (dow === 0 ? -6 : 1 - dow));
const key = mon.toISOString().slice(0, 10);
if (!groups[key]) groups[key] = []; if (!groups[key]) groups[key] = [];
groups[key].push(enrichMovie(m, genreMap, null, null)); groups[key].push(enrichMovie(m,genreMap,null,null));
} }
res.json(groups); res.json(groups);
} catch (e) { res.status(500).json({ error: e.message }); } } catch(e) { res.status(500).json({ error: e.message }); }
}); });
// Modal: TMDb-Daten sofort, xREL via separaten Endpoint
router.get('/movie/:id', authenticate, async (req, res) => { router.get('/movie/:id', authenticate, async (req, res) => {
try { try {
const [detail, genreMap, extIds] = await Promise.all([ const [detail, genreMap, extIds] = await Promise.all([
tmdb(`/movie/${req.params.id}`, { append_to_response: 'credits,release_dates' }), tmdb(`/movie/${req.params.id}`, { append_to_response: 'credits,release_dates' }),
getGenreMap(), getGenreMap(),
tmdb(`/movie/${req.params.id}/external_ids`).catch(() => ({})), tmdb(`/movie/${req.params.id}/external_ids`).catch(()=>({})),
]); ]);
const fsk = extractFSK(detail.release_dates); const fsk = extractFSK(detail.release_dates);
const imdbId = extIds.imdb_id || detail.imdb_id || null; const imdbId = extIds.imdb_id || null;
let xrel = [];
try {
const extInfoId = await findExtInfoId(imdbId, detail.title, detail.original_title);
if (extInfoId) xrel = await getGermanReleasesById(extInfoId);
} catch (_) {}
res.json({ res.json({
id: detail.id, id: detail.id, title: detail.title||detail.original_title,
title: detail.title || detail.original_title, original_title: detail.original_title, tagline: detail.tagline,
original_title: detail.original_title, overview: detail.overview, poster_path: detail.poster_path,
tagline: detail.tagline, backdrop_path: detail.backdrop_path, release_date: detail.release_date,
overview: detail.overview, runtime: detail.runtime, vote_average: detail.vote_average,
poster_path: detail.poster_path, genres: (detail.genres||[]).map(g => g.name), fsk,
backdrop_path: detail.backdrop_path, cast: (detail.credits?.cast||[]).slice(0,8).map(a => a.name),
release_date: detail.release_date, director: detail.credits?.crew?.find(c => c.job==='Director')?.name||null,
runtime: detail.runtime,
vote_average: detail.vote_average,
genres: (detail.genres || []).map(g => g.name),
fsk,
cast: (detail.credits?.cast || []).slice(0, 8).map(a => a.name),
director: detail.credits?.crew?.find(c => c.job === 'Director')?.name || null,
tmdb_url: `https://www.themoviedb.org/movie/${detail.id}`, tmdb_url: `https://www.themoviedb.org/movie/${detail.id}`,
imdb_url: imdbId ? `https://www.imdb.com/title/${imdbId}` : null, imdb_url: imdbId ? `https://www.imdb.com/title/${imdbId}` : null,
xrel, imdb_id: imdbId,
has_xrel: xrel.length > 0,
}); });
} catch (e) { res.status(500).json({ error: e.message }); } } catch(e) { res.status(500).json({ error: e.message }); }
}); });
// POST /api/tools/media/xrel-check – Badge Check mit IMDb-ID // xREL separat – lädt im Hintergrund, cached per tmdb_id
// Frontend schickt { movies: [{ id, title, original_title, imdb_id }] } router.get('/movie/:id/xrel', authenticate, async (req, res) => {
try {
const cacheKey = `xrel:tmdb:${req.params.id}`;
const cached = cacheGet(cacheKey);
if (cached !== undefined) return res.json({ xrel: cached, has_xrel: cached.length > 0 });
// Brauchen Titel + IMDb-ID
const [detail, extIds] = await Promise.all([
tmdb(`/movie/${req.params.id}`, { append_to_response: '' }).catch(()=>({})),
tmdb(`/movie/${req.params.id}/external_ids`).catch(()=>({})),
]);
const imdbId = extIds.imdb_id || null;
const xrel = await getXrelData(req.params.id, imdbId, detail.title, detail.original_title);
res.json({ xrel, has_xrel: xrel.length > 0 });
} catch(e) { res.status(500).json({ error: e.message }); }
});
// Badge-Check: benutzt denselben Cache wie Modal
router.post('/xrel-check', authenticate, async (req, res) => { router.post('/xrel-check', authenticate, async (req, res) => {
const movies = (req.body.movies || []).slice(0, 1); const movies = (req.body.movies||[]).slice(0,1);
if (!movies.length) return res.json({}); if (!movies.length) return res.json({});
const m = movies[0]; const m = movies[0];
const cacheKey = `xrel:tmdb:${m.id}`;
try { try {
const extInfoId = await findExtInfoId(m.imdb_id || null, m.title, m.original_title); const cached = cacheGet(cacheKey);
if (!extInfoId) return res.json({ [m.id]: false }); if (cached !== undefined) return res.json({ [m.id]: cached.length > 0 });
const releases = await getGermanReleasesById(extInfoId); const xrel = await getXrelData(m.id, m.imdb_id||null, m.title, m.original_title);
res.json({ [m.id]: releases.length > 0 }); res.json({ [m.id]: xrel.length > 0 });
} catch (_) { } catch(_) { res.json({ [m.id]: false }); }
res.json({ [m.id]: false });
}
}); });
router.get('/favorites', authenticate, (req, res) => { router.get('/favorites', authenticate, (req, res) => {
const rows = db.prepare('SELECT * FROM movie_favorites WHERE user_id=? ORDER BY release_date ASC, title ASC').all(req.user.id); res.json(db.prepare('SELECT * FROM movie_favorites WHERE user_id=? ORDER BY release_date ASC').all(req.user.id));
res.json(rows);
}); });
router.post('/favorites', authenticate, (req, res) => { router.post('/favorites', authenticate, (req, res) => {
const { tmdb_id, title, poster_path, release_date_de, release_date, genres, fsk } = req.body; const { tmdb_id, title, poster_path, release_date_de, release_date, genres, fsk } = req.body;
if (!tmdb_id) return res.status(400).json({ error: 'tmdb_id fehlt' }); if (!tmdb_id) return res.status(400).json({ error: 'tmdb_id fehlt' });
@@ -335,18 +284,13 @@ router.post('/favorites', authenticate, (req, res) => {
db.prepare(`INSERT OR IGNORE INTO movie_favorites (user_id,tmdb_id,title,poster_path,release_date_de,release_date,genres,fsk) VALUES (?,?,?,?,?,?,?,?)`) db.prepare(`INSERT OR IGNORE INTO movie_favorites (user_id,tmdb_id,title,poster_path,release_date_de,release_date,genres,fsk) VALUES (?,?,?,?,?,?,?,?)`)
.run(req.user.id, tmdb_id, title||'', poster_path||'', release_date_de||'', release_date||'', JSON.stringify(genres||[]), fsk||''); .run(req.user.id, tmdb_id, title||'', poster_path||'', release_date_de||'', release_date||'', JSON.stringify(genres||[]), fsk||'');
res.json({ ok: true }); res.json({ ok: true });
} catch (e) { res.status(500).json({ error: e.message }); } } catch(e) { res.status(500).json({ error: e.message }); }
}); });
router.delete('/favorites/:tmdb_id', authenticate, (req, res) => { router.delete('/favorites/:tmdb_id', authenticate, (req, res) => {
db.prepare('DELETE FROM movie_favorites WHERE user_id=? AND tmdb_id=?').run(req.user.id, Number(req.params.tmdb_id)); db.prepare('DELETE FROM movie_favorites WHERE user_id=? AND tmdb_id=?').run(req.user.id, Number(req.params.tmdb_id));
res.json({ ok: true }); res.json({ ok: true });
}); });
router.get('/settings', authenticate, requireAdmin, (req, res) => res.json({ configured: !!getToken() }));
router.get('/settings', authenticate, requireAdmin, (req, res) => {
res.json({ configured: !!getToken() });
});
router.put('/settings', authenticate, requireAdmin, (req, res) => { router.put('/settings', authenticate, requireAdmin, (req, res) => {
const { tmdb_token } = req.body; const { tmdb_token } = req.body;
if (typeof tmdb_token !== 'string') return res.status(400).json({ error: 'tmdb_token fehlt' }); if (typeof tmdb_token !== 'string') return res.status(400).json({ error: 'tmdb_token fehlt' });
@@ -354,11 +298,8 @@ router.put('/settings', authenticate, requireAdmin, (req, res) => {
genreCache = null; genreCache = null;
res.json({ ok: true }); res.json({ ok: true });
}); });
// DELETE /api/tools/media/xrel-cache – Cache leeren (Admin)
router.delete('/xrel-cache', authenticate, requireAdmin, (req, res) => { router.delete('/xrel-cache', authenticate, requireAdmin, (req, res) => {
const info = db.prepare('DELETE FROM xrel_cache').run(); res.json({ deleted: db.prepare('DELETE FROM xrel_cache').run().changes });
res.json({ deleted: info.changes });
}); });
module.exports = router; module.exports = router;

13
frontend/src/tools/media.jsx
View File

@@ -476,15 +476,14 @@ function MovieModal({ tmdbId, onClose, mobile }) {
useEffect(() => { useEffect(() => {
setLoading(true); setDetail(null); setXrel(null); setError(''); setLoading(true); setDetail(null); setXrel(null); setError('');
// TMDb-Daten sofort laden und anzeigen
api(`/tools/media/movie/${tmdbId}`) api(`/tools/media/movie/${tmdbId}`)
.then(d => { .then(d => { setDetail(d); setLoading(false); })
// TMDb-Daten sofort anzeigen
setDetail(d);
setLoading(false);
// xREL ist bereits im response enthalten (Backend lädt parallel)
setXrel(Array.isArray(d.xrel) ? d.xrel : []);
})
.catch(e => { setError(e.message); setLoading(false); }); .catch(e => { setError(e.message); setLoading(false); });
// xREL separat und unabhängig nachladen
api(`/tools/media/movie/${tmdbId}/xrel`)
.then(d => setXrel(d.xrel || []))
.catch(() => setXrel([]));
// Body-Scroll sperren // Body-Scroll sperren
const prev = document.body.style.overflow; const prev = document.body.style.overflow;
document.body.style.overflow = 'hidden'; document.body.style.overflow = 'hidden';