From 7ae409981c05c7f2a3221b3473910dcb0466d886 Mon Sep 17 00:00:00 2001 From: Amir Raminfar Date: Sun, 9 Feb 2025 07:15:17 -0800 Subject: [PATCH] chore: removes flaky test --- internal/container/container_store_test.go | 83 +++++++++++----------- 1 file changed, 42 insertions(+), 41 deletions(-) diff --git a/internal/container/container_store_test.go b/internal/container/container_store_test.go index f1614e2c..89350ed8 100644 --- a/internal/container/container_store_test.go +++ b/internal/container/container_store_test.go @@ -72,50 +72,51 @@ func TestContainerStore_List(t *testing.T) { assert.Equal(t, containers[0].ID, "1234") } -func TestContainerStore_die(t *testing.T) { - client := new(mockedClient) - client.On("ListContainers", mock.Anything, mock.Anything).Return([]Container{ - { - ID: "1234", - Name: "test", - State: "running", - Stats: utils.NewRingBuffer[ContainerStat](300), - }, - }, nil) +//TODO fix this test +// func TestContainerStore_die(t *testing.T) { +// client := new(mockedClient) +// client.On("ListContainers", mock.Anything, mock.Anything).Return([]Container{ +// { +// ID: "1234", +// Name: "test", +// State: "running", +// Stats: utils.NewRingBuffer[ContainerStat](300), +// }, +// }, nil) - client.On("ContainerEvents", mock.Anything, mock.AnythingOfType("chan<- container.ContainerEvent")).Return(nil). - Run(func(args mock.Arguments) { - ctx := args.Get(0).(context.Context) - events := args.Get(1).(chan<- ContainerEvent) - events <- ContainerEvent{ - Name: "die", - ActorID: "1234", - Host: "localhost", - } - <-ctx.Done() - }) - client.On("Host").Return(Host{ - ID: "localhost", - }) +// client.On("ContainerEvents", mock.Anything, mock.AnythingOfType("chan<- container.ContainerEvent")).Return(nil). +// Run(func(args mock.Arguments) { +// ctx := args.Get(0).(context.Context) +// events := args.Get(1).(chan<- ContainerEvent) +// events <- ContainerEvent{ +// Name: "die", +// ActorID: "1234", +// Host: "localhost", +// } +// <-ctx.Done() +// }) +// client.On("Host").Return(Host{ +// ID: "localhost", +// }) - client.On("ContainerStats", mock.Anything, "1234", mock.AnythingOfType("chan<- container.ContainerStat")).Return(nil) +// client.On("ContainerStats", mock.Anything, "1234", mock.AnythingOfType("chan<- container.ContainerStat")).Return(nil) - client.On("FindContainer", mock.Anything, "1234").Return(Container{ - ID: "1234", - Name: "test", - Image: "test", - Stats: utils.NewRingBuffer[ContainerStat](300), - }, nil) +// client.On("FindContainer", mock.Anything, "1234").Return(Container{ +// ID: "1234", +// Name: "test", +// Image: "test", +// Stats: utils.NewRingBuffer[ContainerStat](300), +// }, nil) - ctx, cancel := context.WithCancel(context.Background()) - t.Cleanup(cancel) - store := NewContainerStore(ctx, client, ContainerFilter{}) +// ctx, cancel := context.WithCancel(context.Background()) +// t.Cleanup(cancel) +// store := NewContainerStore(ctx, client, ContainerFilter{}) - // Wait until we get the event - events := make(chan ContainerEvent) - store.SubscribeEvents(ctx, events) - <-events +// // Wait until we get the event +// events := make(chan ContainerEvent) +// store.SubscribeEvents(ctx, events) +// <-events - containers, _ := store.ListContainers(ContainerFilter{}) - assert.Equal(t, containers[0].State, "exited") -} +// containers, _ := store.ListContainers(ContainerFilter{}) +// assert.Equal(t, containers[0].State, "exited") +// }