diff --git a/sources/ch4.py b/sources/ch4.py index 7adec89..06864c4 100644 --- a/sources/ch4.py +++ b/sources/ch4.py @@ -25,6 +25,9 @@ CRAWL_DELAY = int(getenv("MONOLITH_CH4_CRAWL_DELAY", 5)) # Semaphore value ? THREADS_SEMAPHORE = int(getenv("MONOLITH_CH4_THREADS_SEMAPHORE", 1000)) +# Boards to crawl +BOARDS = getenv("MONOLITH_CH4_BOARDS", "").split(",") + # CONFIGURATION END # @@ -58,7 +61,10 @@ class Chan4(object): self.log.debug(f"Decoded hash key: {self.hash_key}") async def run(self): - await self.get_board_list() + if not BOARDS: + await self.get_board_list() + else: + self.boards = BOARDS while True: await self.get_thread_lists(self.boards) await asyncio.sleep(CRAWL_DELAY)