checkout

type CouponUserLimiter = couponUserLimiter

type Deps struct {
	Orders    Orders
	Coupons   pricing.CouponFinder
	Payments  gateway.MethodFinder
	Plans     PlanReader
	UserSubs  UserSubscriptionReader
	Wallets   Wallets
	Tx        Transactor
	Inventory Inventory
	Queue     OrderQueue
	// Gateways opens the gateway of an order's payment method; nil selects
	// the production gateways.
	Gateways *gateway.Registry
	// SingleModel forbids holding more than one blocking subscription;
	// read per request because the admin can change it at runtime.
	SingleModel func() bool
	// CurrencyUnit is the site currency; read per request because the admin
	// can change it at runtime.
	CurrencyUnit func() string
}

type Inventory interface {
	Reserve(context.Context, string, int64) error
	Restore(context.Context, string, int64) error
}

type OrderQueue interface {
	EnqueueActivation(ctx context.Context, orderNo string) error
	EnqueueDeferredClose(ctx context.Context, orderNo string) error
}

type Orders interface {
	FindOneByOrderNo(ctx context.Context, orderNo string) (*orderEntity.Order, error)
	MarkOrderPaid(ctx context.Context, orderNo, tradeNo string) (bool, error)
	CountUserCouponUsage(ctx context.Context, userID int64, coupon string) (int64, error)
	IsUserEligibleForNewOrder(ctx context.Context, userID int64) (bool, error)
}

type PlanReader interface {
	FindOne(ctx context.Context, id int64) (*subscribeEntity.Subscribe, error)
}

type PlanTerms struct {
	Plan     *subscribeEntity.Subscribe
	Quantity int64
	Coupon   *coupon.Coupon
	Method   *paymentEntity.Payment
}

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

type Transactor interface {
	InBillingTx(ctx context.Context, fn func(repository.BillingStore) error) error
}

type UserSubscriptionReader interface {
	HasBlockingSubscription(ctx context.Context, userID int64) (bool, error)
	CountQuotaConsumingSubscriptions(ctx context.Context, userID, subscribeID int64) (int64, error)
	FindOneUserSubscribe(ctx context.Context, id int64) (*usersub.SubscribeDetails, error)
	FindOneSubscribe(ctx context.Context, id int64) (*usersub.Subscribe, error)
}

type Wallets interface {
	FindWallet(ctx context.Context, userID int64) (*walletEntity.Wallet, error)
}