sanspie
1030dc9a43
ci-platforms / build (amd64, darwin, macos-15-intel) (push) Skipped
ci-platforms / build (amd64, windows, windows-2022) (push) Skipped
ci-platforms / build (arm64, darwin, macos-15) (push) Skipped
ci / checks (push) Successful in 4m58s
ci / build (amd64, linux, ubuntu-24.04) (push) Successful in 27m47s
ci / release (push) Successful in 11m57s
95 lines
2.5 KiB
Go
95 lines
2.5 KiB
Go
package run
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/hex"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"aego/app/agent"
|
|
"aego/core/log"
|
|
"aego/core/rewind"
|
|
"aego/engine/recorder"
|
|
"aego/modules/audio"
|
|
"aego/modules/camera"
|
|
"aego/modules/gameplay"
|
|
"aego/project"
|
|
"aego/sdk"
|
|
)
|
|
|
|
const maxRunLog = 200
|
|
|
|
func AgentRunner(mods ...sdk.Module) agent.Runner {
|
|
return func(p *project.Project, r agent.RunRequest) (agent.RunReport, error) {
|
|
var buf bytes.Buffer
|
|
lg := log.New(log.NewTextSink(&buf))
|
|
lg.SetLevel(log.Warn)
|
|
frames, seed := r.Frames, r.Seed
|
|
if frames <= 0 {
|
|
frames = 120
|
|
}
|
|
if seed == 0 {
|
|
seed = 1
|
|
}
|
|
a, err := Open(p, Config{Headless: true, FrameTime: defaultDetStep, Seed: seed, ScenePath: r.Scene, Logger: lg, NoProfile: true}, mods...)
|
|
if err != nil {
|
|
return agent.RunReport{Log: logLines(buf.String())}, err
|
|
}
|
|
rep := agent.RunReport{}
|
|
driver := a.Driver()
|
|
for rep.Frames < frames {
|
|
if !a.Engine.Step(driver) {
|
|
rep.Error = "the game stopped at frame " + strconv.Itoa(rep.Frames+1)
|
|
if err := a.Engine.Err(); err != nil {
|
|
rep.Error += ": " + err.Error()
|
|
}
|
|
break
|
|
}
|
|
rep.Frames++
|
|
}
|
|
sum, _, _ := WorldHash(a.Engine.MainWorld(), rewind.NewHasher())
|
|
rep.Hash = hex.EncodeToString(sum[:])
|
|
rep.Counters = counters(a)
|
|
a.Close()
|
|
rep.Log = logLines(buf.String())
|
|
return rep, nil
|
|
}
|
|
}
|
|
|
|
func logLines(s string) []string {
|
|
var out []string
|
|
for _, l := range strings.Split(strings.TrimSpace(s), "\n") {
|
|
if l = strings.TrimSpace(l); l != "" {
|
|
out = append(out, l)
|
|
}
|
|
}
|
|
if len(out) > maxRunLog {
|
|
out = append(out[:maxRunLog], "…")
|
|
}
|
|
return out
|
|
}
|
|
|
|
// counters sums what the modules counted during the run, for scene run and run_headless.
|
|
func counters(a *App) map[string]uint64 {
|
|
out := map[string]uint64{}
|
|
w := a.Engine.MainWorld()
|
|
if s := gameplay.Of(w); s != nil {
|
|
st := s.Stats()
|
|
out["gameplay.steps"], out["gameplay.casts"], out["gameplay.hits"] = st.Steps, st.Casts, st.Hits
|
|
out["gameplay.deaths"], out["gameplay.respawns"], out["gameplay.pickups"] = st.Deaths, st.Respawns, st.Pickups
|
|
}
|
|
if c := camera.Of(w); c != nil {
|
|
c.Outputs(func(camera.OutputInfo) { out["camera.outputs"]++ })
|
|
}
|
|
if m := audio.ModuleOf(a.Engine); m != nil {
|
|
c, st := m.Counts(), m.Stats()
|
|
out["audio.finished"], out["audio.stolen"], out["audio.rejected"], out["audio.starved"] = c.Finished, c.Stolen, c.Rejected, c.Starved
|
|
out["audio.underruns"] = st.Underruns
|
|
}
|
|
if r := w.Recorder; r != nil {
|
|
counts := r.Counts()
|
|
out["events.audio"], out["events.gameplay"] = counts[recorder.Audio], counts[recorder.Gameplay]
|
|
}
|
|
return out
|
|
}
|