Source code for tradeexecutor.ethereum.hot_wallet_sync

"""Handling of stablecoin deposits as strategy reserves."""

import datetime
from typing import List

from eth_typing import HexAddress
from web3 import Web3

from tradeexecutor.ethereum.wallet import sync_reserves
from tradeexecutor.state.sync import apply_sync_events
from tradeexecutor.state.portfolio import Portfolio
from tradeexecutor.state.identifier import AssetIdentifier


[docs]class EthereumHotWalletReserveSyncer:
    """Checks any Ethereum address for changes in the portfolio that may have happened outside the drawing.

    - Withdrawals

    - Deposits

    - Rebases

    - Interest payments

    .. note ::

        Private key nonce sync is handled by
        :py:func:`tradeexecutor.ethereum.UniswapV2ExecutionModel.uniswap_v2_execution.initialize`.
    """

[docs]    def __init__(self, web3: Web3, wallet_address: HexAddress):
        self.web3 = web3
        self.wallet_address = wallet_address

[docs]    def __call__(self, portfolio: Portfolio, ts: datetime.datetime, supported_reserves: List[AssetIdentifier]):
        events = sync_reserves(self.web3, ts, self.wallet_address, [], supported_reserves)
        apply_sync_events(portfolio, events)
        return events