diff --git a/internal/app/e2e_test.go b/internal/app/e2e_test.go index 071b3bb..5953c97 100644 --- a/internal/app/e2e_test.go +++ b/internal/app/e2e_test.go @@ -144,8 +144,8 @@ type e2eChannel struct { } func (c *e2eChannel) Run(_ context.Context) error { return nil } -func (c *e2eChannel) OnMessage(f func(chat.Incoming)) { - c.onMsg = f +func (c *e2eChannel) OnMessage(h chat.Handler) { + c.onMsg = h } func (c *e2eChannel) Send(_ context.Context, _ chat.Address, m chat.Message) error { c.sent = append(c.sent, m) diff --git a/internal/storage/storage_test.go b/internal/storage/storage_test.go index cbabab9..ab03614 100644 --- a/internal/storage/storage_test.go +++ b/internal/storage/storage_test.go @@ -111,10 +111,16 @@ func TestUpdateTaskStatus(t *testing.T) { t.Fatalf("UpdateTask collecting→ready: %v", err) } - // ready → running + // ready → approved + task.Status = StatusApproved + if err := s.UpdateTask(ctx, task); err != nil { + t.Fatalf("UpdateTask ready→approved: %v", err) + } + + // approved → running task.Status = StatusRunning if err := s.UpdateTask(ctx, task); err != nil { - t.Fatalf("UpdateTask ready→running: %v", err) + t.Fatalf("UpdateTask approved→running: %v", err) } // running → success