reduxjs/redux-devtools
1
1
Fork 0
mirror of https://github.com/reduxjs/redux-devtools.git synced 2025-11-04 01:47:25 +03:00
Code Issues Packages Projects Releases Wiki Activity

auto-commit on INIT, handle committing multiple

Browse Source
This commit is contained in:
echenley 2016-02-09 15:58:40 -06:00
parent c883e837ba
commit ef073a1fa4
1 changed files with 34 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/instrument.js
View File

@ -165,6 +165,21 @@ function liftReducerWith(reducer, initialCommittedState, monitorReducer, options
computedStates
} = liftedState;
function commitExcessActions() {
// If maxAge has been exceeded, auto-commit excess.
const excess = stagedActionIds.length - options.maxAge + 1;
const idsToDelete = stagedActionIds.slice(1, excess + 1);
idsToDelete.forEach(id => delete actionsById[id]);
skippedActionIds = skippedActionIds.filter(id => idsToDelete.indexOf(id) === -1);
stagedActionIds = [0, ...stagedActionIds.slice(excess + 1)];
committedState = computedStates[excess].state;
computedStates = computedStates.slice(excess);
currentStateIndex = currentStateIndex > excess
? currentStateIndex - excess
: 0;
}
// By default, agressively recompute every state whatever happens.
// This has O(n) performance, so we'll override this to a sensible
// value whenever we feel like we don't have to recompute the states.
@ -240,13 +255,10 @@ function liftReducerWith(reducer, initialCommittedState, monitorReducer, options
stagedActionIds.length === options.maxAge &&
!computedStates[1].error
) {
// If maxAge has been reached, auto-commit earliest non-@@INIT action.
delete actionsById[stagedActionIds[1]];
skippedActionIds = skippedActionIds.filter(id => id !== stagedActionIds[1]);
stagedActionIds = [0].concat(stagedActionIds.slice(2));
committedState = computedStates[1].state;
computedStates = computedStates.slice(1);
} else if (currentStateIndex === stagedActionIds.length - 1) {
commitExcessActions();
}
if (currentStateIndex === stagedActionIds.length - 1) {
currentStateIndex++;
}
const actionId = nextActionId++;
@ -275,6 +287,21 @@ function liftReducerWith(reducer, initialCommittedState, monitorReducer, options
case '@@redux/INIT': {
// Always recompute states on hot reload and init.
minInvalidatedStateIndex = 0;
if (options.maxAge && stagedActionIds.length >= options.maxAge) {
// states must be computed prior to committing
computedStates = recomputeStates(
computedStates,
minInvalidatedStateIndex,
reducer,
committedState,
actionsById,
stagedActionIds,
skippedActionIds
);
commitExcessActions();
}
break;
}
default: {