Add remote_signer_public_keys_url

src/config/settings.py

@@ -49,6 +49,7 @@ class Settings(metaclass=Singleton):
     keystores_password_dir: Path
     keystores_password_file: Path
     remote_signer_url: str | None
+    remote_signer_public_keys_url: str | None
     dappnode: bool = False
     hashi_vault_key_paths: list[str] | None
     hashi_vault_url: str | None
@@ -163,6 +164,9 @@ def set(
 
         # remote signer configuration
         self.remote_signer_url = remote_signer_url
+        self.remote_signer_public_keys_url: str = decouple_config(
+            'REMOTE_SIGNER_PUBLIC_KEYS_URL', default=None
+        )
         self.dappnode = dappnode
 
         # hashi vault configuration

src/validators/keystores/remote.py

@@ -1,6 +1,8 @@
 import dataclasses
 import logging
 from dataclasses import dataclass
+from typing import cast
+from urllib.parse import urljoin
 
 import milagro_bls_binding as bls
 from aiohttp import ClientSession, ClientTimeout
@@ -85,7 +87,11 @@ async def get_exit_signature(
 
     @staticmethod
     async def _get_remote_signer_public_keys() -> list[HexStr]:
-        signer_url = f'{settings.remote_signer_url}/api/v1/eth2/publicKeys'
+        signer_base_url = cast(
+            str, settings.remote_signer_public_keys_url or settings.remote_signer_url
+        )
+
+        signer_url = urljoin(signer_base_url, '/api/v1/eth2/publicKeys')
         async with ClientSession(timeout=ClientTimeout(REMOTE_SIGNER_TIMEOUT)) as session:
             response = await session.get(signer_url)
 
@@ -115,7 +121,9 @@ async def _sign_exit_request(
             voluntary_exit=VoluntaryExitMessage(epoch=fork.epoch, validator_index=validator_index),
         )
 
-        signer_url = f'{settings.remote_signer_url}/api/v1/eth2/sign/0x{public_key.hex()}'
+        signer_base_url = cast(str, settings.remote_signer_url)
+        signer_url = urljoin(signer_base_url, f'/api/v1/eth2/sign/0x{public_key.hex()}')
+
         async with ClientSession(timeout=ClientTimeout(REMOTE_SIGNER_TIMEOUT)) as session:
             response = await session.post(signer_url, json=dataclasses.asdict(data))