Disallow connection for blacklisted validator

backend-developers-ltd · Oct 8, 2024 · 5c9a0ba · 5c9a0ba
1 parent d7046ee
commit 5c9a0ba
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/miner/app/src/compute_horde_miner/miner/miner_consumer/validator_interface.py b/miner/app/src/compute_horde_miner/miner/miner_consumer/validator_interface.py
@@ -77,6 +77,12 @@ async def connect(self):
         ):
             msg = f"Inactive validator: {self.validator_key}"
             fail = True
+        validator_blacklisted = await ValidatorBlacklist.objects.filter(
+            validator=self.validator
+        ).aexists()
+        if validator_blacklisted:
+            msg = f"Blacklisted validator: {self.validator_key}"
+            fail = True
         if fail:
             await self.send(miner_requests.GenericError(details=msg).model_dump_json())
             logger.info(msg)