antcolony

8.4 KB

1. // previous.hl — mission 026 (ticket antcolony#1; the first live run, ident.worldapi.org#2, built and tested everything in
2. // a work copy, ran out of steps, and the next worker would have started over): the brief of a ticket that had an
3. // earlier colony session gets a short "Previous attempt" section — how that session ended, its result, what is still
4. // open, where its work copy is, and its report path — so the next worker CONTINUES instead of starting over.
5. //
6. // The last colony session = the last lease event in the ticket's history (`→ in progress` with `colony-lease: <S>`,
7. // also salvage's lease; v0: "session <S> started on <H>"). How it ended = the last marker of THAT session after it:
8. // `colony-report: S` (`· half done` = half done), `colony-verdict: S · fail`, `colony-run: S` (no usable report),
9. // `colony-lease-expired: S`, `colony-parked: S`. The rest comes from its run folder `runs/<S>/` on THIS host
10. // (session.json, report.json); the work copy = every `.scratch/<name>` the report names (relative → the dev folder).
11. import { env } from 'hl:proc'
12. import { exists } from 'hl:fs'
13. import { NL, readJson, fromCwd, isList, isString } from './util.hl'
14. import { isSessionStart } from './relations.hl'
16. // the runs folder (same rule as work.hl runsDir: COLONY_RUNS_DIR, else <COLONY_HOME>/runs) or null
17. static runsDirOf = () => {
18. let r = env('COLONY_RUNS_DIR')
19. if (r != null && r != '') { return fromCwd(r) }
20. let home = env('COLONY_HOME')
21. if (home == null || home == '') { return null }
22. return home + '/runs'
23. }
25. // a lease event → { session, host } or null
26. static startOf = (e) => {
27. if (!isSessionStart(e)) { return null }
28. let t = e.text
29. let i = t.indexOf('colony-lease: ')
30. if (i >= 0) {
31. let line = t.slice(i + 14)
32. let nl = line.indexOf(NL)
33. if (nl >= 0) { line = line.slice(0, nl) }
34. let parts = line.split(' · ')
35. let host = null
36. for (p of parts) { if (p.startsWith('host ')) { host = p.slice(5) } }
37. return { session = parts[0].trim() host = host }
38. }
39. // v0: "session <S> started on <H>"
40. let j = t.indexOf(' started on ')
41. let rest = t.slice(j + 12)
42. let nl2 = rest.indexOf(NL)
43. return { session = t.slice(8, j).trim() host = (nl2 >= 0 ? rest.slice(0, nl2) : rest).trim() }
44. }
46. // how session S ended, from the events after its start → text
47. static endingOf = (events, fromSeq, s) => {
48. let ending = 'no result in the ticket (it may still run, or it crashed)'
49. for (e of events) {
50. if (e.seq > fromSeq && e.text != null) {
51. let t = e.text
52. if (e.kind == 'comment' && t.includes('colony-report: ' + s + ' ·')) { ending = t.includes(' · half done') ? 'HALF DONE — its report said the work is not complete' : t.includes(' · ready to deploy') ? 'built, its report was posted — waiting for the deploy (mission 027)' : 'its report was posted (ready for the creator to test)' }
53. else if (e.kind == 'comment' && t.includes('colony-deployed: ' + s + ' ·')) { ending = 'built and deployed — ready for the creator to test' }
54. else if (e.kind == 'comment' && t.includes('colony-verdict: ' + s + ' · fail')) { ending = 'its report FAILED the check (see that comment in the history)' }
55. else if (t.includes('colony-run: ' + s + ' ·')) { ending = 'it stopped without a usable report (out of steps / time, or its report was incomplete)' }
56. else if (t.includes('colony-lease-expired: ' + s + ' ·')) { ending = 'it stopped answering (the lease expired)' }
57. else if (t.includes('colony-parked: ' + s + ' ·')) { ending = 'it was paused (usage limit / scheduler stopped)' }
58. }
59. }
60. return ending
61. }
63. static oneLineOf = (s, n) => {
64. let t = s.trim()
65. let nl = t.indexOf(NL)
66. if (nl > 0) { t = t.slice(0, nl).trim() }
67. if (t.length > n) { t = t.slice(0, n - 1).trim() + '…' }
68. return t
69. }
71. // characters that end a path inside prose: space, tab, newline, quotes, backtick, brackets, comma, colon, semicolon, <, >, =
72. static isDelim = (c) => {
73. return c == 32 || c == 9 || c == 10 || c == 13 || c == 34 || c == 39 || c == 96 || c == 40 || c == 41 || c == 44 || c == 58 || c == 59 || c == 91 || c == 93 || c == 60 || c == 62 || c == 61 || c == 123 || c == 125
74. }
76. // every `.scratch/<name>` named in the texts (the work copies), absolute (relative ones → `folder`), nested ones dropped
77. static scratchPaths = (texts, folder) => {
78. let out = []
79. for (t of texts) {
80. let base = 0
81. let rest = t
82. let i = rest.indexOf('.scratch/')
83. while (i >= 0) {
84. let at = base + i
85. let a = at
86. while (a > 0 && !isDelim(t.charCodeAt(a - 1))) { a = a - 1 }
87. let b = at + 9
88. while (b < t.length && !isDelim(t.charCodeAt(b)) && t.charCodeAt(b) != 47) { b = b + 1 }
89. if (b > at + 9) {
90. let p = t.slice(a, b)
91. // a path at the end of a sentence: `… in .scratch/dev-btn.` → without the dot / comma
92. while (p.endsWith('.') || p.endsWith(',')) { p = p.slice(0, p.length - 1) }
93. if (p.startsWith('./')) { p = p.slice(2) }
94. if (!p.startsWith('/')) { p = folder + '/' + p }
95. let nested = false
96. for (q of out) { if (p == q || p.startsWith(q + '/')) { nested = true } }
97. if (!nested) { out.push(p) }
98. }
99. base = b
100. rest = t.slice(b)
101. i = rest.indexOf('.scratch/')
102. }
103. }
104. return out
105. }
107. // the texts of a report that may name its work copy
108. static reportTexts = (r) => {
109. let out = []
110. for (k of ['open' 'done']) { if (isList(r[k])) { for (x of r[k]) { if (isString(x)) { out.push(x) } } } }
111. if (isList(r.verified)) { for (v of r.verified) { if (isString(v.command)) { out.push(v.command) } } }
112. if (isList(r.running)) { for (x of r.running) { if (isString(x.log)) { out.push(x.log) } } }
113. if (isString(r.result)) { out.push(r.result) }
114. return out
115. }
117. // the brief's "Previous attempt" section (list of lines; [] when the ticket never had a colony session).
118. // folder = the project's dev folder (for relative work-copy paths)
119. static previousLines = (events, folder) => {
120. let last = null
121. let lastEv = null
122. let count = 0
123. let seen = []
124. for (e of events) {
125. let st = startOf(e)
126. if (st != null) {
127. last = st
128. lastEv = e
129. if (!seen.includes(st.session)) {
130. seen.push(st.session)
131. count = count + 1
132. }
133. }
134. }
135. if (last == null) { return [] }
136. let s = last.session
137. let o = []
138. o.push('## Previous attempt — continue it, do not start over')
139. o.push('- Session `' + s + '` (started ' + lastEv.when + ' on ' + last.host + (count > 1 ? '; ' + count + ' colony sessions on this ticket so far' : '') + '): ' + endingOf(events, lastEv.seq, s) + '.')
140. let runs = runsDirOf()
141. let dir = runs == null ? null : runs + '/' + s
142. if (dir == null || !exists(dir + '/session.json')) {
143. o.push('- Its run files: `' + last.host + ':runs/' + s + '/` of the scheduler — not on this host, so nothing more is known here. Look in the dev folder (e.g. `.scratch/`) for its work.')
144. } else {
145. let sj = readJson(dir + '/session.json')
146. let meta = sj.error == null ? sj.value : {}
147. let f = meta.folder == null ? folder : meta.folder
148. let rj = exists(dir + '/report.json') ? readJson(dir + '/report.json') : { error = 'no report.json' }
149. if (rj.error == null) {
150. let r = rj.value
151. o.push('- Its result: ' + (isString(r.result) ? oneLineOf(r.result, 200) : '_(none)_') + (r.complete == false ? ' _(not complete)_' : ''))
152. if (isList(r.open) && r.open.length > 0) {
153. o.push('- Still open (from its report):')
154. let k = 0
155. while (k < r.open.length && k < 5) {
156. if (isString(r.open[k])) { o.push(' - ' + oneLineOf(r.open[k], 200)) }
157. k = k + 1
158. }
159. if (r.open.length > 5) { o.push(' - … and ' + (r.open.length - 5) + ' more in the report') }
160. }
161. let wc = scratchPaths(reportTexts(r), f)
162. if (wc.length > 0) {
163. let shown = []
164. let k2 = 0
165. while (k2 < wc.length && k2 < 4) {
166. shown.push('`' + wc[k2] + '`')
167. k2 = k2 + 1
168. }
169. o.push('- Its work copy: ' + shown.join(', ') + ' — check what is there before you change anything.')
170. } else {
171. o.push('- Its work copy: its report names none (no `.scratch/…`) — it worked in `' + f + '` directly, or look in its session.')
172. }
173. o.push('- Its report: `' + dir + '/report.json` (the whole run: `' + dir + '/` — `brief.md`, the session `claude-result*.json`' + (exists(dir + '/verdict.json') ? ', the check `verdict.json`' : '') + ').')
174. } else {
175. let why = meta.outcome == null ? 'unknown' : oneLineOf(meta.outcome, 200)
176. o.push('- It wrote no usable report (' + why + ').')
177. o.push('- Its run files: `' + dir + '/` — its session `claude-result*.json` shows what it did; its work is in `' + f + '` (look in `.scratch/` for a work copy).')
178. }
179. }
180. o.push('- Check what of it exists, then continue from there — and say in your report what you took over.')
181. return o
182. }