agdcslog: integration tests

Author: schzhn

internal/agdcslog/agdcslog_test.go

@@ -4,6 +4,8 @@ import (
 	"bytes"
 	"context"
 	"log/slog"
+	"os"
+	"strconv"
 	"strings"
 	"sync"
 	"testing"
@@ -15,6 +17,43 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
+// testTimeout is the common timeout for tests.
+const testTimeout = 1 * time.Second
+
+const testServiceName = "AdGuardDNSClientTest"
+
+func requireIntegration(t *testing.T) {
+	t.Helper()
+
+	const envName = "TEST_AGDCSLOG"
+
+	val := os.Getenv(envName)
+	if val == "" {
+		t.Skip()
+	}
+
+	ok, err := strconv.ParseBool(val)
+	if err != nil || !ok {
+		t.Skip()
+	}
+}
+
+func integrationSystemLogger(t *testing.T) (l *slog.Logger) {
+	t.Helper()
+
+	ctx := testutil.ContextWithTimeout(t, testTimeout)
+	sl, err := agdcslog.NewSystemLogger(ctx, testServiceName)
+	require.NoError(t, err)
+
+	testutil.CleanupAndRequireSuccess(t, sl.Close)
+
+	h := agdcslog.NewSyslogHandler(sl, &slog.HandlerOptions{
+		Level: slog.LevelDebug,
+	})
+
+	return slog.New(h)
+}
+
 // testLogger is a mock implementation of [agdcslog.SystemLogger] interface for
 // tests.
 //

internal/agdcslog/syslog_darwin_test.go

@@ -0,0 +1,16 @@
+//go:build darwin
+
+package agdcslog_test
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestSystemLogger_integration(t *testing.T) {
+	requireIntegration(t)
+
+	l := integrationSystemLogger(t)
+	require.NotNil(t, l)
+}

internal/agdcslog/syslog_linux_test.go

@@ -0,0 +1,57 @@
+//go:build linux
+
+package agdcslog_test
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"strings"
+	"testing"
+	"time"
+
+	"github.com/AdguardTeam/golibs/osutil/executil"
+	"github.com/AdguardTeam/golibs/testutil"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+func TestSystemLogger_integration(t *testing.T) {
+	requireIntegration(t)
+
+	l := integrationSystemLogger(t)
+
+	since := time.Now()
+	sinceStr := since.Format(time.DateTime)
+
+	msg := fmt.Sprintf("%d", since.UnixNano())
+
+	ctx := testutil.ContextWithTimeout(t, testTimeout)
+	l.DebugContext(ctx, msg)
+
+	require.EventuallyWithT(t, func(ct *assert.CollectT) {
+		findCtx, cancel := context.WithTimeout(ctx, testTimeout)
+		defer cancel()
+
+		ok, err := findInJournald(findCtx, sinceStr, msg)
+		require.NoError(ct, err)
+
+		assert.True(ct, ok)
+	}, testTimeout, testTimeout/10)
+}
+
+func findInJournald(ctx context.Context, since, msg string) (ok bool, err error) {
+	var stdOut, stdErr bytes.Buffer
+
+	err = executil.Run(ctx, executil.SystemCommandConstructor{}, &executil.CommandConfig{
+		Path:   "journalctl",
+		Args:   []string{"-o", "cat", "-t", testServiceName, "--since", since, "--no-pager"},
+		Stdout: &stdOut,
+		Stderr: &stdErr,
+	})
+	if err != nil {
+		return false, fmt.Errorf("journalctl failed: %w; stderr=%q", err, &stdErr)
+	}
+
+	return strings.Contains(stdOut.String(), msg), nil
+}

internal/agdcslog/syslog_windows_test.go

@@ -0,0 +1,16 @@
+//go:build windows
+
+package agdcslog_test
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestSystemLogger_integration(t *testing.T) {
+	requireIntegration(t)
+
+	l := integrationSystemLogger(t)
+	require.NotNil(t, l)
+}