Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion discovery-provider/default_config.ini
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ eth_provider_url = http://audius_ganache_cli_eth_contracts:8545
[solana]
track_listen_count_address = 7K3UpbZViPnQDLn2DAM853B9J5GBxd1L1rLHy4KqSmWG
signer_group_address = FbfwE8ZmVdwUbbEXdq4ofhuUEiAxeSk5kaoYrJJekpnZ
endpoint = https://audius.rpcpool.com,https://api.mainnet-beta.solana.com,https://solana-api.projectserum.com
endpoint = https://audius.rpcpool.com
user_bank_min_slot = 0
user_bank_program_address =
waudio_program_address =
Expand Down
2 changes: 1 addition & 1 deletion discovery-provider/src/app.py
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@ def create_celery(test_config=None):
eth_web3 = Web3(MultiProvider(shared_config["web3"]["eth_provider_url"]))

# Initialize Solana web3 provider
solana_client_manager = SolanaClientManager()
solana_client_manager = SolanaClientManager(shared_config["solana"]["endpoint"])

global registry
global user_factory
Expand Down
6 changes: 2 additions & 4 deletions discovery-provider/src/solana/solana_client_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,17 +12,15 @@

logger = logging.getLogger(__name__)

SOLANA_ENDPOINTS = shared_config["solana"]["endpoint"]

# maximum number of times to retry get_confirmed_transaction call
DEFAULT_MAX_RETRIES = 5
# number of seconds to wait between calls to get_confirmed_transaction
DELAY_SECONDS = 0.2


class SolanaClientManager:
def __init__(self) -> None:
self.endpoints = SOLANA_ENDPOINTS.split(",")
def __init__(self, solana_endpoints) -> None:
self.endpoints = solana_endpoints.split(",")
self.clients = [Client(endpoint) for endpoint in self.endpoints]

def get_client(self, randomize=False) -> Client:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
from src.solana.solana_client_manager import SolanaClientManager
from unittest import mock

solana_client_manager = SolanaClientManager()
solana_client_manager = SolanaClientManager("https://audius.rpcpool.com,https://api.mainnet-beta.solana.com,https://solana-api.projectserum.com")


@mock.patch("solana.rpc.api.Client")
Expand Down