Function TestWaitOnInfinity

pkg/e2e/wait_test.go:56–89

(t *testing.T)

}

func TestWaitOnInfinity(t *testing.T) {
	const projectName = "e2e-wait-infinity"
	c := NewParallelCLI(t)

	cleanup := func() {
		c.RunDockerComposeCmd(t, "--project-name", projectName, "down", "--timeout=0", "--remove-orphans")
	}
	t.Cleanup(cleanup)
	cleanup()

	c.RunDockerComposeCmd(t, "-f", "./fixtures/wait/compose.yaml", "--project-name", projectName, "up", "-d")

	cmd := c.NewDockerComposeCmd(t, "--project-name", projectName, "wait", "infinity")
	r := icmd.StartCmd(cmd)
	assert.NilError(t, r.Error)
	t.Cleanup(func() {
		if r.Cmd.Process != nil {
			_ = r.Cmd.Process.Kill()
		}
	})

	finished := make(chan struct{})
	ticker := time.NewTicker(7 * time.Second)
	go func() {
		_ = r.Cmd.Wait()
		finished <- struct{}{}
	}()

	select {
	case <-finished:
		t.Fatal("wait infinity should not finish")
	case <-ticker.C:
	}
}

func TestWaitAndDrop(t *testing.T) {
	const projectName = "e2e-wait-and-drop"