tx

Documentation

Index

• func ChainSpecificMessageTypeHandlerBootstrap(chainID string)
• type Parser
  • func NewParser(db *gorm.DB, cl *client.ChainClient, processor Processor) Parser
• type Processor
  • func NewProcessor(cl *client.ChainClient) Processor

Functions

func ChainSpecificMessageTypeHandlerBootstrap

func ChainSpecificMessageTypeHandlerBootstrap(chainID string)

Merge the chain specific message type handlers into the core message type handler map. Chain specific handlers will be registered BEFORE any generic handlers. TODO: Remove this function and replace with a more generic solution

Types

type Parser

type Parser interface {
	ProcessRPCBlockByHeightTXs(messageTypeFilters []filter.MessageTypeFilter,
		blockResults *coretypes.ResultBlock, resultBlockRes *coretypes.ResultBlockResults) ([]dbTypes.TxDBWrapper, *time.Time, error)
	ProcessRPCTXs(messageTypeFilters []filter.MessageTypeFilter,
		txEventResp *cosmosTx.GetTxsEventResponse) ([]dbTypes.TxDBWrapper, *time.Time, error)
}

func NewParser

func NewParser(db *gorm.DB, cl *client.ChainClient, processor Processor) Parser

type Processor

type Processor interface {
	ProcessTx(tx txtypes.MergedTx, messagesRaw [][]byte) (txDBWapper dbTypes.TxDBWrapper,
		txTime time.Time, err error)
	ProcessSigners(authInfo *cosmosTx.AuthInfo,
		messageSigners []types.AccAddress) ([]models.Address, []*models.SignerInfo, error)
	ProcessFees(authInfo cosmosTx.AuthInfo, signers []models.Address) ([]models.Fee, error)
	ProcessMessage(messageIndex int, message types.Msg,
		txMessageEventLogs []txtypes.LogMessage,
		uniqueEventTypes map[string]models.MessageEventType,
		uniqueEventAttributeKeys map[string]models.MessageEventAttributeKey) (string, dbTypes.MessageDBWrapper)
}

func NewProcessor

func NewProcessor(cl *client.ChainClient) Processor