Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

TESTID-43: add max recent queries tests #9307

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -0,0 +1,99 @@
/*
* Copyright OpenSearch Contributors
* SPDX-License-Identifier: Apache-2.0
*/

import {
DATASOURCE_NAME,
INDEX_PATTERN_WITH_TIME,
INDEX_WITH_TIME_1,
} from '../../../../../utils/apps/constants';
import { SECONDARY_ENGINE, BASE_PATH } from '../../../../../utils/constants';
import { NEW_SEARCH_BUTTON } from '../../../../../utils/dashboards/data_explorer/elements.js';
import {
getRandomizedWorkspaceName,
setDatePickerDatesAndSearchIfRelevant,
} from '../../../../../utils/apps/query_enhancements/shared';
import { generateMaxQueriesTestConfiguration } from '../../../../../utils/apps/query_enhancements/max_recent_queries';

const workspace = getRandomizedWorkspaceName();

describe('filter for value spec', { testIsolation: true }, () => {
const index = INDEX_PATTERN_WITH_TIME.replace('*', '');
beforeEach(() => {
// Load test data
cy.setupTestData(
SECONDARY_ENGINE.url,
['cypress/fixtures/query_enhancements/data_logs_1/data_logs_small_time_1.mapping.json'],
['cypress/fixtures/query_enhancements/data_logs_1/data_logs_small_time_1.data.ndjson']
);

// Add data source
cy.addDataSource({
name: DATASOURCE_NAME,
url: `${SECONDARY_ENGINE.url}`,
authType: 'no_auth',
});
// Create workspace
cy.deleteWorkspaceByName(workspace);
cy.visit('/app/home');
cy.osd.createInitialWorkspaceWithDataSource(DATASOURCE_NAME, workspace);
cy.createWorkspaceIndexPatterns({
workspaceName: workspace,
indexPattern: index,
timefieldName: 'timestamp',
indexPatternHasTimefield: true,
dataSource: DATASOURCE_NAME,
isEnhancement: true,
});

cy.navigateToWorkSpaceSpecificPage({
url: BASE_PATH,
workspaceName: workspace,
page: 'discover',
isEnhancement: true,
});
cy.getElementByTestId(NEW_SEARCH_BUTTON).click();
});

afterEach(() => {
cy.deleteWorkspaceByName(workspace);
cy.deleteDataSourceByName(DATASOURCE_NAME);
// TODO: Modify deleteIndex to handle an array of index and remove hard code
cy.deleteIndex(INDEX_WITH_TIME_1);
});

generateMaxQueriesTestConfiguration().forEach((config) => {
it(`check max queries for ${config.testName}`, () => {
cy.setDataset(config.dataset, DATASOURCE_NAME, config.datasetType);
cy.setQueryLanguage(config.language);
setDatePickerDatesAndSearchIfRelevant(config.language);
const currentBaseQuery = config.baseQuery;
config.testQueries.forEach((query) => {
cy.setQueryEditor(currentBaseQuery + query, {}, true);
});
cy.getElementByTestId('queryEditorFooterToggleRecentQueriesButton').click({
force: true,
});
// only 10 of the 11 queries should be displayed
cy.getElementByTestIdLike('row-').should('have.length', 10);
const reverseList = [...config.testQueries].reverse();
cy.getElementByTestIdLike('row-').each(($row, rowIndex) => {
expect($row.text()).to.contain(currentBaseQuery + reverseList[rowIndex]);
});
});

it(`check duplicate query for ${config.testName}`, () => {
cy.setDataset(config.dataset, DATASOURCE_NAME, config.datasetType);
cy.setQueryLanguage(config.language);
setDatePickerDatesAndSearchIfRelevant(config.language);
const query = config.baseQuery + 'status_code = 504';
cy.setQueryEditor(query, {}, true);
cy.setQueryEditor(query, {}, true);
cy.getElementByTestId('queryEditorFooterToggleRecentQueriesButton').click({
force: true,
});
cy.contains(query).should('have.length', 1);
});
});
});
63 changes: 63 additions & 0 deletions cypress/utils/apps/query_enhancements/max_recent_queries.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,63 @@
/*
* Copyright OpenSearch Contributors
* SPDX-License-Identifier: Apache-2.0
*/

import { INDEX_PATTERN_WITH_TIME, INDEX_WITH_TIME_1, QueryLanguages } from './constants';

export const MaxQueriesDataTypes = {
INDEX_PATTERN: {
name: 'INDEX_PATTERN',
supportedLanguages: [QueryLanguages.SQL, QueryLanguages.PPL],
},
INDEXES: {
name: 'INDEXES',
supportedLanguages: [QueryLanguages.SQL, QueryLanguages.PPL],
},
};

/**
* Test confuguration for max recent queries
* @returns {object[]}
*/
export const generateMaxQueriesTestConfiguration = () => {
return Object.values(MaxQueriesDataTypes).flatMap((dataset) =>
dataset.supportedLanguages.map((language) => {
let datasetToUse;
switch (dataset.name) {
case MaxQueriesDataTypes.INDEX_PATTERN.name:
datasetToUse = INDEX_PATTERN_WITH_TIME;
break;
case MaxQueriesDataTypes.INDEXES.name:
datasetToUse = INDEX_WITH_TIME_1;
break;
default:
throw new Error(`Unsupported dataset: ${dataset.name}`);
}
const baseQuery = {
'OpenSearch SQL': `SELECT * FROM ${datasetToUse} WHERE `,
PPL: `source = ${datasetToUse} | where `,
};
return {
dataset: datasetToUse,
datasetType: dataset.name,
language: language.name,
baseQuery: baseQuery[language.name],
testQueries: [
'bytes_transferred > 0',
'bytes_transferred < 8000',
'bytes_transferred > 8000',
'status_code = 404',
'status_code = 501',
'status_code = 503',
'status_code = 400',
'status_code = 401',
'status_code = 403',
'status_code = 200',
'event_sequence_number > 10000000',
],
testName: `${language.name} and ${dataset.name}`,
};
})
);
};
Loading