X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/a606686934b4028c29dca8e9dae6b2e188cee9c5..522d7fd117285e4e4ce3ea5ec9b5a1722521b681:/rebuild.go?ds=sidebyside diff --git a/rebuild.go b/rebuild.go index 8522d70..52c0861 100644 --- a/rebuild.go +++ b/rebuild.go @@ -56,6 +56,7 @@ func rebuild(ctx context.Context, agent *Agent, added []DatedMessage, client *Mo } client.LimitCalls(buildCallLimit) + run := BuildRun{ memory: memory, client: client, @@ -136,6 +137,7 @@ func rebuildIdle(root string) error { } var work SubagentWorkFile + err = json.Unmarshal(data, &work) if err != nil { return fmt.Errorf("decode running subagents: %w", err) @@ -157,7 +159,9 @@ func rebuildReadLog(ctx context.Context, root string) ([]DatedMessage, error) { } slices.Sort(paths) + var entries []DatedMessage + for _, path := range paths { var day uint32 @@ -168,6 +172,7 @@ func rebuildReadLog(ctx context.Context, root string) ([]DatedMessage, error) { 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) @@ -215,6 +220,7 @@ func rebuildMerge(old, added []DatedMessage) ([]DatedMessage, error) { } var date time.Time + date, err = time.Parse(time.RFC3339Nano, entry.Date) if err != nil { return nil, fmt.Errorf("parse merge date: %w", err) @@ -263,6 +269,7 @@ func rebuildCopy(source, target string) error { } case entry.Type().IsRegular(): var data []byte + data, err = os.ReadFile(path) if err != nil { return fmt.Errorf("read agent file: %w", err)