internal

Jul 7, 2020

Changes in this version

+ func TestDir(t *testing.T) string

Jan 15, 2020

Changes in this version

+ var ErrDifferentCurrencies = errors.New("different currencies")

+ var ErrMissingRequiredJson = errors.New("missing required JSON field(s)")

+ func AddOriginatorRoutes(logger log.Logger, r *mux.Router, accountsClient AccountsClient, ...)

+ func AddPingRoute(logger log.Logger, r *mux.Router)

+ func AddReceiverRoutes(logger log.Logger, r *mux.Router, customersClient customers.Client, ...)

+ func EncryptStoredAccountNumbers(logger log.Logger, repo *SQLDepositoryRepo, keeper *secrets.StringKeeper) error

+ func GetDepositoryID(r *http.Request) id.Depository

+ func NewAttemper(logger log.Logger, db *sql.DB, maxAttempts int) attempter

+ func Read(r io.Reader) io.Reader

+ func ReadMergedFilename(repo *SQLDepositoryRepo, amount *Amount, id id.Depository) (string, error)

+ func TLSHttpClient(path string) (*http.Client, error)

+ func Wrap(logger log.Logger, w http.ResponseWriter, r *http.Request) http.ResponseWriter

+ type AccountType string

+ const Checking

+ const Savings

+ func (t *AccountType) UnmarshalJSON(b []byte) error

+ func (t AccountType) Validate() error

+ type AccountsClient interface

+ Ping func() error

+ PostTransaction func(requestID string, userID id.User, lines []transactionLine) (*accounts.Transaction, error)

+ ReverseTransaction func(requestID string, userID id.User, transactionID string) error

+ SearchAccounts func(requestID string, userID id.User, dep *Depository) (*accounts.Account, error)

+ func CreateAccountsClient(logger log.Logger, endpoint string, httpClient *http.Client) AccountsClient

+ type Amount struct

+ func NewAmount(symbol string, number string) (*Amount, error)

+ func NewAmountFromInt(symbol string, number int) (*Amount, error)

+ func (a *Amount) FromString(str string) error

+ func (a *Amount) Int() int

+ func (a *Amount) String() string

+ func (a *Amount) UnmarshalJSON(b []byte) error

+ func (a *Amount) Validate() error

+ func (a Amount) Equal(other Amount) bool

+ func (a Amount) MarshalJSON() ([]byte, error)

+ func (a Amount) Plus(other Amount) (Amount, error)

+ type CCDDetail struct

+ PaymentInformation string

+ type Depository struct

+ BankName string

+ Created base.Time

+ EncryptedAccountNumber string

+ Holder string

+ HolderType HolderType

+ ID id.Depository

+ Metadata string

+ ReturnCodes []*ach.ReturnCode

+ RoutingNumber string

+ Status DepositoryStatus

+ Type AccountType

+ Updated base.Time

+ func (d *Depository) DecryptAccountNumber() (string, error)

+ func (d *Depository) ReplaceAccountNumber(num string) error

+ func (d *Depository) UserID() string

+ func (d Depository) MarshalJSON() ([]byte, error)

+ type DepositoryRepository interface

+ GetDepository func(id id.Depository) (*Depository, error)

+ GetMicroDepositCursor func(batchSize int) *MicroDepositCursor

+ GetMicroDeposits func(id id.Depository) ([]*MicroDeposit, error)

+ GetUserDepositories func(userID id.User) ([]*Depository, error)

+ GetUserDepository func(id id.Depository, userID id.User) (*Depository, error)

+ InitiateMicroDeposits func(id id.Depository, userID id.User, microDeposit []*MicroDeposit) error

+ LookupDepositoryFromReturn func(routingNumber string, accountNumber string) (*Depository, error)

+ LookupMicroDepositFromReturn func(id id.Depository, amount *Amount) (*MicroDeposit, error)

+ SetReturnCode func(id id.Depository, amount Amount, returnCode string) error

+ UpdateDepositoryStatus func(id id.Depository, status DepositoryStatus) error

+ UpsertUserDepository func(userID id.User, dep *Depository) error

+ type DepositoryRouter struct

+ func NewDepositoryRouter(logger log.Logger, odfiAccount *ODFIAccount, accountsClient AccountsClient, ...) *DepositoryRouter

+ func (r *DepositoryRouter) RegisterRoutes(router *mux.Router)

+ type DepositoryStatus string

+ const DepositoryRejected

+ const DepositoryUnverified

+ const DepositoryVerified

+ func (ds *DepositoryStatus) UnmarshalJSON(b []byte) error

+ type GroupableTransfer struct

+ Destination string

+ func (t GroupableTransfer) UserID() string

+ type HolderType string

+ const Business

+ const Individual

+ func (t *HolderType) UnmarshalJSON(b []byte) error

+ type IATDetail struct

+ ForeignCorrespondentBankBranchCountryCode string

+ ForeignCorrespondentBankIDNumber string

+ ForeignCorrespondentBankIDNumberQualifier string

+ ForeignCorrespondentBankName string

+ ODFIBranchCurrencyCode string

+ ODFIIDNumberQualifier string

+ ODFIIdentification string

+ ODFIName string

+ OriginatorAddress string

+ OriginatorCity string

+ OriginatorCountryCode string

+ OriginatorName string

+ OriginatorPostalCode string

+ OriginatorState string

+ RDFIBranchCurrencyCode string

+ RDFIIDNumberQualifier string

+ RDFIIdentification string

+ RDFIName string

+ ReceiverAddress string

+ ReceiverCity string

+ ReceiverCountryCode string

+ ReceiverName string

+ ReceiverPostalCode string

+ ReceiverState string

+ type MicroDeposit struct

+ Amount Amount

+ FileID string

+ TransactionID string

+ func (m MicroDeposit) MarshalJSON() ([]byte, error)

+ type MicroDepositCursor struct

+ BatchSize int

+ DepRepo *SQLDepositoryRepo

+ func (cur *MicroDepositCursor) Next() ([]UploadableMicroDeposit, error)

+ type MockDepositoryRepository struct

+ Cur *MicroDepositCursor

+ DepID string

+ Depositories []*Depository

+ Err error

+ MicroDeposits []*MicroDeposit

+ ReturnCode string

+ Status DepositoryStatus

+ func (r *MockDepositoryRepository) GetDepository(id id.Depository) (*Depository, error)

+ func (r *MockDepositoryRepository) GetMicroDepositCursor(batchSize int) *MicroDepositCursor

+ func (r *MockDepositoryRepository) GetMicroDeposits(id id.Depository) ([]*MicroDeposit, error)

+ func (r *MockDepositoryRepository) GetUserDepositories(userID id.User) ([]*Depository, error)

+ func (r *MockDepositoryRepository) GetUserDepository(id id.Depository, userID id.User) (*Depository, error)

+ func (r *MockDepositoryRepository) InitiateMicroDeposits(id id.Depository, userID id.User, microDeposit []*MicroDeposit) error

+ func (r *MockDepositoryRepository) LookupDepositoryFromReturn(routingNumber string, accountNumber string) (*Depository, error)

+ func (r *MockDepositoryRepository) LookupMicroDepositFromReturn(id id.Depository, amount *Amount) (*MicroDeposit, error)

+ func (r *MockDepositoryRepository) SetReturnCode(id id.Depository, amount Amount, returnCode string) error

+ func (r *MockDepositoryRepository) UpdateDepositoryStatus(id id.Depository, status DepositoryStatus) error

+ func (r *MockDepositoryRepository) UpsertUserDepository(userID id.User, dep *Depository) error

+ type MockTransferRepository struct

+ Cur *TransferCursor

+ Err error

+ FileID string

+ ReturnCode string

+ Status TransferStatus

+ Xfer *Transfer

+ func (r *MockTransferRepository) GetFileIDForTransfer(id TransferID, userID id.User) (string, error)

+ func (r *MockTransferRepository) GetTransferCursor(batchSize int, depRepo DepositoryRepository) *TransferCursor

+ func (r *MockTransferRepository) LookupTransferFromReturn(sec string, amount *Amount, traceNumber string, effectiveEntryDate time.Time) (*Transfer, error)

+ func (r *MockTransferRepository) MarkTransferAsMerged(id TransferID, filename string, traceNumber string) error

+ func (r *MockTransferRepository) SetReturnCode(id TransferID, returnCode string) error

+ func (r *MockTransferRepository) UpdateTransferStatus(id TransferID, status TransferStatus) error

+ type ODFIAccount struct

+ func NewODFIAccount(accountsClient AccountsClient, accountNumber string, routingNumber string, ...) *ODFIAccount

+ type Originator struct

+ Address *kyc.Address

+ BirthDate time.Time

+ Created base.Time

+ CustomerID string

+ DefaultDepository id.Depository

+ ID OriginatorID

+ Identification string

+ Metadata string

+ Updated base.Time

+ type OriginatorID string

+ type Receiver struct

+ Address *kyc.Address

+ BirthDate time.Time

+ Created base.Time

+ CustomerID string

+ DefaultDepository id.Depository

+ Email string

+ ID ReceiverID

+ Metadata string

+ Status ReceiverStatus

+ Updated base.Time

+ type ReceiverID string

+ type ReceiverStatus string

+ const ReceiverDeactivated

+ const ReceiverSuspended

+ const ReceiverUnverified

+ const ReceiverVerified

+ func (cs *ReceiverStatus) UnmarshalJSON(b []byte) error

+ type Refresher interface

+ Close func()

+ Start func(interval time.Duration) error

+ func NewRefresher(cfg *config.Config, client customers.Client, db *sql.DB) Refresher

+ type SQLDepositoryRepo struct

+ func NewDepositoryRepo(logger log.Logger, db *sql.DB, keeper *secrets.StringKeeper) *SQLDepositoryRepo

+ func (r *SQLDepositoryRepo) Close() error

+ func (r *SQLDepositoryRepo) GetDepository(depID id.Depository) (*Depository, error)

+ func (r *SQLDepositoryRepo) GetMicroDepositCursor(batchSize int) *MicroDepositCursor

+ func (r *SQLDepositoryRepo) GetMicroDeposits(id id.Depository) ([]*MicroDeposit, error)

+ func (r *SQLDepositoryRepo) GetUserDepositories(userID id.User) ([]*Depository, error)

+ func (r *SQLDepositoryRepo) GetUserDepository(id id.Depository, userID id.User) (*Depository, error)

+ func (r *SQLDepositoryRepo) InitiateMicroDeposits(id id.Depository, userID id.User, microDeposits []*MicroDeposit) error

+ func (r *SQLDepositoryRepo) LookupDepositoryFromReturn(routingNumber string, accountNumber string) (*Depository, error)

+ func (r *SQLDepositoryRepo) LookupMicroDepositFromReturn(id id.Depository, amount *Amount) (*MicroDeposit, error)

+ func (r *SQLDepositoryRepo) MarkMicroDepositAsMerged(filename string, mc UploadableMicroDeposit) error

+ func (r *SQLDepositoryRepo) SetReturnCode(id id.Depository, amount Amount, returnCode string) error

+ func (r *SQLDepositoryRepo) UpdateDepositoryStatus(id id.Depository, status DepositoryStatus) error

+ func (r *SQLDepositoryRepo) UpsertUserDepository(userID id.User, dep *Depository) error

+ type SQLOriginatorRepo struct

+ func NewOriginatorRepo(logger log.Logger, db *sql.DB) *SQLOriginatorRepo

+ func (r *SQLOriginatorRepo) Close() error

+ type SQLReceiverRepo struct

+ func NewReceiverRepo(logger log.Logger, db *sql.DB) *SQLReceiverRepo

+ func (r *SQLReceiverRepo) Close() error

+ type SQLTransferRepo struct

+ func NewTransferRepo(logger log.Logger, db *sql.DB) *SQLTransferRepo

+ func (r *SQLTransferRepo) Close() error

+ func (r *SQLTransferRepo) GetFileIDForTransfer(id TransferID, userID id.User) (string, error)

+ func (r *SQLTransferRepo) GetTransferCursor(batchSize int, depRepo DepositoryRepository) *TransferCursor

+ func (r *SQLTransferRepo) LookupTransferFromReturn(sec string, amount *Amount, traceNumber string, effectiveEntryDate time.Time) (*Transfer, error)

+ func (r *SQLTransferRepo) MarkTransferAsMerged(id TransferID, filename string, traceNumber string) error

+ func (r *SQLTransferRepo) SetReturnCode(id TransferID, returnCode string) error

+ func (r *SQLTransferRepo) UpdateTransferStatus(id TransferID, status TransferStatus) error

+ type TELDetail struct

+ PaymentType TELPaymentType

+ PhoneNumber string

+ type TELPaymentType string

+ const TELReoccurring

+ const TELSingle

+ func (t *TELPaymentType) UnmarshalJSON(b []byte) error

+ type Transfer struct

+ Amount Amount

+ CCDDetail *CCDDetail

+ Created base.Time

+ Description string

+ IATDetail *IATDetail

+ ID TransferID

+ Originator OriginatorID

+ OriginatorDepository id.Depository

+ Receiver ReceiverID

+ ReceiverDepository id.Depository

+ ReturnCode *ach.ReturnCode

+ SameDay bool

+ StandardEntryClassCode string

+ Status TransferStatus

+ TELDetail *TELDetail

+ TransactionID string

+ Type TransferType

+ UserID string

+ WEBDetail *WEBDetail

+ type TransferCursor struct

+ BatchSize int

+ DepRepo DepositoryRepository

+ TransferRepo *SQLTransferRepo

+ func (cur *TransferCursor) Next() ([]*GroupableTransfer, error)

+ type TransferID string

+ func (id TransferID) Equal(s string) bool

+ type TransferRepository interface

+ GetFileIDForTransfer func(id TransferID, userID id.User) (string, error)

+ GetTransferCursor func(batchSize int, depRepo DepositoryRepository) *TransferCursor

+ LookupTransferFromReturn func(sec string, amount *Amount, traceNumber string, effectiveEntryDate time.Time) (*Transfer, error)

+ MarkTransferAsMerged func(id TransferID, filename string, traceNumber string) error

+ SetReturnCode func(id TransferID, returnCode string) error

+ UpdateTransferStatus func(id TransferID, status TransferStatus) error

+ type TransferRouter struct

+ func NewTransferRouter(logger log.Logger, depositoryRepo DepositoryRepository, ...) *TransferRouter

+ func (c *TransferRouter) RegisterRoutes(router *mux.Router)

+ type TransferStatus string

+ const TransferCanceled

+ const TransferFailed

+ const TransferPending

+ const TransferProcessed

+ const TransferReclaimed

+ func (ts *TransferStatus) UnmarshalJSON(b []byte) error

+ func (ts TransferStatus) Equal(other TransferStatus) bool

+ type TransferType string

+ const PullTransfer

+ const PushTransfer

+ func (tt *TransferType) UnmarshalJSON(b []byte) error

+ type UploadableMicroDeposit struct

+ Amount *Amount

+ CreatedAt time.Time

+ DepositoryID string

+ FileID string

+ UserID string

+ type WEBDetail struct

+ PaymentInformation string

+ PaymentType WEBPaymentType

+ type WEBPaymentType string

+ const WEBReoccurring

+ const WEBSingle

+ func (t *WEBPaymentType) UnmarshalJSON(b []byte) error