transfers

package
v0.10.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 22, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateTransfer added in v0.9.0

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 added in v0.9.0

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL