messages

Documentation

Index

• type Service
  • func NewService(ethSigners map[int64]service.Signer, ...) *Service
  • func (ss *Service) ProcessSignature(tsm message.Message) error
  • func (ss *Service) SanityCheckSignature(topicMessage message.Message) (bool, error)
  • func (ss Service) SignMessage(tm model.Transfer) (*message.Message, error)

Types

type Service

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

func NewService

func NewService(
	ethSigners map[int64]service.Signer,
	contractServices map[int64]service.Contracts,
	transferRepository repository.Transfer,
	messageRepository repository.Message,
	mirrorClient client.MirrorNode,
	ethClients map[int64]client.EVM,
	topicID string,
	mappings config.Assets,
) *Service

func (*Service) ProcessSignature

func (ss *Service) ProcessSignature(tsm message.Message) error

ProcessSignature processes the signature message, verifying and updating all necessary fields in the DB

func (*Service) SanityCheckSignature

func (ss *Service) SanityCheckSignature(topicMessage message.Message) (bool, error)

SanityCheckSignature performs validation on the topic message metadata. Validates it against the Transaction Record metadata from DB

func (Service) SignMessage

func (ss Service) SignMessage(tm model.Transfer) (*message.Message, error)