138 lines
3.8 KiB
JavaScript
138 lines
3.8 KiB
JavaScript
import { persistStore, persistReducer } from 'redux-persist';
|
|
import autoMergeLevel2 from 'redux-persist/lib/stateReconciler/autoMergeLevel2';
|
|
import createCompressor from 'redux-persist-transform-compress';
|
|
import createFilter from 'redux-persist-transform-filter';
|
|
import localForage from 'localforage';
|
|
import { createStore, applyMiddleware, compose } from 'redux';
|
|
import thunk from 'redux-thunk';
|
|
import { createHashHistory, createBrowserHistory } from 'history';
|
|
import { routerMiddleware } from 'connected-react-router';
|
|
import createRootReducer from './reducers';
|
|
import { Lbryio } from 'lbryinc';
|
|
import isEqual from 'util/deep-equal';
|
|
|
|
function isFunction(object) {
|
|
return typeof object === 'function';
|
|
}
|
|
|
|
function isNotFunction(object) {
|
|
return !isFunction(object);
|
|
}
|
|
|
|
function createBulkThunkMiddleware() {
|
|
return ({ dispatch, getState }) => next => action => {
|
|
if (action.type === 'BATCH_ACTIONS') {
|
|
action.actions.filter(isFunction).map(actionFn => actionFn(dispatch, getState));
|
|
}
|
|
return next(action);
|
|
};
|
|
}
|
|
|
|
function enableBatching(reducer) {
|
|
return function batchingReducer(state, action) {
|
|
switch (action.type) {
|
|
case 'BATCH_ACTIONS':
|
|
return action.actions.filter(isNotFunction).reduce(batchingReducer, state);
|
|
default:
|
|
return reducer(state, action);
|
|
}
|
|
};
|
|
}
|
|
|
|
const contentFilter = createFilter('content', ['positions', 'history']);
|
|
const fileInfoFilter = createFilter('fileInfo', [
|
|
'fileListPublishedSort',
|
|
'fileListDownloadedSort',
|
|
'fileListSubscriptionSort',
|
|
]);
|
|
const appFilter = createFilter('app', ['hasClickedComment', 'searchOptionsExpanded', 'volume', 'muted']);
|
|
// We only need to persist the receiveAddress for the wallet
|
|
const walletFilter = createFilter('wallet', ['receiveAddress']);
|
|
const searchFilter = createFilter('search', ['options']);
|
|
const tagsFilter = createFilter('tags', ['followedTags']);
|
|
const blockedFilter = createFilter('blocked', ['blockedChannels']);
|
|
const whiteListedReducers = [
|
|
// @if TARGET='app'
|
|
'publish',
|
|
'wallet',
|
|
'tags',
|
|
// 'fileInfo',
|
|
// @endif
|
|
'content',
|
|
'app',
|
|
'search',
|
|
'blocked',
|
|
'settings',
|
|
'sync',
|
|
];
|
|
|
|
const transforms = [
|
|
// @if TARGET='app'
|
|
walletFilter,
|
|
fileInfoFilter,
|
|
blockedFilter,
|
|
tagsFilter,
|
|
// @endif
|
|
appFilter,
|
|
searchFilter,
|
|
tagsFilter,
|
|
contentFilter,
|
|
createCompressor(),
|
|
];
|
|
|
|
const persistOptions = {
|
|
key: 'v0',
|
|
storage: localForage,
|
|
stateReconciler: autoMergeLevel2,
|
|
whitelist: whiteListedReducers,
|
|
// Order is important. Needs to be compressed last or other transforms can't
|
|
// read the data
|
|
transforms,
|
|
};
|
|
|
|
let history;
|
|
// @if TARGET='app'
|
|
history = createHashHistory();
|
|
// @endif
|
|
// @if TARGET='web'
|
|
history = createBrowserHistory();
|
|
// @endif
|
|
|
|
const rootReducer = createRootReducer(history);
|
|
const persistedReducer = persistReducer(persistOptions, rootReducer);
|
|
const bulkThunk = createBulkThunkMiddleware();
|
|
const middleware = [routerMiddleware(history), thunk, bulkThunk];
|
|
const composeEnhancers = window.__REDUX_DEVTOOLS_EXTENSION_COMPOSE__ || compose;
|
|
const store = createStore(
|
|
enableBatching(persistedReducer),
|
|
{}, // initial state
|
|
composeEnhancers(applyMiddleware(...middleware))
|
|
);
|
|
|
|
let currentPayload;
|
|
store.subscribe(() => {
|
|
const state = store.getState();
|
|
const subscriptions = state.subscriptions.subscriptions.map(({ uri }) => uri);
|
|
const tags = state.tags.followedTags;
|
|
const authToken = state.user.accessToken;
|
|
|
|
const newPayload = {
|
|
version: '0.1',
|
|
shared: {
|
|
subscriptions,
|
|
tags,
|
|
},
|
|
};
|
|
|
|
if (!isEqual(newPayload, currentPayload)) {
|
|
currentPayload = newPayload;
|
|
if (authToken) {
|
|
Lbryio.call('user_settings', 'set', { settings: newPayload });
|
|
}
|
|
}
|
|
});
|
|
|
|
const persistor = persistStore(store);
|
|
window.persistor = persistor;
|
|
|
|
export { store, persistor, history, whiteListedReducers };
|