github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-06-27 18:51:07 -04:00
Code Issues Projects Releases Packages Wiki Activity

fix(streams): wired scout test (#221838)

Browse source 
## Summary

Update scout test according to latest change with normalized fields:
https://github.com/elastic/kibana/pull/205113
This commit is contained in:
Kevin Delemme 2025-05-29 10:45:35 -04:00 • committed by GitHub
parent cf46b2d707
commit 567b4d5c6b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 13 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

4
x-pack/platform/plugins/shared/streams_app/ui_tests/tests/classic.spec.ts
View file

@ -67,10 +67,10 @@ test.describe('Classic Streams', { tag: ['@ess', '@svlOblt'] }, () => {
await pageObjects.streams.gotoExtractFieldTab(DATA_STREAM_NAME);
await page.getByText('Add a processor').click();
await page.locator('input[name="field"]').fill('message');
await page.locator('input[name="field"]').fill('body.text');
await page
.locator('input[name="patterns\\.0\\.value"]')
.fill('%{WORD:method} %{URIPATH:request}');
.fill('%{WORD:attributes.method} %{URIPATH:attributes.request}');
await page.getByRole('button', { name: 'Add processor' }).click();
await page.getByRole('button', { name: 'Save changes' }).click();

27
x-pack/platform/plugins/shared/streams_app/ui_tests/tests/wired.spec.ts
View file

@ -25,7 +25,7 @@ test.describe('Wired Streams', { tag: ['@ess', '@svlOblt'] }, () => {
await pageObjects.streams.gotoCreateChildStream('logs');
await page.getByLabel('Stream name').fill('logs.nginx');
await page.getByPlaceholder('Field').fill('agent.name');
await page.getByPlaceholder('Field').fill('attributes.custom_field');
await page.getByPlaceholder('Value').fill('nginx');
await page.getByRole('button', { name: 'Save' }).click();
await expect(page.getByRole('link', { name: 'logs.nginx', exact: true })).toBeVisible();
@ -47,13 +47,9 @@ test.describe('Wired Streams', { tag: ['@ess', '@svlOblt'] }, () => {
index: 'logs',
document: {
'@timestamp': '2025-05-01T00:00:00.000Z',
message: JSON.stringify({
'log.level': 'info',
'log.logger': 'nginx',
message: 'GET /search HTTP/1.1 200 1070000',
}),
'agent.name': 'nginx',
'other.field': 'important',
'log.level': 'warn',
message: 'GET /search HTTP/1.1 200 1070000',
custom_field: 'nginx',
},
refresh: 'wait_for',
});
@ -61,10 +57,10 @@ test.describe('Wired Streams', { tag: ['@ess', '@svlOblt'] }, () => {
await pageObjects.streams.gotoExtractFieldTab('logs.nginx');
await page.getByText('Add a processor').click();
await page.locator('input[name="field"]').fill('message');
await page.locator('input[name="field"]').fill('body.text');
await page
.locator('input[name="patterns\\.0\\.value"]')
.fill('%{WORD:method} %{URIPATH:request}');
.fill('%{WORD:attributes.method} %{URIPATH:attributes.request}');
await page.getByRole('button', { name: 'Add processor' }).click();
await page.getByRole('button', { name: 'Save changes' }).click();
await expect(page.getByText("Stream's processors updated")).toBeVisible();
@ -72,19 +68,18 @@ test.describe('Wired Streams', { tag: ['@ess', '@svlOblt'] }, () => {
// Update "logs.nginx" mapping
await pageObjects.streams.gotoSchemaEditorTab('logs.nginx');
await page.getByPlaceholder('Search...').fill('attributes');
await page.getByTestId('streamsAppContentRefreshButton').click();
await page
.getByRole('row', { name: 'agent.name ----- ----- logs.' })
.getByLabel('Open actions menu')
.click();
await page
.getByRole('row', { name: 'agent.name ----- ----- logs.' })
.getByRole('row', { name: 'attributes.custom_field' })
.getByLabel('Open actions menu')
.click();
await page.getByRole('button', { name: 'Map field' }).click();
await page.getByRole('combobox').selectOption('keyword');
await page.getByRole('button', { name: 'Save changes' }).click();
await page.getByRole('heading', { name: 'agent.name' }).waitFor({ state: 'hidden' });
await page.getByRole('heading', { name: 'logs.foo' }).waitFor({ state: 'hidden' });
await expect(page.getByText('Mapped', { exact: true })).toBeVisible();
await page.getByTestId('toastCloseButton').click();