tracker

13.9 KB

1. // project.hl — tracker.worldapi.org: STEP 1 (tracker.worldapi.org#1), an empty shell. Login copied unchanged from
2. // calendar.worldapi.org (rejected once for a centered sign-in and no header selector — architect, 2026-09-27):
3. // ident only, no own passwords (README "How apps use ident" of ident.worldapi.org), the identity selector in the
4. // header (components/main.hl). No shows, no data yet — later steps come from the creator (CONCEPT.md).
5. //
6. // the header's ident-selector / "Log in with ident" -> <ident>/login?key=&return=<this app>/login/callback
7. // /login/callback?ident_code=<code> the app's server exchanges the code for the identity's short id
8. // (POST <ident>/api/exchange) and signs this app's OWN session in
9. // (session.user = { id = <users @id> }, users.hl)
10. // the header's "Log out" button signs this app's session out via the face trackerLogOut (components/main.hl)
11. // — ident's own session, and the browser's ident cookie, are untouched
12. //
13. // Config (env; no committed secret — the first deploy registers this app in ident and sets these, done by the
14. // architect, as with ident's own .env for SMTP):
15. // TRACKER_PORT (45008), TRACKER_URL (this app's own public address, for the return URL),
16. // IDENT_URL (https://ident.worldapi.org), TRACKER_KEY (pk_…), TRACKER_SECRET (sk_…)
17. import WebFramework from 'hl:web'
18. import { Response } from 'hl:http1'
19. import { randomBytes } from 'hl:crypto'
20. import { env } from 'hl:proc'
21. import { readBytes, exists } from 'hl:fs'
22. import { now, timestamp, every } from 'hl:time'
24. import Styles from './styles.hl'
25. import { exchangeCode, ensureUser } from './users.hl'
26. import Home from './components/home.hl'
27. import LoginFailed from './components/loginfailed.hl'
28. import Show from './components/show.hl'
29. import Unwatched from './components/unwatched.hl'
30. import Schedule from './components/schedule.hl'
31. import MyShows from './components/myshows.hl'
32. import MyMovies from './components/mymovies.hl'
33. import Movies from './components/movies.hl'
34. import AllShows from './components/allshows.hl'
35. import Search from './components/search.hl'
36. import { ensureIndex } from './search.hl'
37. import { syncEnabled, syncShow, persistSync, emptyTotals, addTotals, totalsLine, pauseMsAfter } from './tmdbsync.hl'
38. import { allFollowedShowIds } from './follows.hl'
39. import { refreshCatalogShow } from './catalog.hl'
40. import { dark, darker } from './shared/tokens.hl'
42. static appTitle = "tracker"
44. // ---- THE INSTALLABLE APP (tracker.worldapi.org#10), the same way calendar.worldapi.org does it: hl:web's own web app
45. // manifest (/__hl/manifest.webmanifest, linked from every head with the apple-touch-icon and theme-color) and service
46. // worker (/__hl/sw.js) from these settings — no JavaScript of ours. Icons in icons/ (icon.svg is the source, the PNGs
47. // are rendered from it with rsvg-convert, README "Icons"). The theme colour is the header's background (darker), the
48. // splash background the page's (dark) — both off the tokens, not written out again.
49. appThemeColor = darker.value
50. appBackgroundColor = dark.value
51. appIcons = [
52. { src = '/icons/icon-192.png' sizes = '192x192' purpose = 'any' }
53. { src = '/icons/icon-512.png' sizes = '512x512' purpose = 'any' }
54. { src = '/icons/icon-192.png' sizes = '192x192' purpose = 'maskable' }
55. { src = '/icons/icon-512.png' sizes = '512x512' purpose = 'maskable' }
56. ]
57. appTouchIcon = '/icons/apple-touch-icon.png'
58. appFavicon = '/icons/favicon.svg'
59. // OFFLINE: only the shell — the header and `/` (components/main.hl says "You are offline" while the browser has no
60. // network). The data pages are not kept: without a network they get hl:web's "Unavailable offline" page.
61. offline = [ Home ]
63. styles = Styles
65. port = env('TRACKER_PORT') != null ? toNumber(env('TRACKER_PORT')) : 45008
66. watching = env('TRACKER_WATCH') != '0'
67. // read by hl:web's own manifest config (WebFramework.hl `cfg.sessionDir`), not the constructor call below
68. sessionDir = env('TRACKER_SESSIONS') != null ? env('TRACKER_SESSIONS') : null
70. // ---- THE LOGIN BUTTON'S RETURN (ident README "How apps use ident"), copied from calendar.worldapi.org's project.hl
71. // BACK TO THE PAGE: /login.js puts `?next=` into the button's return URL at the click. Only a same-origin PATH
72. // goes (one `/`, URL-safe characters, ≤ 500). Anything else → `/`.
73. nextChars = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789-._~/?&=%+,;@!$()*:'
74. safePath = (want) => {
75. if (want == null || hlTypeName(want) != 'String' || want == '' || want.length > 500) { return '/' }
76. if (want.slice(0, 1) != '/' || want.slice(0, 2) == '//' || want.slice(0, 7) == '/login/') { return '/' }
77. let i = 0
78. while (i < want.length) {
79. if (!nextChars.includes(want[i])) { return '/' }
80. i = i + 1
81. }
82. return want
83. }
85. // A FAILED LOGIN is a page (components/loginfailed.hl): the reason is parked in the session, then → /login/failed
86. failed = (req, why) => {
87. let s = req.session
88. let fresh = s == null
89. if (fresh) { s = server.sessions.mint() }
90. s.data.loginError = why
91. server.sessions.save(s)
92. let res = new Response('login failed: ' + why, { status = 302 headers = { 'Location' = '/login/failed' 'Cache-Control' = 'no-store' 'Content-Type' = 'text/plain; charset=utf-8' } })
93. if (fresh) { res.headers['Set-Cookie'] = server.sessions.cookieHeader(s.id) }
94. return res
95. }
97. // the function route gets the cookie's session as req.session (hybriel #11); none yet → minted here
98. loginCallback = (route, req) => {
99. if (req.method != 'GET') { return failed(req, 'GET only') }
100. let q = req.query != null ? req.query : {}
101. let code = q.ident_code
102. if (code == null || code == '') { return failed(req, 'ident sent no login code') }
103. let x = exchangeCode(code)
104. if (x.error != null) { return failed(req, x.error) }
105. let u = ensureUser(x.identity)
106. if (u == null) { return failed(req, 'could not store the user') }
107. let s = req.session
108. let fresh = s == null
109. if (fresh) { s = server.sessions.mint() }
110. s.user = { id = u.id }
111. s.data.tag = randomBytes(16)
112. s.data.loginError = null
113. server.sessions.save(s)
114. let res = new Response('logged in', { status = 302 headers = { 'Location' = safePath(q.next) 'Cache-Control' = 'no-store' 'Content-Type' = 'text/plain; charset=utf-8' } })
115. if (fresh) { res.headers['Set-Cookie'] = server.sessions.cookieHeader(s.id) }
116. return res
117. }
119. // ---- /posters/<name> (tracker.worldapi.org#4): a show's poster image, served dynamically from
120. // storage/mpackdb/posters/ (the poster's file name is the show's oldId + its migrated extension,
121. // shows.hl posterName) — falls back to a placeholder svg when the real file isn't there yet (the
122. // mongo export never included the actual poster bytes, see the report's `open`).
123. postersDir = (env('TRACKER_STORAGE') != null ? env('TRACKER_STORAGE') : './storage/mpackdb') + '/posters'
124. placeholderPoster = './assets/poster-placeholder.svg'
125. posterNameChars = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789.-_'
126. isSafePosterName = (name) => {
127. if (name == null || hlTypeName(name) != 'String' || name == '' || name.length > 100) { return false }
128. let i = 0
129. while (i < name.length) {
130. if (!posterNameChars.includes(name[i])) { return false }
131. i = i + 1
132. }
133. return true
134. }
135. endsWithStr = (s, suffix) => { return s.length >= suffix.length && s.slice(s.length - suffix.length) == suffix }
136. mimeOfPoster = (name) => {
137. if (endsWithStr(name, '.png')) { return 'image/png' }
138. if (endsWithStr(name, '.webp')) { return 'image/webp' }
139. if (endsWithStr(name, '.svg')) { return 'image/svg+xml' }
140. return 'image/jpeg'
141. }
142. posterRoute = (route, req) => {
143. let name = route.params != null ? route.params.name : null
144. if (!isSafePosterName(name)) { return new Response('bad poster name', { status = 400 headers = { 'Content-Type' = 'text/plain; charset=utf-8' } }) }
145. let path = postersDir + '/' + name
146. if (exists(path)) { return new Response(readBytes(path), { headers = { 'Content-Type' = mimeOfPoster(name) 'Cache-Control' = 'public, max-age=86400' } }) }
147. return new Response(readBytes(placeholderPoster), { headers = { 'Content-Type' = 'image/svg+xml' 'Cache-Control' = 'public, max-age=3600' } })
148. }
150. // ---- the old addresses of the personal lists (tracker.worldapi.org#8): they all live under /my/ now —
151. // a permanent redirect so old links keep working (architect's decision)
152. movedTo = (path) => { return new Response('moved to ' + path, { status = 301 headers = { 'Location' = path 'Content-Type' = 'text/plain; charset=utf-8' } }) }
153. unwatchedMoved = (route, req) => { return movedTo('/my/unwatched') }
154. scheduleMoved = (route, req) => { return movedTo('/my/schedule') }
156. routes = [
157. { pattern = "/favicon.ico" file = "./icons/favicon.ico" headers = { 'Cache-Control' = 'no-cache' } }
158. // the installable app (tracker.worldapi.org#10): the icons (manifest and service worker are hl:web's own, from appIcons / offline)
159. { pattern = "/icons/icon-192.png" file = "./icons/icon-192.png" headers = { 'Cache-Control' = 'no-cache' } }
160. { pattern = "/icons/icon-512.png" file = "./icons/icon-512.png" headers = { 'Cache-Control' = 'no-cache' } }
161. { pattern = "/icons/apple-touch-icon.png" file = "./icons/apple-touch-icon.png" headers = { 'Cache-Control' = 'no-cache' } }
162. { pattern = "/icons/favicon.svg" file = "./icons/favicon.svg" headers = { 'Cache-Control' = 'no-cache' } }
163. { pattern = "/login/callback" function = loginCallback }
164. { pattern = "/login/failed" component = LoginFailed }
165. { pattern = "/login.js" file = "./login.js" headers = { 'Cache-Control' = 'no-cache' } }
166. { pattern = "/posters/:name" function = posterRoute }
167. // tracker.worldapi.org#13: every movie / every series, 24 per page — the page is a PATH segment (`/movies/page/2`), a
168. // page component cannot read `?page=` (hybriel#11) — and the movies the user follows
169. { pattern = "/movies" component = Movies }
170. { pattern = "/movies/page/:page" component = Movies }
171. { pattern = "/shows" component = AllShows }
172. { pattern = "/shows/page/:page" component = AllShows }
173. { pattern = "/shows/:slug" component = Show }
174. { pattern = "/my/shows" component = MyShows }
175. { pattern = "/my/movies" component = MyMovies }
176. { pattern = "/my/unwatched" component = Unwatched }
177. { pattern = "/my/schedule" component = Schedule }
178. { pattern = "/unwatched" function = unwatchedMoved }
179. { pattern = "/schedule" function = scheduleMoved }
180. // tracker.worldapi.org#14: the search — `/search/<text>` (hl:web gives a page no query string, so not `?q=`)
181. { pattern = "/search/:q?" component = Search }
182. { pattern = "/" component = Home }
183. ]
185. // WHO GETS THE PUSH: the login state reaches the tabs of one session (components/main.hl trackerSignedIn/Out).
186. tagOf = (session) => { return session != null && session.data != null ? session.data.tag : null }
187. audience = {
188. trackerSignedIn = (tag, session) => { return tag != null && tagOf(session) == tag }
189. trackerSignedOut = (tag, session) => { return tag != null && tagOf(session) == tag }
190. }
192. // cookies are per host, not per port: an own name keeps this app's session apart from
193. // ident's own (and from any other worldapi app sharing a dev host), see ident README "Design
194. // tokens" / hybriel#10 hybriel#17.
195. sessionCookie = 'trackersid'
196. // tracker.worldapi.org#14: the search index (search.hl) is built once here at boot (~0.6 s on the real data), not by the
197. // first search
198. searchIndexReady = ensureIndex()
199. server = new WebFramework(routes = routes, styles = styles, port = port, sessionCookie = sessionCookie, watchMode = watching)
201. // ---- THE DAILY TMDB SYNC (tracker.worldapi.org#9, tmdbsync.hl) --------------------------------------
202. // Once a day at TRACKER_SYNC_HOUR (UTC, default 4 — hl:time has no time zones; the container runs UTC) every
203. // followed show is synced from TMDB. hl:web serves ONE request at a time, so the run never takes the server
204. // for itself: a 1-second clock does ONE show per tick (1–3 TMDB requests + maybe its poster) and returns — the
205. // requests that queued meanwhile are served between two ticks, and a tick never starts inside a page render.
206. // After a show that made n requests the next waits n × 260 ms (TMDB: ≤ 40 requests / 10 s) + 550 ms per TVmaze lookup
207. // (≤ 20 / 10 s, tracker.worldapi.org#12).
208. // TRACKER_SYNC=0 switches it off; without TMDB_READ_TOKEN it is off too (logged once).
209. syncHour = env('TRACKER_SYNC_HOUR') != null ? toNumber(env('TRACKER_SYNC_HOUR')) : 4
210. syncOn = env('TRACKER_SYNC') != '0' && syncEnabled
211. syncQueue = []
212. syncAt = 0
213. syncDay = ''
214. syncNextAt = 0
215. syncTotals = emptyTotals()
216. syncTick = () => {
217. let t = now()
218. if (syncQueue.length == 0) {
219. let stamp = timestamp(t)
220. let day = stamp.slice(0, 10)
221. if (toNumber(stamp.slice(11, 13)) != syncHour || day == syncDay) { return null }
222. syncDay = day
223. syncQueue = allFollowedShowIds()
224. syncAt = t
225. syncNextAt = 0
226. syncTotals = emptyTotals()
227. console.log('tmdb sync: start, ' + syncQueue.length + ' followed shows')
228. return null
229. }
230. if (t < syncNextAt) { return null }
231. let id = syncQueue[0]
232. let rest = []
233. let i = 1
234. while (i < syncQueue.length) { rest.push(syncQueue[i]) i = i + 1 }
235. syncQueue = rest
236. let r = syncShow(id)
237. // the public lists (catalog.hl, tracker.worldapi.org#13): this show's place by its newest released episode
238. refreshCatalogShow(id)
239. let took = now() - t
240. syncTotals = addTotals(syncTotals, r)
241. if (r.error != '') { console.log('tmdb sync: ' + r.error) }
242. // a step blocks every request meanwhile (Saturday Night Live, 53 seasons, 4 requests: ~1.7 s) — say so in the log
243. if (took > 1500) { console.log('tmdb sync: slow step, show ' + id + ', ' + r.requests + ' requests, ' + took + ' ms') }
244. syncNextAt = now() + pauseMsAfter(r)
245. if (syncQueue.length == 0 || syncTotals.shows % 10 == 0) { persistSync() }
246. if (syncQueue.length == 0) { console.log('tmdb sync done: ' + totalsLine(syncTotals) + ' seconds=' + ((now() - syncAt) / 1000)) }
247. return null
248. }
249. if (syncOn) {
250. console.log('tmdb sync: daily at ' + syncHour + ':00 UTC')
251. syncClock = every(1)
252. on syncClock.tick(x) {
253. syncTick()
254. return null
255. }
256. } else {
257. console.log('tmdb sync: off (' + (syncEnabled ? 'TRACKER_SYNC=0' : 'no TMDB_READ_TOKEN') + ')')
258. }
260. on Error(e) { console.log('error absorbed: ' + e.message) }