c42e0317de
In order to unify package names, we decided to use `@appsmith` prefix as a marker to indicate that packages belong to our codebase and that these packages are developed internally. So that we can use this prefix, we need to rename the alias of the same name. But since `@appsmith` is currently being used as an alias for `ee` folder, we have to rename the alias as the first step. Related discussion https://theappsmith.slack.com/archives/CPG2ZTXEY/p1722516279126329 EE PR — https://github.com/appsmithorg/appsmith-ee/pull/4801 ## Automation /ok-to-test tags="@tag.All" ### 🔍 Cypress test results <!-- This is an auto-generated comment: Cypress test results --> > [!TIP] > 🟢 🟢 🟢 All cypress tests have passed! 🎉 🎉 🎉 > Workflow run: <https://github.com/appsmithorg/appsmith/actions/runs/10267368821> > Commit: 2b00af2d257e4d4304db0a80072afef7513de6be > <a href="https://internal.appsmith.com/app/cypress-dashboard/rundetails-65890b3c81d7400d08fa9ee5?branch=master&workflowId=10267368821&attempt=2" target="_blank">Cypress dashboard</a>. > Tags: `@tag.All` > Spec: > <hr>Tue, 06 Aug 2024 14:24:22 UTC <!-- end of auto-generated comment: Cypress test results --> ## Communication Should the DevRel and Marketing teams inform users about this change? - [ ] Yes - [x] No
91 lines
2.7 KiB
TypeScript
91 lines
2.7 KiB
TypeScript
/* eslint-disable @typescript-eslint/ban-ts-comment */
|
|
import _ from "lodash";
|
|
import { put, debounce, takeEvery, all } from "redux-saga/effects";
|
|
import type { ReduxAction } from "ee/constants/ReduxActionConstants";
|
|
import { ReduxActionTypes } from "ee/constants/ReduxActionConstants";
|
|
import { batchActionSuccess } from "actions/batchActions";
|
|
import * as log from "loglevel";
|
|
|
|
const BATCH_PRIORITY = {
|
|
[ReduxActionTypes.META_UPDATE_DEBOUNCED_EVAL]: {
|
|
priority: 0,
|
|
needsSaga: false,
|
|
},
|
|
[ReduxActionTypes.SET_META_PROP_AND_EVAL]: {
|
|
priority: 0,
|
|
needsSaga: false,
|
|
},
|
|
[ReduxActionTypes.RESET_WIDGET_META]: {
|
|
priority: 0,
|
|
needsSaga: false,
|
|
},
|
|
[ReduxActionTypes.RESET_WIDGET_META_UPDATES]: {
|
|
priority: 0,
|
|
needsSaga: false,
|
|
},
|
|
[ReduxActionTypes.UPDATE_WIDGET_PROPERTY]: {
|
|
priority: 0,
|
|
needsSaga: false,
|
|
},
|
|
[ReduxActionTypes.EXECUTE_TRIGGER_REQUEST]: {
|
|
priority: 1,
|
|
needsSaga: true,
|
|
},
|
|
[ReduxActionTypes.EXECUTE_PAGE_LOAD_ACTIONS]: {
|
|
priority: 1,
|
|
needsSaga: true,
|
|
},
|
|
[ReduxActionTypes.UPDATE_ACTION_PROPERTY]: {
|
|
priority: 0,
|
|
needsSaga: false,
|
|
},
|
|
[ReduxActionTypes.UPDATE_ACTION_INIT]: {
|
|
priority: 1,
|
|
needsSaga: true,
|
|
},
|
|
};
|
|
|
|
// TODO: Fix this the next time the file is edited
|
|
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
|
const batches: ReduxAction<any>[][] = [];
|
|
|
|
// TODO: Fix this the next time the file is edited
|
|
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
|
function* storeUpdatesSaga(action: ReduxAction<ReduxAction<any>>) {
|
|
try {
|
|
const priority = BATCH_PRIORITY[action.payload.type].priority;
|
|
const currentPriorityBatch = batches[priority] || [];
|
|
currentPriorityBatch.push(action.payload);
|
|
_.set(batches, `[${priority}]`, currentPriorityBatch);
|
|
yield put({ type: ReduxActionTypes.EXECUTE_BATCH });
|
|
} catch (e) {
|
|
log.error(`${action.payload.type} action priority not set`);
|
|
}
|
|
}
|
|
|
|
function* executeBatchSaga() {
|
|
for (let priority = 0; priority < batches.length; priority++) {
|
|
const batch = batches[priority];
|
|
if (Array.isArray(batch) && batch.length) {
|
|
const needsSaga = batch.filter((b) => BATCH_PRIORITY[b.type].needsSaga);
|
|
const canBatch = batch.filter((b) => !BATCH_PRIORITY[b.type].needsSaga);
|
|
batches[priority] = [];
|
|
// @ts-expect-error: Types are not available
|
|
yield put(canBatch);
|
|
if (needsSaga.length) {
|
|
for (const sagaAction of needsSaga) {
|
|
yield put(sagaAction);
|
|
}
|
|
}
|
|
yield put(batchActionSuccess(batch));
|
|
}
|
|
}
|
|
}
|
|
|
|
export default function* root() {
|
|
yield all([
|
|
debounce(20, ReduxActionTypes.EXECUTE_BATCH, executeBatchSaga),
|
|
takeEvery(ReduxActionTypes.BATCHED_UPDATE, storeUpdatesSaga),
|
|
]);
|
|
}
|