messages

Documentation

Index

• type Service
  • func NewService(ethSigner service.Signer, contractsService service.Contracts, ...) *Service
  • func (ss *Service) ProcessSignature(tsm message.Message) error
  • func (ss *Service) SanityCheckSignature(topicMessage message.Message) (bool, error)

Types

type Service

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

func NewService

func NewService(
	ethSigner service.Signer,
	contractsService service.Contracts,
	transferRepository repository.Transfer,
	messageRepository repository.Message,
	hederaClient client.HederaNode,
	mirrorClient client.MirrorNode,
	ethClient client.Ethereum,
	topicID string,
) *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