tracker

2.9 KB

1. // follows.hl — per-user follow data (tracker.worldapi.org#5): which shows a user follows; since mission 047 also the
2. // show page's Follow toggle (`setFollowed`).
3. // storage/mpackdb/follows.db, migrated by tools/migrate.hl (tracker.worldapi.org#2): { show, user, at, oldId }.
4. // Kept apart from shows.hl (show data) and watches.hl (watch state) so /unwatched, /schedule and /my/shows (tickets #5/#6/#7,
5. // "reuse, don't copy") can all import the same functions.
6. import { MPackDB } from 'hl:mpackdb'
7. import { env } from 'hl:proc'
8. import { now } from 'hl:time'
9. import { randomBytes } from 'hl:crypto'
11. static envOr = (name, fallback) => {
12. let v = env(name)
13. return v != null && v.trim() != '' ? v.trim() : fallback
14. }
15. static storageDir = envOr('TRACKER_STORAGE', './storage/mpackdb')
16. static followsTable = new MPackDB(file = storageDir + '/follows.db', primaryKey = '@id', indexes = ['!oldId'])
18. // every follow record of this user ({ show, user, at, … }, `at` = epoch ms) — a linear scan (128 rows
19. // total across every user, migrated data; cheap once per page load) — no declared index on `user`.
20. // /my/shows (tracker.worldapi.org#7) needs the whole record for its follow-date order.
21. static followsOfUser = (userId) => {
22. if (userId == null) { return [] }
23. let out = []
24. for (f of followsTable.find(null, null)) { if (f.user == userId && f.show != null) { out.push(f) } }
25. return out
26. }
28. // the ids of every show this user follows
29. static followedShowIds = (userId) => {
30. let out = []
31. for (f of followsOfUser(userId)) { out.push(f.show) }
32. return out
33. }
35. // every show ANYONE follows, each once, in follow-table order — what the TMDB sync (tmdbsync.hl,
36. // tracker.worldapi.org#9) keeps up to date
37. static allFollowedShowIds = () => {
38. let seen = {}
39. let out = []
40. for (f of followsTable.find(null, null)) {
41. if (f.show != null && seen[f.show] != true) { seen[f.show] = true out.push(f.show) }
42. }
43. return out
44. }
46. // mission 047 (the show page's Follow / Following toggle): does this user follow this show?
47. static isFollowing = (userId, showId) => {
48. if (userId == null || showId == null) { return false }
49. for (f of followsOfUser(userId)) { if (f.show == showId) { return true } }
50. return false
51. }
53. // follow (a new record, follow date = now → the top of /my/shows) or unfollow (every record of this user+show is
54. // deleted). Own 16-hex id + a unique `oldId` marker (the `!oldId` UNIQUE index refuses a second null), never update()
55. // (hybriel#113) — the same shape as watches.hl `setWatched`.
56. static setFollowed = (userId, showId, follow) => {
57. if (userId == null || showId == null) { return false }
58. let mine = []
59. for (f of followsOfUser(userId)) { if (f.show == showId) { mine.push(f) } }
60. if (follow) {
61. if (mine.length > 0) { return true }
62. let id = followsTable.put({ id = randomBytes(8, 'hex') show = showId user = userId at = now() oldId = 'app:' + randomBytes(8, 'hex') })
63. return id != null
64. }
65. let ok = true
66. for (f of mine) { ok = followsTable.delete(f.id) > 0 && ok }
67. return ok
68. }