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

support claim search async dispatch

Browse source
This commit is contained in:
zeppi 2021-04-22 22:31:08 -04:00
parent 4e37ab6580
commit c2e03fa71d
2 changed files with 48 additions and 38 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
dist/bundle.es.js vendored
View file

@ -4018,16 +4018,17 @@ function doClaimSearch(options = {
page: 1 page: 1
}) { }) {
const query = createNormalizedClaimSearchKey(options); const query = createNormalizedClaimSearchKey(options);
return dispatch => { return (() => {
var _ref2 = _asyncToGenerator$1(function* (dispatch) {
dispatch({ dispatch({
type: CLAIM_SEARCH_STARTED, type: CLAIM_SEARCH_STARTED,
data: { query: query } data: { query: query }
}); });
const success = data => { const success = function (data) {
const resolveInfo = {}; const resolveInfo = {};
const urls = []; const urls = [];
data.items.forEach(stream => { data.items.forEach(function (stream) {
resolveInfo[stream.canonical_url] = { stream }; resolveInfo[stream.canonical_url] = { stream };
urls.push(stream.canonical_url); urls.push(stream.canonical_url);
}); });
@ -4042,20 +4043,27 @@ function doClaimSearch(options = {
pageSize: options.page_size pageSize: options.page_size
} }
}); });
return true;
}; };
const failure = err => { const failure = function (err) {
dispatch({ dispatch({
type: CLAIM_SEARCH_FAILED, type: CLAIM_SEARCH_FAILED,
data: { query }, data: { query },
error: err error: err
}); });
return false;
}; };
lbryProxy.claim_search(_extends$5({}, options, { return yield lbryProxy.claim_search(_extends$5({}, options, {
include_purchase_receipt: true include_purchase_receipt: true
})).then(success, failure); })).then(success, failure);
});
return function (_x2) {
return _ref2.apply(this, arguments);
}; };
})();
} }
function doRepost(options) { function doRepost(options) {

8
src/redux/actions/claims.js
View file

@ -65,7 +65,7 @@ export function doResolveUris(
} = {}; } = {};
return Lbry.resolve({ urls: urisToResolve, ...options }).then( return Lbry.resolve({ urls: urisToResolve, ...options }).then(
async (result: ResolveResponse) => { async(result: ResolveResponse) => {
let repostedResults = {}; let repostedResults = {};
const repostsToResolve = []; const repostsToResolve = [];
const fallbackResolveInfo = { const fallbackResolveInfo = {
@ -594,7 +594,7 @@ export function doClaimSearch(
} }
) { ) {
const query = createNormalizedClaimSearchKey(options); const query = createNormalizedClaimSearchKey(options);
return (dispatch: Dispatch) => { return async(dispatch: Dispatch) => {
dispatch({ dispatch({
type: ACTIONS.CLAIM_SEARCH_STARTED, type: ACTIONS.CLAIM_SEARCH_STARTED,
data: { query: query }, data: { query: query },
@ -618,6 +618,7 @@ export function doClaimSearch(
pageSize: options.page_size, pageSize: options.page_size,
}, },
}); });
return true;
}; };
const failure = err => { const failure = err => {
@ -626,9 +627,10 @@ export function doClaimSearch(
data: { query }, data: { query },
error: err, error: err,
}); });
return false;
}; };
Lbry.claim_search({ return await Lbry.claim_search({
...options, ...options,
include_purchase_receipt: true, include_purchase_receipt: true,
}).then(success, failure); }).then(success, failure);