LBRYCommunity/lbry-redux
1
0
Fork 0
Code Issues5 Pull requests6 Projects Releases Packages Wiki Activity

Publish: Handle reflecting-state not updated correctly. #336

Merged
infinite-persistence merged 1 commit from ip4385--publish-status into master 2020-07-10 16:04:24 +02:00
Conversation 1 Commits 1 Files changed 2 +30 -26
2 changed files with 30 additions and 26 deletions
dist
bundle.es.js
src/redux/actions
publish.js

28
dist/bundle.es.js vendored
View file

@ -4758,19 +4758,21 @@ const doCheckReflectingFiles = () => (dispatch, getState) => {
Promise.all(promises).then(function (results) { Promise.all(promises).then(function (results) {
results.forEach(function (res) { results.forEach(function (res) {
const fileListItem = res.items[0]; if (res.items[0]) {
const fileClaimId = fileListItem.claim_id; const fileListItem = res.items[0];
const { const fileClaimId = fileListItem.claim_id;
is_fully_reflected: done, const {
uploading_to_reflector: uploading, is_fully_reflected: done,
reflector_progress: progress uploading_to_reflector: uploading,
} = fileListItem; reflector_progress: progress
if (uploading) { } = fileListItem;
newReflectingById[fileClaimId] = { if (uploading) {
fileListItem: fileListItem, newReflectingById[fileClaimId] = {
progress, fileListItem: fileListItem,
stalled: !done && !uploading progress,
}; stalled: !done && !uploading
};
}
} }
}); });
}).then(function () { }).then(function () {

28
src/redux/actions/publish.js
View file

@ -395,19 +395,21 @@ export const doCheckReflectingFiles = () => (dispatch: Dispatch, getState: GetSt
Promise.all(promises) Promise.all(promises)
.then(results => { .then(results => {
results.forEach(res => { results.forEach(res => {
const fileListItem = res.items[0]; if (res.items[0]) {
const fileClaimId = fileListItem.claim_id; const fileListItem = res.items[0];
const { const fileClaimId = fileListItem.claim_id;
is_fully_reflected: done, const {
uploading_to_reflector: uploading, is_fully_reflected: done,
reflector_progress: progress, uploading_to_reflector: uploading,
} = fileListItem; reflector_progress: progress,
if (uploading) { } = fileListItem;
newReflectingById[fileClaimId] = { if (uploading) {
fileListItem: fileListItem, newReflectingById[fileClaimId] = {
progress, fileListItem: fileListItem,
stalled: !done && !uploading, progress,
}; stalled: !done && !uploading,
};
}
} }
}); });
}) })