Function TestPreStart_FirstHookFailsStopsExecution

pkg/compose/pre_start_test.go:108–134

(t *testing.T)

}

func TestPreStart_FirstHookFailsStopsExecution(t *testing.T) {
	tested, apiClient := newPreStartTestService(t)

	project := &types.Project{Name: "demo"}
	service := types.ServiceConfig{
		Name:  "web",
		Image: "alpine",
		PreStart: []types.ServiceHook{
			{Image: "alpine", Command: types.ShellCommand{"false"}},
			{Image: "alpine", Command: types.ShellCommand{"echo", "never"}},
		},
	}
	ctr := container.Summary{ID: "service-ctr-id"}

	create1 := apiClient.EXPECT().ContainerCreate(gomock.Any(), gomock.Any()).
		Return(client.ContainerCreateResult{ID: "hook-1"}, nil)
	wait1 := apiClient.EXPECT().ContainerWait(gomock.Any(), "hook-1", gomock.Any()).
		Return(waitResultExit(42)).After(create1)
	logs1 := apiClient.EXPECT().ContainerLogs(gomock.Any(), "hook-1", gomock.Any()).
		Return(emptyLogs(), nil).After(wait1)
	apiClient.EXPECT().ContainerStart(gomock.Any(), "hook-1", gomock.Any()).
		Return(client.ContainerStartResult{}, nil).After(logs1)

	err := tested.runPreStart(t.Context(), project, service, ctr, func(api.ContainerEvent) {})
	assert.ErrorContains(t, err, `service "web" pre_start[0]`)
	assert.ErrorContains(t, err, "42")
}

func TestPreStart_PerReplicaRejected(t *testing.T) {
	tested, _ := newPreStartTestService(t)