Jmaa/personal-data
1
0
Fork 0
Code Actions Packages

Hiding client

Browse Source
This commit is contained in:
Jon Michael Aanes 2024-09-02 12:04:03 +02:00
parent 7d82003db8
commit 9349e4e6d4
Signed by: Jmaa
SSH Key Fingerprint: SHA256:Ab0GfHGCblESJx7JRE4fj4bFy/KRpeLhi41y4pF3sNA
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
personal_data/fetchers/defi_kucoin.py
View File

@ -12,13 +12,15 @@ from .. import secrets
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
def get_client():
# TODO: Move these into secrets! assert secrets.KUCOIN_KEY, 'Missing secret: KUCOIN_KEY'
client = kucoin.client.Client( assert secrets.KUCOIN_SECRET, 'Missing secret: KUCOIN_SECRET'
assert secrets.KUCOIN_PASS, 'Missing secret: KUCOIN_PASS'
return kucoin.client.Client(
secrets.KUCOIN_KEY, secrets.KUCOIN_KEY,
secrets.KUCOIN_SECRET, secrets.KUCOIN_SECRET,
secrets.KUCOIN_PASS, secrets.KUCOIN_PASS,
) )
def addresses_to_data_points(addresses: list[dict[str, str]]) -> frozendict: def addresses_to_data_points(addresses: list[dict[str, str]]) -> frozendict:
@ -40,5 +42,5 @@ class KucoinDepositAddresses(Scraper):
deduplicate_ignore_columns = ['account.update_time'] deduplicate_ignore_columns = ['account.update_time']
def scrape(self) -> Iterator[Mapping[str, object]]: def scrape(self) -> Iterator[Mapping[str, object]]:
addresses = client.get_deposit_address('MPC') addresses = get_client().get_deposit_address('MPC')
yield addresses_to_data_points(addresses) yield addresses_to_data_points(addresses)