bnb

func CheckAddress(tx []byte, addrList map[string]*store.MonitorAddress, transferTopic, nftTransferSingleTopic string) bool

func GetBlockFromKafka(value []byte) (*store.Block, error)

func GetCoreAddr(addr string) string

func GetReceiptFromKafka(value []byte) (*store.Receipt, error)

func GetTxFromKafka(value []byte) (*store.Tx, error)

func GetTxType(body []byte) (uint64, error)

func ParseTx(body []byte, transferTopic, nftTransferSingleTopic string, blockchain int64) (*store.SubTx, error)