backend

type Backend interface {
	XMRClient() monero.WalletClient
	ETHClient() extethclient.EthClient
	NetSender

	RecoveryDB() RecoveryDB

	// NewTxSender creates a new transaction sender, called per-swap
	NewTxSender(asset ethcommon.Address, erc20Contract *contracts.IERC20) (txsender.Sender, error)

	// helpers
	NewSwapCreator(addr ethcommon.Address) (*contracts.SwapCreator, error)
	HandleRelayClaimRequest(remotePeer peer.ID, request *message.RelayClaimRequest) (*message.RelayClaimResponse, error)
	GetRelayerAddressHash() (types.Hash, error)
	HasOngoingSwapAsTaker(peer.ID) error
	SubmitClaimToRelayer(
		peer.ID,
		*types.Hash,
		*contracts.SwapCreatorRelaySwap,
		[32]byte,
	) (*message.RelayClaimResponse, error) // Only used by Taker

	// getters
	Ctx() context.Context
	Env() common.Environment
	SwapManager() swap.Manager
	SwapCreator() *contracts.SwapCreator
	SwapCreatorAddr() ethcommon.Address
	SwapTimeout() time.Duration
	XMRDepositAddress(offerID *types.Hash) *mcrypto.Address

	// setters
	SetSwapTimeout(timeout time.Duration)
	SetXMRDepositAddress(*mcrypto.Address, types.Hash)
	ClearXMRDepositAddress(types.Hash)

	// transfer helpers
	TransferXMR(to *mcrypto.Address, amount *coins.PiconeroAmount) (string, error)
	SweepXMR(to *mcrypto.Address) ([]string, error)
	TransferETH(to ethcommon.Address, amount *coins.WeiAmount, gasLimit *uint64) (*ethtypes.Receipt, error)
	SweepETH(to ethcommon.Address) (*ethtypes.Receipt, error)
}

type Config struct {
	Ctx             context.Context
	MoneroClient    monero.WalletClient
	EthereumClient  extethclient.EthClient
	Environment     common.Environment
	SwapCreatorAddr ethcommon.Address
	SwapManager     swap.Manager
	RecoveryDB      RecoveryDB
	Net             NetSender
}

type MockRecoveryDB struct {
	// contains filtered or unexported fields
}

type MockRecoveryDBMockRecorder struct {
	// contains filtered or unexported fields
}

type NetSender interface {
	SendSwapMessage(common.Message, types.Hash) error
	DeleteOngoingSwap(offerID types.Hash)
	CloseProtocolStream(id types.Hash)
	DiscoverRelayers() ([]peer.ID, error)                                                        // Only used by Maker
	QueryRelayerAddress(peer.ID) (types.Hash, error)                                             // only used by taker
	SubmitRelayRequest(peer.ID, *message.RelayClaimRequest) (*message.RelayClaimResponse, error) // only used by taker
}

type RecoveryDB interface {
	PutContractSwapInfo(id types.Hash, info *db.EthereumSwapInfo) error
	GetContractSwapInfo(id types.Hash) (*db.EthereumSwapInfo, error)
	PutSwapPrivateKey(id types.Hash, keys *mcrypto.PrivateSpendKey) error
	GetSwapPrivateKey(id types.Hash) (*mcrypto.PrivateSpendKey, error)
	PutCounterpartySwapPrivateKey(id types.Hash, keys *mcrypto.PrivateSpendKey) error
	GetCounterpartySwapPrivateKey(id types.Hash) (*mcrypto.PrivateSpendKey, error)
	PutSwapRelayerInfo(id types.Hash, info *types.OfferExtra) error
	GetSwapRelayerInfo(id types.Hash) (*types.OfferExtra, error)
	PutCounterpartySwapKeys(id types.Hash, sk *mcrypto.PublicKey, vk *mcrypto.PrivateViewKey) error
	GetCounterpartySwapKeys(id types.Hash) (*mcrypto.PublicKey, *mcrypto.PrivateViewKey, error)
	PutNewSwapTxHash(id types.Hash, txHash types.Hash) error
	GetNewSwapTxHash(id types.Hash) (types.Hash, error)
	DeleteSwap(id types.Hash) error
}