interactor

Documentation

Index

• type CancelTransactionInteractor
  • func NewCancelTransactionInteractor(transactionRepository repositories.TransactionRepository) *CancelTransactionInteractor
  • func (c *CancelTransactionInteractor) Execute(ctx context.Context) error
• type SourceTypeInteractor
  • func NewSourceTypeInteractor(Repository repositories.SourceTypeRepository) *SourceTypeInteractor
  • func (s *SourceTypeInteractor) ExistsByName(ctx context.Context, name string) (bool, error)
• type TransactionInteractor
  • func NewTransactionInteractor(transactionRepository repositories.TransactionRepository, ...) *TransactionInteractor
  • func (i *TransactionInteractor) ProcessTransaction(userID string, sourceType string, dto *dtos.TransactionDTO) (*repositories.TransactionRow, error)
• type UserInteractor
  • func NewUserInteractor(Repository repositories.UserRepository) *UserInteractor
  • func (u *UserInteractor) ExistsByID(ctx context.Context, id string) (bool, error)
  • func (u *UserInteractor) GetBalance(ctx context.Context, id string) (float64, error)

Types

type CancelTransactionInteractor

type CancelTransactionInteractor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewCancelTransactionInteractor

func NewCancelTransactionInteractor(transactionRepository repositories.TransactionRepository) *CancelTransactionInteractor

NewCancelTransactionInteractor creates a new CancelTransactionInteractor

func (*CancelTransactionInteractor) Execute

func (c *CancelTransactionInteractor) Execute(ctx context.Context) error

Execute will cancel all odd transactions and update the balance

type SourceTypeInteractor

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

func NewSourceTypeInteractor

func NewSourceTypeInteractor(Repository repositories.SourceTypeRepository) *SourceTypeInteractor

func (*SourceTypeInteractor) ExistsByName

func (s *SourceTypeInteractor) ExistsByName(ctx context.Context, name string) (bool, error)

type TransactionInteractor

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

func NewTransactionInteractor

func NewTransactionInteractor(transactionRepository repositories.TransactionRepository, userRepository repositories.UserRepository, sourceType repositories.SourceTypeRepository) *TransactionInteractor

func (*TransactionInteractor) ProcessTransaction

func (i *TransactionInteractor) ProcessTransaction(userID string, sourceType string, dto *dtos.TransactionDTO) (*repositories.TransactionRow, error)

type UserInteractor

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

func NewUserInteractor

func NewUserInteractor(Repository repositories.UserRepository) *UserInteractor

func (*UserInteractor) ExistsByID

func (u *UserInteractor) ExistsByID(ctx context.Context, id string) (bool, error)

func (*UserInteractor) GetBalance

func (u *UserInteractor) GetBalance(ctx context.Context, id string) (float64, error)