antcolony

11.9 KB

1. // next.hl — `next`: which ticket gets a worker next, and why the others do not.
2. //
3. // Rules (docs/scheduler-agent.md §2 + "Decided 2026-09-24"):
4. // eligible = state `open` AND the project has metadata (registry) AND that metadata names a
5. // concept AND does not say `"workers": false` (mission 016: such a project is never
6. // eligible, listed with that reason, no creator question); v0 priority = the OLDEST eligible (stored createdMs, ties: lower number).
7. // `in progress` = leased: a worker (today: the architect's mission) has it — v0 has no agent,
8. // so the lease IS the state; `on hold` = held. Both are listed, never picked.
9. // `awaiting creator` / `confirmed` / `rejected` are only counted (the inbox / done).
10. // Mission 022 (relations.hl): an open ticket blocked by any ticket that is not `confirmed`, or with
11. // children (a parent; the scheduler's own creator-question children do not count) is listed,
12. // not eligible; a `rejected` ticket whose last rejection is newer than the last colony session
13. // is a candidate again (same rules, marked "REJECTED … → rework"), other rejected ones are counted.
14. // Mission 030: a QUESTION ticket (relations.hl isCreatorQuestion: source `colony…:question…` or subject `Question…`) is
15. // never work, in no state: open / rejected / on hold → listed "a question for the creator — the librarian
16. // takes its answer (<state>) — never work", BEFORE the rework-on-rejection logic (the pre-030 live run
17. // reworked rejected questions); awaiting creator / confirmed are counted as before.
18. // Mission 027: an `in progress` ticket whose report waits for the deploy (lease.hl readyOf) is listed as "built —
19. // waiting for the deploy" (`./colony ready` lists only those).
20. // With --post, every project that has open tickets but no metadata / no concept gets ONE
21. // question in the creator's inbox (idempotent: source `colony:no-metadata:<p>` / `colony:no-concept:<p>`).
22. import { loadRegistry } from './registry.hl'
23. import { allTickets, readToken, fileQuestion, pageUrl, getJson, ticketPath } from './tickets.hl'
24. import { relationsOf, blockReason, rejectionOf, questionWhy, startsInLastHour } from './relations.hl'
25. import { sortByNumber, NL } from './util.hl'
26. import { readyOf } from './lease.hl'
27. import { env } from 'hl:proc'
28. import { now } from 'hl:time'
29. import { prioOf, prioWord } from './keywords.hl'
31. static refOf = (t) => { return t.project + t.ref }
33. // the rules over every ticket → { reg, eligible (oldest first), notEligible, noMeta, noConcept, counts } or { error }
34. static survey = () => {
35. let reg = loadRegistry()
36. for (e of reg.errors) { console.log('registry: ' + e) }
37. let all = allTickets()
38. if (all.error != null) { return { error = all.error } }
39. // mission 022: every row by id — a child's `source` tells a creator question from real work
40. let byId = {}
41. for (t of all.tickets) { byId[t.id] = t }
42. let lookup = (id) => { return byId[id] }
43. let eligible = []
44. let notEligible = []
45. let noMeta = {}
46. let noConcept = {}
47. let counts = { awaiting = 0 confirmed = 0 rejected = 0 }
48. for (t of all.tickets) {
49. let m = reg.projects[t.project]
50. // mission 030: a question ticket is never work, in no state — checked BEFORE the rework-on-rejection logic
51. let qwhy = questionWhy(t)
52. let qListed = qwhy != null && (t.state == 'open' || t.state == 'rejected' || t.state == 'on hold')
53. let candidate = t.state == 'open' && qwhy == null
54. let pre = ''
55. if (t.state == 'rejected' && qwhy == null) {
56. // mission 022 "Rejections are work": eligible again when the last rejection is newer than the last colony session
57. let d = getJson(ticketPath(t.project, t.number))
58. if (d.status != 200) {
59. notEligible.push({ t = t why = 'rejected, but its history is unreadable (' + d.status + ')' })
60. } else {
61. let rj = rejectionOf(d.json.events)
62. if (rj.eligible) {
63. candidate = true
64. t.rejectedNote = 'REJECTED by the creator ' + rj.rejection.when + ' (newer than the last colony session) → rework'
65. pre = 'rejected by the creator ' + rj.rejection.when + ', but '
66. } else {
67. counts.rejected = counts.rejected + 1
68. }
69. }
70. }
71. if (qListed) {
72. notEligible.push({ t = t why = qwhy + ' (' + t.state + ') — never work' })
73. } else if (candidate) {
74. if (m == null) {
75. notEligible.push({ t = t why = pre + 'project ' + t.project + ' has no metadata (' + reg.dir + '/' + t.project + '.json) → question for the creator' })
76. if (noMeta[t.project] == null) { noMeta[t.project] = [] }
77. noMeta[t.project].push(t)
78. } else if (!m.takesWorkers) {
79. notEligible.push({ t = t why = pre + 'project ' + t.project + ' takes no workers ("workers": false in ' + reg.dir + '/' + t.project + '.json)' })
80. } else if (!m.hasConcept) {
81. notEligible.push({ t = t why = pre + 'project ' + t.project + ' has no concept → question for the creator' })
82. if (noConcept[t.project] == null) { noConcept[t.project] = [] }
83. noConcept[t.project].push(t)
84. } else {
85. // mission 022: blocked by a ticket that is not confirmed / a parent → not work
86. let why = blockReason(relationsOf(t, lookup), pre != '')
87. if (why != null) { notEligible.push({ t = t why = pre + why }) } else { eligible.push(t) }
88. }
89. } else if (t.state == 'in progress') {
90. // mission 027: built on a project with a live site, waiting for the deploy (lease.hl readyOf)
91. let d = getJson(ticketPath(t.project, t.number))
92. let rs = d.status == 200 ? readyOf(d.json.events) : null
93. if (rs != null) {
94. t.readySession = rs
95. notEligible.push({ t = t why = 'built — waiting for the deploy (session ' + rs + '; ./colony ready)' })
96. } else {
97. // mission 030: a question leased by a pre-030 session — listed; `run` never resumes it (daemon.hl)
98. notEligible.push({ t = t why = 'leased: in progress (a worker has it)' + (qwhy == null ? '' : ' — ' + qwhy + ': never resumed') })
99. }
100. } else if (t.state == 'on hold') {
101. notEligible.push({ t = t why = 'on hold' })
102. } else if (t.state == 'awaiting creator' || t.state == 'answered') {
103. // 'answered' = tickets sets it after the creator commented on an awaiting-creator ticket: still the creator's, not the colony's
104. counts.awaiting = counts.awaiting + 1
105. } else if (t.state == 'confirmed') {
106. counts.confirmed = counts.confirmed + 1
107. }
108. }
109. // antcolony#17: the creator's `/prio` (last valid one in the comments; normal = 0) — read for every eligible ticket
110. // antcolony#30: safety net — more than COLONY_MAX_STARTS_PER_HOUR (default 4) sessions started on one ticket within the
111. // last hour → not eligible (whatever the reason it keeps coming back); it is eligible again once the hour has passed
112. let cap = toNumber(env('COLONY_MAX_STARTS_PER_HOUR') == null || env('COLONY_MAX_STARTS_PER_HOUR') == '' ? '4' : env('COLONY_MAX_STARTS_PER_HOUR'))
113. let kept = []
114. for (t of eligible) {
115. let d = getJson(ticketPath(t.project, t.number))
116. t.prio = d.status == 200 ? prioOf(d.json.events, t.project) : 0
117. let n = d.status == 200 ? startsInLastHour(d.json.events, now()) : 0
118. if (cap > 0 && n >= cap) {
119. notEligible.push({ t = t why = 'restart limit: ' + n + ' sessions started within the last hour (max ' + cap + ', COLONY_MAX_STARTS_PER_HOUR)' })
120. } else { kept.push(t) }
121. }
122. eligible = kept
123. // highest priority first, then oldest; the same ms → the lower number
124. // (three stable passes: a combined key would pass 2^53)
125. sortByNumber(eligible, (t) => { return t.number })
126. sortByNumber(eligible, (t) => { return t.createdMs })
127. sortByNumber(eligible, (t) => { return 0 - t.prio })
128. sortByNumber(notEligible, (e) => { return e.t.number })
129. sortByNumber(notEligible, (e) => { return e.t.createdMs })
130. return { reg = reg eligible = eligible notEligible = notEligible noMeta = noMeta noConcept = noConcept counts = counts }
131. }
133. // `cycle` (mission 019): the oldest eligible ticket whose dev folder is on `host` → { ticket } (null: none) or { error }
134. static pickFor = (host) => {
135. let sv = survey()
136. if (sv.error != null) { return { error = 'next: ' + sv.error } }
137. for (t of sv.eligible) {
138. let m = sv.reg.projects[t.project]
139. if (m.dev != null && m.dev.host != null && m.dev.host.toLowerCase() == host.toLowerCase()) { return { ticket = t } }
140. console.log('cycle: next — skipping ' + refOf(t) + ' (eligible, but its dev folder is on ' + (m.dev == null ? '?' : m.dev.host) + ', this host is ' + host + ')')
141. }
142. return { ticket = null }
143. }
145. static runNext = (argv) => {
146. let post = argv.includes('--post')
147. let sv = survey()
148. if (sv.error != null) {
149. console.log('next: ' + sv.error)
150. return false
151. }
152. let eligible = sv.eligible
153. let notEligible = sv.notEligible
154. let noMeta = sv.noMeta
155. let noConcept = sv.noConcept
156. let counts = sv.counts
158. if (eligible.length == 0) {
159. console.log('NEXT: nothing — no eligible open ticket')
160. } else {
161. let n = eligible[0]
162. console.log('NEXT: ' + refOf(n) + ' "' + n.subject + '" — ' + (n.prio != 0 || eligible[eligible.length - 1].prio != 0 ? 'the highest priority (' + prioWord(n.prio) + '), then the oldest, eligible open ticket' : 'the oldest eligible open ticket') + ' (opened ' + n.created + ', ' + eligible.length + ' eligible) ' + pageUrl(n) + (n.rejectedNote != null ? ' — ' + n.rejectedNote : ''))
163. }
164. if (eligible.length > 1) {
165. console.log('')
166. console.log('Eligible, waiting (highest priority, then oldest first):')
167. let i = 1
168. while (i < eligible.length) {
169. let t = eligible[i]
170. console.log(' ' + refOf(t) + ' "' + t.subject + '" — opened ' + t.created + (t.rejectedNote != null ? ' — ' + t.rejectedNote : ''))
171. i = i + 1
172. }
173. }
174. if (notEligible.length > 0) {
175. console.log('')
176. console.log('Not eligible:')
177. for (e of notEligible) { console.log(' ' + refOf(e.t) + ' "' + e.t.subject + '" — ' + e.why) }
178. }
179. console.log('')
180. console.log('Not considered: ' + counts.awaiting + ' awaiting creator (inbox), ' + counts.confirmed + ' confirmed, ' + counts.rejected + ' rejected' + (counts.rejected > 0 ? ' (no rejection newer than the last colony session)' : ''))
182. let qs = []
183. // mission 023: creator-readable — subject "Question: …", ≤ 5 short lines, what to do first
184. for (p of noMeta.keys()) { qs.push({ source = 'colony:no-metadata:' + p subject = 'Question: project ' + p + ' is not set up for the colony yet — where does its code live?' tickets = noMeta[p] first = 'No worker starts on project ' + p + ': the colony does not know where its code lives.' todo = 'tell the architect where the code lives and what it depends on — the architect sets it up.' }) }
185. for (p of noConcept.keys()) { qs.push({ source = 'colony:no-concept:' + p subject = 'Question: project ' + p + ' has no written concept yet — can we write one?' tickets = noConcept[p] first = 'No worker starts on project ' + p + ' until it has a written concept.' todo = 'write the concept with the architect, then answer here.' }) }
186. if (qs.length == 0) { return true }
187. console.log('')
188. if (!post) {
189. console.log('Questions for the creator (' + qs.length + '; `next --post` files them in the inbox):')
190. for (q of qs) { console.log(' ' + q.subject) }
191. return true
192. }
193. let tk = readToken()
194. if (tk.error != null) {
195. console.log('next --post: ' + tk.error)
196. return false
197. }
198. console.log('Questions for the creator:')
199. for (q of qs) {
200. let links = []
201. let k = 0
202. while (k < q.tickets.length && k < 3) {
203. let t = q.tickets[k]
204. links.push('[' + t.project + ' ' + t.ref + '](' + pageUrl(t) + ')')
205. k = k + 1
206. }
207. let waiting = links.join(', ') + (q.tickets.length > 3 ? ' and ' + (q.tickets.length - 3) + ' more' : '')
208. let summary = q.first + NL + NL + '**What to do:** ' + q.todo + NL + NL + '- Waiting: ' + waiting
209. let r = fileQuestion(tk.token, q.source, q.subject, summary, null)
210. if (r.error != null) { console.log(' FAILED ' + q.subject + ': ' + r.error) }
211. else if (r.created) { console.log(' FILED ' + r.ticket.project + r.ticket.ref + ' ' + q.subject + ' ' + pageUrl(r.ticket)) }
212. else { console.log(' HAVE ' + r.ticket.project + r.ticket.ref + ' ' + q.subject + ' (already asked, nothing written)') }
213. }
214. return true
215. }