antcolony

8.4 KB

1. // status.hl — the project status and the daily summary, built from the tickets (ticket antcolony#19; concept README
2. // "STATUS is generated from tickets, not written by models", docs/scheduler-agent.md §2 timer "daily digest"). Code only, no model.
3. // ./colony status [--write] → per project: how many tickets in which state + what waits for the creator;
4. // --write also writes status/STATUS.md (COLONY_STATUS_DIR)
5. // ./colony digest [--post] → the daily summary: what waits for the creator. Dry run prints it; --post files it as
6. // ONE ticket in the inbox project (source `colony:digest:<UTC day>` = once per day, also
7. // after a restart) and writes status/STATUS.md. `run` does it once a day after
8. // COLONY_DIGEST_HOUR (UTC, default 7; `off` = never).
9. // What waits for the creator = tickets in `awaiting creator` (built work to check, or a question to answer). The digest
10. // tickets themselves are left out (source `colony:digest:`). Names are the scheduler's vocabulary (tickets.hl reads the
11. // new server names as the old ones).
12. import { writeFile, mkDir, exists } from 'hl:fs'
13. import { timestamp, now } from 'hl:time'
14. import { allTickets, readToken, fileQuestionIn, inboxProject, pageUrl, setting } from './tickets.hl'
15. import { isWholeNumber } from './claude.hl'
16. import { isCreatorQuestion } from './relations.hl'
17. import { NL, fromCwd, sortStrings } from './util.hl'
19. static DIGEST_SOURCE = 'colony:digest:'
20. static STATES = ['open', 'in progress', 'awaiting creator', 'on hold', 'rejected', 'answered', 'confirmed']
21. static SHOWN = 8
23. static isDigest = (t) => { return t.source != null && t.source.startsWith(DIGEST_SOURCE) }
25. static dayOf = (ms) => { return timestamp(ms).slice(0, 10) }
26. static hourOf = (ms) => { return toNumber(timestamp(ms).slice(11, 13)) }
28. static statusDir = () => { return fromCwd(setting('COLONY_STATUS_DIR', 'status')) }
30. // tickets by project (digest tickets left out) → { names: sorted project names, by: { project: { state: [rows] } } }
31. static group = (rows) => {
32. let by = {}
33. let names = []
34. for (t of rows) {
35. if (!isDigest(t)) {
36. if (by[t.project] == null) { by[t.project] = {} names.push(t.project) }
37. if (by[t.project][t.state] == null) { by[t.project][t.state] = [] }
38. by[t.project][t.state].push(t)
39. }
40. }
41. return { names = sortStrings(names) by = by }
42. }
44. static bullet = (t) => { return '- ' + t.project + t.ref + ' — ' + t.subject + ' — ' + pageUrl(t) }
46. // the tickets waiting for the creator, newest first is not needed: oldest first (they wait longest)
47. static waiting = (g) => {
48. let questions = []
49. let built = []
50. for (p of g.names) {
51. let l = g.by[p]['awaiting creator']
52. if (l != null) {
53. for (t of l) { if (isCreatorQuestion(t)) { questions.push(t) } else { built.push(t) } }
54. }
55. }
56. return { questions = questions built = built }
57. }
59. static listLines = (title, rows) => {
60. let out = []
61. if (rows.length == 0) { return out }
62. out.push(title + ' (' + rows.length + ')')
63. let n = 0
64. for (t of rows) {
65. if (n < SHOWN) { out.push(bullet(t)) }
66. n = n + 1
67. }
68. if (rows.length > SHOWN) { out.push('- … and ' + (rows.length - SHOWN) + ' more') }
69. return out
70. }
72. // `alpha 3, beta 1` — how many of the rows belong to which project
73. static perProject = (rows) => {
74. let n = {}
75. let names = []
76. for (t of rows) {
77. if (n[t.project] == null) { n[t.project] = 0 names.push(t.project) }
78. n[t.project] = n[t.project] + 1
79. }
80. let parts = []
81. for (p of sortStrings(names)) { parts.push(p + ' ' + n[p]) }
82. return parts.join(', ')
83. }
85. // the daily summary → { text, count } (count = how many tickets wait for the creator)
86. static digestText = (rows, ms) => {
87. let g = group(rows)
88. let w = waiting(g)
89. let count = w.questions.length + w.built.length
90. let out = []
91. if (count == 0) {
92. out.push('Nothing waits for you today.')
93. } else {
94. out.push(count + ' ' + (count == 1 ? 'ticket waits' : 'tickets wait') + ' for you.')
95. out.push('')
96. for (l of listLines('Questions to answer', w.questions)) { out.push(l) }
97. if (w.questions.length > 0 && w.built.length > 0) { out.push('') }
98. for (l of listLines('Built, to check', w.built)) { out.push(l) }
99. if (w.built.length > SHOWN) { out.push('By project: ' + perProject(w.built)) }
100. }
101. let working = 0
102. let queued = 0
103. for (p of g.names) {
104. let a = g.by[p]['in progress']
105. let o = g.by[p]['open']
106. if (a != null) { working = working + a.length }
107. if (o != null) { queued = queued + o.length }
108. }
109. out.push('')
110. out.push('The colony is working on ' + working + ' and has ' + queued + ' more in the queue.')
111. return { text = out.join(NL) count = count }
112. }
114. // the status of every project → Markdown (generated, never edited by hand)
115. static statusText = (rows, ms) => {
116. let g = group(rows)
117. let out = []
118. out.push('# Status')
119. out.push('')
120. out.push('Generated from the tickets at ' + timestamp(ms).slice(0, 19) + 'Z — do not edit by hand.')
121. out.push('')
122. out.push('| project | open | in progress | awaiting creator | on hold | rejected | confirmed |')
123. out.push('|---|---|---|---|---|---|---|')
124. for (p of g.names) {
125. let cells = []
126. for (s of ['open', 'in progress', 'awaiting creator', 'on hold', 'rejected', 'confirmed']) {
127. let l = g.by[p][s]
128. let n = l == null ? 0 : l.length
129. if (s == 'awaiting creator' && g.by[p]['answered'] != null) { n = n + g.by[p]['answered'].length }
130. cells.push('' + n)
131. }
132. out.push('| ' + p + ' | ' + cells.join(' | ') + ' |')
133. }
134. out.push('')
135. out.push('## What waits for the creator')
136. out.push('')
137. out.push(digestText(rows, ms).text)
138. for (p of g.names) {
139. let a = g.by[p]['in progress']
140. if (a != null) {
141. out.push('')
142. for (l of listLines('Being worked on in ' + p, a)) { out.push(l) }
143. }
144. }
145. return out.join(NL) + NL
146. }
148. static writeStatusFile = (rows, ms) => {
149. let dir = statusDir()
150. if (!exists(dir)) { mkDir(dir, 493) }
151. writeFile(dir + '/STATUS.md', statusText(rows, ms), 420)
152. return dir + '/STATUS.md'
153. }
155. // file the summary of `day` in the inbox (idempotent by source) → { ticket, created, text, count } or { error }
156. static postDigest = (rows, ms, token) => {
157. let day = dayOf(ms)
158. let d = digestText(rows, ms)
159. let subject = 'Daily summary ' + day + (d.count == 0 ? ' — nothing waits for you' : ' — ' + d.count + (d.count == 1 ? ' ticket waits' : ' tickets wait') + ' for you')
160. let r = fileQuestionIn(token, inboxProject(), DIGEST_SOURCE + day, subject, d.text + NL + NL + 'colony-digest: ' + day, null)
161. if (r.error != null) { return r }
162. return { ticket = r.ticket created = r.created text = d.text count = d.count }
163. }
165. // the daemon: once a day after the digest hour. `st` = { day } remembers the last day done in this process.
166. // Returns a log line or null.
167. static digestTick = (st, ms) => {
168. let h = setting('COLONY_DIGEST_HOUR', '7')
169. if (h == 'off') { return null }
170. if (!isWholeNumber(h) || toNumber(h) > 23) { return null }
171. let hour = toNumber(h)
172. if (st.day == dayOf(ms) || hourOf(ms) < hour) { return null }
173. let a = allTickets()
174. if (a.error != null) { return 'digest: ' + a.error }
175. let tk = readToken()
176. if (tk.error != null) { return 'digest: ' + tk.error }
177. let r = postDigest(a.tickets, ms, tk.token)
178. if (r.error != null) { return 'digest: ' + r.error }
179. writeStatusFile(a.tickets, ms)
180. st.day = dayOf(ms)
181. return 'DIGEST ' + dayOf(ms) + ' — ' + r.count + ' waiting · ' + (r.created ? 'filed ' : 'already filed ') + r.ticket.project + r.ticket.ref
182. }
184. static runStatus = (argv) => {
185. let a = allTickets()
186. if (a.error != null) { console.log('status: ' + a.error) return false }
187. let ms = now()
188. console.log(statusText(a.tickets, ms))
189. if (argv.includes('--write')) { console.log('written: ' + writeStatusFile(a.tickets, ms)) }
190. return true
191. }
193. static runDigest = (argv) => {
194. let a = allTickets()
195. if (a.error != null) { console.log('digest: ' + a.error) return false }
196. let ms = now()
197. if (!argv.includes('--post')) {
198. console.log('Daily summary ' + dayOf(ms) + ' (dry run; --post files it in ' + inboxProject() + ')')
199. console.log('')
200. console.log(digestText(a.tickets, ms).text)
201. return true
202. }
203. let tk = readToken()
204. if (tk.error != null) { console.log('digest: ' + tk.error) return false }
205. let r = postDigest(a.tickets, ms, tk.token)
206. if (r.error != null) { console.log('digest: ' + r.error) return false }
207. console.log(r.text)
208. console.log('')
209. console.log((r.created ? 'filed ' : 'already filed today: ') + r.ticket.project + r.ticket.ref + ' ' + pageUrl(r.ticket))
210. console.log('written: ' + writeStatusFile(a.tickets, ms))
211. return true
212. }