tracker

3.2 KB

1. // tests/faketmdb.mjs — A FAKE TMDB for the gate (tracker.worldapi.org#9): a tiny local HTTP server that answers
2. // the three calls tmdbsync.hl makes, from fixed JSON — no real TMDB call ever happens in the gate. The app is
3. // pointed at it with TMDB_BASE_URL=<base>/3 and TMDB_IMAGE_URL=<base>/t/p.
4. //
5. // GET /3/tv/<id> details (shows[id] minus the episodes)
6. // GET /3/tv/<id>?append_to_response=season/1,… the same + "season/<n>" = { name, overview, air_date, episodes }
7. // GET /t/p/w342/<file>.png a 1×1 png
8. //
9. // `fake.shows` is mutable (the gate adds an episode before the in-app run), `fake.delayMs` slows every answer
10. // down, `fake.requests` records every request (path, authorization) so the gate can prove what was asked.
11. import http from 'node:http';
13. export const PNG = Buffer.from('iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAADUlEQVR42mNk+M9QDwADhgGAWjR9awAAAABJRU5ErkJggg==', 'base64');
15. export async function startFakeTmdb({ port, shows }) {
16. const fake = { shows, delayMs: 0, requests: [], base: `http://127.0.0.1:${port}` };
17. const details = (s) => ({
18. id: s.id, name: s.name, overview: s.overview, status: s.status, poster_path: s.poster_path,
19. number_of_seasons: s.seasons.filter(x => x.season_number > 0).length,
20. number_of_episodes: s.seasons.filter(x => x.season_number > 0).reduce((a, x) => a + x.episodes.length, 0),
21. seasons: s.seasons.map(x => ({ id: x.id, season_number: x.season_number, name: x.name, overview: x.overview || '', air_date: x.air_date, episode_count: x.episodes.length })),
22. });
23. const server = http.createServer((req, res) => {
24. const url = new URL(req.url, fake.base);
25. fake.requests.push({ path: url.pathname + url.search, authorization: req.headers['authorization'] || null });
26. const answer = () => {
27. let m = url.pathname.match(/^\/3\/tv\/(\d+)$/);
28. if (m && fake.shows[m[1]]) {
29. const s = fake.shows[m[1]];
30. const out = details(s);
31. for (const part of (url.searchParams.get('append_to_response') || '').split(',').filter(Boolean)) {
32. const sm = part.match(/^season\/(\d+)$/);
33. const season = sm && s.seasons.find(x => x.season_number === Number(sm[1]));
34. if (season) out[part] = { id: season.id, season_number: season.season_number, name: season.name, overview: season.overview || '', air_date: season.air_date,
35. episodes: season.episodes.map(e => ({ id: e.id, season_number: season.season_number, episode_number: e.episode_number, name: e.name, overview: e.overview || '', air_date: e.air_date })) };
36. }
37. res.writeHead(200, { 'content-type': 'application/json' });
38. return res.end(JSON.stringify(out));
39. }
40. if (/^\/t\/p\/w342\/[a-z0-9]+\.png$/.test(url.pathname)) { res.writeHead(200, { 'content-type': 'image/png' }); return res.end(PNG); }
41. res.writeHead(404, { 'content-type': 'application/json' });
42. res.end('{"status_code":34,"status_message":"The resource you requested could not be found."}');
43. };
44. if (fake.delayMs > 0) setTimeout(answer, fake.delayMs); else answer();
45. });
46. await new Promise((ok, fail) => { server.once('error', fail); server.listen(port, '127.0.0.1', ok); });
47. fake.stop = () => new Promise(r => server.close(() => r()));
48. return fake;
49. }