From c2e03fa71d6f6e09cf551093357df94cd930ae8f Mon Sep 17 00:00:00 2001 From: zeppi Date: Thu, 22 Apr 2021 22:31:08 -0400 Subject: [PATCH] support claim search async dispatch --- dist/bundle.es.js | 78 ++++++++++++++++++++----------------- src/redux/actions/claims.js | 8 ++-- 2 files changed, 48 insertions(+), 38 deletions(-) diff --git a/dist/bundle.es.js b/dist/bundle.es.js index c445cdc..2a9f916 100644 --- a/dist/bundle.es.js +++ b/dist/bundle.es.js @@ -4018,44 +4018,52 @@ function doClaimSearch(options = { page: 1 }) { const query = createNormalizedClaimSearchKey(options); - return dispatch => { - dispatch({ - type: CLAIM_SEARCH_STARTED, - data: { query: query } + return (() => { + var _ref2 = _asyncToGenerator$1(function* (dispatch) { + dispatch({ + type: CLAIM_SEARCH_STARTED, + data: { query: query } + }); + + const success = function (data) { + const resolveInfo = {}; + const urls = []; + data.items.forEach(function (stream) { + resolveInfo[stream.canonical_url] = { stream }; + urls.push(stream.canonical_url); + }); + + dispatch({ + type: CLAIM_SEARCH_COMPLETED, + data: { + query, + resolveInfo, + urls, + append: options.page && options.page !== 1, + pageSize: options.page_size + } + }); + return true; + }; + + const failure = function (err) { + dispatch({ + type: CLAIM_SEARCH_FAILED, + data: { query }, + error: err + }); + return false; + }; + + return yield lbryProxy.claim_search(_extends$5({}, options, { + include_purchase_receipt: true + })).then(success, failure); }); - const success = data => { - const resolveInfo = {}; - const urls = []; - data.items.forEach(stream => { - resolveInfo[stream.canonical_url] = { stream }; - urls.push(stream.canonical_url); - }); - - dispatch({ - type: CLAIM_SEARCH_COMPLETED, - data: { - query, - resolveInfo, - urls, - append: options.page && options.page !== 1, - pageSize: options.page_size - } - }); + return function (_x2) { + return _ref2.apply(this, arguments); }; - - const failure = err => { - dispatch({ - type: CLAIM_SEARCH_FAILED, - data: { query }, - error: err - }); - }; - - lbryProxy.claim_search(_extends$5({}, options, { - include_purchase_receipt: true - })).then(success, failure); - }; + })(); } function doRepost(options) { diff --git a/src/redux/actions/claims.js b/src/redux/actions/claims.js index a50c4f6..cd0cb6d 100644 --- a/src/redux/actions/claims.js +++ b/src/redux/actions/claims.js @@ -65,7 +65,7 @@ export function doResolveUris( } = {}; return Lbry.resolve({ urls: urisToResolve, ...options }).then( - async (result: ResolveResponse) => { + async(result: ResolveResponse) => { let repostedResults = {}; const repostsToResolve = []; const fallbackResolveInfo = { @@ -594,7 +594,7 @@ export function doClaimSearch( } ) { const query = createNormalizedClaimSearchKey(options); - return (dispatch: Dispatch) => { + return async(dispatch: Dispatch) => { dispatch({ type: ACTIONS.CLAIM_SEARCH_STARTED, data: { query: query }, @@ -618,6 +618,7 @@ export function doClaimSearch( pageSize: options.page_size, }, }); + return true; }; const failure = err => { @@ -626,9 +627,10 @@ export function doClaimSearch( data: { query }, error: err, }); + return false; }; - Lbry.claim_search({ + return await Lbry.claim_search({ ...options, include_purchase_receipt: true, }).then(success, failure);