LBRYCommunity/lbry-redux
1
0
Fork 0
Code Issues 5 Pull requests 6 Projects Releases Packages Wiki Activity

add fatal error sync action

Browse source
This commit is contained in:
Sean Yesmunt 2020-11-12 13:21:13 -05:00
parent 8093d69807
commit 8344379bfd
4 changed files with 96 additions and 69 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

80
dist/bundle.es.js vendored
View file

@ -289,6 +289,7 @@ const FETCH_COST_INFO_FAILED = 'FETCH_COST_INFO_FAILED';
// Sync
const USER_STATE_POPULATE = 'USER_STATE_POPULATE';
const SYNC_FATAL_ERROR = 'SYNC_FATAL_ERROR';
var action_types = /*#__PURE__*/Object.freeze({
WINDOW_FOCUSED: WINDOW_FOCUSED,
@ -529,7 +530,8 @@ var action_types = /*#__PURE__*/Object.freeze({
FETCH_COST_INFO_STARTED: FETCH_COST_INFO_STARTED,
FETCH_COST_INFO_COMPLETED: FETCH_COST_INFO_COMPLETED,
FETCH_COST_INFO_FAILED: FETCH_COST_INFO_FAILED,
USER_STATE_POPULATE: USER_STATE_POPULATE
USER_STATE_POPULATE: USER_STATE_POPULATE,
SYNC_FATAL_ERROR: SYNC_FATAL_ERROR
});
const CC_LICENSES = [{
@ -1754,43 +1756,55 @@ function doPopulateSharedUserState(sharedSettings) {
}
function doPreferenceSet(key, value, version, success, fail) {
const preference = {
type: typeof value,
version,
value
};
return dispatch => {
const preference = {
type: typeof value,
version,
value
};
const options = {
key,
value: JSON.stringify(preference)
};
const options = {
key,
value: JSON.stringify(preference)
};
lbryProxy.preference_set(options).then(() => {
success(preference);
}).catch(() => {
if (fail) {
fail();
}
});
lbryProxy.preference_set(options).then(() => {
success(preference);
}).catch(() => {
dispatch({
type: SYNC_FATAL_ERROR
});
if (fail) {
fail();
}
});
};
}
function doPreferenceGet(key, success, fail) {
const options = {
key
return dispatch => {
const options = {
key
};
return lbryProxy.preference_get(options).then(result => {
if (result) {
const preference = result[key];
return success(preference);
}
return success(null);
}).catch(err => {
dispatch({
type: SYNC_FATAL_ERROR
});
if (fail) {
fail(err);
}
});
};
return lbryProxy.preference_get(options).then(result => {
if (result) {
const preference = result[key];
return success(preference);
}
return success(null);
}).catch(err => {
if (fail) {
fail(err);
}
});
}
//
@ -1831,7 +1845,7 @@ const buildSharedStateMiddleware = (actions, sharedStateFilters, sharedStateCb)
if (!isEqual(oldShared, shared)) {
// only update if the preference changed from last call in the same session
oldShared = shared;
doPreferenceSet(preferenceKey, shared, SHARED_PREFERENCE_VERSION);
dispatch(doPreferenceSet(preferenceKey, shared, SHARED_PREFERENCE_VERSION));
}
if (sharedStateCb) {

1
src/constants/action_types.js
View file

@ -268,3 +268,4 @@ export const FETCH_COST_INFO_FAILED = 'FETCH_COST_INFO_FAILED';
// Sync
export const USER_STATE_POPULATE = 'USER_STATE_POPULATE';
export const SYNC_FATAL_ERROR = 'SYNC_FATAL_ERROR';

82
src/redux/actions/sync.js
View file

@ -74,45 +74,57 @@ export function doPreferenceSet(
success: Function,
fail: Function
) {
const preference = {
type: typeof value,
version,
value,
};
return (dispatch: Dispatch) => {
const preference = {
type: typeof value,
version,
value,
};
const options = {
key,
value: JSON.stringify(preference),
};
const options = {
key,
value: JSON.stringify(preference),
};
Lbry.preference_set(options)
.then(() => {
success(preference);
})
.catch(() => {
if (fail) {
fail();
}
});
Lbry.preference_set(options)
.then(() => {
success(preference);
})
.catch(() => {
dispatch({
type: ACTIONS.SYNC_FATAL_ERROR,
});
if (fail) {
fail();
}
});
};
}
export function doPreferenceGet(key: string, success: Function, fail?: Function) {
const options = {
key,
return (dispatch: Dispatch) => {
const options = {
key,
};
return Lbry.preference_get(options)
.then(result => {
if (result) {
const preference = result[key];
return success(preference);
}
return success(null);
})
.catch(err => {
dispatch({
type: ACTIONS.SYNC_FATAL_ERROR,
});
if (fail) {
fail(err);
}
});
};
return Lbry.preference_get(options)
.then(result => {
if (result) {
const preference = result[key];
return success(preference);
}
return success(null);
})
.catch(err => {
if (fail) {
fail(err);
}
});
}

2
src/redux/middleware/shared-state.js
View file

@ -49,7 +49,7 @@ export const buildSharedStateMiddleware = (
if (!isEqual(oldShared, shared)) {
// only update if the preference changed from last call in the same session
oldShared = shared;
doPreferenceSet(preferenceKey, shared, SHARED_PREFERENCE_VERSION);
dispatch(doPreferenceSet(preferenceKey, shared, SHARED_PREFERENCE_VERSION));
}
if (sharedStateCb) {