chain

type ChainName string

type EthereumMainnetSubscriberOption interface {
	Apply(*ethereumMainnetSubscriber)
}

type SubscriberManager interface {
	WalletTransactionTracker

	// RegisterSubscribers registers new subscribers and calls its Init.
	// RegisterSubscriber should not be called concurrently.
	RegisterSubscribers(subscribers ...TransactionSubscriber) error

	// StartAll accepts a sink which will receive all tracked wallet events from
	// all of the registered subscribers. StartAll blocks and exits with an
	// error if something goes wrong in one of the registered subscribers.
	StartAll(sink chan<- *TrackedWalletEvent) error
}

type TrackedWalletEvent struct {
	ChainName   ChainName
	Source      string
	Destination string
	Amount      *big.Int
	Fees        *big.Int
}

type TransactionSubscriber interface {
	// Init initializes the subscriber, sets up any required connections and
	// prepares the subscriber to start receiving messages.
	Init() error

	// Start starts the subscriber. Returned channel will produce events
	// whenever a transaction for one of the registered wallets is received from
	// RPC provider. Start does not block.
	Start() (<-chan *TrackedWalletEvent, <-chan error)

	// TrackWallet starts to track transactions of provided wallet
	TrackWallet(wallet string) error

	// UntrackWallet stops tracking wallet's transactions
	UntrackWallet(wallet string) error

	// Name returns the chain name of given TransactionSubscriber
	Name() ChainName
}

type WalletTransactionTracker interface {
	// TrackWallet starts tracking wallet's transactions within the given chain
	// subscriber.
	TrackWallet(wallet string, chain ChainName) error

	// UntrackWallet stops tracking wallet's transactions within the given chain
	// subscriber.
	UntrackWallet(wallet string, chain ChainName) error
}

type WithRpcClientOptions struct {
	Opts []rpc.ClientOption
}