diff options
Diffstat (limited to 'golang/pkg/agent/run.go')
| -rw-r--r-- | golang/pkg/agent/run.go | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/golang/pkg/agent/run.go b/golang/pkg/agent/run.go index 1d70be8..8767c50 100644 --- a/golang/pkg/agent/run.go +++ b/golang/pkg/agent/run.go @@ -11,7 +11,7 @@ import ( ) type agent struct { - channel chan shipError + channel chan error client *api.Client db *database.DB getenv func(string) string @@ -32,7 +32,7 @@ func Run( getenv func(string) string, ) error { agent := agent{ - channel: make(chan shipError), + channel: make(chan error), client: client, db: db, getenv: getenv, @@ -57,12 +57,11 @@ func Run( state++ case visit_all_shipyards: if err := agent.visitAllShipyards(&agent.ships[1]); err != nil { - agent.sendShipError(fmt.Errorf("agent runner returned an error on state %d: %w", state, err), &agent.ships[1]) + agent.channel <- fmt.Errorf("agent runner returned an error on state %d: %w", state, err) } state++ - return default: - agent.sendShipError(fmt.Errorf("agent runner reach an unknown state: %d", state), nil) + agent.channel <- fmt.Errorf("agent runner reach an unknown state: %d", state) return } } @@ -71,8 +70,8 @@ func Run( errWg.Add(1) go func() { defer errWg.Done() - for shipErr := range agent.channel { - slog.Error("ship error", "err", shipErr.err, "ship", shipErr.ship.Symbol) + for err := range agent.channel { + slog.Error("error", "err", err) } }() agent.wg.Wait() |