ac91339d54
## Description Following are the improvements made in this PR: - Remove the unnecessary space b/w form and CTA in Gsheet onboarding step - Made one new RadioButtonControl in form control and replaced the current dropdown by radio buttons. - Move the callout to after the permissions | scope property. - Limit the width of the white section Fixes #30523 output screenshot:  Desired design:  > > _Please also include relevant motivation and context. List any dependencies that are required for this change. Add links to Notion, Figma or any other documents that might be relevant to the PR._ *Fixes #`35950` _or_ Fixes `Issue URL` > [!WARNING] > _If no issue exists, please create an issue first, and check with the maintainers if the issue is valid._ ## Automation /ok-to-test tags="" ### 🔍 Cypress test results <!-- This is an auto-generated comment: Cypress test results --> > [!CAUTION] > If you modify the content in this section, you are likely to disrupt the CI result for your PR. <!-- end of auto-generated comment: Cypress test results --> ## Communication Should the DevRel and Marketing teams inform users about this change? - [ ] Yes - [ ] No <!-- This is an auto-generated comment: release notes by coderabbit.ai --> ## Summary by CodeRabbit ## Summary by CodeRabbit - **New Features** - Introduced a new `RadioButtonControl` component for improved form control options. - Enhanced the `FormControlRegistry` to support radio button controls. - Updated the Google Sheets plugin to use radio buttons for permission settings. - **UI Changes** - Corrected styling syntax in the `FormContainer` for proper rendering. - Reorganized the display order of information banners in the `DatasourceForm` for better clarity. - **Tests** - Added a comprehensive suite of unit tests for the `RadioButtonControl` component to ensure proper functionality and user interaction. <!-- end of auto-generated comment: release notes by coderabbit.ai -->
1956 lines
66 KiB
TypeScript
1956 lines
66 KiB
TypeScript
import { ObjectsRegistry } from "../Objects/Registry";
|
|
import { WIDGET } from "../../locators/WidgetLocators";
|
|
import { EntityItems } from "./AssertHelper";
|
|
import EditorNavigation, {
|
|
AppSidebar,
|
|
AppSidebarButton,
|
|
EntityType,
|
|
PageLeftPane,
|
|
PagePaneSegment,
|
|
} from "./EditorNavigation";
|
|
import datasource from "../../locators/DatasourcesEditor.json";
|
|
import PageList from "./PageList";
|
|
import { anvilLocators } from "./Anvil/Locators";
|
|
|
|
export const DataSourceKVP = {
|
|
Postgres: "PostgreSQL",
|
|
Mongo: "MongoDB",
|
|
MySql: "MySQL",
|
|
UnAuthenticatedGraphQL: "GraphQL API",
|
|
AuthenticatedGraph: "Authenticated GraphQL API",
|
|
MsSql: "Microsoft SQL Server",
|
|
Airtable: "Airtable",
|
|
ArangoDB: "ArangoDB",
|
|
Firestore: "Firestore",
|
|
Elasticsearch: "Elasticsearch",
|
|
Redis: "Redis",
|
|
Oracle: "Oracle",
|
|
S3: "S3",
|
|
Twilio: "Twilio",
|
|
SMTP: "SMTP",
|
|
}; //DataSources KeyValuePair
|
|
|
|
export enum Widgets {
|
|
Dropdown,
|
|
Table,
|
|
Chart,
|
|
Text,
|
|
WDSTable,
|
|
}
|
|
|
|
type AppModes = "Edit" | "View";
|
|
|
|
interface RunQueryParams {
|
|
toValidateResponse?: boolean;
|
|
expectedStatus?: boolean;
|
|
waitTimeInterval?: number;
|
|
}
|
|
|
|
export class DataSources {
|
|
private agHelper = ObjectsRegistry.AggregateHelper;
|
|
private table = ObjectsRegistry.Table;
|
|
private entityExplorer = ObjectsRegistry.EntityExplorer;
|
|
private locator = ObjectsRegistry.CommonLocators;
|
|
private apiPage = ObjectsRegistry.ApiPage;
|
|
private dataManager = ObjectsRegistry.DataManager;
|
|
private assertHelper = ObjectsRegistry.AssertHelper;
|
|
|
|
public ContainerKVP = (containerName: string) => {
|
|
return {
|
|
MsSql: this.dataManager.mssql_docker(containerName),
|
|
Arango: this.dataManager.arango_docker(containerName),
|
|
Elasticsearch: this.dataManager.elastic_docker(containerName),
|
|
};
|
|
}; //Container KeyValuePair
|
|
private _dsReviewSection = "[data-testid='t--ds-review-section']";
|
|
public _addNewDataSource = ".t--add-datasource-button";
|
|
private _addNewDatasourceFromBlankScreen =
|
|
".t--add-datasource-button-blank-screen";
|
|
public _newDatasourceBtn =
|
|
".t--add-datasource-button, .t--add-datasource-button-blank-screen";
|
|
private _createNewPlgin = (pluginName: string) =>
|
|
".t--plugin-name:contains('" + pluginName + "')";
|
|
public _host = (index = "0") =>
|
|
"input[name$='.datasourceConfiguration.endpoints[" + index + "].host']";
|
|
public _port = "input[name$='.datasourceConfiguration.endpoints[0].port']";
|
|
public _databaseName =
|
|
"input[name$='.datasourceConfiguration.authentication.databaseName']";
|
|
public _username =
|
|
"input[name$='.datasourceConfiguration.authentication.username']";
|
|
private _section = (name: string) =>
|
|
"//div[text()='" + name + "']/parent::div";
|
|
public _password =
|
|
"input[name $= '.datasourceConfiguration.authentication.password']";
|
|
private _testDs = ".t--test-datasource";
|
|
_saveDs = ".t--save-datasource";
|
|
_datasourceCard = ".t--datasource";
|
|
_dsMenuoptions = "div.t--datasource-menu-option";
|
|
_editButton = ".t--edit-datasource";
|
|
_reconnectDataSourceModal = "[data-testid=t--tab-RECONNECT_DATASOURCES]";
|
|
_closeDataSourceModal = ".t--reconnect-close-btn";
|
|
_dsEntityItem = "[data-guided-tour-id='explorer-entity-Datasources']";
|
|
_activeDS = "[data-selected='true']";
|
|
_mockDatasourceName = "[data-testid=mockdatasource-name]";
|
|
_templateMenu = ".t--template-menu";
|
|
_bindDataButton = "[data-testid=t--bind-data]";
|
|
_addSuggestedExisting = "t--suggested-widget-existing";
|
|
_addSuggestedAddNew = "t--suggested-widget-add-new";
|
|
_templateMenuOption = (action: string) =>
|
|
"//div[contains(@class, 't--template-menu')]//div[text()='" + action + "']";
|
|
_createQuery = ".t--create-query";
|
|
_visibleTextSpan = (spanText: string) =>
|
|
"//span[contains(text(),'" + spanText + "')]";
|
|
_dsOptionMenuItem = (text: string) =>
|
|
"//div[@role='menuitem']//span[text()='" + text + "']";
|
|
_dropdownTitle = (ddTitle: string) =>
|
|
"//p[contains(text(),'" +
|
|
ddTitle +
|
|
"')]/ancestor::div[@class='form-config-top']/following-sibling::div[@class='t--form-control-DROP_DOWN']//input | //label[text()='" +
|
|
ddTitle +
|
|
"']/following-sibling::span//button";
|
|
_reconnectModal = "[data-testid='reconnect-datasource-modal']";
|
|
_reconnect = ".t--reconnect-btn";
|
|
_dropdown = (ddTitle: string) =>
|
|
"//span[contains(@title, '" +
|
|
ddTitle +
|
|
"') and text() = '" +
|
|
ddTitle +
|
|
"']";
|
|
_activeDSListReconnectModal = (dbName: string) =>
|
|
"//div[contains(@class, 't--ds-list')]//span[text()='" + dbName + "']";
|
|
_runQueryBtn = ".t--run-query";
|
|
_newDatabases = "#new-datasources";
|
|
_newDatasourceContainer = "#new-integrations-wrapper";
|
|
_selectDatasourceDropdown = "[data-testid=t--datasource-dropdown]";
|
|
_selectTableDropdown =
|
|
"[data-testid=t--table-dropdown] .rc-select-selection-item";
|
|
_selectSheetNameDropdown =
|
|
"[data-testid=t--sheetName-dropdown] .rc-select-selector";
|
|
_selectTableHeaderIndexInput = "[data-testid=t--tableHeaderIndex]";
|
|
_dropdownOption = ".rc-select-item-option-content";
|
|
_generatePageBtn = "[data-testid=t--generate-page-form-submit]";
|
|
_selectedRow = ".tr.selected-row";
|
|
_activeTab = "span:contains('Active')";
|
|
_selectedActiveTab = "button[aria-selected='true'] " + this._activeTab;
|
|
_contextMenuDSReviewPage = "[data-testid='t--context-menu-trigger']";
|
|
_contextMenuDelete = ".t--datasource-option-delete";
|
|
_datasourceCardGeneratePageBtn =
|
|
".t--generate-template, .t--datasource-generate-page";
|
|
_queryOption = (option: string) =>
|
|
"//div[contains(@class, 'rc-select-item-option-content') and text() = '" +
|
|
option +
|
|
"'] | //a[contains(@class, 'single-select')]//div[text()='" +
|
|
option +
|
|
"']";
|
|
_queryTableResponse =
|
|
"//div[@data-guided-tour-id='query-table-response']//div[@class='tbody']//div[@class ='td']";
|
|
_queryResponseHeader = (header: string) =>
|
|
"//div[@data-guided-tour-id='query-table-response']//div[@class='table']//div[@role ='columnheader']//span[text()='" +
|
|
header +
|
|
"']";
|
|
_refreshIcon = "button .bp3-icon-refresh";
|
|
_addIcon = "button .bp3-icon-add";
|
|
_queryError = "[data-testid='t--query-error']";
|
|
_queryEditorTabs = (responseType: string) =>
|
|
"//button[@role='tab' or @role='tablist']//span[text()='" +
|
|
responseType +
|
|
"']";
|
|
_queryResponse = (responseType: string) =>
|
|
"//div[@data-testid='t--response-tab-segmented-control']//span[text()='" +
|
|
responseType +
|
|
"']";
|
|
_queryRecordResult = (recordCount: number) =>
|
|
`//div/span[text()='Result:']/span[number(substring-before(normalize-space(text()), ' Record')) >= ${recordCount}]`;
|
|
_noRecordFound = "span[data-testid='no-data-table-message']";
|
|
_usePreparedStatement =
|
|
"input[name='actionConfiguration.pluginSpecifiedTemplates[0].value'][type='checkbox'], input[name='actionConfiguration.formData.preparedStatement.data'][type='checkbox']";
|
|
_mockDB = (dbName: string) =>
|
|
"//span[text()='" +
|
|
dbName +
|
|
"']/ancestor::div[contains(@class, 't--mock-datasource')][1]";
|
|
private _createBlankGraphQL = ".t--createBlankApiGraphqlCard";
|
|
private _graphQLHeaderKey = "input[name='headers[0].key']";
|
|
private _graphQLHeaderValue = "input[name='headers[0].value']";
|
|
_graphqlQueryEditor = ".t--graphql-query-editor";
|
|
_graphqlVariableEditor = ".t--graphql-variable-editor";
|
|
_graphqlPagination = {
|
|
_limitVariable: ".t--apiFormPaginationLimitVariable .rc-select-selector",
|
|
_limitValue: ".t--apiFormPaginationLimitValue .CodeMirror textarea",
|
|
_offsetVariable: ".t--apiFormPaginationOffsetVariable .rc-select-selector",
|
|
_offsetValue: ".t--apiFormPaginationOffsetValue .CodeMirror textarea",
|
|
_prevLimitVariable: ".t--apiFormPaginationPrevLimitVariable",
|
|
_prevLimitValue: ".t--apiFormPaginationPrevLimitValue .CodeMirror textarea",
|
|
_prevCursorVariable: ".t--apiFormPaginationPrevCursorVariable",
|
|
_prevCursorValue:
|
|
".t--apiFormPaginationPrevCursorValue .CodeMirror textarea",
|
|
_nextLimitVariable: ".t--apiFormPaginationNextLimitVariable",
|
|
_nextLimitValue: ".t--apiFormPaginationNextLimitValue .CodeMirror textarea",
|
|
_nextCursorVariable: ".t--apiFormPaginationNextCursorVariable",
|
|
_nextCursorValue:
|
|
".t--apiFormPaginationNextCursorValue .CodeMirror textarea",
|
|
};
|
|
_queryDoc = ".t--datasource-documentation-link";
|
|
_globalSearchModal = ".t--global-search-modal";
|
|
_globalSearchInput = ".t--global-search-input";
|
|
_gsScopeDropdown =
|
|
"[data-testid^='datasourceStorages.'][data-testid$='.datasourceConfiguration.authentication.scopeString']";
|
|
_gsScopeOptions = ".ads-v2-radio-group";
|
|
_queryTimeout = "//input[@name='actionConfiguration.timeoutInMillisecond']";
|
|
_getStructureReq = "/api/v1/datasources/*/structure?ignoreCache=true";
|
|
_editDatasourceFromActiveTab = (dsName: string) =>
|
|
".t--datasource-name:contains('" + dsName + "')";
|
|
_mandatoryMark = "//span[text()='*']";
|
|
_deleteDSHostPort = ".t--delete-field";
|
|
_dsTabSchema = "[data-testid='t--tab-SCHEMA_TAB']";
|
|
private _pageSelectionMenu = "[data-testId='t--page-selection']";
|
|
|
|
private _pageSelectMenuItem = ".ads-v2-menu__menu-item";
|
|
|
|
private _suggestedWidget = (widgetType: string, parentClass: string) =>
|
|
"//div[contains(@data-testid, '" +
|
|
parentClass +
|
|
"')]//div[contains(@data-testid, 't--suggested-widget-" +
|
|
widgetType +
|
|
"')]";
|
|
|
|
_noSchemaAvailable = (dbName: string) =>
|
|
"//div[text()='" +
|
|
dbName +
|
|
"']/ancestor::div[contains(@class, 't--entity-item')]/following-sibling::div//p[text()='Schema not available']";
|
|
// Authenticated API locators
|
|
public _authApiDatasource = ".t--createAuthApiDatasource";
|
|
private _authType = "[data-testid=authType]";
|
|
private _oauth2 = ".rc-select-item-option:contains('OAuth 2.0')";
|
|
private _accessTokenUrl =
|
|
"[data-testid='authentication.accessTokenUrl'] input";
|
|
private _clientID = "[data-testid='authentication.clientId'] input";
|
|
private _clientSecret = "[data-testid='authentication.clientSecret'] input";
|
|
private _clientCredentails =
|
|
".rc-select-item-option:contains('Client Credentials')";
|
|
private _authorizationCode =
|
|
".rc-select-item-option:contains('Authorization Code')";
|
|
private _grantType = "[data-testid='authentication.grantType']";
|
|
private _authorizationURL =
|
|
"[data-testid='authentication.authorizationUrl'] input";
|
|
_consent = '[name="confirm"]';
|
|
_consentSubmit = "//button[text()='Submit']";
|
|
public _datasourceModalSave = ".t--datasource-modal-save";
|
|
public _datasourceModalDoNotSave = ".t--datasource-modal-do-not-save";
|
|
public _cancelEditDatasourceButton = ".t--cancel-edit-datasource";
|
|
public _urlInputControl = "input[name='url']";
|
|
public _headerKey = "input[name='headers[0].key']";
|
|
public _mongoCollectionPath = "t--actionConfiguration.formData.collection";
|
|
_getJSONswitchLocator = (fieldName: string) =>
|
|
"//p[contains(text(),'" +
|
|
fieldName +
|
|
"')]/ancestor::div[@class='form-config-top']//button";
|
|
_nestedWhereClauseKey = (index: number) =>
|
|
".t--actionConfiguration\\.formData\\.where\\.data\\.children\\[" +
|
|
index +
|
|
"\\]\\.key";
|
|
_nestedWhereClauseValue = (index: number) =>
|
|
".t--actionConfiguration\\.formData\\.where\\.data\\.children\\[" +
|
|
index +
|
|
"\\]\\.value";
|
|
_whereDelete = (index: number) =>
|
|
"[data-testid='t--where-clause-delete-[" + index + "]']";
|
|
|
|
_bodyCodeMirror = "//div[contains(@class, 't--actionConfiguration.body')]";
|
|
private _reconnectModalDSToolTip = ".t--ds-list .t--ds-list-title";
|
|
private _reconnectModalDSToopTipIcon = ".t--ds-list .ads-v2-icon";
|
|
_multiSelectDropdown = (ddName: string) =>
|
|
"//p[contains(text(),'" +
|
|
ddName +
|
|
"')]/ancestor::div[@class='form-config-top']/following-sibling::div//div[contains(@class, 'rc-select-multiple')]";
|
|
private _datasourceSchemaRefreshBtn = ".datasourceStructure-refresh";
|
|
private _datasourceStructureHeader = ".datasourceStructure-header";
|
|
_datasourceSchemaColumn = ".t--datasource-column";
|
|
_datasourceStructureSearchInput = ".datasourceStructure-search input";
|
|
_jsModeSortingControl = ".t--actionConfiguration\\.formData\\.sortBy\\.data";
|
|
public _queryEditorCollapsibleIcon = ".collapsible-icon";
|
|
_globalSearchTrigger = ".t--global-search-modal-trigger";
|
|
_globalSearchOptions = ".t--searchHit";
|
|
private _dataSourceInfo = (dsName: string) =>
|
|
"//span[text()='" +
|
|
dsName +
|
|
"']/ancestor::div[contains(@class, 't--datasource')]//div[@data-testid='datasource-collapse-wrapper']";
|
|
_snippingBanner = ".t--sniping-mode-banner";
|
|
_s3CrudIcons = (
|
|
fieldName: string,
|
|
type: "Edit" | "Delete" | "CopyURL" | "Download",
|
|
) =>
|
|
"//span[text()='" +
|
|
fieldName +
|
|
"']/ancestor::div[@type='CANVAS_WIDGET'][1]//div[@data-widgetname-cy='" +
|
|
type +
|
|
"Icon']";
|
|
_s3EditFileName =
|
|
"[data-widgetname-cy='update_file_name'] div[data-testid='input-container']";
|
|
_s3MaxFileSizeAlert = "//p[@role='alert']";
|
|
_entityExplorerID = (dsName: string) =>
|
|
"[data-testid='t--entity-item-" + dsName + "']";
|
|
_stagingTab = "[data-testid='t--ds-data-filter-Staging']";
|
|
_graphQlDsHintOption = (dsName: string) =>
|
|
"//div/span[text() ='" + dsName + "']";
|
|
_imgFireStoreLogo = "//img[contains(@src, 'firestore.svg')]";
|
|
_dsVirtuosoElement = `div .t--schema-virtuoso-container`;
|
|
private _dsVirtuosoList = `[data-test-id="virtuoso-item-list"]`;
|
|
private _dsSchemaContainer = `[data-testId="datasource-schema-container"]`;
|
|
private _dsVirtuosoElementTable = (targetTableName: string) =>
|
|
`${this._dsSchemaEntityItem}[data-testid='t--entity-item-${targetTableName}']`;
|
|
private _dsPageTabListItem = (buttonText: string) =>
|
|
`//div[contains(@class, 't--datasource-tab-list')]/button/span[text()='${buttonText}']`;
|
|
_dsPageTabContainerTableName = (tableName: string) =>
|
|
`.t--datasource-tab-container ${this._entityExplorerID(tableName)}`;
|
|
_dsPageTableTriggermenuTarget = (tableName: string) =>
|
|
`${this._dsPageTabContainerTableName(tableName)} ${
|
|
this._entityTriggerElement
|
|
}`;
|
|
_gSheetQueryPlaceholder = ".CodeMirror-placeholder";
|
|
_dsStructurePreviewMode = ".datasourceStructure-datasource-view-mode";
|
|
private _dsSchemaEntityItem = ".t--entity-item";
|
|
private _entityTriggerElement = ".t--template-menu-trigger";
|
|
_dsSchemaTableResponse = ".t--table-response";
|
|
|
|
public AssertDSEditViewMode(mode: AppModes) {
|
|
if (mode == "Edit") this.agHelper.AssertElementAbsence(this._editButton);
|
|
else if (mode == "View") this.agHelper.AssertElementExist(this._editButton);
|
|
}
|
|
|
|
public GeneratePageWithDB(datasourceName: any, tableName: string) {
|
|
PageList.AddNewPage("Generate page with data");
|
|
this.agHelper.GetNClick(this._selectDatasourceDropdown);
|
|
this.agHelper.GetNClickByContains(
|
|
this.locator._dropdownText,
|
|
datasourceName,
|
|
);
|
|
this.agHelper.GetNClick(this._selectTableDropdown, 0, true);
|
|
cy.get(
|
|
`div[role="listbox"] p[kind="span"]:contains("${tableName}")`,
|
|
).click();
|
|
this.agHelper.GetNClick(this._generatePageBtn);
|
|
this.assertHelper.AssertNetworkStatus("@replaceLayoutWithCRUDPage", 201);
|
|
this.agHelper.ClickButton("Got it");
|
|
}
|
|
|
|
public GeneratePageWithMockDB() {
|
|
PageList.AddNewPage("Generate page with data");
|
|
this.agHelper.GetNClick(this._selectDatasourceDropdown);
|
|
this.agHelper.GetNClickByContains(
|
|
this._dropdownOption,
|
|
"Connect new datasource",
|
|
);
|
|
this.agHelper.GetNClick(this._mockDB("Users"));
|
|
this.agHelper.Sleep(500);
|
|
this.assertHelper.AssertNetworkStatus("@getDatasourceStructure"); //Making sure table dropdown is populated
|
|
this.agHelper.GetNClick(this._selectTableDropdown, 0, true);
|
|
this.agHelper.GetNClickByContains(this._dropdownOption, "public.users");
|
|
this.agHelper.GetNClick(this._generatePageBtn, 0, true);
|
|
this.assertHelper.AssertNetworkStatus("@replaceLayoutWithCRUDPage", 201);
|
|
this.agHelper.ClickButton("Got it");
|
|
}
|
|
|
|
public StartDataSourceRoutes() {
|
|
cy.intercept("POST", "/api/v1/datasources").as("saveDatasource");
|
|
cy.intercept("POST", "/api/v1/datasources/test").as("testDatasource");
|
|
cy.intercept("PUT", "/api/v1/datasources/*").as("updateDatasource");
|
|
}
|
|
|
|
private ReplaceApplicationIdForInterceptPages(fixtureFile: any) {
|
|
let currentAppId, currentURL;
|
|
cy.readFile(
|
|
fixtureFile,
|
|
// (err: string) => {
|
|
// if (err) {
|
|
// return console.error(err);
|
|
// }}
|
|
).then((data) => {
|
|
cy.url().then((url) => {
|
|
currentURL = url;
|
|
const myRegexp = /applications(.*)/;
|
|
const match = myRegexp.exec(currentURL);
|
|
currentAppId = match ? match[1].split("/")[1] : null;
|
|
data.data.page.applicationId = currentAppId;
|
|
cy.writeFile(fixtureFile, JSON.stringify(data));
|
|
});
|
|
});
|
|
}
|
|
|
|
public StartInterceptRoutesForMySQL() {
|
|
//All stubbing - updating app id to current app id for Delete app by api call to be successfull:
|
|
|
|
this.ReplaceApplicationIdForInterceptPages(
|
|
"cypress/fixtures/mySQL_PUT_replaceLayoutWithCRUD.json",
|
|
);
|
|
|
|
cy.intercept("POST", "/api/v1/datasources/test", {
|
|
fixture: "testAction.json",
|
|
}).as("testDatasource");
|
|
cy.intercept("GET", "/api/v1/datasources/*/structure?ignoreCache=*", {
|
|
fixture: "mySQL_GET_selectTableDropdown.json",
|
|
}).as("getDatasourceStructure");
|
|
cy.intercept("PUT", "/api/v1/pages/crud-page/*", {
|
|
fixture: "mySQL_PUT_replaceLayoutWithCRUD.json",
|
|
}).as("replaceLayoutWithCRUDPage");
|
|
cy.intercept("GET", "/api/v1/actions*", {
|
|
fixture: "mySQL_GET_Actions.json",
|
|
}).as("getActions");
|
|
cy.intercept("POST", "/api/v1/actions/execute", {
|
|
fixture: "mySQL_POST_Execute.json",
|
|
}).as("postExecute");
|
|
cy.intercept("POST", "/api/v1/pages/crud-page", {
|
|
fixture: "mySQL_PUT_replaceLayoutWithCRUD.json",
|
|
}).as("replaceLayoutWithCRUDPage");
|
|
}
|
|
|
|
public StartInterceptRoutesForMongo() {
|
|
//All stubbing
|
|
this.ReplaceApplicationIdForInterceptPages(
|
|
"cypress/fixtures/mongo_PUT_replaceLayoutWithCRUD.json",
|
|
);
|
|
|
|
cy.intercept("POST", "/api/v1/datasources/test", {
|
|
fixture: "testAction.json",
|
|
}).as("testDatasource");
|
|
cy.intercept("GET", "/api/v1/datasources/*/structure?ignoreCache=*", {
|
|
fixture: "mongo_GET_selectTableDropdown.json",
|
|
}).as("getDatasourceStructure");
|
|
cy.intercept("PUT", "/api/v1/pages/crud-page/*", {
|
|
fixture: "mongo_PUT_replaceLayoutWithCRUD.json",
|
|
}).as("replaceLayoutWithCRUDPage");
|
|
cy.intercept("GET", "/api/v1/actions*", {
|
|
fixture: "mongo_GET_Actions.json",
|
|
}).as("getActions");
|
|
cy.intercept("POST", "/api/v1/actions/execute", {
|
|
fixture: "mongo_POST_Actions.json",
|
|
}).as("postExecute");
|
|
cy.intercept("POST", "/api/v1/pages/crud-page", {
|
|
fixture: "mongo_PUT_replaceLayoutWithCRUD.json",
|
|
}).as("post_replaceLayoutCRUDStub");
|
|
}
|
|
|
|
public StartInterceptRoutesForFirestore() {
|
|
//All stubbing
|
|
cy.intercept("POST", "/api/v1/datasources/test", {
|
|
fixture: "testAction.json",
|
|
}).as("testDatasource");
|
|
}
|
|
|
|
public CreatePlugIn(
|
|
pluginName: string,
|
|
waitForToastDisappear = false,
|
|
index = 0,
|
|
) {
|
|
cy.get(this._createNewPlgin(pluginName))
|
|
.parent("div")
|
|
.eq(index)
|
|
.trigger("click", { force: true });
|
|
this.agHelper.Sleep();
|
|
//this.agHelper.WaitUntilEleAppear(this.locator._toastMsg);
|
|
this.agHelper.AssertElementAbsence(
|
|
this.locator._specificToast("Duplicate key error"),
|
|
);
|
|
this.agHelper.PressEscape();
|
|
// if (waitForToastDisappear)
|
|
// this.agHelper.WaitUntilToastDisappear("datasource created");
|
|
// else this.agHelper.AssertContains("datasource created");
|
|
}
|
|
|
|
public EditDatasource() {
|
|
this.agHelper.GetNClick(this._editButton);
|
|
}
|
|
|
|
public NavigateToDSCreateNew() {
|
|
AppSidebar.navigate(AppSidebarButton.Data);
|
|
cy.get("body").then(($body) => {
|
|
if ($body.find(this._addNewDataSource).length > 0) {
|
|
this.agHelper.GetNClick(this._addNewDataSource, 0, true);
|
|
} else {
|
|
this.agHelper.GetNClick(this._addNewDatasourceFromBlankScreen, 0, true);
|
|
}
|
|
});
|
|
this.agHelper.AssertElementVisibility(this._newDatabases);
|
|
}
|
|
|
|
CreateMockDB(dbName: "Users" | "Movies"): Cypress.Chainable<string> {
|
|
this.NavigateToDSCreateNew();
|
|
cy.get(this._mockDatasourceName)
|
|
.contains(dbName, { matchCase: false })
|
|
.click();
|
|
this.assertHelper.AssertNetworkStatus("@getMockDb"); //To return the right mock DB name
|
|
return cy
|
|
.get("@getMockDb")
|
|
.then(($createdMock: any) => $createdMock.response?.body.data.name);
|
|
}
|
|
|
|
public FillPostgresDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
shouldAddTrailingSpaces = false,
|
|
username = "",
|
|
password = "",
|
|
) {
|
|
const hostAddress = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].postgres_host + " "
|
|
: this.dataManager.dsValues[environment].postgres_host;
|
|
const databaseName = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].postgres_databaseName + " "
|
|
: this.dataManager.dsValues[environment].postgres_databaseName;
|
|
this.ValidateNSelectDropdown("Connection mode", "Read / Write");
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].postgres_port.toString(),
|
|
);
|
|
this.agHelper.ClearNType(this._host(), hostAddress);
|
|
this.agHelper.ClearNType(this._databaseName, databaseName);
|
|
|
|
this.agHelper.ClearNType(
|
|
this._username,
|
|
username == ""
|
|
? this.dataManager.dsValues[environment].postgres_username
|
|
: username,
|
|
);
|
|
|
|
this.agHelper.ClearNType(
|
|
this._password,
|
|
password == ""
|
|
? this.dataManager.dsValues[environment].postgres_password
|
|
: password,
|
|
);
|
|
this.ValidateNSelectDropdown("SSL mode", "Default");
|
|
}
|
|
|
|
public ValidatePostgresDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
const databaseName =
|
|
this.dataManager.dsValues[environment].postgres_databaseName;
|
|
this.agHelper.AssertContains(databaseName, "exist", this._dsReviewSection);
|
|
}
|
|
|
|
public ValidateMongoForm(environment = this.dataManager.defaultEnviorment) {
|
|
const databaseName =
|
|
this.dataManager.dsValues[environment].mongo_databaseName;
|
|
this.agHelper.AssertContains(this._dsReviewSection, databaseName);
|
|
}
|
|
|
|
public FillOracleDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
shouldAddTrailingSpaces = false,
|
|
username = "",
|
|
password = "",
|
|
) {
|
|
const hostAddress = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].oracle_host + " "
|
|
: this.dataManager.dsValues[environment].oracle_host;
|
|
const databaseName = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].oracle_service + " "
|
|
: this.dataManager.dsValues[environment].oracle_service;
|
|
this.agHelper.ClearNType(this._host(), hostAddress);
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].oracle_port.toString(),
|
|
);
|
|
this.agHelper.ClearNType(this._databaseName, databaseName);
|
|
this.agHelper.ClearNType(
|
|
this._username,
|
|
username == ""
|
|
? this.dataManager.dsValues[environment].oracle_username
|
|
: username,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._password,
|
|
password == ""
|
|
? this.dataManager.dsValues[environment].oracle_password
|
|
: password,
|
|
);
|
|
}
|
|
|
|
public FillMongoDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
shouldAddTrailingSpaces = false,
|
|
) {
|
|
const hostAddress = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].mongo_host + " "
|
|
: this.dataManager.dsValues[environment].mongo_host;
|
|
this.ValidateNSelectDropdown("Connection mode", "Read / Write");
|
|
this.agHelper.ClearNType(this._host(), hostAddress);
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].mongo_port.toString(),
|
|
);
|
|
this.agHelper.ClearTextField(this._databaseName);
|
|
const databaseName = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].mongo_databaseName + " "
|
|
: this.dataManager.dsValues[environment].mongo_databaseName;
|
|
this.agHelper.TypeText(this._databaseName, databaseName);
|
|
}
|
|
|
|
public FillMySqlDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
shouldAddTrailingSpaces = false,
|
|
) {
|
|
const hostAddress = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].mysql_host + " "
|
|
: this.dataManager.dsValues[environment].mysql_host;
|
|
const databaseName = shouldAddTrailingSpaces
|
|
? this.dataManager.dsValues[environment].mysql_databaseName + " "
|
|
: this.dataManager.dsValues[environment].mysql_databaseName;
|
|
|
|
this.agHelper.ClearNType(this._host(), hostAddress);
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].mysql_port.toString(),
|
|
);
|
|
this.agHelper.ClearNType(this._databaseName, databaseName);
|
|
this.agHelper.ClearNType(
|
|
this._username,
|
|
this.dataManager.dsValues[environment].mysql_username,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._password,
|
|
this.dataManager.dsValues[environment].mysql_password,
|
|
);
|
|
}
|
|
|
|
public FillMsSqlDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
leaveDBNameEmpty = true,
|
|
) {
|
|
this.agHelper.ClearNType(
|
|
this._host(),
|
|
this.dataManager.dsValues[environment].mssql_host,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].mssql_port.toString(),
|
|
);
|
|
|
|
if (leaveDBNameEmpty) {
|
|
this.agHelper.ClearTextField(this._databaseName);
|
|
} else {
|
|
const databaseName =
|
|
this.dataManager.dsValues[environment].mssql_databaseName;
|
|
this.agHelper.ClearNType(this._databaseName, databaseName);
|
|
}
|
|
this.agHelper.ClearNType(
|
|
this._username,
|
|
this.dataManager.dsValues[environment].mssql_username,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._password,
|
|
this.dataManager.dsValues[environment].mssql_password,
|
|
);
|
|
}
|
|
|
|
public FillAirtableDSForm() {
|
|
this.ValidateNSelectDropdown(
|
|
"Authentication type",
|
|
"Please select an option",
|
|
"Personal access token",
|
|
);
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Bearer token") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
Cypress.env("AIRTABLE_BEARER"),
|
|
);
|
|
this.agHelper.Sleep();
|
|
}
|
|
|
|
public FillArangoDSForm(environment = this.dataManager.defaultEnviorment) {
|
|
this.agHelper.ClearNType(
|
|
this._host(),
|
|
this.dataManager.dsValues[environment].arango_host,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].arango_port.toString(),
|
|
);
|
|
//Validating db name is _system, currently unable to create DB via curl in Arango
|
|
this.agHelper
|
|
.GetText(this._databaseName, "val")
|
|
.then(($dbName) => expect($dbName).to.eq("_system"));
|
|
this.agHelper.ClearNType(
|
|
this._username,
|
|
this.dataManager.dsValues[environment].arango_username,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._password,
|
|
this.dataManager.dsValues[environment].arango_password,
|
|
);
|
|
}
|
|
|
|
public FillFirestoreDSForm(environment = this.dataManager.defaultEnviorment) {
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Database URL") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
this.dataManager.dsValues[environment].firestore_database_url,
|
|
);
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Project Id") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
this.dataManager.dsValues[environment].firestore_projectID,
|
|
);
|
|
this.agHelper.UpdateFieldInput(
|
|
this.locator._inputFieldByName("Service account credentials"),
|
|
JSON.stringify(
|
|
this.dataManager.dsValues[environment].firestore_serviceaccountkey,
|
|
),
|
|
);
|
|
}
|
|
|
|
public FillElasticSearchDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
this.agHelper.ClearNType(
|
|
this._host(),
|
|
this.dataManager.dsValues[environment].elastic_host,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].elastic_port.toString(),
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._username,
|
|
this.dataManager.dsValues[environment].elastic_username,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._password,
|
|
this.dataManager.dsValues[environment].elastic_password,
|
|
);
|
|
}
|
|
|
|
public FillUnAuthenticatedGraphQLDSForm(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
enterOrSelectUrl: "enter" | "select" = "enter",
|
|
dsNameToSelect = "",
|
|
) {
|
|
this.agHelper.GetNClick(this._createBlankGraphQL);
|
|
cy.get("@guid").then((uid) => {
|
|
this.agHelper.RenameWithInPane("GraphQL_API" + "_" + uid, true);
|
|
|
|
if (enterOrSelectUrl == "enter")
|
|
this.apiPage.EnterURL(
|
|
this.dataManager.dsValues[environment].GraphqlApiUrl_TED,
|
|
);
|
|
else if (enterOrSelectUrl == "select") {
|
|
this.agHelper.GetNClick(this.apiPage._resourceUrl);
|
|
this.agHelper.GetNClick(this._graphQlDsHintOption(dsNameToSelect));
|
|
}
|
|
|
|
this.assertHelper.AssertNetworkStatus("@createNewApi", 201);
|
|
cy.wrap("GraphQL_API" + "_" + uid).as("dsName");
|
|
});
|
|
}
|
|
|
|
public FillAuthenticatedGrapgQLURL(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("URL") + "//" + this.locator._inputField,
|
|
this.dataManager.dsValues[environment].GraphqlApiUrl_TED,
|
|
);
|
|
}
|
|
|
|
public CreateNFillAuthenticatedGraphQLDSForm(
|
|
dataSourceName: string,
|
|
hKey: string,
|
|
hValue: string,
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
this.FillAuthenticatedGrapgQLURL(environment);
|
|
|
|
this.agHelper.ClearNType(this._graphQLHeaderKey, hKey);
|
|
this.agHelper.ClearNType(this._graphQLHeaderValue, hValue);
|
|
cy.get("@guid").then((uid: any) => {
|
|
dataSourceName = dataSourceName + " " + uid;
|
|
this.agHelper.RenameWithInPane(dataSourceName, false);
|
|
this.SaveDatasource();
|
|
cy.wrap(dataSourceName).as("dsName");
|
|
});
|
|
}
|
|
|
|
public FillRedisDSForm(environment = this.dataManager.defaultEnviorment) {
|
|
this.agHelper.ClearNType(
|
|
this._host(),
|
|
this.dataManager.dsValues[environment].redis_host,
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._port,
|
|
this.dataManager.dsValues[environment].redis_port.toString(),
|
|
);
|
|
}
|
|
|
|
public FillS3DSForm() {
|
|
this.agHelper.ClearNType(this._username, Cypress.env("S3_ACCESS_KEY"));
|
|
this.agHelper.ClearNType(this._password, Cypress.env("S3_SECRET_KEY"));
|
|
}
|
|
|
|
public FillTwilioDSForm(environment = this.dataManager.defaultEnviorment) {
|
|
this.ValidateNSelectDropdown("Authentication type", "", "Basic auth");
|
|
this.agHelper.ClearNType(
|
|
this._username,
|
|
this.dataManager.dsValues[environment].twilio_username.toString(),
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this._password,
|
|
this.dataManager.dsValues[environment].twilio_password.toString(),
|
|
);
|
|
}
|
|
|
|
public TestSaveDatasource(expectedRes = true, isReconnectModal = false) {
|
|
this.TestDatasource(expectedRes);
|
|
this.SaveDatasource(isReconnectModal);
|
|
}
|
|
|
|
public TestDatasource(expectedRes = true) {
|
|
this.agHelper.Sleep(500); //bit of time for CI!
|
|
this.agHelper.GetNClick(this._testDs, 0, false, 0);
|
|
this.agHelper.AssertNetworkDataSuccess("@testDatasource", expectedRes);
|
|
if (expectedRes) {
|
|
this.agHelper.AssertContains("datasource is valid");
|
|
}
|
|
}
|
|
|
|
public SaveDatasource(isReconnectModal = false, isSavingEnvInOldDS = false) {
|
|
this.agHelper.Sleep(500); //bit of time for CI!
|
|
this.agHelper.GetNClick(this._saveDs);
|
|
if (!isReconnectModal) {
|
|
this.assertHelper.AssertNetworkStatus("@saveDatasource", 201);
|
|
if (!isSavingEnvInOldDS)
|
|
this.agHelper.AssertContains("datasource created");
|
|
} else {
|
|
this.assertHelper.AssertNetworkStatus("@updateDatasource", 200);
|
|
}
|
|
}
|
|
|
|
public AssertSaveDSButtonDisability(isDisabled = true) {
|
|
this.agHelper.AssertElementEnabledDisabled(this._saveDs, 0, isDisabled);
|
|
}
|
|
|
|
public AuthAPISaveAndAuthorize() {
|
|
cy.get(this._saveDs).click();
|
|
this.assertHelper.AssertNetworkStatus("@saveDatasource", 201);
|
|
}
|
|
|
|
public UpdateDatasource() {
|
|
this.agHelper.GetNClick(this._saveDs);
|
|
// this.assertHelper.AssertNetworkStatus("@updateDatasource", 200);
|
|
this.agHelper.AssertContains("datasource updated");
|
|
}
|
|
|
|
public DeleteDatasourceFromWithinDS(
|
|
datasourceName: string,
|
|
expectedRes: number | number[] = 200 || 409 || [200, 409],
|
|
) {
|
|
EditorNavigation.SelectEntityByName(datasourceName, EntityType.Datasource);
|
|
this.agHelper.Sleep(); //for the Datasource page to open
|
|
this.DeleteDSDirectly(expectedRes, false);
|
|
}
|
|
|
|
// this initiates saving via the cancel button.
|
|
public cancelDSEditAndAssertModalPopUp(
|
|
shouldPopUpBeShown = false,
|
|
shouldSave = false,
|
|
) {
|
|
// click cancel button.
|
|
this.agHelper.GetNClick(this._cancelEditDatasourceButton, 0, false, 200);
|
|
|
|
if (shouldPopUpBeShown) {
|
|
this.AssertDatasourceSaveModalVisibilityAndSave(shouldSave);
|
|
} else {
|
|
this.AssertDSDialogVisibility(false);
|
|
}
|
|
}
|
|
|
|
public DeleteDSDirectly(
|
|
expectedRes: number | number[] = 200 || 409 || [200, 409],
|
|
toNavigateToDSInfoPage = true,
|
|
) {
|
|
toNavigateToDSInfoPage &&
|
|
this.agHelper.GetNClick(this._cancelEditDatasourceButton, 0, true, 200);
|
|
this.agHelper.GetNClick(this._contextMenuDSReviewPage);
|
|
this.agHelper.GetNClick(this._contextMenuDelete);
|
|
this.agHelper.GetNClick(this.locator._visibleTextSpan("Are you sure?"));
|
|
this.ValidateDSDeletion(expectedRes);
|
|
}
|
|
|
|
public ValidateDSDeletion(expectedRes: number | number[] = 200) {
|
|
this.assertHelper
|
|
.AssertNetworkStatus("@deleteDatasource", expectedRes)
|
|
.then((responseStatus) => {
|
|
this.agHelper.AssertContains(
|
|
responseStatus === 200
|
|
? "datasource deleted successfully"
|
|
: "Cannot delete datasource",
|
|
);
|
|
});
|
|
}
|
|
|
|
public AssertDSInActiveList(dsName: string | RegExp) {
|
|
AppSidebar.navigate(AppSidebarButton.Data);
|
|
return this.agHelper.GetNAssertContains(this._datasourceCard, dsName);
|
|
}
|
|
|
|
CreateQueryAfterDSSaved(query = "", queryName = "") {
|
|
this.agHelper.GetNClick(this._createQuery);
|
|
// Check if page selection is open (when multiple pages in app)
|
|
cy.get("body").then(($body) => {
|
|
if ($body.find(this._pageSelectionMenu).length > 0) {
|
|
// Select the current page
|
|
cy.get(this._pageSelectionMenu)
|
|
.find(this._pageSelectMenuItem)
|
|
.first()
|
|
.click();
|
|
}
|
|
});
|
|
//this.assertHelper.AssertNetworkStatus("@createNewApi", 201);
|
|
this.AssertRunButtonVisibility();
|
|
if (queryName) this.agHelper.RenameWithInPane(queryName);
|
|
if (query) {
|
|
this.EnterQuery(query);
|
|
this.AssertRunButtonDisability(false);
|
|
}
|
|
}
|
|
|
|
public AssertRunButtonVisibility() {
|
|
this.agHelper.AssertElementVisibility(
|
|
this.locator._buttonByText("Run"),
|
|
true,
|
|
0,
|
|
20000,
|
|
);
|
|
}
|
|
|
|
public CreateQueryForDS(
|
|
datasourceName: string,
|
|
query = "",
|
|
queryName = "",
|
|
cancelEditDs = true,
|
|
) {
|
|
EditorNavigation.SelectEntityByName(datasourceName, EntityType.Datasource);
|
|
if (cancelEditDs) {
|
|
this.cancelIfEditing();
|
|
}
|
|
this.CreateQueryAfterDSSaved(query, queryName);
|
|
}
|
|
|
|
public GeneratePageForDS(datasourceName: string) {
|
|
EditorNavigation.SelectEntityByName(datasourceName, EntityType.Datasource);
|
|
this.cancelIfEditing();
|
|
this.agHelper.GetNClick(this._datasourceCardGeneratePageBtn);
|
|
}
|
|
|
|
private cancelIfEditing() {
|
|
cy.get("body").then(($body) => {
|
|
if ($body.find(this._cancelEditDatasourceButton).length > 0) {
|
|
this.agHelper.GetNClick(this._cancelEditDatasourceButton, 0, true, 200);
|
|
}
|
|
});
|
|
}
|
|
|
|
DeleteQuery(queryName: string) {
|
|
PageLeftPane.switchSegment(PagePaneSegment.Queries);
|
|
this.entityExplorer.ActionContextMenuByEntityName({
|
|
entityNameinLeftSidebar: queryName,
|
|
action: "Delete",
|
|
entityType: EntityItems.Query,
|
|
});
|
|
}
|
|
|
|
public ValidateNSelectDropdown(
|
|
ddTitle: string,
|
|
currentValue: string,
|
|
newValue = "",
|
|
) {
|
|
if (currentValue)
|
|
cy.xpath(this._visibleTextSpan(currentValue))
|
|
//.scrollIntoView()
|
|
.should("exist", currentValue + " dropdown value not present");
|
|
if (newValue != "") {
|
|
this.agHelper.GetNClick(this._dropdownTitle(ddTitle));
|
|
//cy.xpath(this._dropdown(currentValue)).last().click({ force: true });
|
|
//to expand the dropdown
|
|
//this.agHelper.GetNClick(this._queryOption(newValue))
|
|
cy.xpath(this._queryOption(newValue)).last().click({ force: true }); //to select the new value
|
|
}
|
|
}
|
|
|
|
public ValidateReviewModeConfig(
|
|
dsName: "PostgreSQL" | "MongoDB",
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
if (dsName === "PostgreSQL") {
|
|
this.ValidatePostgresDSForm(environment);
|
|
} else if (dsName === "MongoDB") {
|
|
this.ValidateMongoForm(environment);
|
|
}
|
|
}
|
|
|
|
public ReconnectSingleDSNAssert(
|
|
dbName: string,
|
|
dsName: "PostgreSQL" | "MySQL" | "MongoDB",
|
|
) {
|
|
this.ReconnectModalValidation(dbName, dsName);
|
|
if (dsName == "PostgreSQL") this.FillPostgresDSForm();
|
|
else if (dsName == "MySQL") this.FillMySqlDSForm();
|
|
else if (dsName == "MongoDB") this.FillMongoDSForm();
|
|
this.TestSaveDatasource(true, true);
|
|
this.assertHelper.AssertNetworkStatus("@getConsolidatedData", 200);
|
|
this.assertHelper.AssertNetworkStatus("getWorkspace");
|
|
}
|
|
|
|
public ReconnectModalValidation(
|
|
dbName: string,
|
|
dsName: "PostgreSQL" | "MySQL" | "MongoDB",
|
|
) {
|
|
this.WaitForReconnectModalToAppear();
|
|
this.agHelper.AssertElementVisibility(
|
|
this._activeDSListReconnectModal(dsName),
|
|
);
|
|
this.agHelper.AssertElementVisibility(
|
|
this._activeDSListReconnectModal(dbName),
|
|
);
|
|
|
|
//Checking if tooltip for Ds name & icon is present (useful in cases of long name for ds)
|
|
this.agHelper.AssertText(this._reconnectModalDSToolTip, "text", dbName);
|
|
this.agHelper.AssertElementVisibility(this._reconnectModalDSToopTipIcon);
|
|
}
|
|
|
|
public WaitForReconnectModalToAppear() {
|
|
this.agHelper.AssertElementVisibility(this._reconnectModal);
|
|
this.agHelper.AssertElementVisibility(this._testDs); //Making sure modal is fully loaded
|
|
}
|
|
|
|
public ReconnectDSbyType(
|
|
dsName: "PostgreSQL" | "MySQL" | "MongoDB" | "S3" | "MongoDBUri",
|
|
) {
|
|
this.WaitForReconnectModalToAppear();
|
|
|
|
if (dsName !== "MongoDBUri")
|
|
this.agHelper.GetNClick(this.locator._visibleTextSpan(dsName));
|
|
else if (dsName == "MongoDBUri")
|
|
this.agHelper.GetNClick(this.locator._visibleTextSpan("MongoDB"));
|
|
|
|
const methodMap = {
|
|
PostgreSQL: this.FillPostgresDSForm,
|
|
MySQL: this.FillMySqlDSForm,
|
|
MongoDB: this.FillMongoDSForm,
|
|
S3: this.FillS3DSForm,
|
|
MongoDBUri: this.FillMongoDatasourceFormWithURI,
|
|
};
|
|
if (methodMap[dsName]) {
|
|
methodMap[dsName].call(this);
|
|
}
|
|
this.SaveDatasource(true);
|
|
}
|
|
|
|
RunQuery({
|
|
expectedStatus = true,
|
|
toValidateResponse = true,
|
|
waitTimeInterval = 500,
|
|
}: Partial<RunQueryParams> = {}) {
|
|
this.AssertRunButtonDisability(false);
|
|
this.agHelper.GetNClick(this._runQueryBtn, 0, true, waitTimeInterval);
|
|
this.agHelper.AssertElementAbsence(
|
|
this.locator._cancelActionExecution,
|
|
10000,
|
|
); //For the run to give response
|
|
if (toValidateResponse) {
|
|
this.agHelper.Sleep();
|
|
this.assertHelper.AssertNetworkExecutionSuccess(
|
|
"@postExecute",
|
|
expectedStatus,
|
|
);
|
|
}
|
|
}
|
|
|
|
AssertRunButtonDisability(disabled = false) {
|
|
this.agHelper.AssertElementEnabledDisabled(this._runQueryBtn, 0, disabled);
|
|
}
|
|
|
|
public ReadQueryTableResponse(index: number, timeout = 100) {
|
|
//timeout can be sent higher values incase of larger tables
|
|
this.agHelper.Sleep(timeout); //Settling time for table!
|
|
return cy.xpath(this._queryTableResponse).eq(index).invoke("text");
|
|
}
|
|
|
|
public AssertQueryTableResponse(
|
|
index: number,
|
|
expectedValue: string,
|
|
timeout = 100,
|
|
) {
|
|
this.ReadQueryTableResponse(index, timeout).then(($cellData: any) => {
|
|
expect($cellData).to.eq(expectedValue);
|
|
});
|
|
}
|
|
|
|
public AssertQueryResponseHeaders(columnHeaders: string[]) {
|
|
columnHeaders.forEach(($header) =>
|
|
this.agHelper.AssertElementVisibility(this._queryResponseHeader($header)),
|
|
);
|
|
}
|
|
|
|
public AssertJSONFormHeader(
|
|
rowindex: number,
|
|
colIndex: number,
|
|
headerString: string,
|
|
validateCellData: "" | string = "",
|
|
isMongo = false,
|
|
) {
|
|
let jsonHeaderString = "";
|
|
this.table
|
|
.ReadTableRowColumnData(rowindex, colIndex, "v2")
|
|
.then(($cellData) => {
|
|
if (validateCellData) expect($cellData).to.eq(validateCellData);
|
|
|
|
jsonHeaderString =
|
|
isMongo == true
|
|
? "Update Document " + headerString + ": " + $cellData
|
|
: "Update Row " + headerString + ": " + $cellData;
|
|
this.agHelper
|
|
.GetText(this.locator._jsonFormHeader)
|
|
.then(($header: any) => expect($header).to.eq(jsonHeaderString));
|
|
});
|
|
}
|
|
|
|
ToggleUsePreparedStatement(enable = true || false) {
|
|
this.apiPage.SelectPaneTab("Settings");
|
|
if (enable) this.agHelper.CheckUncheck(this._usePreparedStatement, true);
|
|
else this.agHelper.CheckUncheck(this._usePreparedStatement, false);
|
|
this.apiPage.SelectPaneTab("Query");
|
|
}
|
|
|
|
public EnterQuery(query: string, sleep = 500, toVerifySave = true) {
|
|
this.agHelper.UpdateCodeInput(
|
|
this.locator._codeEditorTarget,
|
|
query,
|
|
"query",
|
|
);
|
|
toVerifySave && this.agHelper.AssertAutoSave();
|
|
this.agHelper.Sleep(sleep); //waiting a bit before proceeding!
|
|
this.assertHelper.AssertNetworkStatus("@saveAction", 200);
|
|
}
|
|
|
|
public RunQueryNVerifyResponseViews(
|
|
expectedRecordsCount = 1,
|
|
tableCheck = true,
|
|
) {
|
|
this.RunQuery();
|
|
tableCheck &&
|
|
this.agHelper.AssertElementVisibility(this._queryResponse("TABLE"));
|
|
this.agHelper.AssertElementVisibility(this._queryResponse("JSON"));
|
|
this.agHelper.AssertElementVisibility(this._queryResponse("RAW"));
|
|
this.CheckResponseRecordsCount(expectedRecordsCount);
|
|
}
|
|
|
|
public CheckResponseRecordsCount(expectedRecordCount: number) {
|
|
this.agHelper.AssertElementVisibility(
|
|
this._queryRecordResult(expectedRecordCount),
|
|
);
|
|
}
|
|
|
|
public CreateDataSource(
|
|
dsType:
|
|
| "Postgres"
|
|
| "Mongo"
|
|
| "MySql"
|
|
| "UnAuthenticatedGraphQL"
|
|
| "AuthenticatedGraph"
|
|
| "MsSql"
|
|
| "Airtable"
|
|
| "ArangoDB"
|
|
| "Firestore"
|
|
| "Elasticsearch"
|
|
| "Redis"
|
|
| "Oracle"
|
|
| "S3"
|
|
| "Twilio",
|
|
navigateToCreateNewDs = true,
|
|
testNSave = true,
|
|
environment = this.dataManager.defaultEnviorment,
|
|
assetEnvironmentSelected = false,
|
|
// function to be executed before filling the datasource form
|
|
preDSConfigAction?: (arg?: string) => void,
|
|
) {
|
|
let guid: any;
|
|
let dataSourceName = "";
|
|
this.agHelper.GenerateUUID();
|
|
navigateToCreateNewDs && this.NavigateToDSCreateNew();
|
|
|
|
cy.get("@guid").then((uid) => {
|
|
if (DataSourceKVP[dsType] != "GraphQL API") {
|
|
this.CreatePlugIn(DataSourceKVP[dsType]);
|
|
guid = uid;
|
|
dataSourceName = dsType + " " + guid;
|
|
this.agHelper.RenameWithInPane(dataSourceName, false);
|
|
// Execute the preDSConfigAction if it is defined
|
|
if (!!preDSConfigAction) {
|
|
preDSConfigAction.bind(this)(environment);
|
|
}
|
|
if (assetEnvironmentSelected) {
|
|
this.agHelper.AssertSelectedTab(
|
|
this.locator.ds_editor_env_filter(environment),
|
|
"true",
|
|
);
|
|
}
|
|
if (DataSourceKVP[dsType] == "PostgreSQL")
|
|
this.FillPostgresDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "Oracle")
|
|
this.FillOracleDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "MySQL")
|
|
this.FillMySqlDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "MongoDB")
|
|
this.FillMongoDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "Microsoft SQL Server")
|
|
this.FillMsSqlDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "Airtable") this.FillAirtableDSForm();
|
|
else if (DataSourceKVP[dsType] == "ArangoDB")
|
|
this.FillArangoDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "Firestore")
|
|
this.FillFirestoreDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "Elasticsearch")
|
|
this.FillElasticSearchDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "Redis")
|
|
this.FillRedisDSForm(environment);
|
|
else if (DataSourceKVP[dsType] == "S3") this.FillS3DSForm();
|
|
else if (DataSourceKVP[dsType] == "Twilio") this.FillTwilioDSForm();
|
|
else if (DataSourceKVP[dsType] == "Authenticated GraphQL API")
|
|
this.FillAuthenticatedGrapgQLURL();
|
|
|
|
if (testNSave) {
|
|
this.TestSaveDatasource();
|
|
} else {
|
|
this.SaveDatasource();
|
|
}
|
|
cy.wrap(dataSourceName).as("dsName");
|
|
} else if (DataSourceKVP[dsType] == "GraphQL API") {
|
|
this.FillUnAuthenticatedGraphQLDSForm(environment);
|
|
}
|
|
});
|
|
}
|
|
|
|
public CreateQueryFromOverlay(
|
|
dsName: string,
|
|
query = "",
|
|
queryName = "",
|
|
sleep = 500,
|
|
) {
|
|
this.agHelper.RemoveUIElement("EvaluatedPopUp"); //to close the evaluated pop-up
|
|
this.entityExplorer.CreateNewDsQuery(dsName);
|
|
if (query) {
|
|
this.EnterQuery(query, sleep);
|
|
}
|
|
if (queryName) this.agHelper.RenameWithInPane(queryName);
|
|
}
|
|
|
|
public UpdateGraphqlQueryAndVariable(options?: {
|
|
query?: string;
|
|
variable?: string;
|
|
}) {
|
|
if (options?.query) {
|
|
this.agHelper.UpdateCodeInput(this._graphqlQueryEditor, options.query);
|
|
}
|
|
|
|
if (options?.variable) {
|
|
this.agHelper.UpdateCodeInput(
|
|
this._graphqlVariableEditor,
|
|
options.variable as string,
|
|
);
|
|
}
|
|
|
|
this.agHelper.Sleep();
|
|
}
|
|
|
|
public UpdateGraphqlPaginationParams(options: {
|
|
limit?: {
|
|
variable: string;
|
|
value: any;
|
|
};
|
|
offset?: {
|
|
variable: string;
|
|
value: any;
|
|
};
|
|
}) {
|
|
if (options.limit) {
|
|
// Select Limit variable from dropdown
|
|
cy.get(this._graphqlPagination._limitVariable).click({
|
|
force: true,
|
|
});
|
|
cy.get(".rc-select-item-option")
|
|
.contains(options.limit.variable)
|
|
.click({ force: true });
|
|
|
|
// Set the Limit value as 1
|
|
cy.get(this._graphqlPagination._limitValue)
|
|
.first()
|
|
.focus()
|
|
.type(options.limit.value);
|
|
}
|
|
|
|
if (options.offset) {
|
|
// Select Offset vaiable from dropdown
|
|
cy.get(this._graphqlPagination._offsetVariable).click({
|
|
force: true,
|
|
});
|
|
cy.get(".rc-select-item-option")
|
|
.eq(2)
|
|
.contains(options.offset.variable)
|
|
.click({ force: true });
|
|
|
|
// Set the Limit value as 1
|
|
cy.get(this._graphqlPagination._offsetValue)
|
|
.first()
|
|
.focus()
|
|
.type(options.offset.value);
|
|
}
|
|
|
|
this.agHelper.Sleep();
|
|
}
|
|
|
|
public SetQueryTimeout(
|
|
queryTimeout = 20000,
|
|
action: "QUERY" | "API" = "QUERY",
|
|
) {
|
|
this.agHelper.GetNClick(this._queryEditorTabs("Settings"));
|
|
cy.xpath(this._queryTimeout)
|
|
.clear()
|
|
.type(queryTimeout.toString(), { delay: 0 }); //Delay 0 to work like paste!
|
|
this.agHelper.AssertAutoSave();
|
|
|
|
if (action === "QUERY") {
|
|
this.agHelper.GetNClick(this._queryEditorTabs("Query"));
|
|
}
|
|
}
|
|
|
|
//Update with new password in the datasource conf page
|
|
public UpdatePassword(newPassword: string) {
|
|
cy.get(this._password).type(newPassword);
|
|
}
|
|
|
|
//Fetch schema from server and validate UI for the updates
|
|
public VerifySchema(
|
|
dataSourceName: string,
|
|
schema: string,
|
|
isUpdate = false,
|
|
) {
|
|
if (isUpdate) {
|
|
this.UpdateDatasource();
|
|
} else {
|
|
this.SaveDatasource();
|
|
}
|
|
this.selectTabOnDatasourcePage("View data");
|
|
cy.wait("@getDatasourceStructure").then(() => {
|
|
cy.get(this._dsSchemaContainer).contains(schema);
|
|
});
|
|
}
|
|
|
|
public VerifyTableSchemaOnQueryEditor(schema: string) {
|
|
this.agHelper.AssertElementVisibility(this._dsVirtuosoElementTable(schema));
|
|
}
|
|
|
|
public VerifySchemaAbsenceInQueryEditor() {
|
|
this.agHelper.AssertElementAbsence(this._datasourceStructureHeader);
|
|
}
|
|
|
|
public VerifyColumnSchemaOnQueryEditor(schema: string, index = 0) {
|
|
this.agHelper
|
|
.GetElement(this._datasourceSchemaColumn)
|
|
.eq(index)
|
|
.contains(schema);
|
|
}
|
|
|
|
public RefreshDatasourceSchema() {
|
|
this.agHelper.GetNClick(this._datasourceSchemaRefreshBtn);
|
|
}
|
|
|
|
public FilterAndVerifyDatasourceSchemaBySearch(
|
|
search: string,
|
|
expectedTableName = search,
|
|
) {
|
|
this.agHelper.Sleep(2500); //for query editor to load
|
|
this.agHelper.ClearNType(this._datasourceStructureSearchInput, search);
|
|
this.agHelper.Sleep(1000); //for search result to load
|
|
this.VerifyTableSchemaOnQueryEditor(expectedTableName);
|
|
}
|
|
|
|
public createQueryWithDatasourceSchemaTemplate(
|
|
datasourceName: string,
|
|
tableName: string,
|
|
templateName: string,
|
|
) {
|
|
this.CreateQueryForDS(datasourceName);
|
|
this.AssertTableInVirtuosoList(datasourceName, tableName);
|
|
this.agHelper.GetNClick(this._dsVirtuosoElementTable(tableName));
|
|
cy.get(this._dsVirtuosoElementTable(tableName))
|
|
.find(this._entityTriggerElement)
|
|
.should("be.visible")
|
|
.click();
|
|
this.agHelper.GetNClick(
|
|
this.entityExplorer.locator._contextMenuItem(templateName),
|
|
0,
|
|
true,
|
|
);
|
|
this.agHelper.Sleep(500);
|
|
}
|
|
|
|
public AssertDSDialogVisibility(isVisible = true) {
|
|
if (isVisible) {
|
|
this.agHelper.AssertElementVisibility(this._datasourceModalDoNotSave);
|
|
this.agHelper.AssertElementVisibility(this._datasourceModalSave);
|
|
} else {
|
|
this.agHelper.AssertElementAbsence(this._datasourceModalDoNotSave);
|
|
this.agHelper.AssertElementAbsence(this._datasourceModalSave);
|
|
}
|
|
}
|
|
|
|
public AssertDatasourceSaveModalVisibilityAndSave(save = true) {
|
|
this.AssertDSDialogVisibility();
|
|
if (save) {
|
|
this.agHelper.GetNClick(
|
|
this.locator._visibleTextSpan("Save"),
|
|
0,
|
|
true,
|
|
0,
|
|
);
|
|
this.assertHelper.AssertNetworkStatus("@saveDatasource", 201);
|
|
this.agHelper.AssertContains("datasource created");
|
|
} else
|
|
this.agHelper.GetNClick(
|
|
this.locator._visibleTextSpan("Don't save"),
|
|
0,
|
|
true,
|
|
0,
|
|
);
|
|
this.AssertDSDialogVisibility(false);
|
|
}
|
|
|
|
// this initiates saving via the back button.
|
|
public SaveDSFromDialog(save = true) {
|
|
AppSidebar.navigate(AppSidebarButton.Editor, true);
|
|
this.AssertDatasourceSaveModalVisibilityAndSave(save);
|
|
}
|
|
|
|
public getDSEntity(dSName: string) {
|
|
return `[data-guided-tour-id="explorer-entity-${dSName}"]`;
|
|
}
|
|
|
|
public FillAuthAPIUrl(environment = this.dataManager.defaultEnviorment) {
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("URL") + "//" + this.locator._inputField,
|
|
this.dataManager.dsValues[environment].authenticatedApiUrl,
|
|
);
|
|
}
|
|
|
|
public AssertCursorPositionForTextInput(
|
|
selector: string,
|
|
moveCursor: string,
|
|
typeText = "as",
|
|
cursorPosition = 0,
|
|
) {
|
|
this.agHelper
|
|
.GetElement(selector)
|
|
.type(moveCursor)
|
|
.type(typeText)
|
|
.should("have.prop", "selectionStart", cursorPosition);
|
|
}
|
|
|
|
public AddOAuth2AuthorizationCodeDetails(
|
|
accessTokenUrl: string,
|
|
clientId: string,
|
|
clientSecret: string,
|
|
authURL: string,
|
|
) {
|
|
this.agHelper.GetNClick(this._authType);
|
|
this.agHelper.GetNClick(this._oauth2);
|
|
this.agHelper.GetNClick(this._grantType);
|
|
this.agHelper.GetNClick(this._authorizationCode);
|
|
this.agHelper.TypeText(this._accessTokenUrl, accessTokenUrl);
|
|
this.agHelper.TypeText(this._clientID, clientId);
|
|
this.agHelper.TypeText(this._clientSecret, clientSecret);
|
|
this.agHelper.TypeText(this._authorizationURL, authURL);
|
|
}
|
|
|
|
public EditDSFromActiveTab(dsName: string) {
|
|
this.agHelper.GetNClick(this._editDatasourceFromActiveTab(dsName));
|
|
}
|
|
|
|
public FillMongoDatasourceFormWithURI(
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
this.ValidateNSelectDropdown(
|
|
"Use mongo connection string URI",
|
|
"No",
|
|
"Yes",
|
|
);
|
|
this.agHelper.ClearNType(
|
|
this.locator._inputFieldByName("Connection string URI") + "//input",
|
|
this.dataManager.mongo_uri(environment),
|
|
);
|
|
}
|
|
|
|
public CreateOAuthClient(
|
|
grantType: string,
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
let clientId, clientSecret;
|
|
|
|
// Login to TED OAuth
|
|
let formData = new FormData();
|
|
formData.append(
|
|
"username",
|
|
this.dataManager.dsValues[environment].OAuth_Username,
|
|
);
|
|
cy.request(
|
|
"POST",
|
|
this.dataManager.dsValues[environment].OAuth_Host,
|
|
formData,
|
|
).then((response) => {
|
|
expect(response.status).to.equal(200);
|
|
});
|
|
|
|
// Create client
|
|
let clientData = new FormData();
|
|
clientData.append("client_name", "appsmith_cs_post");
|
|
clientData.append("client_uri", "http://localhost/");
|
|
clientData.append("scope", "profile");
|
|
clientData.append(
|
|
"redirect_uri",
|
|
this.dataManager.dsValues[environment].OAuth_RedirectUrl,
|
|
);
|
|
clientData.append("grant_type", grantType);
|
|
clientData.append("response_type", "code");
|
|
clientData.append("token_endpoint_auth_method", "client_secret_post");
|
|
cy.request(
|
|
"POST",
|
|
this.dataManager.dsValues[environment].OAuth_Host + "/create_client",
|
|
clientData,
|
|
).then((response) => {
|
|
expect(response.status).to.equal(200);
|
|
});
|
|
|
|
// Get Client Credentials
|
|
cy.request("GET", this.dataManager.dsValues[environment].OAuth_Host).then(
|
|
(response) => {
|
|
clientId = response.body.split("client_id: </strong>");
|
|
clientId = clientId[1].split("<strong>client_secret: </strong>");
|
|
clientSecret = clientId[1].split("<strong>");
|
|
clientSecret = clientSecret[0].trim();
|
|
clientId = clientId[0].trim();
|
|
cy.wrap(clientId).as("OAuthClientID");
|
|
cy.wrap(clientSecret).as("OAuthClientSecret");
|
|
},
|
|
);
|
|
}
|
|
|
|
public CreateOAuthDatasource(
|
|
datasourceName: string,
|
|
grantType: "ClientCredentials" | "AuthCode",
|
|
clientId: string,
|
|
clientSecret: string,
|
|
) {
|
|
this.NavigateToDSCreateNew();
|
|
//Click on Authenticated API
|
|
this.agHelper.GetNClick(this._authApiDatasource, 0, true);
|
|
this.FillAPIOAuthForm(datasourceName, grantType, clientId, clientSecret);
|
|
|
|
// save datasource
|
|
this.agHelper.Sleep(500);
|
|
this.agHelper.GetNClick(this._saveDs);
|
|
|
|
//Accept consent
|
|
this.agHelper.GetNClick(this._consent);
|
|
this.agHelper.GetNClick(this._consentSubmit);
|
|
|
|
//Validate save
|
|
this.assertHelper.AssertNetworkStatus("@saveDatasource", 201);
|
|
}
|
|
|
|
public FillAPIOAuthForm(
|
|
dsName: string,
|
|
grantType: "ClientCredentials" | "AuthCode",
|
|
clientId: string,
|
|
clientSecret: string,
|
|
environment = this.dataManager.defaultEnviorment,
|
|
) {
|
|
if (dsName) this.agHelper.RenameWithInPane(dsName, false);
|
|
// Fill Auth Form
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("URL") + "//" + this.locator._inputField,
|
|
this.dataManager.dsValues[environment].OAuth_ApiUrl,
|
|
);
|
|
this.agHelper.GetNClick(this._authType);
|
|
this.agHelper.GetNClick(this._oauth2);
|
|
this.agHelper.GetNClick(this._grantType);
|
|
if (grantType == "ClientCredentials")
|
|
this.agHelper.GetNClick(this._clientCredentails);
|
|
else if (grantType == "AuthCode")
|
|
this.agHelper.GetNClick(this._authorizationCode);
|
|
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Access token URL") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
this.dataManager.dsValues[environment].OAUth_AccessTokenUrl,
|
|
);
|
|
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Client ID") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
clientId,
|
|
);
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Client secret") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
clientSecret,
|
|
);
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Scope(s)") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
"profile",
|
|
);
|
|
this.agHelper.TypeText(
|
|
this.locator._inputFieldByName("Authorization URL") +
|
|
"//" +
|
|
this.locator._inputField,
|
|
this.dataManager.dsValues[environment].OAuth_AuthUrl,
|
|
);
|
|
}
|
|
|
|
public AssertBindDataVisible() {
|
|
cy.get(this._bindDataButton).should("be.visible");
|
|
}
|
|
|
|
public AddSuggestedWidget(
|
|
widget: Widgets,
|
|
parentClass = this._addSuggestedAddNew,
|
|
force = false,
|
|
index = 0,
|
|
) {
|
|
cy.get(this._bindDataButton).should("be.visible").click({ force: true });
|
|
switch (widget) {
|
|
case Widgets.Dropdown:
|
|
this.agHelper.GetNClick(
|
|
this._suggestedWidget("SELECT_WIDGET", parentClass),
|
|
);
|
|
this.agHelper.AssertElementVisibility(
|
|
this.locator._widgetInCanvas(WIDGET.SELECT),
|
|
);
|
|
break;
|
|
case Widgets.Table:
|
|
this.agHelper.GetNClick(
|
|
this._suggestedWidget("TABLE_WIDGET_V2", parentClass),
|
|
index,
|
|
force,
|
|
);
|
|
this.agHelper.AssertElementVisibility(
|
|
this.locator._widgetInCanvas(WIDGET.TABLE),
|
|
);
|
|
break;
|
|
case Widgets.WDSTable:
|
|
this.agHelper.GetNClick(
|
|
this._suggestedWidget("TABLE_WIDGET_V2", parentClass),
|
|
index,
|
|
force,
|
|
);
|
|
this.agHelper.AssertElementVisibility(
|
|
anvilLocators.anvilWidgetTypeSelector(anvilLocators.WDSTABLE),
|
|
);
|
|
break;
|
|
case Widgets.Chart:
|
|
this.agHelper.GetNClick(
|
|
this._suggestedWidget("CHART_WIDGET", parentClass),
|
|
);
|
|
this.agHelper.AssertElementVisibility(
|
|
this.locator._widgetInCanvas(WIDGET.CHART),
|
|
);
|
|
break;
|
|
case Widgets.Text:
|
|
this.agHelper.GetNClick(
|
|
this._suggestedWidget("TEXT_WIDGET", parentClass),
|
|
);
|
|
this.agHelper.AssertElementVisibility(
|
|
this.locator._widgetInCanvas(WIDGET.TEXT),
|
|
);
|
|
break;
|
|
}
|
|
}
|
|
|
|
public EnterJSContext({
|
|
fieldLabel,
|
|
fieldValue,
|
|
}: {
|
|
fieldValue: string;
|
|
fieldLabel: string;
|
|
}) {
|
|
this.agHelper.Sleep();
|
|
this.agHelper
|
|
.GetElement(this._getJSONswitchLocator(fieldLabel))
|
|
.invoke("attr", "data-selected")
|
|
.then(($state: any) => {
|
|
if (!$state.includes("true"))
|
|
this.agHelper.GetNClick(
|
|
this._getJSONswitchLocator(fieldLabel),
|
|
0,
|
|
true,
|
|
);
|
|
else this.agHelper.Sleep(200);
|
|
});
|
|
this.agHelper.EnterValue(fieldValue, {
|
|
propFieldName: "",
|
|
directInput: false,
|
|
inputFieldName: fieldLabel,
|
|
});
|
|
}
|
|
|
|
public StopNDeleteContainer(containerName: string) {
|
|
// Stop the container
|
|
cy.exec(`docker stop ${containerName}`).then((stopResult) => {
|
|
cy.log("Output from stopping container:" + stopResult.stdout);
|
|
cy.log("Error from stopping container:" + stopResult.stderr);
|
|
|
|
// Delete the container
|
|
cy.exec(`docker rm ${containerName}`).then((deleteResult) => {
|
|
cy.log("Output from deleting container:" + deleteResult.stdout);
|
|
cy.log("Error from deleting container:" + deleteResult.stderr);
|
|
});
|
|
});
|
|
}
|
|
|
|
public IsContainerReady(containerName: string) {
|
|
return cy
|
|
.exec(`docker inspect -f '{{.State.Status}}' ${containerName}`)
|
|
.then((result) => {
|
|
const containerStatus = result.stdout.trim();
|
|
return containerStatus === "running";
|
|
});
|
|
}
|
|
|
|
public StartContainerNVerify(
|
|
containerType: "MsSql" | "Arango" | "Elasticsearch",
|
|
containerName: string,
|
|
sleepTime = 40000,
|
|
) {
|
|
let containerCommand = "";
|
|
switch (containerType) {
|
|
case "MsSql":
|
|
containerCommand = this.ContainerKVP(containerName).MsSql;
|
|
break;
|
|
case "Arango":
|
|
containerCommand = this.ContainerKVP(containerName).Arango;
|
|
break;
|
|
case "Elasticsearch":
|
|
containerCommand = this.ContainerKVP(containerName).Elasticsearch;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
cy.exec(containerCommand).then((result) => {
|
|
// Wait for the container to be ready
|
|
cy.waitUntil(() => this.IsContainerReady(containerName), {
|
|
interval: 5000,
|
|
timeout: 60000,
|
|
}).then((isReady) => {
|
|
if (isReady) {
|
|
cy.log("Run id of started container is:" + result.stdout);
|
|
this.agHelper.Sleep(sleepTime); //allow some time for container to settle start for CI
|
|
} else
|
|
cy.log(
|
|
`Error from ${containerName} container start action:` +
|
|
result.stderr,
|
|
); // Container did not start properly within the timeout
|
|
});
|
|
});
|
|
}
|
|
|
|
public EnterSortByValues(sortBy: string, option: string, index = 0) {
|
|
this.agHelper
|
|
.GetElement(this._jsModeSortingControl)
|
|
.eq(0)
|
|
.children()
|
|
.eq(index)
|
|
.then((ele) => {
|
|
cy.wrap(ele)
|
|
.children()
|
|
.eq(0)
|
|
.find("textarea")
|
|
.type(sortBy, { force: true });
|
|
cy.wrap(ele).children().eq(1).find("input").click();
|
|
});
|
|
this.agHelper.GetNClickByContains(this._dropdownOption, option);
|
|
}
|
|
|
|
public ClearSortByOption(index = 0) {
|
|
this.agHelper.Sleep(500);
|
|
this.agHelper
|
|
.GetElement(this._jsModeSortingControl)
|
|
.eq(0)
|
|
.children()
|
|
.eq(index)
|
|
.find(`button[data-testid='t--sorting-delete-[${index}]']`)
|
|
.click({ force: true });
|
|
this.agHelper.Sleep(500);
|
|
}
|
|
|
|
public AddNewSortByParameter() {
|
|
this.agHelper
|
|
.GetElement(this._jsModeSortingControl)
|
|
.find("button[data-testid='t--sorting-add-field']")
|
|
.click({ force: true });
|
|
}
|
|
|
|
public AddQueryFromGlobalSearch(datasourceName: string) {
|
|
this.agHelper.GetNClick(this._globalSearchTrigger);
|
|
this.agHelper.Sleep(500);
|
|
this.agHelper.TypeText(this._globalSearchInput, datasourceName);
|
|
this.agHelper.Sleep(500);
|
|
this.agHelper.GetNClickByContains(
|
|
this._globalSearchOptions,
|
|
new RegExp("^" + datasourceName + "$"),
|
|
);
|
|
this.agHelper.WaitUntilEleAppear(this._createQuery);
|
|
this.CreateQueryAfterDSSaved();
|
|
}
|
|
|
|
public AssertDataSourceInfo(info: string[]) {
|
|
info.forEach(($infs) => {
|
|
this.agHelper.AssertElementVisibility(
|
|
this.locator._visibleTextDiv($infs),
|
|
);
|
|
});
|
|
}
|
|
|
|
public GeneratePostgresCRUDPage(dbName: string) {
|
|
PageList.AddNewPage("Generate page with data");
|
|
this.agHelper.GetNClick(this._selectDatasourceDropdown);
|
|
this.agHelper.GetNClickByContains(
|
|
this._dropdownOption,
|
|
"Connect new datasource",
|
|
);
|
|
this.CreateDataSource("Postgres", false);
|
|
this.assertHelper.AssertNetworkStatus("@getDatasourceStructure");
|
|
this.agHelper.GetNClick(this._selectTableDropdown, 0, true);
|
|
this.agHelper.GetNClickByContains(this._dropdownOption, dbName);
|
|
this.agHelper.GetNClick(this._generatePageBtn);
|
|
this.assertHelper.AssertNetworkStatus("@replaceLayoutWithCRUDPage", 201);
|
|
this.agHelper.AssertContains("Successfully generated a page");
|
|
this.assertHelper.AssertNetworkStatus("@getActions", 200);
|
|
this.assertHelper.AssertNetworkStatus("@postExecute", 200);
|
|
this.agHelper.GetNClick(this._visibleTextSpan("Got it"));
|
|
this.assertHelper.AssertNetworkStatus("@updateLayout", 200);
|
|
}
|
|
|
|
public AssertTableInVirtuosoList(
|
|
dsName: string,
|
|
targetTableName: string,
|
|
presence = true,
|
|
) {
|
|
const ds_entity_name = dsName.replace(/\s/g, "_");
|
|
cy.intercept("GET", "/api/v1/datasources/*/structure?ignoreCache=*").as(
|
|
`getDatasourceStructureUpdated_${ds_entity_name}`,
|
|
);
|
|
cy.get("[data-testid=t--tab-SCHEMA_TAB]").first().click({ force: true });
|
|
this.RefreshDatasourceSchema();
|
|
this.assertHelper
|
|
.WaitForNetworkCall(`@getDatasourceStructureUpdated_${ds_entity_name}`)
|
|
.then(async (response) => {
|
|
const tables: any[] = response?.body.data?.tables || [];
|
|
const indexOfTable = tables.findIndex(
|
|
(table) => table.name === targetTableName,
|
|
);
|
|
if (presence) {
|
|
this.agHelper.Sleep();
|
|
this.agHelper
|
|
.GetNClick(this._dsVirtuosoElement)
|
|
.then((parentElement) => {
|
|
const heightOfParentElement = parentElement.outerHeight() || 0;
|
|
|
|
// Every element (tables in this scenario) in the virtual list has equal heights. Assumption: Every table element accordion is collapsed by default.
|
|
const containerElement = parentElement.find(this._dsVirtuosoList);
|
|
const elementHeight = parseInt(
|
|
containerElement.children().first().attr("data-known-size") ||
|
|
"",
|
|
10,
|
|
);
|
|
// Total height of the parent container holding the tables in the dom normally without virtualization rendering
|
|
const totalScroll = tables.length * elementHeight;
|
|
if (heightOfParentElement < totalScroll) {
|
|
// Index of the table present in the array of tables which will determine the presence of element inside the parent container
|
|
let offset = indexOfTable * elementHeight;
|
|
const scrollPercent = Math.max(
|
|
(offset / (totalScroll || 1)) * 100,
|
|
0,
|
|
);
|
|
if (scrollPercent > 0) {
|
|
this.agHelper.ScrollToXY(
|
|
this._dsVirtuosoElement,
|
|
0,
|
|
`${scrollPercent}%`,
|
|
);
|
|
}
|
|
}
|
|
// To close any template pop up, click on the body
|
|
cy.get(this.locator._body).click({ force: true });
|
|
this.agHelper.AssertElementVisibility(
|
|
this._dsVirtuosoElementTable(targetTableName),
|
|
);
|
|
});
|
|
} else {
|
|
this.agHelper.AssertElementAbsence(
|
|
this._dsVirtuosoElementTable(targetTableName),
|
|
);
|
|
expect(indexOfTable).to.equal(-1);
|
|
}
|
|
});
|
|
}
|
|
|
|
public selectTabOnDatasourcePage(tab: "View data" | "Configurations") {
|
|
this.agHelper.GetNClick(this._dsPageTabListItem(tab));
|
|
}
|
|
|
|
public getDatasourceListItemDescription(name: string) {
|
|
return cy
|
|
.get(datasource.datasourceCard)
|
|
.contains(name)
|
|
.parents(datasource.datasourceCard)
|
|
.find(".ads-v2-listitem__bdesc")
|
|
.invoke("text");
|
|
}
|
|
|
|
public SelectTableFromPreviewSchemaList(targetTableName: string) {
|
|
this.agHelper.GetNClick(
|
|
this._dsVirtuosoElementTable(targetTableName),
|
|
0,
|
|
false,
|
|
1000,
|
|
);
|
|
}
|
|
|
|
private IsTemplateMenuTriggerForSchemaTableVisible(index: number = 0) {
|
|
this.agHelper
|
|
.GetElement(`${this._dsSchemaContainer} ${this._dsSchemaEntityItem}`)
|
|
.eq(index)
|
|
.find(this._entityTriggerElement)
|
|
.should("be.visible");
|
|
}
|
|
|
|
public ClickTemplateMenuForSchemaTable(index: number = 0) {
|
|
this.agHelper
|
|
.GetElement(`${this._dsSchemaContainer} ${this._dsSchemaEntityItem}`)
|
|
.eq(index)
|
|
.realHover();
|
|
this.IsTemplateMenuTriggerForSchemaTableVisible(index);
|
|
this.agHelper
|
|
.GetElement(`${this._dsSchemaContainer} ${this._dsSchemaEntityItem}`)
|
|
.eq(index)
|
|
.find(this._entityTriggerElement)
|
|
.click();
|
|
this.IsTemplateMenuTriggerForSchemaTableVisible(index);
|
|
}
|
|
}
|