tracker

2.9 KB

1. // watches.hl — PER-USER WATCH STATE (episode/season checks, tracker.worldapi.org#4), reused as-is
2. // (not copied) by /unwatched and /schedule (tickets #5/#6: "same check icon and watch logic as the
3. // show page — reuse, don't copy"). storage/mpackdb/watches.db, migrated by tools/migrate.hl
4. // (tracker.worldapi.org#2): { targetType ('episode'|'season'), target, user, at, oldId }.
5. import { MPackDB } from 'hl:mpackdb'
6. import { env } from 'hl:proc'
7. import { now } from 'hl:time'
8. import { randomBytes } from 'hl:crypto'
10. static envOr = (name, fallback) => {
11. let v = env(name)
12. return v != null && v.trim() != '' ? v.trim() : fallback
13. }
14. static storageDir = envOr('TRACKER_STORAGE', './storage/mpackdb')
15. static watchesTable = new MPackDB(file = storageDir + '/watches.db', primaryKey = '@id', indexes = ['!oldId'])
17. // every watch of this user — a linear scan (11692 rows total across every user, migrated data; cheap
18. // once per page load) — no declared index on `user`
19. static watchesOfUser = (userId) => {
20. if (userId == null) { return [] }
21. let out = []
22. for (w of watchesTable.find(null, null)) { if (w.user == userId) { out.push(w) } }
23. return out
24. }
26. static findWatch = (rows, targetType, targetId) => {
27. for (w of rows) { if (w.targetType == targetType && w.target == targetId) { return w } }
28. return null
29. }
30. static isWatched = (rows, targetType, targetId) => { return findWatch(rows, targetType, targetId) != null }
32. // the check's class — "a disc with a check in it", solid once watched, regular while not (the
33. // SAME icon and class the show page uses, tracker.worldapi.org#4/#5 — /unwatched and /schedule
34. // reuse this instead of each declaring their own)
35. static watchClassOf = (watched) => { return watched ? 'checkicon solid' : 'checkicon regular' }
37. // a NEW watch's oldId can't be null: the table's `!oldId` UNIQUE index would refuse a second one
38. // (the migrated rows all carry a real Mongo hex id; a fresh watch gets its own unique marker instead)
39. static setWatched = (userId, targetType, targetId, rows, watched) => {
40. let existing = findWatch(rows, targetType, targetId)
41. if (watched) {
42. if (existing != null) { return true }
43. let id = watchesTable.put({ id = randomBytes(8, 'hex') targetType = targetType target = targetId user = userId at = now() oldId = 'app:' + randomBytes(8, 'hex') })
44. return id != null
45. }
46. if (existing == null) { return true }
47. return watchesTable.delete(existing.id) > 0
48. }
50. // a season check toggles the season's OWN watch record AND every one of its episodes (creator: "if
51. // the season is checked or unchecked all its episodes get checked or unchecked") — `rows` is the
52. // snapshot from BEFORE this batch; every target below is distinct, so the staleness across the loop
53. // never matters (no two calls touch the same target)
54. static setSeasonWatched = (userId, seasonId, episodeIds, rows, watched) => {
55. let ok = setWatched(userId, 'season', seasonId, rows, watched)
56. for (eid of episodeIds) { ok = setWatched(userId, 'episode', eid, rows, watched) && ok }
57. return ok
58. }