Compare commits
2 Commits
feat/2efdd
...
631387fda7
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
631387fda7 | ||
| 18b48bfdc4 |
@@ -144,8 +144,8 @@ type e2eChannel struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c *e2eChannel) Run(_ context.Context) error { return nil }
|
func (c *e2eChannel) Run(_ context.Context) error { return nil }
|
||||||
func (c *e2eChannel) OnMessage(f func(chat.Incoming)) {
|
func (c *e2eChannel) OnMessage(h chat.Handler) {
|
||||||
c.onMsg = f
|
c.onMsg = h
|
||||||
}
|
}
|
||||||
func (c *e2eChannel) Send(_ context.Context, _ chat.Address, m chat.Message) error {
|
func (c *e2eChannel) Send(_ context.Context, _ chat.Address, m chat.Message) error {
|
||||||
c.sent = append(c.sent, m)
|
c.sent = append(c.sent, m)
|
||||||
|
|||||||
@@ -111,10 +111,16 @@ func TestUpdateTaskStatus(t *testing.T) {
|
|||||||
t.Fatalf("UpdateTask collecting→ready: %v", err)
|
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
|
task.Status = StatusRunning
|
||||||
if err := s.UpdateTask(ctx, task); err != nil {
|
if err := s.UpdateTask(ctx, task); err != nil {
|
||||||
t.Fatalf("UpdateTask ready→running: %v", err)
|
t.Fatalf("UpdateTask approved→running: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// running → success
|
// running → success
|
||||||
|
|||||||
Reference in New Issue
Block a user