}
client.LimitCalls(buildCallLimit)
+
run := BuildRun{
memory: memory,
client: client,
}
var work SubagentWorkFile
+
err = json.Unmarshal(data, &work)
if err != nil {
return fmt.Errorf("decode running subagents: %w", err)
}
slices.Sort(paths)
+
var entries []DatedMessage
+
for _, path := range paths {
var day uint32
err = journalScanFile(ctx, path, day, 0, false, func(line []byte, _ Position) error {
var message Message
+
err = json.Unmarshal(line, &message)
if err != nil {
return fmt.Errorf("decode message: %w", err)
}
var date time.Time
+
date, err = time.Parse(time.RFC3339Nano, entry.Date)
if err != nil {
return nil, fmt.Errorf("parse merge date: %w", err)
}
case entry.Type().IsRegular():
var data []byte
+
data, err = os.ReadFile(path)
if err != nil {
return fmt.Errorf("read agent file: %w", err)