Function TestLogsTailFollowRotate

cmd/nerdctl/container/container_logs_test.go:439–483

(t *testing.T)

}

func TestLogsTailFollowRotate(t *testing.T) {
	// FIXME this is flaky by nature... the number of lines is arbitrary, the wait is arbitrary,
	// and both are some sort of educated guess that things will mostly always kinda work maybe...
	const sampleJSONLog = `{"log":"A\n","stream":"stdout","time":"2024-04-11T12:01:09.800288974Z"}`
	const linesPerFile = 200

	testCase := nerdtest.Setup()

	// tail log is not supported on Windows
	testCase.Require = require.Not(require.Windows)

	testCase.Setup = func(data test.Data, helpers test.Helpers) {
		helpers.Ensure("run", "-d", "--log-driver", "json-file",
			"--log-opt", fmt.Sprintf("max-size=%d", len(sampleJSONLog)*linesPerFile),
			"--log-opt", "max-file=10",
			"--name", data.Identifier(), testutil.CommonImage,
			"sh", "-euc", "while true; do echo A; usleep 100; done")
		// FIXME: ... inherently racy...
		time.Sleep(5 * time.Second)
	}

	testCase.Cleanup = func(data test.Data, helpers test.Helpers) {
		helpers.Anyhow("rm", "-f", data.Identifier())
	}

	testCase.Command = func(data test.Data, helpers test.Helpers) test.TestableCommand {
		cmd := helpers.Command("logs", "-f", data.Identifier())
		// FIXME: this is flaky by nature. We assume that the container has started and will output enough in 5 seconds.
		cmd.WithTimeout(5 * time.Second)
		return cmd
	}

	testCase.Expected = test.Expects(expect.ExitCodeTimeout, nil, func(stdout string, t tig.T) {
		tailLogs := strings.Split(strings.TrimSpace(stdout), "\n")
		for _, line := range tailLogs {
			if line != "" {
				assert.Equal(t, "A", line)
			}
		}

		assert.Assert(t, len(tailLogs) > linesPerFile, fmt.Sprintf("expected %d lines or more, found %d", linesPerFile, len(tailLogs)))
	})

	testCase.Run(t)
}

func TestLogsNoneLoggerHasNoLogURI(t *testing.T) {
	testCase := nerdtest.Setup()