94 lines
2.6 KiB
JavaScript
94 lines
2.6 KiB
JavaScript
import merge from 'lodash.merge'
|
|
import localforage from 'localforage'
|
|
import { each, get, set, cloneDeep } from 'lodash'
|
|
|
|
let loaded = false
|
|
|
|
const defaultReducer = (state, paths) => (
|
|
paths.length === 0 ? state : paths.reduce((substate, path) => {
|
|
set(substate, path, get(state, path))
|
|
return substate
|
|
}, {})
|
|
)
|
|
|
|
const saveImmedeatelyActions = [
|
|
'markNotificationsAsSeen',
|
|
'clearCurrentUser',
|
|
'setCurrentUser',
|
|
'setHighlight',
|
|
'setOption',
|
|
'setClientData',
|
|
'setToken',
|
|
'clearToken',
|
|
'emojiUsed',
|
|
]
|
|
|
|
const defaultStorage = (() => {
|
|
return localforage
|
|
})()
|
|
|
|
export default function createPersistedState ({
|
|
key = 'vuex-lz',
|
|
paths = [],
|
|
getState = (key, storage) => {
|
|
let value = storage.getItem(key)
|
|
return value
|
|
},
|
|
setState = (key, state, storage) => {
|
|
if (!loaded) {
|
|
console.log('waiting for old state to be loaded...')
|
|
return Promise.resolve()
|
|
} else {
|
|
return storage.setItem(key, state)
|
|
}
|
|
},
|
|
reducer = defaultReducer,
|
|
storage = defaultStorage,
|
|
subscriber = store => handler => store.subscribe(handler)
|
|
} = {}) {
|
|
return getState(key, storage).then((savedState) => {
|
|
return store => {
|
|
try {
|
|
if (savedState !== null && typeof savedState === 'object') {
|
|
// build user cache
|
|
const usersState = savedState.users || {}
|
|
usersState.usersObject = {}
|
|
const users = usersState.users || []
|
|
each(users, (user) => { usersState.usersObject[user.id] = user })
|
|
savedState.users = usersState
|
|
|
|
store.replaceState(
|
|
merge({}, store.state, savedState)
|
|
)
|
|
}
|
|
loaded = true
|
|
} catch (e) {
|
|
console.error("Couldn't load state")
|
|
console.error(e)
|
|
loaded = true
|
|
}
|
|
subscriber(store)((mutation, state) => {
|
|
try {
|
|
if (saveImmedeatelyActions.includes(mutation.type)) {
|
|
setState(key, reducer(cloneDeep(state), paths), storage)
|
|
.then(success => {
|
|
if (typeof success !== 'undefined') {
|
|
if (mutation.type === 'setOption' || mutation.type === 'setCurrentUser') {
|
|
store.dispatch('settingsSaved', { success })
|
|
}
|
|
}
|
|
}, error => {
|
|
if (mutation.type === 'setOption' || mutation.type === 'setCurrentUser') {
|
|
store.dispatch('settingsSaved', { error })
|
|
}
|
|
})
|
|
}
|
|
} catch (e) {
|
|
console.error("Couldn't persist state:")
|
|
console.error(e)
|
|
}
|
|
})
|
|
}
|
|
})
|
|
}
|