transfers

Documentation

Index

• type Service
  • func NewService(hederaNode client.HederaNode, mirrorNode client.MirrorNode, ...) *Service
  • func (ts *Service) InitiateNewTransfer(tm payload.Transfer) (*entity.Transfer, error)
  • func (ts *Service) Paged(req *model.PagedRequest) (*model.Paged, error)
  • func (ts *Service) ProcessNativeNftTransfer(tm payload.Transfer) error
  • func (ts *Service) ProcessNativeTransfer(tm payload.Transfer) error
  • func (ts *Service) ProcessWrappedTransfer(tm payload.Transfer) error
  • func (ts *Service) SanityCheckTransfer(tx mirrorNodeTransaction.Transaction) model.SanityCheckResult
  • func (ts *Service) TransferData(txId string) (interface{}, error)

Types

type Service

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

func NewService

func NewService(
	hederaNode client.HederaNode,
	mirrorNode client.MirrorNode,
	contractServices map[uint64]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,
	prometheusService service.Prometheus,
	assetsService service.Assets,
) *Service

func (*Service) InitiateNewTransfer

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

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

func (*Service) Paged

func (ts *Service) Paged(req *model.PagedRequest) (*model.Paged, error)

func (*Service) ProcessNativeNftTransfer

func (ts *Service) ProcessNativeNftTransfer(tm payload.Transfer) error

func (*Service) ProcessNativeTransfer

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

func (*Service) ProcessWrappedTransfer

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

func (*Service) SanityCheckTransfer

func (ts *Service) SanityCheckTransfer(tx mirrorNodeTransaction.Transaction) model.SanityCheckResult

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

func (*Service) TransferData

func (ts *Service) TransferData(txId string) (interface{}, error)

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