Function TestDebugFileSink_RotateForScope

utils/log/logger_test.go:259–332

(t *testing.T)

}

func TestDebugFileSink_RotateForScope(t *testing.T) {
	SetRedactor(nil)
	console := &syncBuffer{}
	logger := newConsoleLogger(console, zap.InfoLevel)

	dir := t.TempDir()
	originPath := filepath.Join(dir, "agent-debug.log")
	originFile, err := os.Create(originPath)
	if err != nil {
		t.Fatalf("create origin: %v", err)
	}
	defer originFile.Close()

	wrapped, sink := AddDebugFileSink(logger, originFile, 0)
	if sink == nil {
		t.Fatalf("AddDebugFileSink returned nil")
	}
	defer SetDebugFileSink(nil)

	wrapped.Debug("origin-line")

	if err := sink.RotateForScope("test-set-1"); err != nil {
		t.Fatalf("RotateForScope: %v", err)
	}
	wrapped.Debug("scope-1-line")

	if err := sink.RotateForScope("test-set-2"); err != nil {
		t.Fatalf("RotateForScope: %v", err)
	}
	wrapped.Debug("scope-2-line")

	// Repeat scope is a no-op.
	if err := sink.RotateForScope("test-set-2"); err != nil {
		t.Fatalf("repeat RotateForScope: %v", err)
	}
	wrapped.Debug("scope-2-line-2")

	if err := sink.Flush(); err != nil {
		t.Fatalf("flush: %v", err)
	}

	originBytes, _ := os.ReadFile(originPath)
	if !strings.Contains(string(originBytes), "origin-line") {
		t.Errorf("origin-line missing from %s: %s", originPath, originBytes)
	}
	if strings.Contains(string(originBytes), "scope-1-line") {
		t.Errorf("scope-1-line leaked into origin file: %s", originBytes)
	}

	scope1Path := filepath.Join(dir, "test-set-1", "agent-debug.log")
	scope1Bytes, err := os.ReadFile(scope1Path)
	if err != nil {
		t.Fatalf("read scope-1 file: %v", err)
	}
	if !strings.Contains(string(scope1Bytes), "scope-1-line") {
		t.Errorf("scope-1-line missing from %s: %s", scope1Path, scope1Bytes)
	}
	if strings.Contains(string(scope1Bytes), "scope-2-line") {