LBRYCommunity/lbryinc
1
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity

Changes needed for additional youtube transfer UI #62

Merged
neb-b merged 4 commits from onboarding into master 2019-10-07 04:40:02 +02:00
Conversation 0 Commits 4 Files changed 13 +1159 -706
12 changed files with 1159 additions and 706 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 7c94a38683 - Show all commits

1
.eslintrc.json
View file

@ -22,6 +22,7 @@
"__": true
},
"rules": {
"consistent-return": 0,
"import/no-commonjs": "warn",
"import/no-amd": "warn",
"import/prefer-default-export": "ignore",

464
dist/bundle.es.js vendored
View file

@ -8,10 +8,46 @@ var lbryRedux = require('lbry-redux');
var querystring = _interopDefault(require('querystring'));
var reselect = require('reselect');
// Auth Token
// User
const GENERATE_AUTH_TOKEN_FAILURE = 'GENERATE_AUTH_TOKEN_FAILURE';
const GENERATE_AUTH_TOKEN_STARTED = 'GENERATE_AUTH_TOKEN_STARTED';
const GENERATE_AUTH_TOKEN_SUCCESS = 'GENERATE_AUTH_TOKEN_SUCCESS'; // Claims
const GENERATE_AUTH_TOKEN_SUCCESS = 'GENERATE_AUTH_TOKEN_SUCCESS';
const AUTHENTICATION_STARTED = 'AUTHENTICATION_STARTED';
const AUTHENTICATION_SUCCESS = 'AUTHENTICATION_SUCCESS';
const AUTHENTICATION_FAILURE = 'AUTHENTICATION_FAILURE';
const USER_EMAIL_DECLINE = 'USER_EMAIL_DECLINE';
const USER_EMAIL_NEW_STARTED = 'USER_EMAIL_NEW_STARTED';
const USER_EMAIL_NEW_SUCCESS = 'USER_EMAIL_NEW_SUCCESS';
const USER_EMAIL_NEW_EXISTS = 'USER_EMAIL_NEW_EXISTS';
const USER_EMAIL_NEW_FAILURE = 'USER_EMAIL_NEW_FAILURE';
const USER_EMAIL_VERIFY_SET = 'USER_EMAIL_VERIFY_SET';
const USER_EMAIL_VERIFY_STARTED = 'USER_EMAIL_VERIFY_STARTED';
const USER_EMAIL_VERIFY_SUCCESS = 'USER_EMAIL_VERIFY_SUCCESS';
const USER_EMAIL_VERIFY_FAILURE = 'USER_EMAIL_VERIFY_FAILURE';
const USER_EMAIL_VERIFY_RETRY = 'USER_EMAIL_VERIFY_RETRY';
const USER_PHONE_RESET = 'USER_PHONE_RESET';
const USER_PHONE_NEW_STARTED = 'USER_PHONE_NEW_STARTED';
const USER_PHONE_NEW_SUCCESS = 'USER_PHONE_NEW_SUCCESS';
const USER_PHONE_NEW_FAILURE = 'USER_PHONE_NEW_FAILURE';
const USER_PHONE_VERIFY_STARTED = 'USER_PHONE_VERIFY_STARTED';
const USER_PHONE_VERIFY_SUCCESS = 'USER_PHONE_VERIFY_SUCCESS';
const USER_PHONE_VERIFY_FAILURE = 'USER_PHONE_VERIFY_FAILURE';
const USER_IDENTITY_VERIFY_STARTED = 'USER_IDENTITY_VERIFY_STARTED';
const USER_IDENTITY_VERIFY_SUCCESS = 'USER_IDENTITY_VERIFY_SUCCESS';
const USER_IDENTITY_VERIFY_FAILURE = 'USER_IDENTITY_VERIFY_FAILURE';
const USER_FETCH_STARTED = 'USER_FETCH_STARTED';
const USER_FETCH_SUCCESS = 'USER_FETCH_SUCCESS';
const USER_FETCH_FAILURE = 'USER_FETCH_FAILURE';
const USER_INVITE_STATUS_FETCH_STARTED = 'USER_INVITE_STATUS_FETCH_STARTED';
const USER_INVITE_STATUS_FETCH_SUCCESS = 'USER_INVITE_STATUS_FETCH_SUCCESS';
const USER_INVITE_STATUS_FETCH_FAILURE = 'USER_INVITE_STATUS_FETCH_FAILURE';
const USER_INVITE_NEW_STARTED = 'USER_INVITE_NEW_STARTED';
const USER_INVITE_NEW_SUCCESS = 'USER_INVITE_NEW_SUCCESS';
const USER_INVITE_NEW_FAILURE = 'USER_INVITE_NEW_FAILURE';
const FETCH_ACCESS_TOKEN_SUCCESS = 'FETCH_ACCESS_TOKEN_SUCCESS';
const USER_YOUTUBE_IMPORT_STARTED = 'USER_YOUTUBE_IMPORT_STARTED';
const USER_YOUTUBE_IMPORT_FAILURE = 'USER_YOUTUBE_IMPORT_FAILURE';
const USER_YOUTUBE_IMPORT_SUCCESS = 'USER_YOUTUBE_IMPORT_SUCCESS'; // Claims
const FETCH_FEATURED_CONTENT_STARTED = 'FETCH_FEATURED_CONTENT_STARTED';
const FETCH_FEATURED_CONTENT_COMPLETED = 'FETCH_FEATURED_CONTENT_COMPLETED';
@ -83,6 +119,7 @@ const FETCH_SUB_COUNT_COMPLETED = 'FETCH_SUB_COUNT_COMPLETED'; // Cross-device S
const GET_SYNC_STARTED = 'GET_SYNC_STARTED';
const GET_SYNC_COMPLETED = 'GET_SYNC_COMPLETED';
const GET_SYNC_FAILED = 'GET_SYNC_FAILED';
const SET_SYNC_STARTED = 'SET_SYNC_STARTED';
const SET_SYNC_FAILED = 'SET_SYNC_FAILED';
const SET_SYNC_COMPLETED = 'SET_SYNC_COMPLETED';
@ -95,6 +132,42 @@ var action_types = /*#__PURE__*/Object.freeze({
GENERATE_AUTH_TOKEN_FAILURE: GENERATE_AUTH_TOKEN_FAILURE,
GENERATE_AUTH_TOKEN_STARTED: GENERATE_AUTH_TOKEN_STARTED,
GENERATE_AUTH_TOKEN_SUCCESS: GENERATE_AUTH_TOKEN_SUCCESS,
AUTHENTICATION_STARTED: AUTHENTICATION_STARTED,
AUTHENTICATION_SUCCESS: AUTHENTICATION_SUCCESS,
AUTHENTICATION_FAILURE: AUTHENTICATION_FAILURE,
USER_EMAIL_DECLINE: USER_EMAIL_DECLINE,
USER_EMAIL_NEW_STARTED: USER_EMAIL_NEW_STARTED,
USER_EMAIL_NEW_SUCCESS: USER_EMAIL_NEW_SUCCESS,
USER_EMAIL_NEW_EXISTS: USER_EMAIL_NEW_EXISTS,
USER_EMAIL_NEW_FAILURE: USER_EMAIL_NEW_FAILURE,
USER_EMAIL_VERIFY_SET: USER_EMAIL_VERIFY_SET,
USER_EMAIL_VERIFY_STARTED: USER_EMAIL_VERIFY_STARTED,
USER_EMAIL_VERIFY_SUCCESS: USER_EMAIL_VERIFY_SUCCESS,
USER_EMAIL_VERIFY_FAILURE: USER_EMAIL_VERIFY_FAILURE,
USER_EMAIL_VERIFY_RETRY: USER_EMAIL_VERIFY_RETRY,
USER_PHONE_RESET: USER_PHONE_RESET,
USER_PHONE_NEW_STARTED: USER_PHONE_NEW_STARTED,
USER_PHONE_NEW_SUCCESS: USER_PHONE_NEW_SUCCESS,
USER_PHONE_NEW_FAILURE: USER_PHONE_NEW_FAILURE,
USER_PHONE_VERIFY_STARTED: USER_PHONE_VERIFY_STARTED,
USER_PHONE_VERIFY_SUCCESS: USER_PHONE_VERIFY_SUCCESS,
USER_PHONE_VERIFY_FAILURE: USER_PHONE_VERIFY_FAILURE,
USER_IDENTITY_VERIFY_STARTED: USER_IDENTITY_VERIFY_STARTED,
USER_IDENTITY_VERIFY_SUCCESS: USER_IDENTITY_VERIFY_SUCCESS,
USER_IDENTITY_VERIFY_FAILURE: USER_IDENTITY_VERIFY_FAILURE,
USER_FETCH_STARTED: USER_FETCH_STARTED,
USER_FETCH_SUCCESS: USER_FETCH_SUCCESS,
USER_FETCH_FAILURE: USER_FETCH_FAILURE,
USER_INVITE_STATUS_FETCH_STARTED: USER_INVITE_STATUS_FETCH_STARTED,
USER_INVITE_STATUS_FETCH_SUCCESS: USER_INVITE_STATUS_FETCH_SUCCESS,
USER_INVITE_STATUS_FETCH_FAILURE: USER_INVITE_STATUS_FETCH_FAILURE,
USER_INVITE_NEW_STARTED: USER_INVITE_NEW_STARTED,
USER_INVITE_NEW_SUCCESS: USER_INVITE_NEW_SUCCESS,
USER_INVITE_NEW_FAILURE: USER_INVITE_NEW_FAILURE,
FETCH_ACCESS_TOKEN_SUCCESS: FETCH_ACCESS_TOKEN_SUCCESS,
USER_YOUTUBE_IMPORT_STARTED: USER_YOUTUBE_IMPORT_STARTED,
USER_YOUTUBE_IMPORT_FAILURE: USER_YOUTUBE_IMPORT_FAILURE,
USER_YOUTUBE_IMPORT_SUCCESS: USER_YOUTUBE_IMPORT_SUCCESS,
FETCH_FEATURED_CONTENT_STARTED: FETCH_FEATURED_CONTENT_STARTED,
FETCH_FEATURED_CONTENT_COMPLETED: FETCH_FEATURED_CONTENT_COMPLETED,
FETCH_TRENDING_CONTENT_STARTED: FETCH_TRENDING_CONTENT_STARTED,
@ -159,6 +232,7 @@ var action_types = /*#__PURE__*/Object.freeze({
FETCH_SUB_COUNT_COMPLETED: FETCH_SUB_COUNT_COMPLETED,
GET_SYNC_STARTED: GET_SYNC_STARTED,
GET_SYNC_COMPLETED: GET_SYNC_COMPLETED,
GET_SYNC_FAILED: GET_SYNC_FAILED,
SET_SYNC_STARTED: SET_SYNC_STARTED,
SET_SYNC_FAILED: SET_SYNC_FAILED,
SET_SYNC_COMPLETED: SET_SYNC_COMPLETED,
@ -168,6 +242,16 @@ var action_types = /*#__PURE__*/Object.freeze({
SYNC_APPLY_FAILED: SYNC_APPLY_FAILED
});
const NOT_TRANSFERRED = 'not_transferred';
const PENDING_TRANSFER = 'pending_transfer';
const COMPLETED_TRANSFER = 'completed_transfer';
var youtube = /*#__PURE__*/Object.freeze({
NOT_TRANSFERRED: NOT_TRANSFERRED,
PENDING_TRANSFER: PENDING_TRANSFER,
COMPLETED_TRANSFER: COMPLETED_TRANSFER
});
const Lbryio = {
enabled: true,
authenticationPromise: null,
@ -1040,18 +1124,26 @@ const selectUserInviteStatusFailed = reselect.createSelector(selectUserInvitesRe
const selectUserInviteNewIsPending = reselect.createSelector(selectState$2, state => state.inviteNewIsPending);
const selectUserInviteNewErrorMessage = reselect.createSelector(selectState$2, state => state.inviteNewErrorMessage);
const selectUserInviteReferralLink = reselect.createSelector(selectState$2, state => state.referralLink);
const selectYTImportPending = reselect.createSelector(selectState$2, state => state.ytChannelImportPending);
const selectYTImportError = reselect.createSelector(selectState$2, state => state.ytChannelImportErrorMessage);
const selectYouTubeImportPending = reselect.createSelector(selectState$2, state => state.youtubeChannelImportPending);
const selectYouTubeImportError = reselect.createSelector(selectState$2, state => state.youtubeChannelImportErrorMessage);
const selectYouTubeImportVideosComplete = reselect.createSelector(selectState$2, state => {
const total = state.youtubeChannelImportTotal;
const complete = state.youtubeChannelImportComplete || 0;
if (total) {
return [complete, total];
}
});
function doFetchInviteStatus() {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_INVITE_STATUS_FETCH_STARTED
type: USER_INVITE_STATUS_FETCH_STARTED
});
Promise.all([Lbryio.call('user', 'invite_status'), Lbryio.call('user_referral_code', 'list')]).then(([status, code]) => {
dispatch(doRewardList());
dispatch({
type: lbryRedux.ACTIONS.USER_INVITE_STATUS_FETCH_SUCCESS,
type: USER_INVITE_STATUS_FETCH_SUCCESS,
data: {
invitesRemaining: status.invites_remaining ? status.invites_remaining : 0,
invitees: status.invitees,
@ -1060,7 +1152,7 @@ function doFetchInviteStatus() {
});
}).catch(error => {
dispatch({
type: lbryRedux.ACTIONS.USER_INVITE_STATUS_FETCH_FAILURE,
type: USER_INVITE_STATUS_FETCH_FAILURE,
data: {
error
}
@ -1087,12 +1179,12 @@ function doInstallNew(appVersion, os = null) {
function doAuthenticate(appVersion, os = null) {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.AUTHENTICATION_STARTED
type: AUTHENTICATION_STARTED
});
Lbryio.authenticate().then(user => {
// analytics.setUser(user);
dispatch({
type: lbryRedux.ACTIONS.AUTHENTICATION_SUCCESS,
type: AUTHENTICATION_SUCCESS,
data: {
user
}
@ -1102,7 +1194,7 @@ function doAuthenticate(appVersion, os = null) {
doInstallNew(appVersion, os);
}).catch(error => {
dispatch({
type: lbryRedux.ACTIONS.AUTHENTICATION_FAILURE,
type: AUTHENTICATION_FAILURE,
data: {
error
}
@ -1113,20 +1205,19 @@ function doAuthenticate(appVersion, os = null) {
function doUserFetch() {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_FETCH_STARTED
type: USER_FETCH_STARTED
});
Lbryio.getCurrentUser().then(user => {
// analytics.setUser(user);
dispatch(doRewardList());
dispatch({
type: lbryRedux.ACTIONS.USER_FETCH_SUCCESS,
type: USER_FETCH_SUCCESS,
data: {
user
}
});
}).catch(error => {
dispatch({
type: lbryRedux.ACTIONS.USER_FETCH_FAILURE,
type: USER_FETCH_FAILURE,
data: {
error
}
@ -1141,7 +1232,7 @@ function doUserCheckEmailVerified() {
if (user.has_verified_email) {
dispatch(doRewardList());
dispatch({
type: lbryRedux.ACTIONS.USER_FETCH_SUCCESS,
type: USER_FETCH_SUCCESS,
data: {
user
}
@ -1152,13 +1243,13 @@ function doUserCheckEmailVerified() {
}
function doUserPhoneReset() {
return {
type: lbryRedux.ACTIONS.USER_PHONE_RESET
type: USER_PHONE_RESET
};
}
function doUserPhoneNew(phone, countryCode) {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_PHONE_NEW_STARTED,
type: USER_PHONE_NEW_STARTED,
data: {
phone,
country_code: countryCode
@ -1167,7 +1258,7 @@ function doUserPhoneNew(phone, countryCode) {
const success = () => {
dispatch({
type: lbryRedux.ACTIONS.USER_PHONE_NEW_SUCCESS,
type: USER_PHONE_NEW_SUCCESS,
data: {
phone
}
@ -1176,7 +1267,7 @@ function doUserPhoneNew(phone, countryCode) {
const failure = error => {
dispatch({
type: lbryRedux.ACTIONS.USER_PHONE_NEW_FAILURE,
type: USER_PHONE_NEW_FAILURE,
data: {
error
}
@ -1191,7 +1282,7 @@ function doUserPhoneNew(phone, countryCode) {
}
function doUserPhoneVerifyFailure(error) {
return {
type: lbryRedux.ACTIONS.USER_PHONE_VERIFY_FAILURE,
type: USER_PHONE_VERIFY_FAILURE,
data: {
error
}
@ -1202,7 +1293,7 @@ function doUserPhoneVerify(verificationCode) {
const phoneNumber = selectPhoneToVerify(getState());
const countryCode = selectUserCountryCode(getState());
dispatch({
type: lbryRedux.ACTIONS.USER_PHONE_VERIFY_STARTED,
type: USER_PHONE_VERIFY_STARTED,
code: verificationCode
});
Lbryio.call('user', 'phone_number_confirm', {
@ -1212,7 +1303,7 @@ function doUserPhoneVerify(verificationCode) {
}, 'post').then(user => {
if (user.is_identity_verified) {
dispatch({
type: lbryRedux.ACTIONS.USER_PHONE_VERIFY_SUCCESS,
type: USER_PHONE_VERIFY_SUCCESS,
data: {
user
}
@ -1225,7 +1316,7 @@ function doUserPhoneVerify(verificationCode) {
function doUserEmailToVerify(email) {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_VERIFY_SET,
type: USER_EMAIL_VERIFY_SET,
data: {
email
}
@ -1235,13 +1326,13 @@ function doUserEmailToVerify(email) {
function doUserEmailNew(email) {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_NEW_STARTED,
type: USER_EMAIL_NEW_STARTED,
email
});
const success = () => {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_NEW_SUCCESS,
type: USER_EMAIL_NEW_SUCCESS,
data: {
email
}
@ -1251,7 +1342,7 @@ function doUserEmailNew(email) {
const failure = error => {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_NEW_FAILURE,
type: USER_EMAIL_NEW_FAILURE,
data: {
error
}
@ -1276,13 +1367,13 @@ function doUserEmailNew(email) {
function doUserResendVerificationEmail(email) {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_VERIFY_RETRY,
type: USER_EMAIL_VERIFY_RETRY,
email
});
const success = () => {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_NEW_SUCCESS,
type: USER_EMAIL_NEW_SUCCESS,
data: {
email
}
@ -1292,7 +1383,7 @@ function doUserResendVerificationEmail(email) {
const failure = error => {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_NEW_FAILURE,
type: USER_EMAIL_NEW_FAILURE,
data: {
error
}
@ -1310,7 +1401,7 @@ function doUserResendVerificationEmail(email) {
}
function doUserEmailVerifyFailure(error) {
return {
type: lbryRedux.ACTIONS.USER_EMAIL_VERIFY_FAILURE,
type: USER_EMAIL_VERIFY_FAILURE,
data: {
error
}
@ -1320,7 +1411,7 @@ function doUserEmailVerify(verificationToken, recaptcha) {
return (dispatch, getState) => {
const email = selectEmailToVerify(getState());
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_VERIFY_STARTED,
type: USER_EMAIL_VERIFY_STARTED,
code: verificationToken,
recaptcha
});
@ -1331,7 +1422,7 @@ function doUserEmailVerify(verificationToken, recaptcha) {
}, 'post').then(userEmail => {
if (userEmail.is_verified) {
dispatch({
type: lbryRedux.ACTIONS.USER_EMAIL_VERIFY_SUCCESS,
type: USER_EMAIL_VERIFY_SUCCESS,
data: {
email
}
@ -1346,7 +1437,7 @@ function doUserEmailVerify(verificationToken, recaptcha) {
function doFetchAccessToken() {
return dispatch => {
const success = token => dispatch({
type: lbryRedux.ACTIONS.FETCH_ACCESS_TOKEN_SUCCESS,
type: FETCH_ACCESS_TOKEN_SUCCESS,
data: {
token
}
@ -1358,7 +1449,7 @@ function doFetchAccessToken() {
function doUserIdentityVerify(stripeToken) {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_IDENTITY_VERIFY_STARTED,
type: USER_IDENTITY_VERIFY_STARTED,
token: stripeToken
});
Lbryio.call('user', 'verify_identity', {
@ -1366,7 +1457,7 @@ function doUserIdentityVerify(stripeToken) {
}, 'post').then(user => {
if (user.is_identity_verified) {
dispatch({
type: lbryRedux.ACTIONS.USER_IDENTITY_VERIFY_SUCCESS,
type: USER_IDENTITY_VERIFY_SUCCESS,
data: {
user
}
@ -1377,7 +1468,7 @@ function doUserIdentityVerify(stripeToken) {
}
}).catch(error => {
dispatch({
type: lbryRedux.ACTIONS.USER_IDENTITY_VERIFY_FAILURE,
type: USER_IDENTITY_VERIFY_FAILURE,
data: {
error: error.toString()
}
@ -1388,13 +1479,13 @@ function doUserIdentityVerify(stripeToken) {
function doUserInviteNew(email) {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_INVITE_NEW_STARTED
type: USER_INVITE_NEW_STARTED
});
Lbryio.call('user', 'invite', {
email
}, 'post').then(() => {
dispatch({
type: lbryRedux.ACTIONS.USER_INVITE_NEW_SUCCESS,
type: USER_INVITE_NEW_SUCCESS,
data: {
email
}
@ -1405,7 +1496,7 @@ function doUserInviteNew(email) {
dispatch(doFetchInviteStatus());
}).catch(error => {
dispatch({
type: lbryRedux.ACTIONS.USER_INVITE_NEW_FAILURE,
type: USER_INVITE_NEW_FAILURE,
data: {
error
}
@ -1416,14 +1507,16 @@ function doUserInviteNew(email) {
function doClaimYoutubeChannels() {
return dispatch => {
dispatch({
type: lbryRedux.ACTIONS.USER_YOUTUBE_IMPORT_STARTED
type: USER_YOUTUBE_IMPORT_STARTED
});
lbryRedux.Lbry.address_list().then(addressList => addressList.sort((a, b) => a.used_times - b.used_times)[0]).then(address => Lbryio.call('yt', 'transfer', {
let transferResponse;
return lbryRedux.Lbry.address_list().then(addressList => addressList.sort((a, b) => a.used_times - b.used_times)[0]).then(address => Lbryio.call('yt', 'transfer', {
address: address.address,
public_key: address.pubkey
}).then(response => {
if (response && response.success) {
Promise.all(response.map(channelMeta => {
if (response && response.length) {
transferResponse = response;
return Promise.all(response.map(channelMeta => {
if (channelMeta && channelMeta.channel && channelMeta.channel.channel_certificate) {
return lbryRedux.Lbry.channel_import({
channel_data: channelMeta.channel.channel_certificate
@ -1433,7 +1526,8 @@ function doClaimYoutubeChannels() {
return null;
})).then(() => {
const actions = [{
type: lbryRedux.ACTIONS.USER_YOUTUBE_IMPORT_COMPLETED
type: USER_YOUTUBE_IMPORT_SUCCESS,
data: transferResponse
}];
actions.push(doUserFetch());
actions.push(lbryRedux.doFetchChannelListMine());
@ -1442,7 +1536,29 @@ function doClaimYoutubeChannels() {
}
})).catch(error => {
dispatch({
type: lbryRedux.ACTIONS.USER_YOUTUBE_IMPORT_FAILURE,
type: USER_YOUTUBE_IMPORT_FAILURE,
data: String(error)
});
});
};
}
function doCheckYoutubeTransfer() {
return dispatch => {
dispatch({
type: USER_YOUTUBE_IMPORT_STARTED
});
return Lbryio.call('yt', 'transfer').then(response => {
if (response && response.length) {
dispatch({
type: USER_YOUTUBE_IMPORT_SUCCESS,
data: response
});
} else {
throw new Error();
}
}).catch(error => {
dispatch({
type: USER_YOUTUBE_IMPORT_FAILURE,
data: String(error)
});
});
@ -2203,41 +2319,6 @@ const doFetchSubCount = claimId => dispatch => {
});
};
function doSetSync(oldHash, newHash, data) {
return dispatch => {
dispatch({
type: SET_SYNC_STARTED
});
Lbryio.call('sync', 'set', {
old_hash: oldHash,
new_hash: newHash,
data
}, 'post').then(response => {
if (!response.hash) {
return dispatch({
type: SET_SYNC_FAILED,
data: {
error: 'No hash returned for sync/set.'
}
});
}
return dispatch({
type: SET_SYNC_COMPLETED,
data: {
syncHash: response.hash
}
});
}).catch(error => {
dispatch({
type: SET_SYNC_FAILED,
data: {
error
}
});
});
};
}
function doSetDefaultAccount(success, failure) {
return dispatch => {
dispatch({
@ -2276,11 +2357,9 @@ function doSetDefaultAccount(success, failure) {
failure(err);
}
});
} else {
} else if (failure) {
// no default account to set
if (failure) {
failure('Could not set a default account'); // fail
}
failure('Could not set a default account'); // fail
}
}).catch(err => {
if (failure) {
@ -2289,33 +2368,83 @@ function doSetDefaultAccount(success, failure) {
});
};
}
function doGetSync(password) {
function doSetSync(oldHash, newHash, data, password) {
return dispatch => {
dispatch({
type: SET_SYNC_STARTED
});
Lbryio.call('sync', 'set', {
old_hash: oldHash,
new_hash: newHash,
data
}, 'post').then(response => {
if (!response.hash) {
return dispatch({
type: SET_SYNC_FAILED,
data: {
error: 'No hash returned for sync/set.'
}
});
}
if (oldHash && newHash !== oldHash) {
dispatch(doSetDefaultAccount(() => {
if (password !== undefined) {
lbryRedux.Lbry.account_unlock({
password
});
dispatch(lbryRedux.doFetchChannelListMine());
}
}));
}
return dispatch({
type: SET_SYNC_COMPLETED,
data: {
syncHash: response.hash
}
});
}).catch(error => {
dispatch({
type: SET_SYNC_FAILED,
data: {
error
}
});
});
};
}
function doGetSync(password = '') {
return dispatch => {
dispatch({
type: GET_SYNC_STARTED
});
const data = {};
lbryRedux.Lbry.sync_hash().then(hash => {
Lbryio.call('sync', 'get', {
hash
}, 'post').then(response => {
const data = {
hasSyncedWallet: true
};
const syncHash = response.hash;
data.syncHash = syncHash;
data.syncData = response.data;
data.hasSyncedWallet = true;
if (response.changed) {
const syncHash = response.hash;
data.syncHash = syncHash;
data.syncData = response.data;
lbryRedux.Lbry.sync_apply({
return lbryRedux.Lbry.sync_apply({
password,
data: response.data
}).then(({
hash: walletHash,
data: walletData
}) => {
dispatch({
type: GET_SYNC_COMPLETED,
data
});
if (walletHash !== syncHash) {
// different local hash, need to synchronise
dispatch(doSetSync(syncHash, walletHash, walletData));
dispatch(doSetSync(syncHash, walletHash, walletData, password));
}
});
}
@ -2325,22 +2454,31 @@ function doGetSync(password) {
data
});
}).catch(() => {
// user doesn't have a synced wallet
dispatch({
type: GET_SYNC_COMPLETED,
data: {
hasSyncedWallet: false,
syncHash: null
}
}); // call sync_apply to get data to sync
// first time sync. use any string for old hash
if (data.hasSyncedWallet) {
dispatch({
type: GET_SYNC_FAILED,
data: {
error: 'Error getting synced wallet'
}
});
} else {
// user doesn't have a synced wallet
dispatch({
type: GET_SYNC_COMPLETED,
data: {
hasSyncedWallet: false,
syncHash: null
}
}); // call sync_apply to get data to sync
// first time sync. use any string for old hash
lbryRedux.Lbry.sync_apply({
password
}).then(({
hash: walletHash,
data
}) => dispatch(doSetSync('', walletHash, data)));
lbryRedux.Lbry.sync_apply({
password
}).then(({
hash: walletHash,
data: syncApplyData
}) => dispatch(doSetSync('', walletHash, syncApplyData, password)));
}
});
});
};
@ -2562,44 +2700,44 @@ const defaultState$3 = {
invitesRemaining: undefined,
invitees: undefined,
user: undefined,
ytChannelImportPending: false,
ytChannelImportErrorMessage: ''
youtubeChannelImportPending: false,
youtubeChannelImportErrorMessage: ''
};
reducers$2[lbryRedux.ACTIONS.AUTHENTICATION_STARTED] = state => Object.assign({}, state, {
reducers$2[AUTHENTICATION_STARTED] = state => Object.assign({}, state, {
authenticationIsPending: true,
userIsPending: true,
user: defaultState$3.user
});
reducers$2[lbryRedux.ACTIONS.AUTHENTICATION_SUCCESS] = (state, action) => Object.assign({}, state, {
reducers$2[AUTHENTICATION_SUCCESS] = (state, action) => Object.assign({}, state, {
authenticationIsPending: false,
userIsPending: false,
user: action.data.user
});
reducers$2[lbryRedux.ACTIONS.AUTHENTICATION_FAILURE] = state => Object.assign({}, state, {
reducers$2[AUTHENTICATION_FAILURE] = state => Object.assign({}, state, {
authenticationIsPending: false,
userIsPending: false,
user: null
});
reducers$2[lbryRedux.ACTIONS.USER_FETCH_STARTED] = state => Object.assign({}, state, {
reducers$2[USER_FETCH_STARTED] = state => Object.assign({}, state, {
userIsPending: true
});
reducers$2[lbryRedux.ACTIONS.USER_FETCH_SUCCESS] = (state, action) => Object.assign({}, state, {
reducers$2[USER_FETCH_SUCCESS] = (state, action) => Object.assign({}, state, {
userIsPending: false,
user: action.data.user,
emailToVerify: action.data.user.has_verified_email ? null : state.emailToVerify
});
reducers$2[lbryRedux.ACTIONS.USER_FETCH_FAILURE] = state => Object.assign({}, state, {
reducers$2[USER_FETCH_FAILURE] = state => Object.assign({}, state, {
userIsPending: true,
user: null
});
reducers$2[lbryRedux.ACTIONS.USER_PHONE_NEW_STARTED] = (state, action) => {
reducers$2[USER_PHONE_NEW_STARTED] = (state, action) => {
const user = Object.assign({}, state.user);
user.country_code = action.data.country_code;
return Object.assign({}, state, {
@ -2609,42 +2747,42 @@ reducers$2[lbryRedux.ACTIONS.USER_PHONE_NEW_STARTED] = (state, action) => {
});
};
reducers$2[lbryRedux.ACTIONS.USER_PHONE_NEW_SUCCESS] = (state, action) => Object.assign({}, state, {
reducers$2[USER_PHONE_NEW_SUCCESS] = (state, action) => Object.assign({}, state, {
phoneToVerify: action.data.phone,
phoneNewIsPending: false
});
reducers$2[lbryRedux.ACTIONS.USER_PHONE_RESET] = state => Object.assign({}, state, {
reducers$2[USER_PHONE_RESET] = state => Object.assign({}, state, {
phoneToVerify: null
});
reducers$2[lbryRedux.ACTIONS.USER_PHONE_NEW_FAILURE] = (state, action) => Object.assign({}, state, {
reducers$2[USER_PHONE_NEW_FAILURE] = (state, action) => Object.assign({}, state, {
phoneNewIsPending: false,
phoneNewErrorMessage: action.data.error
});
reducers$2[lbryRedux.ACTIONS.USER_PHONE_VERIFY_STARTED] = state => Object.assign({}, state, {
reducers$2[USER_PHONE_VERIFY_STARTED] = state => Object.assign({}, state, {
phoneVerifyIsPending: true,
phoneVerifyErrorMessage: ''
});
reducers$2[lbryRedux.ACTIONS.USER_PHONE_VERIFY_SUCCESS] = (state, action) => Object.assign({}, state, {
reducers$2[USER_PHONE_VERIFY_SUCCESS] = (state, action) => Object.assign({}, state, {
phoneToVerify: '',
phoneVerifyIsPending: false,
user: action.data.user
});
reducers$2[lbryRedux.ACTIONS.USER_PHONE_VERIFY_FAILURE] = (state, action) => Object.assign({}, state, {
reducers$2[USER_PHONE_VERIFY_FAILURE] = (state, action) => Object.assign({}, state, {
phoneVerifyIsPending: false,
phoneVerifyErrorMessage: action.data.error
});
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_NEW_STARTED] = state => Object.assign({}, state, {
reducers$2[USER_EMAIL_NEW_STARTED] = state => Object.assign({}, state, {
emailNewIsPending: true,
emailNewErrorMessage: ''
});
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_NEW_SUCCESS] = (state, action) => {
reducers$2[USER_EMAIL_NEW_SUCCESS] = (state, action) => {
const user = Object.assign({}, state.user);
user.primary_email = action.data.email;
return Object.assign({}, state, {
@ -2654,22 +2792,22 @@ reducers$2[lbryRedux.ACTIONS.USER_EMAIL_NEW_SUCCESS] = (state, action) => {
});
};
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_NEW_EXISTS] = (state, action) => Object.assign({}, state, {
reducers$2[USER_EMAIL_NEW_EXISTS] = (state, action) => Object.assign({}, state, {
emailToVerify: action.data.email,
emailNewIsPending: false
});
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_NEW_FAILURE] = (state, action) => Object.assign({}, state, {
reducers$2[USER_EMAIL_NEW_FAILURE] = (state, action) => Object.assign({}, state, {
emailNewIsPending: false,
emailNewErrorMessage: action.data.error
});
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_VERIFY_STARTED] = state => Object.assign({}, state, {
reducers$2[USER_EMAIL_VERIFY_STARTED] = state => Object.assign({}, state, {
emailVerifyIsPending: true,
emailVerifyErrorMessage: ''
});
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_VERIFY_SUCCESS] = (state, action) => {
reducers$2[USER_EMAIL_VERIFY_SUCCESS] = (state, action) => {
const user = Object.assign({}, state.user);
user.primary_email = action.data.email;
return Object.assign({}, state, {
@ -2679,32 +2817,32 @@ reducers$2[lbryRedux.ACTIONS.USER_EMAIL_VERIFY_SUCCESS] = (state, action) => {
});
};
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_VERIFY_FAILURE] = (state, action) => Object.assign({}, state, {
reducers$2[USER_EMAIL_VERIFY_FAILURE] = (state, action) => Object.assign({}, state, {
emailVerifyIsPending: false,
emailVerifyErrorMessage: action.data.error
});
reducers$2[lbryRedux.ACTIONS.USER_EMAIL_VERIFY_SET] = (state, action) => Object.assign({}, state, {
reducers$2[USER_EMAIL_VERIFY_SET] = (state, action) => Object.assign({}, state, {
emailToVerify: action.data.email
});
reducers$2[lbryRedux.ACTIONS.USER_IDENTITY_VERIFY_STARTED] = state => Object.assign({}, state, {
reducers$2[USER_IDENTITY_VERIFY_STARTED] = state => Object.assign({}, state, {
identityVerifyIsPending: true,
identityVerifyErrorMessage: ''
});
reducers$2[lbryRedux.ACTIONS.USER_IDENTITY_VERIFY_SUCCESS] = (state, action) => Object.assign({}, state, {
reducers$2[USER_IDENTITY_VERIFY_SUCCESS] = (state, action) => Object.assign({}, state, {
identityVerifyIsPending: false,
identityVerifyErrorMessage: '',
user: action.data.user
});
reducers$2[lbryRedux.ACTIONS.USER_IDENTITY_VERIFY_FAILURE] = (state, action) => Object.assign({}, state, {
reducers$2[USER_IDENTITY_VERIFY_FAILURE] = (state, action) => Object.assign({}, state, {
identityVerifyIsPending: false,
identityVerifyErrorMessage: action.data.error
});
reducers$2[lbryRedux.ACTIONS.FETCH_ACCESS_TOKEN_SUCCESS] = (state, action) => {
reducers$2[FETCH_ACCESS_TOKEN_SUCCESS] = (state, action) => {
const {
token
} = action.data;
@ -2713,51 +2851,57 @@ reducers$2[lbryRedux.ACTIONS.FETCH_ACCESS_TOKEN_SUCCESS] = (state, action) => {
});
};
reducers$2[lbryRedux.ACTIONS.USER_INVITE_STATUS_FETCH_STARTED] = state => Object.assign({}, state, {
reducers$2[USER_INVITE_STATUS_FETCH_STARTED] = state => Object.assign({}, state, {
inviteStatusIsPending: true
});
reducers$2[lbryRedux.ACTIONS.USER_INVITE_STATUS_FETCH_SUCCESS] = (state, action) => Object.assign({}, state, {
reducers$2[USER_INVITE_STATUS_FETCH_SUCCESS] = (state, action) => Object.assign({}, state, {
inviteStatusIsPending: false,
invitesRemaining: action.data.invitesRemaining,
invitees: action.data.invitees,
referralLink: action.data.referralLink
});
reducers$2[lbryRedux.ACTIONS.USER_INVITE_NEW_STARTED] = state => Object.assign({}, state, {
reducers$2[USER_INVITE_NEW_STARTED] = state => Object.assign({}, state, {
inviteNewIsPending: true,
inviteNewErrorMessage: ''
});
reducers$2[lbryRedux.ACTIONS.USER_INVITE_NEW_SUCCESS] = state => Object.assign({}, state, {
reducers$2[USER_INVITE_NEW_SUCCESS] = state => Object.assign({}, state, {
inviteNewIsPending: false,
inviteNewErrorMessage: ''
});
reducers$2[lbryRedux.ACTIONS.USER_INVITE_NEW_FAILURE] = (state, action) => Object.assign({}, state, {
reducers$2[USER_INVITE_NEW_FAILURE] = (state, action) => Object.assign({}, state, {
inviteNewIsPending: false,
inviteNewErrorMessage: action.data.error.message
});
reducers$2[lbryRedux.ACTIONS.USER_INVITE_STATUS_FETCH_FAILURE] = state => Object.assign({}, state, {
reducers$2[USER_INVITE_STATUS_FETCH_FAILURE] = state => Object.assign({}, state, {
inviteStatusIsPending: false,
invitesRemaining: null,
invitees: null
});
reducers$2[lbryRedux.ACTIONS.USER_YOUTUBE_IMPORT_STARTED] = state => Object.assign({}, state, {
ytChannelImportPending: true,
ytChannelImportErrorMessage: ''
reducers$2[USER_YOUTUBE_IMPORT_STARTED] = state => Object.assign({}, state, {
youtubeChannelImportPending: true,
youtubeChannelImportErrorMessage: ''
});
reducers$2[lbryRedux.ACTIONS.USER_YOUTUBE_IMPORT_COMPLETED] = state => Object.assign({}, state, {
ytChannelImportPending: false,
ytChannelImportErrorMessage: ''
});
reducers$2[USER_YOUTUBE_IMPORT_SUCCESS] = (state, action) => {
const total = action.data.reduce((acc, value) => acc + value.total_published_videos, 0);
const complete = action.data.reduce((acc, value) => acc + value.total_transferred, 0);
return Object.assign({}, state, {
youtubeChannelImportPending: false,
youtubeChannelImportErrorMessage: '',
youtubeChannelImportTotal: total,
youtubeChannelImportComplete: complete
});
};
reducers$2[lbryRedux.ACTIONS.USER_YOUTUBE_IMPORT_FAILURE] = (state, action) => Object.assign({}, state, {
ytChannelImportPending: false,
ytChannelImportErrorMessage: action.data
reducers$2[USER_YOUTUBE_IMPORT_FAILURE] = (state, action) => Object.assign({}, state, {
youtubeChannelImportPending: false,
youtubeChannelImportErrorMessage: action.data
});
function userReducer(state = defaultState$3, action) {
@ -2952,6 +3096,7 @@ const defaultState$9 = {
syncHash: null,
syncData: null,
setSyncErrorMessage: null,
getSyncErrorMessage: null,
syncApplyErrorMessage: '',
syncApplyIsPending: false,
getSyncIsPending: false,
@ -2960,7 +3105,8 @@ const defaultState$9 = {
};
reducers$3[GET_SYNC_STARTED] = state => Object.assign({}, state, {
getSyncIsPending: true
getSyncIsPending: true,
getSyncErrorMessage: null
});
reducers$3[GET_SYNC_COMPLETED] = (state, action) => Object.assign({}, state, {
@ -2971,6 +3117,11 @@ reducers$3[GET_SYNC_COMPLETED] = (state, action) => Object.assign({}, state, {
hashChanged: action.data.hashChanged
});
reducers$3[GET_SYNC_FAILED] = (state, action) => Object.assign({}, state, {
getSyncIsPending: false,
getSyncErrorMessage: action.data.error
});
reducers$3[SET_SYNC_STARTED] = state => Object.assign({}, state, {
setSyncIsPending: true,
setSyncErrorMessage: null
@ -3047,6 +3198,7 @@ const selectHasSyncedWallet = reselect.createSelector(selectState$9, state => st
const selectSyncHash = reselect.createSelector(selectState$9, state => state.syncHash);
const selectSyncData = reselect.createSelector(selectState$9, state => state.syncData);
const selectSetSyncErrorMessage = reselect.createSelector(selectState$9, state => state.setSyncErrorMessage);
const selectGetSyncErrorMessage = reselect.createSelector(selectState$9, state => state.getSyncErrorMessage);
const selectGetSyncIsPending = reselect.createSelector(selectState$9, state => state.getSyncIsPending);
const selectSetSyncIsPending = reselect.createSelector(selectState$9, state => state.setSyncIsPending);
const selectHashChanged = reselect.createSelector(selectState$9, state => state.hashChanged);
@ -3055,6 +3207,7 @@ const selectSyncApplyErrorMessage = reselect.createSelector(selectState$9, state
exports.LBRYINC_ACTIONS = action_types;
exports.Lbryio = Lbryio;
exports.YOUTUBE_STATUSES = youtube;
exports.authReducer = authReducer;
exports.blacklistReducer = blacklistReducer;
exports.costInfoReducer = costInfoReducer;
@ -3068,6 +3221,7 @@ exports.doCheckSubscription = doCheckSubscription;
exports.doCheckSubscriptions = doCheckSubscriptions;
exports.doCheckSubscriptionsInit = doCheckSubscriptionsInit;
exports.doCheckSync = doCheckSync;
exports.doCheckYoutubeTransfer = doCheckYoutubeTransfer;
exports.doClaimEligiblePurchaseRewards = doClaimEligiblePurchaseRewards;
exports.doClaimRewardClearError = doClaimRewardClearError;
exports.doClaimRewardType = doClaimRewardType;
@ -3147,6 +3301,7 @@ exports.selectFetchingRewards = selectFetchingRewards;
exports.selectFetchingTrendingUris = selectFetchingTrendingUris;
exports.selectFilteredOutpoints = selectFilteredOutpoints;
exports.selectFirstRunCompleted = selectFirstRunCompleted;
exports.selectGetSyncErrorMessage = selectGetSyncErrorMessage;
exports.selectGetSyncIsPending = selectGetSyncIsPending;
exports.selectHasSyncedWallet = selectHasSyncedWallet;
exports.selectHashChanged = selectHashChanged;
@ -3197,8 +3352,9 @@ exports.selectUserIsVerificationCandidate = selectUserIsVerificationCandidate;
exports.selectUserPhone = selectUserPhone;
exports.selectUserVerifiedEmail = selectUserVerifiedEmail;
exports.selectViewMode = selectViewMode;
exports.selectYTImportError = selectYTImportError;
exports.selectYTImportPending = selectYTImportPending;
exports.selectYouTubeImportError = selectYouTubeImportError;
exports.selectYouTubeImportPending = selectYouTubeImportPending;
exports.selectYouTubeImportVideosComplete = selectYouTubeImportVideosComplete;
exports.selectYoutubeChannels = selectYoutubeChannels;
exports.setSubscriptionLatest = setSubscriptionLatest;
exports.statsReducer = statsReducer;

1120
dist/bundle.js vendored
View file

File diff suppressed because it is too large Load diff

39
src/constants/action_types.js
View file

@ -1,7 +1,43 @@
// Auth Token
// User
export const GENERATE_AUTH_TOKEN_FAILURE = 'GENERATE_AUTH_TOKEN_FAILURE';
export const GENERATE_AUTH_TOKEN_STARTED = 'GENERATE_AUTH_TOKEN_STARTED';
export const GENERATE_AUTH_TOKEN_SUCCESS = 'GENERATE_AUTH_TOKEN_SUCCESS';
export const AUTHENTICATION_STARTED = 'AUTHENTICATION_STARTED';
export const AUTHENTICATION_SUCCESS = 'AUTHENTICATION_SUCCESS';
neb-b commented 2019-10-01 05:19:42 +02:00 (Migrated from github.com)
Review
Copy link

We were importing all of these from lbry-redux. Not sure why

We were importing all of these from `lbry-redux`. Not sure why
export const AUTHENTICATION_FAILURE = 'AUTHENTICATION_FAILURE';
export const USER_EMAIL_DECLINE = 'USER_EMAIL_DECLINE';
export const USER_EMAIL_NEW_STARTED = 'USER_EMAIL_NEW_STARTED';
export const USER_EMAIL_NEW_SUCCESS = 'USER_EMAIL_NEW_SUCCESS';
export const USER_EMAIL_NEW_EXISTS = 'USER_EMAIL_NEW_EXISTS';
export const USER_EMAIL_NEW_FAILURE = 'USER_EMAIL_NEW_FAILURE';
export const USER_EMAIL_VERIFY_SET = 'USER_EMAIL_VERIFY_SET';
export const USER_EMAIL_VERIFY_STARTED = 'USER_EMAIL_VERIFY_STARTED';
export const USER_EMAIL_VERIFY_SUCCESS = 'USER_EMAIL_VERIFY_SUCCESS';
export const USER_EMAIL_VERIFY_FAILURE = 'USER_EMAIL_VERIFY_FAILURE';
export const USER_EMAIL_VERIFY_RETRY = 'USER_EMAIL_VERIFY_RETRY';
export const USER_PHONE_RESET = 'USER_PHONE_RESET';
export const USER_PHONE_NEW_STARTED = 'USER_PHONE_NEW_STARTED';
export const USER_PHONE_NEW_SUCCESS = 'USER_PHONE_NEW_SUCCESS';
export const USER_PHONE_NEW_FAILURE = 'USER_PHONE_NEW_FAILURE';
export const USER_PHONE_VERIFY_STARTED = 'USER_PHONE_VERIFY_STARTED';
export const USER_PHONE_VERIFY_SUCCESS = 'USER_PHONE_VERIFY_SUCCESS';
export const USER_PHONE_VERIFY_FAILURE = 'USER_PHONE_VERIFY_FAILURE';
export const USER_IDENTITY_VERIFY_STARTED = 'USER_IDENTITY_VERIFY_STARTED';
export const USER_IDENTITY_VERIFY_SUCCESS = 'USER_IDENTITY_VERIFY_SUCCESS';
export const USER_IDENTITY_VERIFY_FAILURE = 'USER_IDENTITY_VERIFY_FAILURE';
export const USER_FETCH_STARTED = 'USER_FETCH_STARTED';
export const USER_FETCH_SUCCESS = 'USER_FETCH_SUCCESS';
export const USER_FETCH_FAILURE = 'USER_FETCH_FAILURE';
export const USER_INVITE_STATUS_FETCH_STARTED = 'USER_INVITE_STATUS_FETCH_STARTED';
export const USER_INVITE_STATUS_FETCH_SUCCESS = 'USER_INVITE_STATUS_FETCH_SUCCESS';
export const USER_INVITE_STATUS_FETCH_FAILURE = 'USER_INVITE_STATUS_FETCH_FAILURE';
export const USER_INVITE_NEW_STARTED = 'USER_INVITE_NEW_STARTED';
export const USER_INVITE_NEW_SUCCESS = 'USER_INVITE_NEW_SUCCESS';
export const USER_INVITE_NEW_FAILURE = 'USER_INVITE_NEW_FAILURE';
export const FETCH_ACCESS_TOKEN_SUCCESS = 'FETCH_ACCESS_TOKEN_SUCCESS';
export const USER_YOUTUBE_IMPORT_STARTED = 'USER_YOUTUBE_IMPORT_STARTED';
export const USER_YOUTUBE_IMPORT_FAILURE = 'USER_YOUTUBE_IMPORT_FAILURE';
export const USER_YOUTUBE_IMPORT_SUCCESS = 'USER_YOUTUBE_IMPORT_SUCCESS';
// Claims
export const FETCH_FEATURED_CONTENT_STARTED = 'FETCH_FEATURED_CONTENT_STARTED';
@ -82,6 +118,7 @@ export const FETCH_SUB_COUNT_COMPLETED = 'FETCH_SUB_COUNT_COMPLETED';
// Cross-device Sync
export const GET_SYNC_STARTED = 'GET_SYNC_STARTED';
export const GET_SYNC_COMPLETED = 'GET_SYNC_COMPLETED';
export const GET_SYNC_FAILED = 'GET_SYNC_FAILED';
export const SET_SYNC_STARTED = 'SET_SYNC_STARTED';
export const SET_SYNC_FAILED = 'SET_SYNC_FAILED';
export const SET_SYNC_COMPLETED = 'SET_SYNC_COMPLETED';

3
src/constants/youtube.js Normal file
View file

@ -0,0 +1,3 @@
export const NOT_TRANSFERRED = 'not_transferred';
export const PENDING_TRANSFER = 'pending_transfer';
export const COMPLETED_TRANSFER = 'completed_transfer';

10
src/index.js
View file

@ -1,4 +1,5 @@
import * as LBRYINC_ACTIONS from 'constants/action_types';
import * as YOUTUBE_STATUSES from 'constants/youtube';
import Lbryio from 'lbryio';
import rewards from 'rewards';
import subscriptionsReducer from 'redux/reducers/subscriptions';
@ -7,7 +8,7 @@ import subscriptionsReducer from 'redux/reducers/subscriptions';
export { userStateSyncMiddleware } from 'redux/middleware/sync';
// constants
export { LBRYINC_ACTIONS };
export { LBRYINC_ACTIONS, YOUTUBE_STATUSES };
// Lbryio and rewards
export { Lbryio, rewards };
@ -58,6 +59,7 @@ export {
doUserIdentityVerify,
doUserInviteNew,
doClaimYoutubeChannels,
doCheckYoutubeTransfer,
} from 'redux/actions/user';
export { doFetchCostInfoForUri } from 'redux/actions/cost_info';
export { doBlackListedOutpointsSubscribe } from 'redux/actions/blacklist';
@ -153,8 +155,9 @@ export {
selectUserInviteReferralLink,
selectUserVerifiedEmail,
selectYoutubeChannels,
selectYTImportPending,
selectYTImportError,
selectYouTubeImportPending,
selectYouTubeImportError,
selectYouTubeImportVideosComplete,
} from 'redux/selectors/user';
export {
makeSelectFetchingCostInfoForUri,
@ -176,6 +179,7 @@ export {
selectSyncData,
selectSyncHash,
selectSetSyncErrorMessage,
selectGetSyncErrorMessage,
selectGetSyncIsPending,
selectSetSyncIsPending,
selectSyncApplyIsPending,

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

@ -1,35 +1,6 @@
import * as ACTIONS from 'constants/action_types';
import Lbryio from 'lbryio';
import { Lbry } from 'lbry-redux';
export function doSetSync(oldHash, newHash, data) {
return dispatch => {
dispatch({
type: ACTIONS.SET_SYNC_STARTED,
});
Lbryio.call('sync', 'set', { old_hash: oldHash, new_hash: newHash, data }, 'post')
.then(response => {
if (!response.hash) {
return dispatch({
type: ACTIONS.SET_SYNC_FAILED,
data: { error: 'No hash returned for sync/set.' },
});
}
return dispatch({
type: ACTIONS.SET_SYNC_COMPLETED,
data: { syncHash: response.hash },
});
})
.catch(error => {
dispatch({
type: ACTIONS.SET_SYNC_FAILED,
data: { error },
});
});
};
}
import { Lbry, doFetchChannelListMine } from 'lbry-redux';
export function doSetDefaultAccount(success, failure) {
return dispatch => {
@ -67,11 +38,9 @@ export function doSetDefaultAccount(success, failure) {
failure(err);
}
});
} else {
} else if (failure) {
// no default account to set
if (failure) {
failure('Could not set a default account'); // fail
}
failure('Could not set a default account'); // fail
}
})
.catch(err => {
@ -82,45 +51,96 @@ export function doSetDefaultAccount(success, failure) {
};
}
export function doGetSync(password) {
export function doSetSync(oldHash, newHash, data, password) {
return dispatch => {
dispatch({
type: ACTIONS.SET_SYNC_STARTED,
});
Lbryio.call('sync', 'set', { old_hash: oldHash, new_hash: newHash, data }, 'post')
.then(response => {
if (!response.hash) {
return dispatch({
type: ACTIONS.SET_SYNC_FAILED,
data: { error: 'No hash returned for sync/set.' },
});
}
if (oldHash && newHash !== oldHash) {
dispatch(
doSetDefaultAccount(() => {
if (password !== undefined) {
Lbry.account_unlock({ password });
dispatch(doFetchChannelListMine());
}
})
);
}
return dispatch({
type: ACTIONS.SET_SYNC_COMPLETED,
data: { syncHash: response.hash },
});
})
.catch(error => {
dispatch({
type: ACTIONS.SET_SYNC_FAILED,
data: { error },
});
});
};
}
export function doGetSync(password = '') {
return dispatch => {
dispatch({
type: ACTIONS.GET_SYNC_STARTED,
});
const data = {};
Lbry.sync_hash().then(hash => {
Lbryio.call('sync', 'get', { hash }, 'post')
.then(response => {
const data = { hasSyncedWallet: true };
if (response.changed) {
const syncHash = response.hash;
data.syncHash = syncHash;
data.syncData = response.data;
const syncHash = response.hash;
data.syncHash = syncHash;
data.syncData = response.data;
data.hasSyncedWallet = true;
Lbry.sync_apply({ password, data: response.data }).then(
if (response.changed) {
return Lbry.sync_apply({ password, data: response.data }).then(
({ hash: walletHash, data: walletData }) => {
dispatch({ type: ACTIONS.GET_SYNC_COMPLETED, data });
if (walletHash !== syncHash) {
// different local hash, need to synchronise
dispatch(doSetSync(syncHash, walletHash, walletData));
dispatch(doSetSync(syncHash, walletHash, walletData, password));
}
}
);
}
dispatch({ type: ACTIONS.GET_SYNC_COMPLETED, data });
})
.catch(() => {
// user doesn't have a synced wallet
dispatch({
type: ACTIONS.GET_SYNC_COMPLETED,
data: { hasSyncedWallet: false, syncHash: null },
});
if (data.hasSyncedWallet) {
dispatch({
type: ACTIONS.GET_SYNC_FAILED,
data: {
error: 'Error getting synced wallet',
},
});
} else {
// user doesn't have a synced wallet
dispatch({
type: ACTIONS.GET_SYNC_COMPLETED,
data: { hasSyncedWallet: false, syncHash: null },
});
// call sync_apply to get data to sync
// first time sync. use any string for old hash
Lbry.sync_apply({ password }).then(({ hash: walletHash, data }) =>
dispatch(doSetSync('', walletHash, data))
);
// call sync_apply to get data to sync
// first time sync. use any string for old hash
Lbry.sync_apply({ password }).then(({ hash: walletHash, data: syncApplyData }) =>
dispatch(doSetSync('', walletHash, syncApplyData, password))
);
}
});
});
};

43
src/redux/actions/user.js
View file

@ -1,4 +1,5 @@
import { ACTIONS, Lbry, doToast, doFetchChannelListMine, batchActions } from 'lbry-redux';
import { Lbry, doToast, doFetchChannelListMine, batchActions } from 'lbry-redux';
import * as ACTIONS from 'constants/action_types';
import { doClaimRewardType, doRewardList } from 'redux/actions/rewards';
import {
selectEmailToVerify,
@ -84,9 +85,7 @@ export function doUserFetch() {
});
Lbryio.getCurrentUser()
.then(user => {
// analytics.setUser(user);
dispatch(doRewardList());
dispatch({
type: ACTIONS.USER_FETCH_SUCCESS,
data: { user },
@ -388,15 +387,18 @@ export function doClaimYoutubeChannels() {
dispatch({
type: ACTIONS.USER_YOUTUBE_IMPORT_STARTED,
});
Lbry.address_list()
let transferResponse;
return Lbry.address_list()
.then(addressList => addressList.sort((a, b) => a.used_times - b.used_times)[0])
.then(address =>
Lbryio.call('yt', 'transfer', {
address: address.address,
public_key: address.pubkey,
}).then(response => {
if (response && response.success) {
Promise.all(
if (response && response.length) {
transferResponse = response;
return Promise.all(
response.map(channelMeta => {
if (channelMeta && channelMeta.channel && channelMeta.channel.channel_certificate) {
return Lbry.channel_import({
@ -408,7 +410,8 @@ export function doClaimYoutubeChannels() {
).then(() => {
const actions = [
{
type: ACTIONS.USER_YOUTUBE_IMPORT_COMPLETED,
type: ACTIONS.USER_YOUTUBE_IMPORT_SUCCESS,
data: transferResponse,
},
];
actions.push(doUserFetch());
@ -426,3 +429,29 @@ export function doClaimYoutubeChannels() {
});
};
}
export function doCheckYoutubeTransfer() {
return dispatch => {
dispatch({
type: ACTIONS.USER_YOUTUBE_IMPORT_STARTED,
});
return Lbryio.call('yt', 'transfer')
.then(response => {
if (response && response.length) {
dispatch({
type: ACTIONS.USER_YOUTUBE_IMPORT_SUCCESS,
data: response,
});
} else {
throw new Error();
}
})
.catch(error => {
dispatch({
type: ACTIONS.USER_YOUTUBE_IMPORT_FAILURE,
data: String(error),
});
});
};
}

8
src/redux/reducers/sync.js
View file

@ -6,6 +6,7 @@ const defaultState = {
syncHash: null,
syncData: null,
setSyncErrorMessage: null,
getSyncErrorMessage: null,
syncApplyErrorMessage: '',
syncApplyIsPending: false,
getSyncIsPending: false,
@ -16,6 +17,7 @@ const defaultState = {
reducers[ACTIONS.GET_SYNC_STARTED] = state =>
Object.assign({}, state, {
getSyncIsPending: true,
getSyncErrorMessage: null,
});
reducers[ACTIONS.GET_SYNC_COMPLETED] = (state, action) =>
@ -27,6 +29,12 @@ reducers[ACTIONS.GET_SYNC_COMPLETED] = (state, action) =>
hashChanged: action.data.hashChanged,
});
reducers[ACTIONS.GET_SYNC_FAILED] = (state, action) =>
Object.assign({}, state, {
getSyncIsPending: false,
getSyncErrorMessage: action.data.error,
});
reducers[ACTIONS.SET_SYNC_STARTED] = state =>
Object.assign({}, state, {
setSyncIsPending: true,

29
src/redux/reducers/user.js
View file

@ -1,4 +1,4 @@
import { ACTIONS } from 'lbry-redux';
import * as ACTIONS from 'constants/action_types';
const reducers = {};
@ -14,8 +14,8 @@ const defaultState = {
invitesRemaining: undefined,
invitees: undefined,
user: undefined,
ytChannelImportPending: false,
ytChannelImportErrorMessage: '',
youtubeChannelImportPending: false,
youtubeChannelImportErrorMessage: '',
};
reducers[ACTIONS.AUTHENTICATION_STARTED] = state =>
@ -225,20 +225,27 @@ reducers[ACTIONS.USER_INVITE_STATUS_FETCH_FAILURE] = state =>
reducers[ACTIONS.USER_YOUTUBE_IMPORT_STARTED] = state =>
Object.assign({}, state, {
ytChannelImportPending: true,
ytChannelImportErrorMessage: '',
youtubeChannelImportPending: true,
youtubeChannelImportErrorMessage: '',
});
reducers[ACTIONS.USER_YOUTUBE_IMPORT_COMPLETED] = state =>
Object.assign({}, state, {
ytChannelImportPending: false,
ytChannelImportErrorMessage: '',
reducers[ACTIONS.USER_YOUTUBE_IMPORT_SUCCESS] = (state, action) => {
const total = action.data.reduce((acc, value) => acc + value.total_published_videos, 0);
const complete = action.data.reduce((acc, value) => acc + value.total_transferred, 0);
return Object.assign({}, state, {
youtubeChannelImportPending: false,
youtubeChannelImportErrorMessage: '',
youtubeChannelImportTotal: total,
youtubeChannelImportComplete: complete,
});
};
reducers[ACTIONS.USER_YOUTUBE_IMPORT_FAILURE] = (state, action) =>
Object.assign({}, state, {
ytChannelImportPending: false,
ytChannelImportErrorMessage: action.data,
youtubeChannelImportPending: false,
youtubeChannelImportErrorMessage: action.data,
});
export function userReducer(state = defaultState, action) {

5
src/redux/selectors/sync.js
View file

@ -13,6 +13,11 @@ export const selectSetSyncErrorMessage = createSelector(
state => state.setSyncErrorMessage
);
export const selectGetSyncErrorMessage = createSelector(
selectState,
state => state.getSyncErrorMessage
);
export const selectGetSyncIsPending = createSelector(selectState, state => state.getSyncIsPending);
export const selectSetSyncIsPending = createSelector(selectState, state => state.setSyncIsPending);

17
src/redux/selectors/user.js
View file

@ -142,12 +142,21 @@ export const selectUserInviteReferralLink = createSelector(
state => state.referralLink
);
export const selectYTImportPending = createSelector(
export const selectYouTubeImportPending = createSelector(
selectState,
state => state.ytChannelImportPending
state => state.youtubeChannelImportPending
);
export const selectYTImportError = createSelector(
export const selectYouTubeImportError = createSelector(
selectState,
state => state.ytChannelImportErrorMessage
state => state.youtubeChannelImportErrorMessage
);
export const selectYouTubeImportVideosComplete = createSelector(selectState, state => {
const total = state.youtubeChannelImportTotal;
const complete = state.youtubeChannelImportComplete || 0;
if (total) {
return [complete, total];
}
});