fc808ea3bb
## Description - This PR includes tests for Redis datasource - basics tests with querying in query page ## Type of change - New script ## How Has This Been Tested? - Cypress CI runs ## Checklist: ### QA activity: - [x] Added Test Plan Approved label after reviewing all Cypress test
1229 lines
42 KiB
TypeScript
1229 lines
42 KiB
TypeScript
import datasourceFormData from "../../fixtures/datasources.json";
|
|
import { ObjectsRegistry } from "../Objects/Registry";
|
|
import { WIDGET } from "../../locators/WidgetLocators";
|
|
|
|
const DataSourceKVP = {
|
|
Postgres: "PostgreSQL",
|
|
Mongo: "MongoDB",
|
|
MySql: "MySQL",
|
|
UnAuthenticatedGraphQL: "GraphQL API",
|
|
MsSql: "Microsoft SQL Server",
|
|
Airtable: "Airtable",
|
|
Arango: "ArangoDB",
|
|
Firestore: "Firestore",
|
|
Elasticsearch: "Elasticsearch",
|
|
Redis: "Redis",
|
|
}; //DataSources KeyValuePair
|
|
|
|
export enum Widgets {
|
|
Dropdown,
|
|
Table,
|
|
Chart,
|
|
Text,
|
|
}
|
|
|
|
interface RunQueryParams {
|
|
toValidateResponse?: boolean;
|
|
expectedStatus?: boolean;
|
|
waitTimeInterval?: number;
|
|
}
|
|
export class DataSources {
|
|
private agHelper = ObjectsRegistry.AggregateHelper;
|
|
private table = ObjectsRegistry.Table;
|
|
private ee = ObjectsRegistry.EntityExplorer;
|
|
private locator = ObjectsRegistry.CommonLocators;
|
|
private homePage = ObjectsRegistry.HomePage;
|
|
private apiPage = ObjectsRegistry.ApiPage;
|
|
|
|
private _dsCreateNewTab = "[data-cy=t--tab-CREATE_NEW]";
|
|
private _addNewDataSource = ".t--entity-add-btn.datasources";
|
|
private _createNewPlgin = (pluginName: string) =>
|
|
".t--plugin-name:contains('" + pluginName + "')";
|
|
private _collapseContainer = ".t--collapse-section-container";
|
|
private _host = "input[name='datasourceConfiguration.endpoints[0].host']";
|
|
private _port = "input[name='datasourceConfiguration.endpoints[0].port']";
|
|
_databaseName =
|
|
"input[name='datasourceConfiguration.authentication.databaseName']";
|
|
private _username =
|
|
"input[name='datasourceConfiguration.authentication.username']";
|
|
private _sectionAuthentication =
|
|
"[data-cy=section-Authentication] .t--collapse-section-container";
|
|
private _password =
|
|
"input[name = 'datasourceConfiguration.authentication.password']";
|
|
private _testDs = ".t--test-datasource";
|
|
_saveAndAuthorizeDS = ".t--save-and-authorize-datasource";
|
|
_saveDs = ".t--save-datasource";
|
|
_datasourceCard = ".t--datasource";
|
|
_editButton = ".t--edit-datasource";
|
|
_reconnectDataSourceModal = "[data-cy=t--tab-RECONNECT_DATASOURCES]";
|
|
_closeDataSourceModal = ".t--reconnect-close-btn";
|
|
_skiptoApplicationBtn = "//span[text()='Skip to Application']/parent::a";
|
|
_dsEntityItem = "[data-guided-tour-id='explorer-entity-Datasources']";
|
|
_activeDS = "[data-testid='active-datasource-name']";
|
|
_mockDatasourceName = "[data-testid=mockdatasource-name]";
|
|
_templateMenu = ".t--template-menu";
|
|
_templateMenuOption = (action: string) =>
|
|
"//div[contains(@class, 't--template-menu')]//div[text()='" + action + "']";
|
|
_createQuery = ".t--create-query";
|
|
_visibleTextSpan = (spanText: string) =>
|
|
"//span[contains(text(),'" + spanText + "')]";
|
|
_dropdownTitle = (ddTitle: string) =>
|
|
"//p[contains(text(),'" +
|
|
ddTitle +
|
|
"')]/ancestor::div[@class='form-config-top']/following-sibling::div[@class='t--form-control-DROP_DOWN']//div[@role='listbox']";
|
|
_reconnectModal = "div.reconnect-datasource-modal";
|
|
_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-cy=t--datasource-dropdown]";
|
|
_selectTableDropdown = "[data-cy=t--table-dropdown]";
|
|
_selectSheetNameDropdown = "[data-cy=t--sheetName-dropdown]";
|
|
_selectTableHeaderIndexInput = "[data-cy=t--tableHeaderIndex]";
|
|
_dropdownOption = ".bp3-popover-content .t--dropdown-option";
|
|
_generatePageBtn = "[data-cy=t--generate-page-form-submit]";
|
|
_selectedRow = ".tr.selected-row";
|
|
_activeTab = "span:contains('Active')";
|
|
_selectedActiveTab = "li[aria-selected='true'] " + this._activeTab;
|
|
_contextMenuDatasource = "span[name='comment-context-menu']";
|
|
_contextMenuDelete = ".t--datasource-option-delete";
|
|
_datasourceCardGeneratePageBtn = ".t--generate-template";
|
|
_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-cy='t--query-error']";
|
|
_queryResponse = (responseType: string) =>
|
|
"li[data-cy='t--tab-" + responseType + "']";
|
|
_queryRecordResult = (recordCount: number) =>
|
|
`//div/span[text()='Result:']/span[contains(text(),' ${recordCount} Record')]`;
|
|
_noRecordFound = "span[data-testid='no-data-table-message']";
|
|
_usePreparedStatement =
|
|
"input[name='actionConfiguration.pluginSpecifiedTemplates[0].value'][type='checkbox']";
|
|
_queriesOnPageText = (dsName: string) =>
|
|
".t--datasource-name:contains('" + dsName + "') .t--queries-for-DB";
|
|
_mockDB = (dbName: string) =>
|
|
"//span[text()='" +
|
|
dbName +
|
|
"']/ancestor::div[contains(@class, 't--mock-datasource')][1]";
|
|
private _createBlankGraphQL = ".t--createBlankApiGraphqlCard";
|
|
private _createBlankCurl = ".t--createBlankCurlCard";
|
|
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",
|
|
_limitValue: ".t--apiFormPaginationLimitValue .CodeMirror textarea",
|
|
_offsetVariable: ".t--apiFormPaginationOffsetVariable",
|
|
_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 = (inputText: string) =>
|
|
"//input[@id='global-search'][@value='" + inputText + "']";
|
|
_gsScopeDropdown =
|
|
"[data-cy='datasourceConfiguration.authentication.scopeString']";
|
|
_gsScopeOptions = ".ads-dropdown-options-wrapper div > span div span";
|
|
private _queryTimeout =
|
|
"//input[@name='actionConfiguration.timeoutInMillisecond']";
|
|
_getStructureReq = "/api/v1/datasources/*/structure?ignoreCache=true";
|
|
_editDatasourceFromActiveTab = (dsName: string) =>
|
|
".t--datasource-name:contains('" + dsName + "')";
|
|
private _suggestedWidget = (widgetType: string) =>
|
|
".t--suggested-widget-" + widgetType + "";
|
|
|
|
private _curlTextArea =
|
|
"//label[text()='Paste CURL Code Here']/parent::form/div";
|
|
_allQueriesforDB = (dbName: string) =>
|
|
"//div[text()='" +
|
|
dbName +
|
|
"']/following-sibling::div[contains(@class, 't--entity') and contains(@class, 'action')]//div[contains(@class, 't--entity-name')]";
|
|
_noSchemaAvailable = (dbName: string) =>
|
|
"//div[text()='" +
|
|
dbName +
|
|
"']/ancestor::div[contains(@class, 't--entity-item')]/following-sibling::div//p[text()='Schema not available']";
|
|
// Authenticated API locators
|
|
private _authApiDatasource = ".t--createAuthApiDatasource";
|
|
private _authType = "[data-cy=authType]";
|
|
private _oauth2 = ".t--dropdown-option:contains('OAuth 2.0')";
|
|
private _accessTokenUrl = "[data-cy='authentication.accessTokenUrl'] input";
|
|
private _scope = "[data-cy='authentication.scopeString'] input";
|
|
private _clientID = "[data-cy='authentication.clientId'] input";
|
|
private _clientSecret = "[data-cy='authentication.clientSecret'] input";
|
|
private _clientCredentails =
|
|
".t--dropdown-option:contains('Client Credentials')";
|
|
private _authorizationCode =
|
|
".t--dropdown-option:contains('Authorization Code')";
|
|
private _grantType = "[data-cy='authentication.grantType']";
|
|
private _authorizationURL =
|
|
"[data-cy='authentication.authorizationUrl'] input";
|
|
private _consent = '[name="confirm"]';
|
|
private _consentSubmit = "//button[text()='Submit']";
|
|
public _datasourceModalSave = ".t--datasource-modal-save";
|
|
public _datasourceModalDoNotSave = ".t--datasource-modal-do-not-save";
|
|
public _deleteDatasourceButton = ".t--delete-datasource";
|
|
public _urlInputControl = "input[name='url']";
|
|
_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-cy='t--where-clause-delete-[" + index + "]']";
|
|
|
|
_bodyCodeMirror = "//div[contains(@class, 't--actionConfiguration.body')]";
|
|
|
|
public AssertDSEditViewMode(mode: "Edit" | "View") {
|
|
if (mode == "Edit") this.agHelper.AssertElementAbsence(this._editButton);
|
|
else if (mode == "View") this.agHelper.AssertElementExist(this._editButton);
|
|
}
|
|
|
|
public GeneratePageWithMockDB() {
|
|
this.ee.AddNewPage("generate-page");
|
|
this.agHelper.GetNClick(this._selectDatasourceDropdown);
|
|
this.agHelper.GetNClick(this.locator._dropdownText, 1);
|
|
this.agHelper.GetNClickByContains(this._mockDatasourceName, "Users");
|
|
this.agHelper.GetNClick(this._selectTableDropdown);
|
|
this.agHelper.GetNClick("[data-cy='t--dropdown-option-public.users']");
|
|
this.agHelper.GetNClick(this._generatePageBtn);
|
|
this.agHelper.ValidateNetworkStatus("@replaceLayoutWithCRUDPage", 201);
|
|
this.agHelper.GetNClick(this.locator._visibleTextSpan("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);
|
|
cy.log(currentURL + "currentURL from intercept is");
|
|
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) {
|
|
cy.get(this._createNewPlgin(pluginName))
|
|
.parent("div")
|
|
.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 ExpandSection(index: number) {
|
|
cy.get(this._collapseContainer).eq(index).click();
|
|
cy.get(this._collapseContainer)
|
|
.eq(index)
|
|
.find(this.locator._chevronUp)
|
|
.should("be.visible");
|
|
}
|
|
|
|
public ExpandSectionByName(locator: string) {
|
|
// Click on collapse section only if it collapsed, if it is expanded
|
|
// we ignore
|
|
cy.get(`${locator} span`)
|
|
.invoke("attr", "icon")
|
|
.then((iconName) => {
|
|
if (iconName === "chevron-down") {
|
|
cy.get(locator).click();
|
|
}
|
|
});
|
|
}
|
|
|
|
public AssertSectionCollapseState(index: number, collapsed = false) {
|
|
cy.get(this._collapseContainer)
|
|
.eq(index)
|
|
.within(() => {
|
|
if (collapsed) {
|
|
cy.get(this.locator._chevronUp).should("not.exist");
|
|
} else {
|
|
cy.get(this.locator._chevronUp).should("exist");
|
|
}
|
|
});
|
|
}
|
|
|
|
public NavigateToDSCreateNew() {
|
|
this.agHelper.GetNClick(this._addNewDataSource);
|
|
// cy.get(this._dsCreateNewTab)
|
|
// .should("be.visible")
|
|
// .click({ force: true });
|
|
cy.get(this._newDatasourceContainer).scrollTo("bottom", {
|
|
ensureScrollable: false,
|
|
});
|
|
cy.get(this._newDatabases).should("be.visible");
|
|
}
|
|
|
|
CreateMockDB(dbName: "Users" | "Movies"): Cypress.Chainable<string> {
|
|
this.NavigateToDSCreateNew();
|
|
this.agHelper.GetNClick(this._mockDB(dbName));
|
|
return cy
|
|
.wait("@getMockDb")
|
|
.then(($createdMock) => $createdMock.response?.body.data.name);
|
|
}
|
|
|
|
public FillPostgresDSForm(
|
|
shouldAddTrailingSpaces = false,
|
|
username = "",
|
|
password = "",
|
|
) {
|
|
const hostAddress = shouldAddTrailingSpaces
|
|
? datasourceFormData["postgres-host"] + " "
|
|
: datasourceFormData["postgres-host"];
|
|
const databaseName = shouldAddTrailingSpaces
|
|
? datasourceFormData["postgres-databaseName"] + " "
|
|
: datasourceFormData["postgres-databaseName"];
|
|
cy.get(this._host).type(hostAddress);
|
|
cy.get(this._port).type(datasourceFormData["postgres-port"].toString());
|
|
cy.get(this._databaseName).clear().type(databaseName);
|
|
this.ExpandSectionByName(this._sectionAuthentication);
|
|
cy.get(this._username).type(
|
|
username == "" ? datasourceFormData["postgres-username"] : username,
|
|
);
|
|
cy.get(this._password).type(
|
|
password == "" ? datasourceFormData["postgres-password"] : password,
|
|
);
|
|
}
|
|
|
|
public FillMongoDSForm(shouldAddTrailingSpaces = false) {
|
|
const hostAddress = shouldAddTrailingSpaces
|
|
? datasourceFormData["mongo-host"] + " "
|
|
: datasourceFormData["mongo-host"];
|
|
cy.get(this._host).type(hostAddress);
|
|
cy.get(this._port).type(datasourceFormData["mongo-port"].toString());
|
|
this.ExpandSectionByName(this._sectionAuthentication);
|
|
cy.get(this._databaseName)
|
|
.clear()
|
|
.type(datasourceFormData["mongo-databaseName"]);
|
|
}
|
|
|
|
public FillMySqlDSForm(shouldAddTrailingSpaces = false) {
|
|
const hostAddress = shouldAddTrailingSpaces
|
|
? datasourceFormData["mysql-host"] + " "
|
|
: datasourceFormData["mysql-host"];
|
|
const databaseName = shouldAddTrailingSpaces
|
|
? datasourceFormData["mysql-databaseName"] + " "
|
|
: datasourceFormData["mysql-databaseName"];
|
|
cy.get(this._host).type(hostAddress);
|
|
cy.get(this._port).type(datasourceFormData["mysql-port"].toString());
|
|
cy.get(this._databaseName).clear().type(databaseName);
|
|
this.ExpandSectionByName(this._sectionAuthentication);
|
|
cy.get(this._username).type(datasourceFormData["mysql-username"]);
|
|
cy.get(this._password).type(datasourceFormData["mysql-password"]);
|
|
}
|
|
|
|
public FillMsSqlDSForm() {
|
|
this.agHelper.UpdateInputValue(
|
|
this._host,
|
|
datasourceFormData["mssql-host"],
|
|
);
|
|
this.agHelper.UpdateInputValue(
|
|
this._port,
|
|
datasourceFormData["mssql-port"].toString(),
|
|
);
|
|
this.agHelper.ClearTextField(this._databaseName);
|
|
// this.agHelper.UpdateInputValue(
|
|
// this._databaseName,
|
|
// datasourceFormData["mssql-databaseName"],
|
|
// ); //Commenting until MsSQL is init loaded into container
|
|
this.ExpandSectionByName(this._sectionAuthentication);
|
|
this.agHelper.UpdateInputValue(
|
|
this._username,
|
|
datasourceFormData["mssql-username"],
|
|
);
|
|
this.agHelper.UpdateInputValue(
|
|
this._password,
|
|
datasourceFormData["mssql-password"],
|
|
);
|
|
}
|
|
|
|
public FillAirtableDSForm() {
|
|
this.ValidateNSelectDropdown(
|
|
"Authentication Type",
|
|
"Please select an option.",
|
|
"Bearer Token",
|
|
);
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("Bearer Token"),
|
|
Cypress.env("AIRTABLE_BEARER"),
|
|
);
|
|
this.agHelper.Sleep();
|
|
}
|
|
|
|
public FillArangoDSForm() {
|
|
this.agHelper.UpdateInputValue(
|
|
this._host,
|
|
datasourceFormData["arango-host"],
|
|
);
|
|
this.agHelper.UpdateInputValue(
|
|
this._port,
|
|
datasourceFormData["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.ExpandSectionByName(this._sectionAuthentication);
|
|
this.agHelper.UpdateInputValue(
|
|
this._username,
|
|
datasourceFormData["arango-username"],
|
|
);
|
|
this.agHelper.UpdateInputValue(
|
|
this._password,
|
|
datasourceFormData["arango-password"],
|
|
);
|
|
}
|
|
|
|
public FillCurlNImport(value: string) {
|
|
this.NavigateToDSCreateNew();
|
|
this.agHelper.GetNClick(this._createBlankCurl);
|
|
this.ImportCurlNRun(value);
|
|
}
|
|
|
|
public ImportCurlNRun(value: string) {
|
|
this.agHelper.UpdateTextArea(this._curlTextArea, value);
|
|
this.agHelper.ClickButton("Import");
|
|
this.apiPage.RunAPI();
|
|
}
|
|
|
|
public FillFirestoreDSForm() {
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("Database URL"),
|
|
datasourceFormData["firestore-database-url"],
|
|
);
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("Project Id"),
|
|
datasourceFormData["firestore-projectID"],
|
|
);
|
|
// cy.fixture("firestore-ServiceAccCreds").then((json: any) => {
|
|
// let ServiceAccCreds = JSON.parse(
|
|
// JSON.stringify(json.serviceAccCredentials),
|
|
// );
|
|
// ServiceAccCreds.private_key = Cypress.env("FIRESTORE_PRIVATE_KEY");
|
|
// //cy.log("ServiceAccCreds is " + JSON.stringify(ServiceAccCreds));
|
|
// cy.log(
|
|
// "ServiceAccCreds.private_key is " +
|
|
// JSON.stringify(ServiceAccCreds.private_key),
|
|
// );
|
|
this.agHelper.UpdateFieldLongInput(
|
|
this.locator._inputFieldByName("Service Account Credentials"),
|
|
JSON.stringify(Cypress.env("FIRESTORE_PRIVATE_KEY")),
|
|
);
|
|
//});
|
|
}
|
|
|
|
public FillElasticSearchDSForm() {
|
|
this.agHelper.UpdateInputValue(
|
|
this._host,
|
|
datasourceFormData["elastic-host"],
|
|
);
|
|
|
|
this.agHelper.UpdateInputValue(
|
|
this._port,
|
|
datasourceFormData["elastic-port"].toString(),
|
|
);
|
|
this.ExpandSectionByName(this._sectionAuthentication);
|
|
this.agHelper.UpdateInputValue(
|
|
this._username,
|
|
datasourceFormData["elastic-username"],
|
|
);
|
|
this.agHelper.UpdateInputValue(
|
|
this._password,
|
|
datasourceFormData["elastic-password"],
|
|
);
|
|
}
|
|
|
|
public FillUnAuthenticatedGraphQLDSForm() {
|
|
this.agHelper.GetNClick(this._createBlankGraphQL);
|
|
this.apiPage.EnterURL(datasourceFormData.GraphqlApiUrl_TED);
|
|
this.agHelper.ValidateNetworkStatus("@createNewApi", 201);
|
|
}
|
|
|
|
public CreateNFillAuthenticatedGraphQLDSForm(
|
|
dataSourceName: string,
|
|
hKey: string,
|
|
hValue: string,
|
|
) {
|
|
this.NavigateToDSCreateNew();
|
|
this.CreatePlugIn("Authenticated GraphQL API");
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("URL"),
|
|
datasourceFormData.GraphqlApiUrl_TED,
|
|
);
|
|
|
|
this.agHelper.UpdateInputValue(this._graphQLHeaderKey, hKey);
|
|
this.agHelper.UpdateInputValue(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() {
|
|
this.agHelper.UpdateInputValue(
|
|
this._host,
|
|
datasourceFormData["redis-host"],
|
|
);
|
|
this.agHelper.UpdateInputValue(
|
|
this._port,
|
|
datasourceFormData["redis-port"].toString(),
|
|
);
|
|
}
|
|
|
|
public TestSaveDatasource(expectedRes = true) {
|
|
this.TestDatasource(expectedRes);
|
|
this.SaveDatasource();
|
|
}
|
|
|
|
public TestDatasource(expectedRes = true) {
|
|
this.agHelper.GetNClick(this._testDs, 0, false, 0);
|
|
this.agHelper.ValidateNetworkDataSuccess("@testDatasource", expectedRes);
|
|
if (expectedRes) {
|
|
this.agHelper.AssertContains("datasource is valid");
|
|
}
|
|
}
|
|
|
|
public SaveDatasource() {
|
|
this.agHelper.GetNClick(this._saveDs);
|
|
this.agHelper.ValidateNetworkStatus("@saveDatasource", 201);
|
|
this.agHelper.AssertContains("datasource created");
|
|
|
|
// cy.wait("@saveDatasource")
|
|
// .then((xhr) => {
|
|
// cy.log(JSON.stringify(xhr.response!.body));
|
|
// }).should("have.nested.property", "response.body.responseMeta.status", 200);
|
|
}
|
|
|
|
public AuthAPISaveAndAuthorize() {
|
|
cy.get(this._saveAndAuthorizeDS).click();
|
|
this.agHelper.ValidateNetworkStatus("@saveDatasource", 201);
|
|
}
|
|
|
|
public UpdateDatasource() {
|
|
this.agHelper.GetNClick(this._saveDs);
|
|
// this.agHelper.ValidateNetworkStatus("@updateDatasource", 200);
|
|
this.agHelper.AssertContains("datasource updated");
|
|
}
|
|
|
|
public DeleteDatasouceFromActiveTab(
|
|
datasourceName: string,
|
|
expectedRes = 200,
|
|
) {
|
|
this.NavigateToActiveTab();
|
|
cy.get(this._datasourceCard)
|
|
.contains(datasourceName)
|
|
.scrollIntoView()
|
|
.should("be.visible")
|
|
.closest(this._datasourceCard)
|
|
.within(() => {
|
|
cy.get(this._contextMenuDatasource).click({ force: true });
|
|
});
|
|
this.agHelper.GetNClick(this._contextMenuDelete);
|
|
this.agHelper.GetNClick(this._visibleTextSpan("Are you sure?"));
|
|
this.agHelper.ValidateNetworkStatus("@deleteDatasource", expectedRes);
|
|
if (expectedRes == 200)
|
|
this.agHelper.AssertContains("datasource deleted successfully");
|
|
else this.agHelper.AssertContains("action(s) using it.");
|
|
}
|
|
|
|
public DeleteDatasouceFromWinthinDS(
|
|
datasourceName: string,
|
|
expectedRes = 200,
|
|
) {
|
|
this.NavigateToActiveTab();
|
|
cy.get(this._datasourceCard)
|
|
.contains(datasourceName)
|
|
.scrollIntoView()
|
|
.should("be.visible")
|
|
.click();
|
|
this.agHelper.Sleep(); //for the Datasource page to open
|
|
//this.agHelper.ClickButton("Delete");
|
|
this.agHelper.GetNClick(
|
|
this.locator._visibleTextSpan("Delete"),
|
|
0,
|
|
false,
|
|
200,
|
|
);
|
|
this.agHelper.GetNClick(this.locator._visibleTextSpan("Are you sure?"));
|
|
this.agHelper.ValidateNetworkStatus("@deleteDatasource", expectedRes);
|
|
if (expectedRes == 200)
|
|
this.agHelper.AssertContains("datasource deleted successfully");
|
|
else this.agHelper.AssertContains("action(s) using it.");
|
|
}
|
|
|
|
public DeleteDSDirectly() {
|
|
this.agHelper.GetNClick(this.locator._visibleTextSpan("Delete"));
|
|
this.agHelper.GetNClick(this.locator._visibleTextSpan("Are you sure?"));
|
|
this.agHelper.AssertContains("deleted successfully");
|
|
}
|
|
|
|
public NavigateToActiveTab() {
|
|
this.agHelper.GetElement(this.locator._body).then(($body) => {
|
|
if ($body.find(this._selectedActiveTab).length == 0) {
|
|
this.NavigateToDSCreateNew();
|
|
this.agHelper.GetNClick(this._activeTab, 0, true);
|
|
}
|
|
});
|
|
}
|
|
|
|
public NavigateFromActiveDS(datasourceName: string, createQuery: boolean) {
|
|
const btnLocator =
|
|
createQuery == true
|
|
? this._createQuery
|
|
: this._datasourceCardGeneratePageBtn;
|
|
|
|
this.ee.NavigateToSwitcher("explorer");
|
|
this.ee.ExpandCollapseEntity("Datasources", false);
|
|
//this.ee.SelectEntityByName(datasourceName, "Datasources");
|
|
//this.ee.ExpandCollapseEntity(datasourceName, false);
|
|
this.NavigateToActiveTab();
|
|
cy.get(this._datasourceCard)
|
|
.contains(datasourceName)
|
|
.scrollIntoView()
|
|
.should("be.visible")
|
|
.closest(this._datasourceCard)
|
|
.within(() => {
|
|
cy.get(btnLocator).click({ force: true });
|
|
});
|
|
this.agHelper.Sleep(2000); //for the CreateQuery/GeneratePage page to load
|
|
}
|
|
|
|
public CreateQueryFromActiveTab(
|
|
datasourceName: string,
|
|
toNavigateToActive = true,
|
|
) {
|
|
if (toNavigateToActive) this.NavigateToActiveTab();
|
|
cy.get(this._datasourceCard, { withinSubject: null })
|
|
.find(this._activeDS)
|
|
.contains(datasourceName)
|
|
.scrollIntoView()
|
|
.should("be.visible")
|
|
.closest(this._datasourceCard)
|
|
.within(() => {
|
|
cy.get(this._createQuery).click({ force: true });
|
|
});
|
|
this.agHelper.Sleep(2000); //for the CreateQuery
|
|
}
|
|
|
|
CreateQueryAfterDSSaved(query = "", queryName = "") {
|
|
this.agHelper.GetNClick(this._createQuery);
|
|
if (queryName) this.agHelper.RenameWithInPane(queryName);
|
|
if (query) {
|
|
this.agHelper.GetNClick(this._templateMenu);
|
|
this.EnterQuery(query);
|
|
}
|
|
}
|
|
|
|
DeleteQuery(queryName: string) {
|
|
this.ee.ExpandCollapseEntity("Queries/JS");
|
|
this.ee.ActionContextMenuByEntityName(queryName, "Delete", "Are you sure?");
|
|
}
|
|
|
|
public ValidateNSelectDropdown(
|
|
ddTitle: string,
|
|
currentValue = "",
|
|
newValue = "",
|
|
) {
|
|
let toChange = false;
|
|
if (currentValue)
|
|
cy.xpath(this._visibleTextSpan(currentValue))
|
|
.scrollIntoView()
|
|
.should("be.visible", currentValue + " dropdown value not present");
|
|
if (newValue) toChange = true;
|
|
if (toChange) {
|
|
cy.xpath(this._dropdownTitle(ddTitle)).click(); //to expand the dropdown
|
|
cy.xpath(this._visibleTextSpan(newValue)).last().click({ force: true }); //to select the new value
|
|
}
|
|
}
|
|
|
|
public ReconnectDataSource(dbName: string, dsName: "PostgreSQL" | "MySQL") {
|
|
this.agHelper.AssertElementVisible(this._reconnectModal);
|
|
cy.xpath(this._activeDSListReconnectModal(dsName)).should("be.visible");
|
|
cy.xpath(this._activeDSListReconnectModal(dbName)).should("be.visible"); //.click()
|
|
this.ValidateNSelectDropdown("Connection Mode", "", "Read / Write");
|
|
if (dsName == "PostgreSQL") this.FillPostgresDSForm();
|
|
else if (dsName == "MySQL") this.FillMySqlDSForm();
|
|
cy.get(this._saveDs).click();
|
|
}
|
|
|
|
public CloseReconnectDataSourceModal() {
|
|
cy.get("body").then(($ele) => {
|
|
if ($ele.find(this._reconnectDataSourceModal).length) {
|
|
this.agHelper.GetNClick(this._skiptoApplicationBtn);
|
|
this.homePage.NavigateToHome();
|
|
}
|
|
});
|
|
}
|
|
|
|
RunQuery({
|
|
expectedStatus = true,
|
|
toValidateResponse = true,
|
|
waitTimeInterval = 500,
|
|
}: Partial<RunQueryParams> = {}) {
|
|
this.agHelper.GetNClick(this._runQueryBtn, 0, true, waitTimeInterval);
|
|
if (toValidateResponse) {
|
|
this.agHelper.AssertElementAbsence(
|
|
this.locator._cancelActionExecution,
|
|
10000,
|
|
); //For the run to give response
|
|
this.agHelper.Sleep();
|
|
this.agHelper.ValidateNetworkExecutionSuccess(
|
|
"@postExecute",
|
|
expectedStatus,
|
|
);
|
|
}
|
|
}
|
|
|
|
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 AssertQueryResponseHeaders(columnHeaders: string[]) {
|
|
columnHeaders.forEach(($header) =>
|
|
this.agHelper.AssertElementVisible(this._queryResponseHeader($header)),
|
|
);
|
|
}
|
|
|
|
public AssertJSONFormHeader(
|
|
rowindex: number,
|
|
colIndex: number,
|
|
headerString: string,
|
|
validateCellData: "" | string = "",
|
|
isMongo = false,
|
|
) {
|
|
let jsonHeaderString = "";
|
|
this.table.ReadTableRowColumnData(rowindex, colIndex).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));
|
|
});
|
|
}
|
|
|
|
public ToggleUsePreparedStatement(enable = true || false) {
|
|
if (enable)
|
|
cy.get(this._usePreparedStatement).check({
|
|
force: true,
|
|
});
|
|
else
|
|
cy.get(this._usePreparedStatement).uncheck({
|
|
force: true,
|
|
});
|
|
|
|
this.agHelper.AssertAutoSave();
|
|
}
|
|
|
|
public EnterQuery(query: string, sleep = 500) {
|
|
cy.get(this.locator._codeEditorTarget).then(($field: any) => {
|
|
this.agHelper.UpdateCodeInput($field, query);
|
|
});
|
|
this.agHelper.AssertAutoSave();
|
|
this.agHelper.Sleep(sleep); //waiting a bit before proceeding!
|
|
cy.wait("@saveAction");
|
|
}
|
|
|
|
public RunQueryNVerifyResponseViews(
|
|
expectedRecordsCount = 1,
|
|
tableCheck = true,
|
|
) {
|
|
this.RunQuery();
|
|
tableCheck &&
|
|
this.agHelper.AssertElementVisible(this._queryResponse("TABLE"));
|
|
this.agHelper.AssertElementVisible(this._queryResponse("JSON"));
|
|
this.agHelper.AssertElementVisible(this._queryResponse("RAW"));
|
|
this.CheckResponseRecordsCount(expectedRecordsCount);
|
|
}
|
|
|
|
public CheckResponseRecordsCount(expectedRecordCount: number) {
|
|
this.agHelper.AssertElementVisible(
|
|
this._queryRecordResult(expectedRecordCount),
|
|
);
|
|
}
|
|
|
|
public CreateDataSource(
|
|
dsType:
|
|
| "Postgres"
|
|
| "Mongo"
|
|
| "MySql"
|
|
| "UnAuthenticatedGraphQL"
|
|
| "MsSql"
|
|
| "Airtable"
|
|
| "Arango"
|
|
| "Firestore"
|
|
| "Elasticsearch"
|
|
| "Redis",
|
|
navigateToCreateNewDs = true,
|
|
testNSave = true,
|
|
) {
|
|
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);
|
|
if (DataSourceKVP[dsType] == "PostgreSQL") this.FillPostgresDSForm();
|
|
else if (DataSourceKVP[dsType] == "MySQL") this.FillMySqlDSForm();
|
|
else if (DataSourceKVP[dsType] == "MongoDB") this.FillMongoDSForm();
|
|
else if (DataSourceKVP[dsType] == "Microsoft SQL Server")
|
|
this.FillMsSqlDSForm();
|
|
else if (DataSourceKVP[dsType] == "Airtable") this.FillAirtableDSForm();
|
|
else if (DataSourceKVP[dsType] == "ArangoDB") this.FillArangoDSForm();
|
|
else if (DataSourceKVP[dsType] == "Firestore")
|
|
this.FillFirestoreDSForm();
|
|
else if (DataSourceKVP[dsType] == "Elasticsearch")
|
|
this.FillElasticSearchDSForm();
|
|
else if (DataSourceKVP[dsType] == "Redis") this.FillRedisDSForm();
|
|
|
|
if (testNSave) {
|
|
this.TestSaveDatasource();
|
|
} else {
|
|
this.SaveDatasource();
|
|
}
|
|
} else if (DataSourceKVP[dsType] == "GraphQL API")
|
|
this.FillUnAuthenticatedGraphQLDSForm();
|
|
cy.wrap(dataSourceName).as("dsName");
|
|
});
|
|
}
|
|
|
|
public CreateQueryFromOverlay(
|
|
dsName: string,
|
|
query = "",
|
|
queryName = "",
|
|
sleep = 500,
|
|
) {
|
|
this.ee.CreateNewDsQuery(dsName);
|
|
if (queryName) this.agHelper.RenameWithInPane(queryName);
|
|
if (query) {
|
|
this.agHelper.GetNClick(this._templateMenu);
|
|
this.EnterQuery(query, sleep);
|
|
}
|
|
}
|
|
|
|
public UpdateGraphqlQueryAndVariable(options?: {
|
|
query?: string;
|
|
variable?: string;
|
|
}) {
|
|
if (options?.query) {
|
|
this.agHelper.GetElement(this._graphqlQueryEditor).then(($field: any) => {
|
|
this.agHelper.UpdateCodeInput($field, options.query as string);
|
|
});
|
|
}
|
|
|
|
if (options?.variable) {
|
|
this.agHelper
|
|
.GetElement(this._graphqlVariableEditor)
|
|
.then(($field: any) => {
|
|
this.agHelper.UpdateCodeInput($field, 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(this._graphqlPagination._limitVariable)
|
|
.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 Variable from dropdown
|
|
cy.get(this._graphqlPagination._offsetVariable).click({
|
|
force: true,
|
|
});
|
|
cy.get(this._graphqlPagination._offsetVariable)
|
|
.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) {
|
|
this.agHelper.GetNClick(this._queryResponse("SETTINGS"));
|
|
cy.xpath(this._queryTimeout)
|
|
.clear()
|
|
.type(queryTimeout.toString(), { delay: 0 }); //Delay 0 to work like paste!
|
|
this.agHelper.AssertAutoSave();
|
|
this.agHelper.GetNClick(this._queryResponse("QUERY"));
|
|
}
|
|
|
|
//Update with new password in the datasource conf page
|
|
public UpdatePassword(newPassword: string) {
|
|
this.ExpandSectionByName(this._sectionAuthentication);
|
|
cy.get(this._password).type(newPassword);
|
|
}
|
|
|
|
//Fetch schema from server and validate UI for the updates
|
|
public VerifySchema(
|
|
dataSourceName: string,
|
|
schema: string,
|
|
isUpdate = false,
|
|
) {
|
|
cy.intercept("GET", this._getStructureReq).as("getDSStructure");
|
|
if (isUpdate) {
|
|
this.UpdateDatasource();
|
|
} else {
|
|
this.SaveDatasource();
|
|
}
|
|
this.ee.ActionContextMenuByEntityName(dataSourceName, "Refresh");
|
|
cy.wait("@getDSStructure").then(() => {
|
|
cy.get(".bp3-collapse-body").contains(schema);
|
|
});
|
|
}
|
|
|
|
public SaveDSFromDialog(save = true) {
|
|
this.agHelper.GoBack();
|
|
this.agHelper.AssertElementVisible(this._datasourceModalDoNotSave);
|
|
this.agHelper.AssertElementVisible(this._datasourceModalSave);
|
|
if (save) {
|
|
this.agHelper.GetNClick(
|
|
this.locator._visibleTextSpan("SAVE"),
|
|
0,
|
|
false,
|
|
0,
|
|
);
|
|
this.agHelper.ValidateNetworkStatus("@saveDatasource", 201);
|
|
this.agHelper.AssertContains("datasource created");
|
|
} else
|
|
this.agHelper.GetNClick(
|
|
this.locator._visibleTextSpan("DON'T SAVE"),
|
|
0,
|
|
false,
|
|
0,
|
|
);
|
|
}
|
|
|
|
public getDSEntity(dSName: string) {
|
|
return `[data-guided-tour-id="explorer-entity-${dSName}"]`;
|
|
}
|
|
|
|
public FillAuthAPIUrl() {
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("URL"),
|
|
datasourceFormData.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(uri: string) {
|
|
this.ValidateNSelectDropdown("Use Mongo Connection String URI", "", "Yes");
|
|
this.agHelper.UpdateInputValue(
|
|
this.locator._inputFieldByName("Connection String URI") + "//input",
|
|
uri,
|
|
);
|
|
}
|
|
|
|
public CreateOAuthClient(grantType: string) {
|
|
let clientId, clientSecret;
|
|
|
|
// Login to TED OAuth
|
|
let formData = new FormData();
|
|
formData.append("username", datasourceFormData["OAuth_Username"]);
|
|
cy.request("POST", datasourceFormData["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", datasourceFormData["OAuth_RedirectUrl"]);
|
|
clientData.append("grant_type", grantType);
|
|
clientData.append("response_type", "code");
|
|
clientData.append("token_endpoint_auth_method", "client_secret_post");
|
|
cy.request(
|
|
"POST",
|
|
datasourceFormData["OAuth_Host"] + "/create_client",
|
|
clientData,
|
|
).then((response) => {
|
|
expect(response.status).to.equal(200);
|
|
});
|
|
|
|
// Get Client Credentials
|
|
cy.request("GET", datasourceFormData["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._saveAndAuthorizeDS);
|
|
|
|
//Accept consent
|
|
this.agHelper.GetNClick(this._consent);
|
|
this.agHelper.GetNClick(this._consentSubmit);
|
|
|
|
//Validate save
|
|
this.agHelper.ValidateNetworkStatus("@saveDatasource", 201);
|
|
}
|
|
|
|
public FillAPIOAuthForm(
|
|
dsName: string,
|
|
grantType: "ClientCredentials" | "AuthCode",
|
|
clientId: string,
|
|
clientSecret: string,
|
|
) {
|
|
if (dsName) this.agHelper.RenameWithInPane(dsName, false);
|
|
// Fill Auth Form
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("URL"),
|
|
datasourceFormData["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.UpdateInput(
|
|
this.locator._inputFieldByName("Access Token URL"),
|
|
datasourceFormData["OAUth_AccessTokenUrl"],
|
|
);
|
|
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("Client ID"),
|
|
clientId,
|
|
);
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("Client Secret"),
|
|
clientSecret,
|
|
);
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("Scope(s)"),
|
|
"profile",
|
|
);
|
|
this.agHelper.UpdateInput(
|
|
this.locator._inputFieldByName("Authorization URL"),
|
|
datasourceFormData["OAuth_AuthUrl"],
|
|
);
|
|
}
|
|
|
|
public AddSuggesstedWidget(widget: Widgets) {
|
|
switch (widget) {
|
|
case Widgets.Dropdown:
|
|
this.agHelper.GetNClick(this._suggestedWidget("SELECT_WIDGET"));
|
|
this.agHelper.AssertElementVisible(
|
|
this.locator._widgetInCanvas(WIDGET.SELECT),
|
|
);
|
|
break;
|
|
case Widgets.Table:
|
|
this.agHelper.GetNClick(this._suggestedWidget("TABLE_WIDGET_V2"));
|
|
this.agHelper.AssertElementVisible(
|
|
this.locator._widgetInCanvas(WIDGET.TABLE),
|
|
);
|
|
break;
|
|
case Widgets.Chart:
|
|
this.agHelper.GetNClick(this._suggestedWidget("CHART_WIDGET"));
|
|
this.agHelper.AssertElementVisible(
|
|
this.locator._widgetInCanvas(WIDGET.CHART),
|
|
);
|
|
break;
|
|
case Widgets.Text:
|
|
this.agHelper.GetNClick(this._suggestedWidget("TEXT_WIDGET"));
|
|
this.agHelper.AssertElementVisible(
|
|
this.locator._widgetInCanvas(WIDGET.TEXT),
|
|
);
|
|
break;
|
|
}
|
|
}
|
|
}
|