messages

Documentation

Index

• type Service
  • func NewService(ethSigners map[uint64]service.Signer, ...) *Service
  • func (ss *Service) ProcessSignature(transferID, signature string, targetChainId uint64, timestamp int64, ...) error
  • func (ss *Service) SanityCheckFungibleSignature(topicMessage *proto_models.TopicEthSignatureMessage) (bool, error)
  • func (ss *Service) SanityCheckNftSignature(topicMessage *proto_models.TopicEthNftSignatureMessage) (bool, error)
  • func (ss Service) SignFungibleMessage(tm payload.Transfer) ([]byte, error)
  • func (ss Service) SignNftMessage(tm payload.Transfer) ([]byte, error)

Types

type Service

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

func NewService

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

func (*Service) ProcessSignature

func (ss *Service) ProcessSignature(transferID, signature string, targetChainId uint64, timestamp int64, authMsg []byte) error

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

func (*Service) SanityCheckFungibleSignature

func (ss *Service) SanityCheckFungibleSignature(topicMessage *proto_models.TopicEthSignatureMessage) (bool, error)

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

func (*Service) SanityCheckNftSignature

func (ss *Service) SanityCheckNftSignature(topicMessage *proto_models.TopicEthNftSignatureMessage) (bool, error)

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

func (Service) SignFungibleMessage

func (ss Service) SignFungibleMessage(tm payload.Transfer) ([]byte, error)

func (Service) SignNftMessage

func (ss Service) SignNftMessage(tm payload.Transfer) ([]byte, error)