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) ProcessTransfer(tm model.Transfer) error
  • func (ts *Service) SanityCheckTransfer(tx mirror_node.Transaction) (string, error)
  • func (ts *Service) SaveRecoveredTxn(txId, amount, nativeAsset, wrappedAsset string, memo 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,
	contractsService service.Contracts,
	signer service.Signer,
	transferRepository repository.Transfer,
	feeRepository repository.Fee,
	feeService service.Fee,
	distributor service.Distributor,
	topicID string,
	bridgeAccount string,
	scheduledService service.Scheduled,
) *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) ProcessTransfer

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

func (*Service) SanityCheckTransfer

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

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

func (*Service) SaveRecoveredTxn

func (ts *Service) SaveRecoveredTxn(txId, amount, nativeAsset, wrappedAsset string, memo string) error

SaveRecoveredTxn creates new Transaction record persisting the recovered Transfer TXn

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