transfers

Documentation

Index

• func CreateTransfer(cfg *config.Config, repo Repository, orgRepo organization.Repository, ...) http.HandlerFunc
• func DeleteUserTransfer(cfg *config.Config, repo Repository, pub pipeline.XferPublisher) http.HandlerFunc
• func GetFundflowDestination(client customers.Client, accountDecryptor accounts.Decryptor, ...) (fundflow.Destination, error)
• func GetFundflowSource(client customers.Client, accountDecryptor accounts.Decryptor, ...) (fundflow.Source, error)
• func GetTransfers(cfg *config.Config, repo Repository) http.HandlerFunc
• func GetUserTransfer(cfg *config.Config, repo Repository) http.HandlerFunc
• func NewRepo(db *sql.DB) *sqlRepo
• func SaveTraceNumbers(repo Repository, xfer *client.Transfer, files []*ach.File) error
• type MockRepository
  • func (r *MockRepository) GetTransfer(id string) (*client.Transfer, error)
  • func (r *MockRepository) LookupTransferFromReturn(amount client.Amount, traceNumber string, effectiveEntryDate time.Time) (*client.Transfer, error)
  • func (r *MockRepository) SaveReturnCode(transferID string, returnCode string) error
  • func (r *MockRepository) UpdateTransferStatus(transferID string, status client.TransferStatus) error
  • func (r *MockRepository) WriteUserTransfer(organization string, transfer *client.Transfer) error
• type Repository
• type Router
  • func NewRouter(cfg *config.Config, repo Repository, orgRepo organization.Repository, ...) *Router
  • func (c *Router) RegisterRoutes(r *mux.Router)

Functions

func CreateTransfer

func CreateTransfer(
	cfg *config.Config,
	repo Repository,
	orgRepo organization.Repository,
	customersClient customers.Client,
	accountDecryptor accounts.Decryptor,
	fundStrategy fundflow.Strategy,
	pub pipeline.XferPublisher,
	limitChecker limiter.Checker,
) http.HandlerFunc

func DeleteUserTransfer

func DeleteUserTransfer(cfg *config.Config, repo Repository, pub pipeline.XferPublisher) http.HandlerFunc

func GetFundflowDestination

func GetFundflowDestination(client customers.Client, accountDecryptor accounts.Decryptor, dst client.Destination, organization string) (fundflow.Destination, error)

func GetFundflowSource

func GetFundflowSource(client customers.Client, accountDecryptor accounts.Decryptor, src client.Source, organization string) (fundflow.Source, error)

func GetTransfers

func GetTransfers(cfg *config.Config, repo Repository) http.HandlerFunc

func GetUserTransfer

func GetUserTransfer(cfg *config.Config, repo Repository) http.HandlerFunc

func NewRepo

func NewRepo(db *sql.DB) *sqlRepo

func SaveTraceNumbers

func SaveTraceNumbers(repo Repository, xfer *client.Transfer, files []*ach.File) error

Types

type MockRepository

type MockRepository struct {
	Transfers []*client.Transfer
	Err       error
}

func (*MockRepository) GetTransfer

func (r *MockRepository) GetTransfer(id string) (*client.Transfer, error)

func (*MockRepository) LookupTransferFromReturn

func (r *MockRepository) LookupTransferFromReturn(amount client.Amount, traceNumber string, effectiveEntryDate time.Time) (*client.Transfer, error)

func (*MockRepository) SaveReturnCode

func (r *MockRepository) SaveReturnCode(transferID string, returnCode string) error

func (*MockRepository) UpdateTransferStatus

func (r *MockRepository) UpdateTransferStatus(transferID string, status client.TransferStatus) error

func (*MockRepository) WriteUserTransfer

func (r *MockRepository) WriteUserTransfer(organization string, transfer *client.Transfer) error

type Repository

type Repository interface {
	GetTransfer(id string) (*client.Transfer, error)
	UpdateTransferStatus(transferID string, status client.TransferStatus) error
	WriteUserTransfer(orgID string, transfer *client.Transfer) error

	SaveReturnCode(transferID string, returnCode string) error

	LookupTransferFromReturn(amount client.Amount, traceNumber string, effectiveEntryDate time.Time) (*client.Transfer, error)
	// contains filtered or unexported methods
}

type Router

type Router struct {
	Logger log.Logger
	Repo   Repository

	Publisher pipeline.XferPublisher

	LimitChecker limiter.Checker

	GetTransfers       http.HandlerFunc
	CreateTransfer     http.HandlerFunc
	GetUserTransfer    http.HandlerFunc
	DeleteUserTransfer http.HandlerFunc
}

func NewRouter

func NewRouter(
	cfg *config.Config,
	repo Repository,
	orgRepo organization.Repository,
	customersClient customers.Client,
	accountDecryptor accounts.Decryptor,
	fundStrategy fundflow.Strategy,
	pub pipeline.XferPublisher,
) *Router

func (*Router) RegisterRoutes

func (c *Router) RegisterRoutes(r *mux.Router)