tracker

3.3 KB

1. // lib/util.hl — small helpers every topic shares (env, paths, dates, lists, text), each ONCE (mission 028: they were copied
2. // into follows, users, shows, watches, tmdbsync, catalog, franchises, details, people, merge, search, shortids).
3. import { env } from 'hl:proc'
4. import { now, timestamp } from 'hl:time'
5. import { randomBytes } from 'hl:crypto'
7. // an environment value, trimmed — `fallback` when it is not set or empty
8. static envOr = (&name, &fallback) => {
9. v = env(name)
10. return v != null && v.trim() != '' ? v.trim() : fallback
11. }
12. // every table and file of the app's data: TRACKER_STORAGE, else storage/mpackdb beside project.hl (relative paths resolve
13. // against the ENTRY script)
14. static storageDir = envOr('TRACKER_STORAGE', './storage/mpackdb')
15. // the image files: a title's poster (tmdb.hl syncPoster) and a person's photo (people.hl syncProfile), served by images.hl
16. static postersDir = storageDir + '/posters'
17. static profilesDir = storageDir + '/profiles'
19. // a new record id: 16 hex (self-assigned — hl:mpackdb's own generated @id can repeat within one millisecond, hybriel#113)
20. static newId = () => { return randomBytes(8, 'hex') }
21. static hexDigits = '0123456789abcdef'
23. // today as 'YYYY-MM-DD' (UTC, like the rest of the app — hl:time has no time zones)
24. static todayStr = () => { return timestamp(now()).slice(0, 10) }
25. // the day `days` from today ('YYYY-MM-DD', UTC; negative = before)
26. static dayStr = (days) => { return timestamp(now() + days * 86400000).slice(0, 10) }
27. // a stored date ('YYYY-MM-DD…') or '' when it is none
28. static dateOr = (&v) => { return v != null && hlTypeName(v) == 'String' && v.length >= 4 ? v : '' }
30. // a text value or null when it is none or only white space (the value itself, not trimmed)
31. static textOr = (&v) => { return v != null && hlTypeName(v) == 'String' && v.trim() != '' ? v : null }
32. // an id (a string or a number) that is there
33. static hasId = (&v) => { return v != null && ('' + v).trim() != '' }
35. static listOr = (&v) => { return v == null ? [] : v }
36. static countOfList = (&list) => {
37. if (list == null) { return 0 }
38. n = list.length
39. return n == null ? 0 : n
40. }
41. static firstOf = (&list) => { return countOfList(list) > 0 ? list[0] : null }
43. // ---- sorting, hand-written (no list sort(), hybriel#1): a bottom-up merge sort of { key, … }, newest (largest) key first,
44. // stable — the public lists (catalog.hl), a person's filmography and /people (people.hl). Tracker#37 (mission 032): it starts
45. // from the runs that are already in order (not from single entries) — same result, but a list that is nearly sorted (/people:
46. // 105k people, 3 runs) costs one merge pass: 0.15 s instead of 1.6 s on the live copy
47. static mergeDesc = (&a, &b) => {
48. out = []
49. let i = 0
50. let j = 0
51. while (i < a.length && j < b.length) {
52. if (b[j].key > a[i].key) { out.push(b[j]) j = j + 1 } else { out.push(a[i]) i = i + 1 }
53. }
54. while (i < a.length) { out.push(a[i]) i = i + 1 }
55. while (j < b.length) { out.push(b[j]) j = j + 1 }
56. return out
57. }
58. static sortDesc = (&list) => {
59. if (list.length == 0) { return [] }
60. let runs = []
61. let run = []
62. for (x of list) {
63. if (run.length > 0 && x.key > run[run.length - 1].key) { runs.push(run) run = [] }
64. run.push(x)
65. }
66. runs.push(run)
67. while (runs.length > 1) {
68. let next = []
69. let k = 0
70. while (k + 1 < runs.length) { next.push(mergeDesc(runs[k], runs[k + 1])) k = k + 2 }
71. if (k < runs.length) { next.push(runs[k]) }
72. runs = next
73. }
74. return runs[0]
75. }