From e61874bb6f08025df845b9364dabc7aff044e4a2 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Mon, 1 Feb 2021 16:02:34 -0300 Subject: [PATCH] only repeat search if it has blocked items --- lbry/wallet/server/db/elastic_search.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/lbry/wallet/server/db/elastic_search.py b/lbry/wallet/server/db/elastic_search.py index 5cbdedbb2..7e133f314 100644 --- a/lbry/wallet/server/db/elastic_search.py +++ b/lbry/wallet/server/db/elastic_search.py @@ -155,13 +155,12 @@ class SearchIndex: total_referenced, response, censor = await self.resolve(*kwargs) else: censor = Censor(Censor.SEARCH) - response, offset, total = await self.search(**kwargs, censor_type=0) + response, offset, total = await self.search(**kwargs) + censor.apply(response) total_referenced.extend(response) - kwargs['limit'] = 20 - kwargs['offset'] = 0 - censored_response, _, _ = await self.search(**kwargs, censor_type='>0') - censor.apply(censored_response) - total_referenced.extend(censored_response) + if censor.censored: + response, _, _ = await self.search(**kwargs, censor_type=0) + total_referenced.extend(response) return Outputs.to_base64(response, await self._get_referenced_rows(total_referenced), offset, total, censor) async def resolve(self, *urls):