service

Documentation

Index

• type MockBurnService
  • func (m *MockBurnService) ProcessEvent(event transfer.Transfer)
  • func (m *MockBurnService) TransactionID(id string) (string, error)
• type MockDistrubutorService
  • func (mds *MockDistrubutorService) CalculateMemberDistribution(validFee int64) ([]transfer.Hedera, error)
  • func (mds *MockDistrubutorService) PrepareTransfers(amount int64, token string) ([]model.Transfer, error)
  • func (mds *MockDistrubutorService) ValidAmount(amount int64) int64
• type MockFeeService
  • func (mfs *MockFeeService) CalculateFee(token string, amount int64) (fee, remainder int64)
• type MockLockService
  • func (m *MockLockService) ProcessEvent(event transfer.Transfer)
• type MockMessageService
  • func (m *MockMessageService) ProcessSignature(tm message.Message) error
  • func (m *MockMessageService) SanityCheckSignature(tm message.Message) (bool, error)
  • func (m *MockMessageService) SignMessage(transfer transfer.Transfer) (*message.Message, error)
• type MockReadOnlyService
  • func (m *MockReadOnlyService) FindAssetTransfer(transferID string, asset string, transfers []transfer.Hedera, ...)
  • func (m *MockReadOnlyService) FindTransfer(transferID string, fetch func() (*mirror_node.Response, error), ...)
• type MockScheduledService
  • func (mss *MockScheduledService) ExecuteScheduledBurnTransaction(id, asset string, amount int64, status *chan string, ...)
  • func (mss *MockScheduledService) ExecuteScheduledMintTransaction(id, asset string, amount int64, status *chan string, ...)
  • func (mss *MockScheduledService) ExecuteScheduledTransferTransaction(id, nativeAsset string, transfers []transfer.Hedera, ...)
• type MockSignerService
  • func (m *MockSignerService) Address() string
  • func (m *MockSignerService) NewKeyTransactor(chainId *big.Int) (*bind.TransactOpts, error)
  • func (m *MockSignerService) Sign(msg []byte) ([]byte, error)
• type MockTransferService
  • func (mts *MockTransferService) Create(ct *transfer.Transfer) (*entity.Transfer, error)
  • func (mts *MockTransferService) GetByTransactionId(txId string) (*entity.Transfer, error)
  • func (mts *MockTransferService) GetWithFee(txId string) (*entity.Transfer, error)
  • func (mts *MockTransferService) GetWithPreloads(txId string) (*entity.Transfer, error)
  • func (mts *MockTransferService) InitiateNewTransfer(tm transfer.Transfer) (*entity.Transfer, error)
  • func (mts *MockTransferService) ProcessNativeTransfer(tm transfer.Transfer) error
  • func (mts *MockTransferService) ProcessWrappedTransfer(tm transfer.Transfer) error
  • func (mts *MockTransferService) SanityCheckTransfer(tx model.Transaction) (int64, string, error)
  • func (mts *MockTransferService) TransferData(txId string) (service.TransferData, error)
  • func (mts *MockTransferService) UpdateStatusCompleted(txId string) error
  • func (mts *MockTransferService) UpdateStatusFailed(txId string) error

Types

type MockBurnService

type MockBurnService struct {
	mock.Mock
}

func (*MockBurnService) ProcessEvent

func (m *MockBurnService) ProcessEvent(event transfer.Transfer)

func (*MockBurnService) TransactionID

func (m *MockBurnService) TransactionID(id string) (string, error)

type MockDistrubutorService

type MockDistrubutorService struct {
	mock.Mock
}

func (*MockDistrubutorService) CalculateMemberDistribution

func (mds *MockDistrubutorService) CalculateMemberDistribution(validFee int64) ([]transfer.Hedera, error)

func (*MockDistrubutorService) PrepareTransfers

func (mds *MockDistrubutorService) PrepareTransfers(amount int64, token string) ([]model.Transfer, error)

func (*MockDistrubutorService) ValidAmount

func (mds *MockDistrubutorService) ValidAmount(amount int64) int64

type MockFeeService

type MockFeeService struct {
	mock.Mock
}

func (*MockFeeService) CalculateFee

func (mfs *MockFeeService) CalculateFee(token string, amount int64) (fee, remainder int64)

type MockLockService

type MockLockService struct {
	mock.Mock
}

func (*MockLockService) ProcessEvent

func (m *MockLockService) ProcessEvent(event transfer.Transfer)

type MockMessageService

type MockMessageService struct {
	mock.Mock
}

func (*MockMessageService) ProcessSignature

func (m *MockMessageService) ProcessSignature(tm message.Message) error

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

func (*MockMessageService) SanityCheckSignature

func (m *MockMessageService) SanityCheckSignature(tm message.Message) (bool, error)

SanityCheckSignature performs any validation required prior handling the topic message (verifies metadata against the corresponding Transaction record)

func (*MockMessageService) SignMessage

func (m *MockMessageService) SignMessage(transfer transfer.Transfer) (*message.Message, error)

type MockReadOnlyService

type MockReadOnlyService struct {
	mock.Mock
}

func (*MockReadOnlyService) FindAssetTransfer

func (m *MockReadOnlyService) FindAssetTransfer(transferID string, asset string, transfers []transfer.Hedera, fetch func() (*mirror_node.Response, error), save func(transactionID, scheduleID, status string) error)

func (*MockReadOnlyService) FindTransfer

func (m *MockReadOnlyService) FindTransfer(transferID string, fetch func() (*mirror_node.Response, error), save func(transactionID, scheduleID, status string) error)

type MockScheduledService

type MockScheduledService struct {
	mock.Mock
}

func (*MockScheduledService) ExecuteScheduledBurnTransaction

func (mss *MockScheduledService) ExecuteScheduledBurnTransaction(id, asset string, amount int64, status *chan string, onExecutionSuccess func(transactionID string, scheduleID string), onExecutionFail, onSuccess, onFail func(transactionID string))

func (*MockScheduledService) ExecuteScheduledMintTransaction

func (mss *MockScheduledService) ExecuteScheduledMintTransaction(id, asset string, amount int64, status *chan string, onExecutionSuccess func(transactionID string, scheduleID string), onExecutionFail, onSuccess, onFail func(transactionID string))

func (*MockScheduledService) ExecuteScheduledTransferTransaction

func (mss *MockScheduledService) ExecuteScheduledTransferTransaction(id, nativeAsset string, transfers []transfer.Hedera, onExecutionSuccess func(transactionID, scheduleID string), onExecutionFail, onSuccess, onFail func(transactionID string))

type MockSignerService

type MockSignerService struct {
	mock.Mock
}

func (*MockSignerService) Address

func (m *MockSignerService) Address() string

func (*MockSignerService) NewKeyTransactor

func (m *MockSignerService) NewKeyTransactor(chainId *big.Int) (*bind.TransactOpts, error)

func (*MockSignerService) Sign

func (m *MockSignerService) Sign(msg []byte) ([]byte, error)

type MockTransferService

type MockTransferService struct {
	mock.Mock
}

func (*MockTransferService) Create

func (mts *MockTransferService) Create(ct *transfer.Transfer) (*entity.Transfer, error)

func (*MockTransferService) GetByTransactionId

func (mts *MockTransferService) GetByTransactionId(txId string) (*entity.Transfer, error)

func (*MockTransferService) GetWithFee

func (mts *MockTransferService) GetWithFee(txId string) (*entity.Transfer, error)

func (*MockTransferService) GetWithPreloads

func (mts *MockTransferService) GetWithPreloads(txId string) (*entity.Transfer, error)

func (*MockTransferService) InitiateNewTransfer

func (mts *MockTransferService) InitiateNewTransfer(tm transfer.Transfer) (*entity.Transfer, error)

func (*MockTransferService) ProcessNativeTransfer

func (mts *MockTransferService) ProcessNativeTransfer(tm transfer.Transfer) error

func (*MockTransferService) ProcessWrappedTransfer

func (mts *MockTransferService) ProcessWrappedTransfer(tm transfer.Transfer) error

func (*MockTransferService) SanityCheckTransfer

func (mts *MockTransferService) SanityCheckTransfer(tx model.Transaction) (int64, string, error)

func (*MockTransferService) TransferData

func (mts *MockTransferService) TransferData(txId string) (service.TransferData, error)

func (*MockTransferService) UpdateStatusCompleted

func (mts *MockTransferService) UpdateStatusCompleted(txId string) error

func (*MockTransferService) UpdateStatusFailed

func (mts *MockTransferService) UpdateStatusFailed(txId string) error