tracker

12.9 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 lib/sync.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|w780/<file>.png a 1×1 png (w780: a backdrop, mission 032)
8. // …?append_to_response=…,external_ids + "external_ids" = shows[id].external_ids (tracker.worldapi.org#12)
9. // GET /3/movie/<id>[?append_to_response=external_ids] movies[id]: { id, title, poster_path } (+ external_ids)
10. // GET /3/search/multi?query=… tracker.worldapi.org#14: { results = search[query in lower case] }
11. // — recorded in `fake.searchRequests`, NOT in `fake.requests`
12. // GET /t/p/w92/<file>.png the search page's small posters → `fake.thumbRequests`
13. // GET /3/person/<id>[?append_to_response=combined_credits] tracker.worldapi.org#16: persons[id] (+ its combined_credits)
14. // GET /t/p/w185/<file>.png a person's photo (1×1 png) — both recorded in `fake.personRequests`
15. // and A FAKE TVMAZE under /tvmaze (the app gets TVMAZE_BASE_URL=<base>/tvmaze):
16. // GET /tvmaze/lookup/shows?imdb=tt…|thetvdb=<id> 301 → /tvmaze/shows/<id> (like the real one), 404 when unknown
17. // GET /tvmaze/shows/<id> { id, name }
18. // GET /tvmaze/shows/<id>?embed=episodes + summary (tvmaze.summaries[id], HTML) + _embedded.episodes = tvmaze.episodes[id]
19. // (tracker.worldapi.org#15, #18): [{ id, season, number, name, airdate }]; 404 without episodes
20. // GET /tvmaze/updates/shows?since=day|week|month tracker.worldapi.org#18: tvmaze.updates ({ "<id>": <time> })
21. // both /tvmaze/shows/<id> answers carry `status` = tvmaze.statuses[id] (tracker#35; null when none); an id in tvmaze.missing → 404
22. // GET /3/tv/changes, /3/movie/changes?start_date=…&end_date=…&page=n tracker.worldapi.org#18: `fake.changes` { tv: [ids], movie: [ids] },
23. // `fake.changesPageSize` (100) per page — recorded in `fake.requests` like every TMDB call;
24. // `fake.changesFail` = true answers 503
25. //
26. // GET /3/collection/<id> tracker.worldapi.org#19 (mission 066): collections[id] = { id, name, parts }; a
27. // movie's details carry `belongs_to_collection` when its fixture has one
28. // …?append_to_response=…,credits (movie) / aggregate_credits (tv) tracker.worldapi.org#26: the fixture's `credits` /
29. // `aggregate_credits` ({ cast: [...] }); details also carry homepage,
30. // tagline, status, genres of the fixture
31. // tracker.worldapi.org#28: a series' details carry the fixture's `created_by`
32. // (default []); credits may carry `crew` (movie: { job }, series: { jobs })
33. // mission 054: every details / search answer carries TMDB's `adult` (false unless the fixture sets it). Mission 068 (tracker#21):
34. // a TV details answer carries the fixture's `type` (Scripted, Talk Show, …; none when the fixture has none).
35. // `fake.shows` is mutable (the gate adds an episode before the in-app run), `fake.delayMs` slows every answer
36. // down, `fake.requests` records every TMDB/image request (path, authorization) so the gate can prove what was asked;
37. // TVmaze requests go to `fake.tvmazeRequests` (paths) instead.
38. import http from 'node:http';
40. export const PNG = Buffer.from('iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAADUlEQVR42mNk+M9QDwADhgGAWjR9awAAAABJRU5ErkJggg==', 'base64');
42. export async function startFakeTmdb({ port, shows, movies = {}, tvmaze = { imdb: {}, thetvdb: {} }, search = {}, persons = {}, collections = {} }) {
43. const fake = { shows, movies, tvmaze, search, persons, collections, changes: { tv: [], movie: [] }, changesPageSize: 100, changesFail: false, delayMs: 0, personDelayMs: 0, requests: [], tvmazeRequests: [], searchRequests: [], thumbRequests: [], personRequests: [], base: `http://127.0.0.1:${port}` };
44. const details = (s) => ({
45. id: s.id, name: s.name, adult: s.adult ?? false, overview: s.overview, status: s.status, poster_path: s.poster_path, backdrop_path: s.backdrop_path ?? null,
46. first_air_date: s.first_air_date, genres: s.genres, original_language: s.original_language, homepage: s.homepage, tagline: s.tagline, created_by: s.created_by || [], type: s.type,
47. number_of_seasons: s.seasons.filter(x => x.season_number > 0).length,
48. number_of_episodes: s.seasons.filter(x => x.season_number > 0).reduce((a, x) => a + x.episodes.length, 0),
49. 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 })),
50. });
51. const server = http.createServer((req, res) => {
52. const url = new URL(req.url, fake.base);
53. if (url.pathname.startsWith('/tvmaze/')) {
54. fake.tvmazeRequests.push(url.pathname + url.search);
55. const json = (code, body, headers = {}) => { res.writeHead(code, { 'content-type': 'application/json', ...headers }); res.end(JSON.stringify(body)); };
56. if (url.pathname === '/tvmaze/lookup/shows') {
57. const [param, value] = [...url.searchParams.entries()][0] || [];
58. const id = param && (fake.tvmaze[param] || {})[value];
59. return id ? json(301, {}, { location: `${fake.base}/tvmaze/shows/${id}` }) : json(404, { name: 'Not Found', status: 404 });
60. }
61. if (url.pathname === '/tvmaze/updates/shows') return json(200, fake.tvmaze.updates || {});
62. const em = url.pathname.match(/^\/tvmaze\/shows\/(\d+)\/episodes$/);
63. if (em) return (fake.tvmaze.episodes || {})[em[1]] ? json(200, fake.tvmaze.episodes[em[1]].map(e => ({ type: 'regular', summary: '<p>tvmaze</p>', ...e }))) : json(404, { name: 'Not Found', status: 404 });
64. const sm = url.pathname.match(/^\/tvmaze\/shows\/(\d+)$/);
65. if (sm && url.searchParams.get('embed') === 'episodes') {
66. const eps = (fake.tvmaze.episodes || {})[sm[1]];
67. return eps ? json(200, { id: Number(sm[1]), name: 'fake TVmaze show ' + sm[1], summary: (fake.tvmaze.summaries || {})[sm[1]] ?? null, status: (fake.tvmaze.statuses || {})[sm[1]] ?? null,
68. _embedded: { episodes: eps.map(e => ({ type: 'regular', summary: '<p>tvmaze</p>', ...e })) } }) : json(404, { name: 'Not Found', status: 404 });
69. }
70. return sm && !(fake.tvmaze.missing || []).includes(Number(sm[1])) ? json(200, { id: Number(sm[1]), name: 'fake TVmaze show ' + sm[1], status: (fake.tvmaze.statuses || {})[sm[1]] ?? null }) : json(404, { name: 'Not Found', status: 404 });
71. }
72. if (url.pathname === '/3/search/multi') {
73. fake.searchRequests.push({ path: url.pathname + url.search, authorization: req.headers['authorization'] || null });
74. // like the real one, every title result carries `adult` (false unless the fixture says otherwise, mission 054)
75. const results = (fake.search[(url.searchParams.get('query') || '').toLowerCase()] || []).map(r => r.media_type === 'person' || 'adult' in r ? r : { ...r, adult: false });
76. res.writeHead(200, { 'content-type': 'application/json' });
77. return res.end(JSON.stringify({ page: 1, results, total_pages: 1, total_results: results.length }));
78. }
79. // the search page's small posters (w92, loaded by the BROWSER from TMDB's image host) — kept out of `requests` too
80. if (/^\/t\/p\/w92\/[a-z0-9]+\.png$/.test(url.pathname)) { fake.thumbRequests.push(url.pathname); res.writeHead(200, { 'content-type': 'image/png' }); return res.end(PNG); }
81. // tracker.worldapi.org#16: the person page's fetch (kept out of `requests`, like the search's) — `personDelayMs` slows it
82. // down so the gate sees the page's "loading" state
83. const pm = url.pathname.match(/^\/3\/person\/(\d+)$/);
84. if (pm || /^\/t\/p\/w185\/[a-z0-9]+\.png$/.test(url.pathname)) {
85. fake.personRequests.push({ path: url.pathname + url.search, authorization: req.headers['authorization'] || null });
86. const answerPerson = () => {
87. if (!pm) { res.writeHead(200, { 'content-type': 'image/png' }); return res.end(PNG); }
88. const pr = fake.persons[pm[1]];
89. if (!pr) { res.writeHead(404, { 'content-type': 'application/json' }); return res.end('{"status_code":34,"status_message":"The resource you requested could not be found."}'); }
90. const { combined_credits, ...out } = pr;
91. if ((url.searchParams.get('append_to_response') || '').split(',').includes('combined_credits')) out.combined_credits = combined_credits || { cast: [], crew: [] };
92. res.writeHead(200, { 'content-type': 'application/json' });
93. res.end(JSON.stringify(out));
94. };
95. if (pm && fake.personDelayMs > 0) return setTimeout(answerPerson, fake.personDelayMs);
96. return answerPerson();
97. }
98. fake.requests.push({ path: url.pathname + url.search, authorization: req.headers['authorization'] || null, at: Date.now() });
99. const answer = () => {
100. const ch = url.pathname.match(/^\/3\/(tv|movie)\/changes$/);
101. if (ch) {
102. if (fake.changesFail) { res.writeHead(503, { 'content-type': 'application/json' }); return res.end('{"status_code":11}'); }
103. const all = fake.changes[ch[1]] || [], size = fake.changesPageSize, page = Number(url.searchParams.get('page') || 1);
104. const results = all.slice((page - 1) * size, page * size).map(id => ({ id, adult: false }));
105. res.writeHead(200, { 'content-type': 'application/json' });
106. return res.end(JSON.stringify({ results, page, total_pages: Math.max(1, Math.ceil(all.length / size)), total_results: all.length }));
107. }
108. const appended = (url.searchParams.get('append_to_response') || '').split(',').filter(Boolean);
109. const mv = url.pathname.match(/^\/3\/movie\/(\d+)$/);
110. if (mv && fake.movies[mv[1]]) {
111. const m = fake.movies[mv[1]];
112. const out = { id: m.id, title: m.title, adult: m.adult ?? false, poster_path: m.poster_path, release_date: m.release_date, overview: m.overview, genres: m.genres,
113. homepage: m.homepage, tagline: m.tagline, status: m.status, backdrop_path: m.backdrop_path ?? null, runtime: m.runtime ?? 0 };
114. if (appended.includes('external_ids')) out.external_ids = m.external_ids || {};
115. if (appended.includes('credits')) out.credits = m.credits || { cast: [], crew: [] };
116. if (m.belongs_to_collection !== undefined) out.belongs_to_collection = m.belongs_to_collection;
117. res.writeHead(200, { 'content-type': 'application/json' });
118. return res.end(JSON.stringify(out));
119. }
120. const cm = url.pathname.match(/^\/3\/collection\/(\d+)$/);
121. if (cm && fake.collections[cm[1]]) {
122. res.writeHead(200, { 'content-type': 'application/json' });
123. return res.end(JSON.stringify(fake.collections[cm[1]]));
124. }
125. let m = url.pathname.match(/^\/3\/tv\/(\d+)$/);
126. if (m && fake.shows[m[1]]) {
127. const s = fake.shows[m[1]];
128. const out = details(s);
129. if (appended.includes('external_ids')) out.external_ids = s.external_ids || {};
130. if (appended.includes('aggregate_credits')) out.aggregate_credits = s.aggregate_credits || { cast: [], crew: [] };
131. for (const part of appended) {
132. const sm = part.match(/^season\/(\d+)$/);
133. const season = sm && s.seasons.find(x => x.season_number === Number(sm[1]));
134. if (season) out[part] = { id: season.id, season_number: season.season_number, name: season.name, overview: season.overview || '', air_date: season.air_date,
135. 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 })) };
136. }
137. res.writeHead(200, { 'content-type': 'application/json' });
138. return res.end(JSON.stringify(out));
139. }
140. // mission 032 (tracker#33): w780 = a backdrop the sync takes as the poster when TMDB has none
141. if (/^\/t\/p\/w(342|780)\/[a-z0-9]+\.png$/.test(url.pathname)) { res.writeHead(200, { 'content-type': 'image/png' }); return res.end(PNG); }
142. res.writeHead(404, { 'content-type': 'application/json' });
143. res.end('{"status_code":34,"status_message":"The resource you requested could not be found."}');
144. };
145. if (fake.delayMs > 0) setTimeout(answer, fake.delayMs); else answer();
146. });
147. await new Promise((ok, fail) => { server.once('error', fail); server.listen(port, '127.0.0.1', ok); });
148. fake.stop = () => new Promise(r => server.close(() => r()));
149. return fake;
150. }