service_readiness_test.go RawHistoryFolder

1package container
2
3import (
4	"strings"
5	"testing"
6	"time"
7
8	"github.com/stretchr/testify/assert"
9	"github.com/stretchr/testify/mock"
10
11	"github.com/bnema/gordon/internal/boundaries/out/mocks"
12)
13
14func TestService_WaitForReady_AutoFallsBackToDelayWhenNoHealthcheck(t *testing.T) {
15	runtime := mocks.NewMockContainerRuntime(t)
16	svc := NewService(runtime, nil, nil, nil, Config{
17		ReadinessMode:  "auto",
18		ReadinessDelay: time.Millisecond,
19	})
20
21	ctx := testContext()
22	containerID := "container-1"
23
24	// Initial running poll
25	runtime.EXPECT().IsContainerRunning(mock.Anything, containerID).Return(true, nil).Once()
26	// Auto mode probes for healthcheck support first
27	runtime.EXPECT().GetContainerHealthStatus(mock.Anything, containerID).Return("", false, nil).Once()
28	// Delay-mode fallback verification
29	runtime.EXPECT().IsContainerRunning(mock.Anything, containerID).Return(true, nil).Once()
30
31	err := svc.waitForReady(ctx, containerID)
32	assert.NoError(t, err)
33}
34
35func TestService_WaitForHealthy_EmptyStatusIsReportedAsStarting(t *testing.T) {
36	runtime := mocks.NewMockContainerRuntime(t)
37	svc := NewService(runtime, nil, nil, nil, Config{})
38
39	ctx := testContext()
40	containerID := "container-1"
41
42	runtime.EXPECT().GetContainerHealthStatus(mock.Anything, containerID).Return("", true, nil).Once()
43
44	err := svc.waitForHealthy(ctx, containerID, 10*time.Millisecond)
45	assert.Error(t, err)
46	assert.True(t, strings.Contains(err.Error(), "last status: starting"))
47}