tracker

3.4 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. // insertion sort, hand-written (no list sort(), hybriel#1) — newest follow first; `at` is epoch ms (migrated
29. // `_createdAt`, or now() for a new follow), a missing one counts as the oldest. Rows carry `followedAt`.
30. // /my/shows and /my/movies (tracker.worldapi.org#7/#13)
31. static insertByFollowDesc = (sorted, row) => {
32. let out = []
33. let inserted = false
34. for (x of sorted) {
35. if (!inserted && row.followedAt >= x.followedAt) { out.push(row) inserted = true }
36. out.push(x)
37. }
38. if (!inserted) { out.push(row) }
39. return out
40. }
42. // the ids of every show this user follows
43. static followedShowIds = (userId) => {
44. let out = []
45. for (f of followsOfUser(userId)) { out.push(f.show) }
46. return out
47. }
49. // every show ANYONE follows, each once, in follow-table order — what the TMDB sync (tmdbsync.hl,
50. // tracker.worldapi.org#9) keeps up to date
51. static allFollowedShowIds = () => {
52. let seen = {}
53. let out = []
54. for (f of followsTable.find(null, null)) {
55. if (f.show != null && seen[f.show] != true) { seen[f.show] = true out.push(f.show) }
56. }
57. return out
58. }
60. // mission 047 (the show page's Follow / Following toggle): does this user follow this show?
61. static isFollowing = (userId, showId) => {
62. if (userId == null || showId == null) { return false }
63. for (f of followsOfUser(userId)) { if (f.show == showId) { return true } }
64. return false
65. }
67. // follow (a new record, follow date = now → the top of /my/shows) or unfollow (every record of this user+show is
68. // deleted). Own 16-hex id + a unique `oldId` marker (the `!oldId` UNIQUE index refuses a second null), never update()
69. // (hybriel#113) — the same shape as watches.hl `setWatched`.
70. static setFollowed = (userId, showId, follow) => {
71. if (userId == null || showId == null) { return false }
72. let mine = []
73. for (f of followsOfUser(userId)) { if (f.show == showId) { mine.push(f) } }
74. if (follow) {
75. if (mine.length > 0) { return true }
76. let id = followsTable.put({ id = randomBytes(8, 'hex') show = showId user = userId at = now() oldId = 'app:' + randomBytes(8, 'hex') })
77. return id != null
78. }
79. let ok = true
80. for (f of mine) { ok = followsTable.delete(f.id) > 0 && ok }
81. return ok
82. }