Documentation ¶
Index ¶
- Constants
- Variables
- type Chore
- type Config
- type ConversionService
- type CreateProjectRecord
- type Customer
- type CustomersDB
- type CustomersPage
- type DB
- type ProjectRecord
- type ProjectRecordsDB
- type ProjectRecordsPage
- type Service
- func (service *Service) Accounts() payments.Accounts
- func (service *Service) ApplyFreeTierCoupons(ctx context.Context) (err error)
- func (service *Service) CreateInvoices(ctx context.Context, period time.Time) (err error)
- func (service *Service) FinalizeInvoices(ctx context.Context) (err error)
- func (service *Service) GetRate(ctx context.Context, curr1, curr2 *currency.Currency) (_ decimal.Decimal, err error)
- func (service *Service) InvoiceApplyProjectRecords(ctx context.Context, period time.Time) (err error)
- func (service *Service) InvoiceApplyTokenBalance(ctx context.Context) (err error)
- func (service *Service) InvoiceItemsFromProjectRecord(projName string, record ProjectRecord) (result []*stripe.InvoiceItemParams)
- func (service *Service) PrepareInvoiceProjectRecords(ctx context.Context, period time.Time) (err error)
- func (service *Service) SetNow(now func() time.Time)
- func (service *Service) UpdateRates(ctx context.Context) (err error)
- type StripeCharges
- type StripeClient
- type StripeCustomerBalanceTransactions
- type StripeCustomers
- type StripeInvoiceItems
- type StripeInvoices
- type StripePaymentMethods
- type StripePromoCodes
- type Transaction
- type TransactionAndUserList
- type TransactionUpdate
- type TransactionsDB
- type TransactionsPage
Constants ¶
const ( // StripeDepositTransactionDescription is the description for Stripe // balance transactions representing STORJ deposits. StripeDepositTransactionDescription = "STORJ deposit" // StripeDepositBonusTransactionDescription is the description for Stripe // balance transactions representing bonuses received for STORJ deposits. StripeDepositBonusTransactionDescription = "STORJ deposit bonus" // StripeMigratedDepositBonusTransactionDescription is the description for // Stripe balance transactions representing bonuses migrated from the // 'credits' table of the satellite DB. StripeMigratedDepositBonusTransactionDescription = "Migrated STORJ deposit bonus" )
Variables ¶
var ErrChore = errs.Class("stripecoinpayments chore")
ErrChore is stripecoinpayments clearing loop chore error class.
var ErrConversion = errs.Class("conversion service")
ErrConversion defines version service error.
var ErrNoCustomer = Error.New("customer doesn't exist")
ErrNoCustomer is error class defining that there is no customer for user.
var ErrProjectRecordExists = Error.New("invoice project record already exists")
ErrProjectRecordExists is error class defining that such project record already exists.
var ErrTransactionConsumed = errs.New("error transaction already consumed")
ErrTransactionConsumed is thrown when trying to consume already consumed transaction.
var ( // Error defines stripecoinpayments service error. Error = errs.Class("stripecoinpayments service") )
Functions ¶
This section is empty.
Types ¶
type Chore ¶ added in v0.25.0
type Chore struct { TransactionCycle *sync2.Cycle AccountBalanceCycle *sync2.Cycle // contains filtered or unexported fields }
Chore runs clearing process of reconciling transactions deposits, customer balance, invoices and usages.
architecture: Chore
func NewChore ¶ added in v0.25.0
func NewChore(log *zap.Logger, service *Service, txInterval, accBalanceInterval time.Duration) *Chore
NewChore creates new clearing loop chore. TODO: uncomment new interval when coupons will be finished.
type Config ¶
type Config struct { StripeSecretKey string `help:"stripe API secret key" default:""` StripePublicKey string `help:"stripe API public key" default:""` StripeFreeTierCouponID string `help:"stripe free tier coupon ID" default:""` CoinpaymentsPublicKey string `help:"coinpayments API public key" default:""` CoinpaymentsPrivateKey string `help:"coinpayments API private key key" default:""` TransactionUpdateInterval time.Duration `help:"amount of time we wait before running next transaction update loop" default:"2m" testDefault:"$TESTINTERVAL"` AccountBalanceUpdateInterval time.Duration `help:"amount of time we wait before running next account balance update loop" default:"2m" testDefault:"$TESTINTERVAL"` ConversionRatesCycleInterval time.Duration `help:"amount of time we wait before running next conversion rates update loop" default:"10m" testDefault:"$TESTINTERVAL"` AutoAdvance bool `help:"toogle autoadvance feature for invoice creation" default:"false"` ListingLimit int `help:"sets the maximum amount of items before we start paging on requests" default:"100" hidden:"true"` }
Config stores needed information for payment service initialization.
type ConversionService ¶ added in v1.34.1
ConversionService updates conversion rates in a loop.
architecture: Service
func NewConversionService ¶ added in v1.34.1
func NewConversionService(log *zap.Logger, service *Service, interval time.Duration) *ConversionService
NewConversionService creates new instance of ConversionService.
func (*ConversionService) Close ¶ added in v1.34.1
func (conversion *ConversionService) Close() (err error)
Close closes underlying cycle.
type CreateProjectRecord ¶ added in v0.25.0
type CreateProjectRecord struct { ProjectID uuid.UUID Storage float64 Egress int64 Segments float64 }
CreateProjectRecord holds info needed for creation new invoice project record.
type CustomersDB ¶
type CustomersDB interface { // Insert inserts a stripe customer into the database. Insert(ctx context.Context, userID uuid.UUID, customerID string) error // GetCustomerID return stripe customers id. GetCustomerID(ctx context.Context, userID uuid.UUID) (string, error) // List returns page with customers ids created before specified date. List(ctx context.Context, offset int64, limit int, before time.Time) (CustomersPage, error) // TODO: get rid of this. Raw() *dbx.DB }
CustomersDB is interface for working with stripe customers table.
architecture: Database
type CustomersPage ¶ added in v0.25.0
CustomersPage holds customers and indicates if there is more data available and provides next offset.
type DB ¶ added in v0.25.0
type DB interface { // Customers is getter for customers db. Customers() CustomersDB // Transactions is getter for transactions db. Transactions() TransactionsDB // ProjectRecords is getter for invoice project records db. ProjectRecords() ProjectRecordsDB }
DB is stripecoinpayments DB interface.
architecture: Database
type ProjectRecord ¶ added in v0.25.0
type ProjectRecord struct { ID uuid.UUID ProjectID uuid.UUID Storage float64 Egress int64 Segments float64 PeriodStart time.Time PeriodEnd time.Time State int }
ProjectRecord holds project usage particular for billing period.
type ProjectRecordsDB ¶ added in v0.25.0
type ProjectRecordsDB interface { // Create creates new invoice project record with credits spendings in the DB. Create(ctx context.Context, records []CreateProjectRecord, start, end time.Time) error // Check checks if invoice project record for specified project and billing period exists. Check(ctx context.Context, projectID uuid.UUID, start, end time.Time) error // Get returns record for specified project and billing period. Get(ctx context.Context, projectID uuid.UUID, start, end time.Time) (*ProjectRecord, error) // Consume consumes invoice project record. Consume(ctx context.Context, id uuid.UUID) error // ListUnapplied returns project records page with unapplied project records. ListUnapplied(ctx context.Context, offset int64, limit int, start, end time.Time) (ProjectRecordsPage, error) }
ProjectRecordsDB is interface for working with invoice project records.
architecture: Database
type ProjectRecordsPage ¶ added in v0.25.0
type ProjectRecordsPage struct { Records []ProjectRecord Next bool NextOffset int64 }
ProjectRecordsPage holds project records and indicates if there is more data available and provides next offset.
type Service ¶
type Service struct { StorageMBMonthPriceCents decimal.Decimal EgressMBPriceCents decimal.Decimal SegmentMonthPriceCents decimal.Decimal // BonusRate amount of percents BonusRate int64 // Coupon Values StripeFreeTierCouponID string // Stripe Extended Features AutoAdvance bool // contains filtered or unexported fields }
Service is an implementation for payment service via Stripe and Coinpayments.
architecture: Service
func NewService ¶
func NewService(log *zap.Logger, stripeClient StripeClient, config Config, db DB, walletsDB storjscan.WalletsDB, billingDB billing.TransactionsDB, projectsDB console.Projects, usageDB accounting.ProjectAccounting, storageTBPrice, egressTBPrice, segmentPrice string, bonusRate int64) (*Service, error)
NewService creates a Service instance.
func (*Service) ApplyFreeTierCoupons ¶ added in v1.37.1
ApplyFreeTierCoupons iterates through all customers in Stripe. For each customer, if that customer does not currently have a Stripe coupon, the free tier Stripe coupon is applied.
func (*Service) CreateInvoices ¶ added in v0.25.0
CreateInvoices lists through all customers and creates invoices.
func (*Service) FinalizeInvoices ¶ added in v1.7.1
FinalizeInvoices sets autoadvance flag on all draft invoices currently available in stripe.
func (*Service) GetRate ¶ added in v0.26.0
func (service *Service) GetRate(ctx context.Context, curr1, curr2 *currency.Currency) (_ decimal.Decimal, err error)
GetRate returns conversion rate for specified currencies.
func (*Service) InvoiceApplyProjectRecords ¶ added in v0.25.0
func (service *Service) InvoiceApplyProjectRecords(ctx context.Context, period time.Time) (err error)
InvoiceApplyProjectRecords iterates through unapplied invoice project records and creates invoice line items for stripe customer.
func (*Service) InvoiceApplyTokenBalance ¶ added in v1.62.1
InvoiceApplyTokenBalance iterates through customer storjscan wallets and creates invoice line items for stripe customer.
func (*Service) InvoiceItemsFromProjectRecord ¶ added in v1.8.1
func (service *Service) InvoiceItemsFromProjectRecord(projName string, record ProjectRecord) (result []*stripe.InvoiceItemParams)
InvoiceItemsFromProjectRecord calculates Stripe invoice item from project record.
func (*Service) PrepareInvoiceProjectRecords ¶ added in v0.25.0
func (service *Service) PrepareInvoiceProjectRecords(ctx context.Context, period time.Time) (err error)
PrepareInvoiceProjectRecords iterates through all projects and creates invoice records if none exist.
type StripeCharges ¶ added in v1.5.2
StripeCharges Stripe Charges interface.
type StripeClient ¶ added in v1.5.2
type StripeClient interface { Customers() StripeCustomers PaymentMethods() StripePaymentMethods Invoices() StripeInvoices InvoiceItems() StripeInvoiceItems CustomerBalanceTransactions() StripeCustomerBalanceTransactions Charges() StripeCharges PromoCodes() StripePromoCodes }
StripeClient Stripe client interface.
func NewStripeClient ¶ added in v1.5.2
func NewStripeClient(log *zap.Logger, config Config) StripeClient
NewStripeClient creates Stripe client from configuration.
func NewStripeMock ¶ added in v1.5.2
func NewStripeMock(id storj.NodeID, customersDB CustomersDB, usersDB console.Users) StripeClient
NewStripeMock creates new Stripe client mock.
A new mock is returned for each unique id. If this method is called multiple times with the same id, it will return the same mock instance for that id.
If called by satellite component, the id param should be the peer.ID(). If called by CLI tool, the id param should be a zero value, i.e. storj.NodeID{}. If called by satellitedb test case, the id param should be a random value, i.e. testrand.NodeID().
type StripeCustomerBalanceTransactions ¶ added in v1.5.2
type StripeCustomerBalanceTransactions interface { New(params *stripe.CustomerBalanceTransactionParams) (*stripe.CustomerBalanceTransaction, error) List(listParams *stripe.CustomerBalanceTransactionListParams) *customerbalancetransaction.Iter }
StripeCustomerBalanceTransactions Stripe CustomerBalanceTransactions interface.
type StripeCustomers ¶ added in v1.5.2
type StripeCustomers interface { New(params *stripe.CustomerParams) (*stripe.Customer, error) Get(id string, params *stripe.CustomerParams) (*stripe.Customer, error) Update(id string, params *stripe.CustomerParams) (*stripe.Customer, error) }
StripeCustomers Stripe Customers interface.
type StripeInvoiceItems ¶ added in v1.5.2
type StripeInvoiceItems interface { New(params *stripe.InvoiceItemParams) (*stripe.InvoiceItem, error) Update(id string, params *stripe.InvoiceItemParams) (*stripe.InvoiceItem, error) List(listParams *stripe.InvoiceItemListParams) *invoiceitem.Iter Del(id string, params *stripe.InvoiceItemParams) (*stripe.InvoiceItem, error) }
StripeInvoiceItems Stripe InvoiceItems interface.
type StripeInvoices ¶ added in v1.5.2
type StripeInvoices interface { New(params *stripe.InvoiceParams) (*stripe.Invoice, error) List(listParams *stripe.InvoiceListParams) *invoice.Iter FinalizeInvoice(id string, params *stripe.InvoiceFinalizeParams) (*stripe.Invoice, error) }
StripeInvoices Stripe Invoices interface.
type StripePaymentMethods ¶ added in v1.5.2
type StripePaymentMethods interface { List(listParams *stripe.PaymentMethodListParams) *paymentmethod.Iter New(params *stripe.PaymentMethodParams) (*stripe.PaymentMethod, error) Attach(id string, params *stripe.PaymentMethodAttachParams) (*stripe.PaymentMethod, error) Detach(id string, params *stripe.PaymentMethodDetachParams) (*stripe.PaymentMethod, error) }
StripePaymentMethods Stripe PaymentMethods interface.
type StripePromoCodes ¶ added in v1.35.2
type StripePromoCodes interface {
List(params *stripe.PromotionCodeListParams) *promotioncode.Iter
}
StripePromoCodes is the Stripe PromoCodes interface.
type Transaction ¶
type Transaction struct { ID coinpayments.TransactionID AccountID uuid.UUID Address string Amount currency.Amount Received currency.Amount Status coinpayments.Status Key string Timeout time.Duration CreatedAt time.Time }
Transaction defines coinpayments transaction info that is stored in the DB.
type TransactionAndUserList ¶ added in v0.31.4
type TransactionAndUserList map[coinpayments.TransactionID]uuid.UUID
TransactionAndUserList is a composite type for storing userID and txID.
func (TransactionAndUserList) IDList ¶ added in v0.31.4
func (idMap TransactionAndUserList) IDList() coinpayments.TransactionIDList
IDList returns transaction id list.
type TransactionUpdate ¶
type TransactionUpdate struct { TransactionID coinpayments.TransactionID Status coinpayments.Status Received currency.Amount }
TransactionUpdate holds transaction update info.
type TransactionsDB ¶
type TransactionsDB interface { // Insert inserts new coinpayments transaction into DB. Insert(ctx context.Context, tx Transaction) (time.Time, error) // Update updates status and received for set of transactions. Update(ctx context.Context, updates []TransactionUpdate, applies coinpayments.TransactionIDList) error // Consume marks transaction as consumed, so it won't participate in apply account balance loop. Consume(ctx context.Context, id coinpayments.TransactionID) error // LockRate locks conversion rate for transaction. LockRate(ctx context.Context, id coinpayments.TransactionID, rate decimal.Decimal) error // GetLockedRate returns locked conversion rate for transaction or error if non exists. GetLockedRate(ctx context.Context, id coinpayments.TransactionID) (decimal.Decimal, error) // ListAccount returns all transaction for specific user. ListAccount(ctx context.Context, userID uuid.UUID) ([]Transaction, error) // ListPending returns TransactionsPage with pending transactions. ListPending(ctx context.Context, offset int64, limit int, before time.Time) (TransactionsPage, error) // ListUnapplied returns TransactionsPage with completed transaction that should be applied to account balance. ListUnapplied(ctx context.Context, offset int64, limit int, before time.Time) (TransactionsPage, error) }
TransactionsDB is an interface which defines functionality of DB which stores coinpayments transactions.
architecture: Database
type TransactionsPage ¶
type TransactionsPage struct { Transactions []Transaction Next bool NextOffset int64 }
TransactionsPage holds set of transaction and indicates if there are more transactions to fetch.
func (*TransactionsPage) CreationTimes ¶ added in v1.8.1
func (page *TransactionsPage) CreationTimes() map[coinpayments.TransactionID]time.Time
CreationTimes returns a map of creation times of page's transactions.
func (*TransactionsPage) IDList ¶
func (page *TransactionsPage) IDList() TransactionAndUserList
IDList returns transaction id list of page's transactions.