Add Quickwit datasource e2e test

Create datasource via UI, ingest dummy logs into Quickwit,
and verify they appear in Explore. Uses unique runId per attempt
for test isolation with index cleanup after each run.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: Platane

tests/quickwit.spec.ts

@@ -0,0 +1,108 @@
+import { test, expect } from '@grafana/plugin-e2e';
+
+// Grafana (inside Docker) reaches Quickwit via the docker service name.
+// The test process (on the host) reaches the same Quickwit via localhost port mapping.
+const QUICKWIT_URL = 'http://quickwit:7280/api/v1';
+const QUICKWIT_INGEST_URL = 'http://localhost:7280/api/v1';
+const INDEX = 'otel-logs-v0_9';
+
+let runId: string;
+let ingestDone: Promise<void>;
+
+test.beforeEach(async () => {
+  runId = `e2e-${Date.now()}`;
+  ingestDone = ingestDummyLogs(runId);
+});
+
+test.afterEach(async () => {
+  await fetch(`${QUICKWIT_INGEST_URL}/indexes/${INDEX}/clear`, { method: 'PUT' }).catch(() => {});
+});
+
+test('create datasource and explore logs', async ({ page }) => {
+  let datasourceUid: string;
+
+  await test.step('look for the plugin in the list of datasources', async () => {
+    await page.goto('/connections/datasources/new');
+    await page.getByPlaceholder('Filter by name or type').fill('quickwit');
+    await expect(page.getByText('Quickwit', { exact: true })).toBeVisible();
+  });
+
+  await test.step('create datasource via UI', async () => {
+    await page.goto('/connections/datasources/new');
+    await page.getByPlaceholder('Filter by name or type').fill('quickwit');
+    await page.getByText('Quickwit', { exact: true }).click();
+
+    // Wait for the config form to load
+    await expect(page.getByText('Index settings')).toBeVisible();
+
+    // Fill required fields
+    await page.getByRole('textbox', { name: /URL/ }).fill(QUICKWIT_URL);
+    await page.getByRole('textbox', { name: 'Index ID' }).fill(INDEX);
+
+    // Save & test
+    await page.getByRole('button', { name: 'Save & test' }).click();
+    await expect(page.getByText('plugin is running')).toBeVisible();
+
+    // Extract datasource UID from URL for cleanup
+    const url = page.url();
+    const match = url.match(/\/datasources\/edit\/([^/]+)/);
+    expect(match).toBeDefined();
+    datasourceUid = match?.[1] ?? '';
+  });
+
+  await test.step('wait for quickwit logs to be ingested', async () => {
+    await ingestDone;
+  });
+
+  await test.step('explore logs returns hits', async () => {
+    // Navigate to explore from the datasource config page
+    await page.goto(`/connections/datasources/edit/${datasourceUid}`);
+    await page.getByRole('link', { name: 'Explore data' }).click();
+
+    await expect(page.getByText(`log-1-${runId}`).first()).toBeVisible();
+    await expect(page.getByText(`log-2-${runId}`).first()).toBeVisible();
+  });
+});
+
+/**
+ * call quickwit ingest API to ingest dummy logs
+ */
+async function ingestDummyLogs(runId: string) {
+  const now = Date.now() * 1_000_000; // nanoseconds
+  const ndjson = [
+    {
+      timestamp_nanos: now,
+      service_name: runId,
+      severity_text: 'INFO',
+      body: { message: `log-1-${runId}` },
+    },
+    {
+      timestamp_nanos: now - 1_000_000_000,
+      service_name: runId,
+      severity_text: 'WARN',
+      body: { message: `log-2-${runId}` },
+    },
+  ]
+    .map((l) => JSON.stringify(l))
+    .join('\n');
+
+  const res = await fetch(`${QUICKWIT_INGEST_URL}/${INDEX}/ingest?commit=wait_for`, {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: ndjson,
+  });
+  if (!res.ok) {
+    throw new Error(`Ingest failed: ${res.status} ${await res.text()}`);
+  }
+
+  // Verify logs are indexed and searchable
+  const search = await fetch(`${QUICKWIT_INGEST_URL}/${INDEX}/search`, {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify({ query: `service_name:${runId}` }),
+  });
+  const { num_hits } = await search.json();
+  if (num_hits === 0) {
+    throw new Error('Ingest failed: no searchable logs');
+  }
+}