From 9c269c90bb3ee72bb5fa162b288c20ebcfb54eca Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Thu, 5 Nov 2020 22:56:13 -0300 Subject: [PATCH] accept FILTERING_CHANNEL_IDS and BLOCKING_CHANNEL_IDS env vars as the old SDK --- lbry/blockchain/sync/synchronizer.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/lbry/blockchain/sync/synchronizer.py b/lbry/blockchain/sync/synchronizer.py index 5daeb248d..b48f9500b 100644 --- a/lbry/blockchain/sync/synchronizer.py +++ b/lbry/blockchain/sync/synchronizer.py @@ -1,6 +1,7 @@ import os import asyncio import logging +from binascii import unhexlify from typing import Optional, Tuple, Set, List, Coroutine from concurrent.futures import ThreadPoolExecutor @@ -53,8 +54,12 @@ class BlockchainSync(Sync): self.block_hash_event = asyncio.Event() self.tx_hash_event = asyncio.Event() self.mempool = [] - self.filtering_channel_hashes = set() - self.blocking_channel_hashes = set() + self.filtering_channel_hashes = { + unhexlify(channel_id)[::-1] for channel_id in + os.getenv('FILTERING_CHANNEL_IDS', '').split(' ') if channel_id} + self.blocking_channel_hashes = { + unhexlify(channel_id)[::-1] for channel_id in + os.getenv('BLOCKING_CHANNEL_IDS', '').split(' ') if channel_id} async def wait_for_chain_ready(self): while True: