tracker

1.3 KB

1. // follows.hl — READ-ONLY per-user follow data (tracker.worldapi.org#5): which shows a user follows.
2. // storage/mpackdb/follows.db, migrated by tools/migrate.hl (tracker.worldapi.org#2): { show, user, at, oldId }.
3. // Kept apart from shows.hl (show data) and watches.hl (watch state) so /unwatched, /schedule and /my/shows (tickets #5/#6/#7,
4. // "reuse, don't copy") can all import the same functions.
5. import { MPackDB } from 'hl:mpackdb'
6. import { env } from 'hl:proc'
8. static envOr = (name, fallback) => {
9. let v = env(name)
10. return v != null && v.trim() != '' ? v.trim() : fallback
11. }
12. static storageDir = envOr('TRACKER_STORAGE', './storage/mpackdb')
13. static followsTable = new MPackDB(file = storageDir + '/follows.db', primaryKey = '@id', indexes = ['!oldId'])
15. // every follow record of this user ({ show, user, at, … }, `at` = epoch ms) — a linear scan (128 rows
16. // total across every user, migrated data; cheap once per page load) — no declared index on `user`.
17. // /my/shows (tracker.worldapi.org#7) needs the whole record for its follow-date order.
18. static followsOfUser = (userId) => {
19. if (userId == null) { return [] }
20. let out = []
21. for (f of followsTable.find(null, null)) { if (f.user == userId && f.show != null) { out.push(f) } }
22. return out
23. }
25. // the ids of every show this user follows
26. static followedShowIds = (userId) => {
27. let out = []
28. for (f of followsOfUser(userId)) { out.push(f.show) }
29. return out
30. }