/**
 * End-to-end UI test for log streaming feature.
 *
 * This test verifies:
 * 1. Log streaming can be configured via the UI
 * 2. Test events are streamed to VictoriaLogs via syslog
 * 3. Events can be queried from VictoriaLogs
 */

import { test, expect } from '../../../../fixtures/base';

test.use({ capability: 'observability' });

test.describe(
	'Log Streaming UI E2E @capability:observability @licensed',
	{
		annotation: [{ type: 'owner', description: 'Lifecycle & Governance' }],
	},
	() => {
		test.beforeEach(async ({ n8n }) => {
			await n8n.api.enableFeature('logStreaming');
		});

		test('should configure syslog destination via UI and send test event', async ({
			n8n,
			services,
		}) => {
			const obs = services.observability;

			// ========== STEP 1: Configure Log Streaming via UI ==========
			await n8n.navigate.toLogStreaming();
			await expect(n8n.settingsLogStreaming.getActionBoxLicensed()).toBeVisible();

			// Create syslog destination pointing to VictoriaLogs
			await n8n.settingsLogStreaming.createSyslogDestination({
				name: 'VictoriaLogs E2E Test',
				host: obs.syslog.host,
				port: obs.syslog.port,
			});
			// Send test event
			await n8n.settingsLogStreaming.sendTestEvent();

			// ========== STEP 3: Verify Event in VictoriaLogs ==========
			// Use wildcard search - LogsQL interprets dots as word separators
			const testEvent = await obs.logs.waitForLog('*destination.test*', {
				timeoutMs: 30000,
				start: '-2m',
			});

			expect(testEvent).toBeTruthy();
		});
	},
);