mirrors/dozzle
1
0
Fork 0
mirror of https://github.com/amir20/dozzle.git synced 2025-12-21 13:23:07 +01:00
Code Issues Projects Releases Wiki Activity

chore: removes flaky test

Browse Source
This commit is contained in:
Amir Raminfar
2025-02-09 07:15:17 -08:00
parent 20fb7984d2
commit 7ae409981c
1 changed files with 42 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

83
internal/container/container_store_test.go
View File

@@ -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")
// }