transfers

Documentation

Index

• type Service
  • func NewService(hederaNode client.HederaNode, mirrorNode client.MirrorNode, ...) *Service
  • func (ts *Service) InitiateNewTransfer(tm model.Transfer) (*entity.Transfer, error)
  • func (ts *Service) ProcessNativeTransfer(tm model.Transfer) error
  • func (ts *Service) ProcessWrappedTransfer(tm model.Transfer) error
  • func (ts *Service) SanityCheckTransfer(tx hedera_mirror_node.Transaction) (int64, string, error)
  • func (ts *Service) TransferData(txId string) (service.TransferData, error)

Types

type Service

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

func NewService

func NewService(
	hederaNode client.HederaNode,
	mirrorNode client.MirrorNode,
	contractServices map[int64]service.Contracts,
	transferRepository repository.Transfer,
	scheduleRepository repository.Schedule,
	feeRepository repository.Fee,
	feeService service.Fee,
	distributor service.Distributor,
	topicID string,
	bridgeAccount string,
	scheduledService service.Scheduled,
	messageService service.Messages,
) *Service

func (*Service) InitiateNewTransfer

func (ts *Service) InitiateNewTransfer(tm model.Transfer) (*entity.Transfer, error)

InitiateNewTransfer Stores the incoming transfer message into the Database aware of already processed transfers

func (*Service) ProcessNativeTransfer

func (ts *Service) ProcessNativeTransfer(tm model.Transfer) error

func (*Service) ProcessWrappedTransfer

func (ts *Service) ProcessWrappedTransfer(tm model.Transfer) error

func (*Service) SanityCheckTransfer

func (ts *Service) SanityCheckTransfer(tx hedera_mirror_node.Transaction) (int64, string, error)

SanityCheck performs validation on the memo and state proof for the transaction

func (*Service) TransferData

func (ts *Service) TransferData(txId string) (service.TransferData, error)

TransferData returns from the database the given transfer, its signatures and calculates if its messages have reached super majority