import { all, select, put, take, takeEvery, call, race, } from "redux-saga/effects"; import * as Sentry from "@sentry/react"; import { ReduxAction, ReduxActionErrorTypes, ReduxActionTypes, ReduxActionWithMeta, ReduxFormActionTypes, } from "constants/ReduxActionConstants"; import { getFormData } from "selectors/formSelectors"; import { QUERY_EDITOR_FORM_NAME } from "constants/forms"; import history from "utils/history"; import { QUERIES_EDITOR_URL, QUERIES_EDITOR_ID_URL, APPLICATIONS_URL, } from "constants/routes"; import { getCurrentApplicationId, getCurrentPageId, } from "selectors/editorSelectors"; import { autofill, change, initialize } from "redux-form"; import { getAction, getPluginEditorConfigs, getDatasource, getPluginTemplates, } from "selectors/entitiesSelector"; import { QueryAction } from "entities/Action"; import { setActionProperty } from "actions/actionActions"; import { fetchPluginForm } from "actions/pluginActions"; import { isEmpty, merge } from "lodash"; import { getConfigInitialValues } from "components/formControls/utils"; import { Variant } from "components/ads/common"; import { Toaster } from "components/ads/Toast"; function* changeQuerySaga(actionPayload: ReduxAction<{ id: string }>) { const { id } = actionPayload.payload; const state = yield select(); const editorConfigs = state.entities.plugins.editorConfigs; const settingConfigs = state.entities.plugins.settingConfigs; let configInitialValues = {}; // // Typescript says Element does not have blur function but it does; // document.activeElement && // "blur" in document.activeElement && // // eslint-disable-next-line @typescript-eslint/ban-ts-comment // // @ts-ignore: No types available // document.activeElement.blur(); const applicationId = yield select(getCurrentApplicationId); const pageId = yield select(getCurrentPageId); if (!applicationId || !pageId) { history.push(APPLICATIONS_URL); return; } const action = yield select(getAction, id); if (!action) { history.push(QUERIES_EDITOR_URL(applicationId, pageId)); return; } let currentEditorConfig = editorConfigs[action.datasource.pluginId]; if (!currentEditorConfig) { yield put(fetchPluginForm({ id: action.datasource.pluginId })); // Wait for either these events const { success } = yield race({ error: take(ReduxActionErrorTypes.FETCH_PLUGIN_FORM_ERROR), success: take(ReduxActionTypes.FETCH_PLUGIN_FORM_SUCCESS), }); // Update the config if (success) { currentEditorConfig = success.payload.editor; } } const currentSettingConfig = settingConfigs[action.datasource.pluginId]; // If config exists if (currentEditorConfig) { // Get initial values configInitialValues = yield call( getConfigInitialValues, currentEditorConfig, ); } if (currentSettingConfig) { const settingInitialValues = yield call( getConfigInitialValues, currentSettingConfig, ); configInitialValues = merge(configInitialValues, settingInitialValues); } // Merge the initial values and action. const formInitialValues = merge(configInitialValues, action); yield put(initialize(QUERY_EDITOR_FORM_NAME, formInitialValues)); } function* formValueChangeSaga( actionPayload: ReduxActionWithMeta, ) { const { form, field } = actionPayload.meta; if (field === "dynamicBindingPathList" || field === "name") return; if (form !== QUERY_EDITOR_FORM_NAME) return; const { values } = yield select(getFormData, QUERY_EDITOR_FORM_NAME); if (field === "datasource.id") { const editorConfigs = yield select(getPluginEditorConfigs); const datasource = yield select(getDatasource, actionPayload.payload); // Update the datasource not just the datasource id. yield put( setActionProperty({ actionId: values.id, propertyName: "datasource", value: datasource, }), ); if (!editorConfigs[datasource.pluginId]) { yield put(fetchPluginForm({ id: datasource.pluginId })); } // Update the datasource of the form as well yield put(autofill(QUERY_EDITOR_FORM_NAME, "datasource", datasource)); return; } yield put( setActionProperty({ actionId: values.id, propertyName: field, value: actionPayload.payload, }), ); } function* handleQueryCreatedSaga(actionPayload: ReduxAction) { const { id, pluginType, pluginId, actionConfiguration, } = actionPayload.payload; if (pluginType === "DB") { const state = yield select(); const editorConfigs = state.entities.plugins.editorConfigs; if (!editorConfigs[pluginId]) { yield put(fetchPluginForm({ id: pluginId })); } yield put(initialize(QUERY_EDITOR_FORM_NAME, actionPayload.payload)); const applicationId = yield select(getCurrentApplicationId); const pageId = yield select(getCurrentPageId); const pluginTemplates = yield select(getPluginTemplates); const queryTemplate = pluginTemplates[pluginId]; // Do not show template view if the query has body(code) or if there are no templates const showTemplate = !( !!actionConfiguration.body || isEmpty(queryTemplate) ); history.replace( QUERIES_EDITOR_ID_URL(applicationId, pageId, id, { editName: "true", showTemplate, }), ); } } function* handleNameChangeSaga( action: ReduxAction<{ id: string; name: string }>, ) { yield put(change(QUERY_EDITOR_FORM_NAME, "name", action.payload.name)); } function* handleNameChangeSuccessSaga( action: ReduxAction<{ actionId: string }>, ) { const { actionId } = action.payload; const actionObj = yield select(getAction, actionId); yield take(ReduxActionTypes.FETCH_ACTIONS_FOR_PAGE_SUCCESS); if (!actionObj) { // Error case, log to sentry Toaster.show({ text: "Error occured while renaming query", variant: Variant.danger, }); Sentry.captureException(new Error("Error occured while renaming query"), { extra: { actionId: actionId, }, }); return; } } function* handleNameChangeFailureSaga( action: ReduxAction<{ oldName: string }>, ) { yield put(change(QUERY_EDITOR_FORM_NAME, "name", action.payload.oldName)); } export default function* root() { yield all([ takeEvery(ReduxActionTypes.CREATE_ACTION_SUCCESS, handleQueryCreatedSaga), takeEvery(ReduxActionTypes.QUERY_PANE_CHANGE, changeQuerySaga), takeEvery(ReduxActionTypes.SAVE_ACTION_NAME_INIT, handleNameChangeSaga), takeEvery( ReduxActionTypes.SAVE_ACTION_NAME_SUCCESS, handleNameChangeSuccessSaga, ), takeEvery( ReduxActionErrorTypes.SAVE_ACTION_NAME_ERROR, handleNameChangeFailureSaga, ), // Intercepting the redux-form change actionType takeEvery(ReduxFormActionTypes.VALUE_CHANGE, formValueChangeSaga), takeEvery(ReduxFormActionTypes.ARRAY_REMOVE, formValueChangeSaga), ]); }