harvester2

type Adapter interface {
	GetLastBlockNumber() (uint64, error)
	GetBalance(wallet *common.Address, contract *common.Address, blockNumber uint64) (*big.Int, error)
	GetNFTBalance(block int64, wallet *common.Address, nftContract *common.Address) ([]umid.UMID, error)
	GetStakeBalance(block int64, wallet *common.Address, nftContract *common.Address) (map[umid.UMID]*[3]*big.Int, error)
	GetLogs(fromBlock, toBlock int64, addresses []common.Address) ([]any, error)
	RegisterNewBlockListener(f AdapterListener)
	Run()
	GetInfo() (umid umid.UMID, name BCType, rpcURL string)
}

type AdapterListener func(blockNumber uint64)

type Address common.Address

type BCType string

type Callback *func(p any)

type Callbacks struct {
	Mu   sync.RWMutex
	Data map[BCType]map[Event]map[Callback]bool
}

type Contract Address

type Event string

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

type IHarvester2 interface {
	RegisterAdapter(adapter Adapter)

	AddWallet(bcType BCType, wallet Address) error
	RemoveWallet(bcType BCType, wallet Address) error

	AddNFTContract(bcType BCType, contract Address) error
	RemoveNFTContract(bcType BCType, contract Address) error

	AddTokenContract(bcType BCType, contract Address) error
	RemoveTokenContract(bcType BCType, contract Address) error

	AddTokenListener(bcType BCType, contract Address, listener TokenListener) error
	AddNFTListener(bcType BCType, contract Address, listener NFTListener) error
	AddStakeListener(bcType BCType, contract Address, listener StakeListener) error

	GetWalletTokenData(bcType BCType, contract Address, wallet Address) (*TokenData, error)
	GetWalletNFTData(bcType BCType, contract Address, wallet Address) (*NFTData, error)
}

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

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

type NFTData struct {
	Wallet   *Address
	Contract *Address
	TokenIDs []umid.UMID
}

type NFTListener func(events []*NFTData)

type NftEvent struct {
	From      string
	To        string
	OdysseyID umid.UMID
	Contract  string
}

type RestakeLog struct {
	UserWallet        common.Address
	FromOdysseyID     umid.UMID
	ToOdysseyID       umid.UMID
	Amount            *big.Int
	TokenType         uint8
	TotalStakedToFrom *big.Int
	TotalStakedToTo   *big.Int
	Contract          common.Address
}

type Stake struct {
	TotalAmount    *big.Int
	TotalDADAmount *big.Int
	TotalMOMAmount *big.Int
}

type StakeCell struct {
	Stakes map[umid.UMID]*Stake
	// contains filtered or unexported fields
}

type StakeData struct {
	Wallet    *Address
	Contract  *Address
	OdysseyID *umid.UMID
	Stake     *Stake
}

type StakeEvent struct {
	TxHash    string
	Wallet    string
	OdysseyID umid.UMID
	Amount    *big.Int
}

type StakeListener func(events []*StakeData)

type StakeLog struct {
	TxHash       string
	UserWallet   common.Address
	OdysseyID    umid.UMID
	AmountStaked *big.Int
	TokenType    uint8
	TotalStaked  *big.Int
	Contract     common.Address
}

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

type TokenData struct {
	Wallet      *Address
	Contract    *Address
	TotalAmount *big.Int
}

type TokenListener func(events []*TokenData)

type TransferERC20Log struct {
	From     common.Address
	To       common.Address
	Value    *big.Int
	Contract common.Address
}

type TransferNFTLog struct {
	From     common.Address
	To       common.Address
	TokenID  umid.UMID
	Contract common.Address
}

type UnstakeLog struct {
	UserWallet     common.Address
	OdysseyID      umid.UMID
	AmountUnstaked *big.Int
	TokenType      uint8
	TotalStaked    *big.Int
	Contract       common.Address
}

type UpdateEvent struct {
	Wallet   string
	Contract string
	Amount   *big.Int
}

type Wallet Address