Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

claim_ids query

Browse source
This commit is contained in:
Victor Shyba 2021-02-09 21:38:41 -03:00
parent 8d028adc53
commit 0a194b5b01
2 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lbry/wallet/server/db/elastic_search.py
View file

@ -38,7 +38,8 @@ class SearchIndex:
"default": {"tokenizer": "whitespace", "filter": ["lowercase", "porter_stem"]}}}, "default": {"tokenizer": "whitespace", "filter": ["lowercase", "porter_stem"]}}},
"index": "index":
{"refresh_interval": -1, {"refresh_interval": -1,
"number_of_shards": 1} "number_of_shards": 1,
"number_of_replicas": 0}
}, },
"mappings": { "mappings": {
"properties": { "properties": {
@ -89,6 +90,7 @@ class SearchIndex:
for bulk in range(0, len(to_update), 400): for bulk in range(0, len(to_update), 400):
await self.update(to_update[bulk:bulk+400]) await self.update(to_update[bulk:bulk+400])
await self.client.indices.refresh(self.index) await self.client.indices.refresh(self.index)
await self.client.indices.flush(self.index)
async def apply_filters(self, blocked_streams, blocked_channels, filtered_streams, filtered_channels): async def apply_filters(self, blocked_streams, blocked_channels, filtered_streams, filtered_channels):
def make_query(censor_type, blockdict, channels=False): def make_query(censor_type, blockdict, channels=False):
@ -290,7 +292,7 @@ FIELDS = {'is_controlling', 'last_take_over_height', 'claim_id', 'claim_name', '
'trending_group', 'trending_mixed', 'trending_local', 'trending_global', 'channel_id', 'tx_id', 'tx_nout', 'trending_group', 'trending_mixed', 'trending_local', 'trending_global', 'channel_id', 'tx_id', 'tx_nout',
'signature', 'signature_digest', 'public_key_bytes', 'public_key_hash', 'public_key_id', '_id', 'tags', 'signature', 'signature_digest', 'public_key_bytes', 'public_key_hash', 'public_key_id', '_id', 'tags',
'reposted_claim_id'} 'reposted_claim_id'}
TEXT_FIELDS = {'author', 'canonical_url', 'channel_id', 'claim_name', 'description', TEXT_FIELDS = {'author', 'canonical_url', 'channel_id', 'claim_name', 'description', 'claim_id',
'media_type', 'normalized', 'public_key_bytes', 'public_key_hash', 'short_url', 'signature', 'media_type', 'normalized', 'public_key_bytes', 'public_key_hash', 'short_url', 'signature',
'signature_digest', 'stream_type', 'title', 'tx_id', 'fee_currency', 'reposted_claim_id', 'tags'} 'signature_digest', 'stream_type', 'title', 'tx_id', 'fee_currency', 'reposted_claim_id', 'tags'}
RANGE_FIELDS = { RANGE_FIELDS = {
@ -367,6 +369,8 @@ def expand_query(**kwargs):
query['must_not'].append({"term": {'_id': channel_id}}) query['must_not'].append({"term": {'_id': channel_id}})
elif key == 'channel_ids': elif key == 'channel_ids':
query['must'].append({"terms": {'channel_id.keyword': value}}) query['must'].append({"terms": {'channel_id.keyword': value}})
elif key == 'claim_ids':
query['must'].append({"terms": {'claim_id.keyword': value}})
elif key == 'media_types': elif key == 'media_types':
query['must'].append({"terms": {'media_type.keyword': value}}) query['must'].append({"terms": {'media_type.keyword': value}})
elif key == 'stream_types': elif key == 'stream_types':

2
tests/integration/blockchain/test_claim_commands.py
View file

@ -173,6 +173,8 @@ class ClaimSearchCommand(ClaimTestCase):
# abandoned stream won't show up for streams in channel search # abandoned stream won't show up for streams in channel search
await self.stream_abandon(txid=signed2['txid'], nout=0) await self.stream_abandon(txid=signed2['txid'], nout=0)
await self.assertFindsClaims([], channel_ids=[channel_id2]) await self.assertFindsClaims([], channel_ids=[channel_id2])
# resolve by claim ids
await self.assertFindsClaims([three, two], claim_ids=[self.get_claim_id(three), self.get_claim_id(two)])
async def test_source_filter(self): async def test_source_filter(self):
no_source = await self.stream_create('no_source', data=None) no_source = await self.stream_create('no_source', data=None)