From dd950f5b0d7bd5242206b3c59656a8ad0be91da8 Mon Sep 17 00:00:00 2001 From: Victor Shyba <victor.shyba@gmail.com> Date: Tue, 26 Jan 2021 22:33:17 -0300 Subject: [PATCH] tag can have empty space --- lbry/wallet/server/db/writer.py | 4 ++-- scripts/sync.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lbry/wallet/server/db/writer.py b/lbry/wallet/server/db/writer.py index 9469343bc..68e3b4fe0 100644 --- a/lbry/wallet/server/db/writer.py +++ b/lbry/wallet/server/db/writer.py @@ -815,7 +815,7 @@ class SQLDB: for claim in self.execute(f""" SELECT claimtrie.claim_hash as is_controlling, claimtrie.last_take_over_height, - (select group_concat(tag, ' ') from tag where tag.claim_hash in (claim.claim_hash, claim.reposted_claim_hash)) as tags, + (select group_concat(tag, ',,') from tag where tag.claim_hash in (claim.claim_hash, claim.reposted_claim_hash)) as tags, (select group_concat(language, ' ') from language where language.claim_hash in (claim.claim_hash, claim.reposted_claim_hash)) as languages, claim.* FROM claim LEFT JOIN claimtrie USING (claim_hash) @@ -840,7 +840,7 @@ class SQLDB: claim['censor_type'] = 1 claim['censoring_channel_hash'] = self.filtered_channels.get(reason_id) - claim['tags'] = claim['tags'].split(' ') if claim['tags'] else [] + claim['tags'] = claim['tags'].split(',,') if claim['tags'] else [] claim['languages'] = claim['languages'].split(' ') if claim['languages'] else [] if not self.claim_queue.full(): self.claim_queue.put_nowait(('update', claim)) diff --git a/scripts/sync.py b/scripts/sync.py index b4d4fee62..e075ff2c5 100644 --- a/scripts/sync.py +++ b/scripts/sync.py @@ -22,7 +22,7 @@ async def get_all(db): for num, claim in enumerate(db.execute(f""" SELECT claimtrie.claim_hash as is_controlling, claimtrie.last_take_over_height, - (select group_concat(tag, ' ') from tag where tag.claim_hash in (claim.claim_hash, claim.reposted_claim_hash)) as tags, + (select group_concat(tag, ',,') from tag where tag.claim_hash in (claim.claim_hash, claim.reposted_claim_hash)) as tags, (select group_concat(language, ' ') from language where language.claim_hash in (claim.claim_hash, claim.reposted_claim_hash)) as languages, claim.* FROM claim LEFT JOIN claimtrie USING (claim_hash) @@ -30,7 +30,7 @@ FROM claim LEFT JOIN claimtrie USING (claim_hash) claim = dict(claim._asdict()) claim['censor_type'] = 0 claim['censoring_channel_hash'] = None - claim['tags'] = claim['tags'].split(' ') if claim['tags'] else [] + claim['tags'] = claim['tags'].split(',,') if claim['tags'] else [] claim['languages'] = claim['languages'].split(' ') if claim['languages'] else [] if num % 10_000 == 0: print(num, total)