harvester

type Adapter interface {
	GetLastBlockNumber() (uint64, error)
	GetTokenBalance(contract *common.Address, wallet *common.Address, blockNumber uint64) (*big.Int, uint64, error)
	GetNFTBalance(nftContract *common.Address, wallet *common.Address, block uint64) ([]common.Hash, error)
	GetEtherBalance(wallet *common.Address, block uint64) (*big.Int, error)
	GetTokenLogs(fromBlock, toBlock uint64, addresses []common.Address) ([]any, error)
	GetNFTLogs(fromBlock, toBlock uint64, contracts []common.Address) ([]any, error)
	GetEtherLogs(fromBlock, toBlock uint64, wallets map[common.Address]bool) ([]ChangeEtherLog, error)
	RegisterNewBlockListener(f AdapterListener)
	Run()
	GetInfo() (umid umid.UMID, name string, rpcURL string)
}

type AdapterListener func(blockNumber uint64)

type ChangeEtherLog struct {
	Block  uint64
	Wallet common.Address
	Delta  *big.Int
}

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

type DoInit struct {
}

type Ethers struct {
	SubscribeQueue  *SubscribeQueue
	DB              *DB
	DefaultContract common.Address
	// contains filtered or unexported fields
}

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

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

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

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

type NFTCell struct {
	Contract common.Address
	Wallet   common.Address
	ItemID   common.Hash
	Block    uint64
}

type NFTs struct {
	SubscribeQueue *SubscribeQueue
	DB             *DB
	// contains filtered or unexported fields
}

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

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

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

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

type TokenCell struct {
	Contract common.Address
	Wallet   common.Address
	Value    *big.Int
	Block    uint64
}

type Tokens struct {
	SubscribeQueue *SubscribeQueue
	DB             *DB
	// contains filtered or unexported fields
}

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

type TransferNFTLog struct {
	Block    uint64
	From     common.Address
	To       common.Address
	TokenID  common.Hash
	Contract common.Address
}

type UpdateCell struct {
	Contract common.Address
	Wallet   common.Address
	Value    *big.Int
	IDs      []common.Hash
	Block    uint64
}

type UpdateNFTEvent struct {
	Contract common.Address
	Wallet   common.Address
	IDs      []common.Hash
}

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

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

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