libstripe

package
v0.0.0-...-122f59b Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MetadataKeyAppID          = "app_id"
	MetadataKeyPlanName       = "plan_name"
	MetadataKeyPriceType      = "price_type"
	MetadataKeyUsageType      = "usage_type"
	MetadatakeySMSRegion      = "sms_region"
	MetadatakeyWhatsappRegion = "whatsapp_region"
	MetadataKeyFreeQuantity   = "free_quantity"
)
View Source 
const RedisCacheKeySubscriptionPlans = "cache:portal:subscription-plans"

Variables

View Source 
var DependencySet = wire.NewSet(
	NewLogger,
	NewClientAPI,
	NewStripeCache,
	wire.Struct(new(Service), "*"),
	wire.Bind(new(Cache), new(*StripeCache)),
)
View Source 
var ErrAppAlreadySubscribed = errors.New("app already subscribed")
View Source 
var ErrCustomerAlreadySubscribed = errors.New("custom already subscribed")
View Source 
var ErrNoInvoice = errors.New("subscription has no invoice")
View Source 
var ErrNoPaymentIntent = errors.New("invoice has no payment intent")
View Source 
var ErrNoSubscription = errors.New("customer has no subscription")
View Source 
var ErrUnknownEvent = errors.New("unknown stripe event")

Functions

func NewClientAPI 

func NewClientAPI(stripeConfig *portalconfig.StripeConfig, logger Logger) *client.API

func NewPriceFromProductOfProductList 

func NewPriceFromProductOfProductList(stripeProduct *stripe.Product) (price *model.Price, err error)

func NewPriceFromProductOfSubscription 

func NewPriceFromProductOfSubscription(stripeProduct *stripe.Product, stripePrice *stripe.Price) (price *model.Price, err error)

Types

type Cache 

type Cache interface {
	Get(context.Context, redisutil.SimpleCmdable, redisutil.Item) ([]byte, error)
}

type CheckoutSession 

type CheckoutSession struct {
	StripeCheckoutSessionID string
	StripeCustomerID        *string
	AppID                   string
	URL                     string
	ExpiresAt               int64
	Status                  stripe.CheckoutSessionStatus
}

func NewCheckoutSession 

func NewCheckoutSession(checkoutSession *stripe.CheckoutSession) *CheckoutSession

func (*CheckoutSession) IsCompleted 

func (cs *CheckoutSession) IsCompleted() bool

type CheckoutSessionCompletedEvent 

type CheckoutSessionCompletedEvent struct {
	AppID                   string
	PlanName                string
	StripeCustomerID        string
	StripeCheckoutSessionID string
}

func (*CheckoutSessionCompletedEvent) EventType 

func (e *CheckoutSessionCompletedEvent) EventType() EventType

type CustomerSubscriptionCreatedEvent 

type CustomerSubscriptionCreatedEvent struct {
	*CustomerSubscriptionEvent
}

func (*CustomerSubscriptionCreatedEvent) EventType 

func (e *CustomerSubscriptionCreatedEvent) EventType() EventType

type CustomerSubscriptionDeletedEvent 

type CustomerSubscriptionDeletedEvent struct {
	*CustomerSubscriptionEvent
}

func (*CustomerSubscriptionDeletedEvent) EventType 

func (e *CustomerSubscriptionDeletedEvent) EventType() EventType

type CustomerSubscriptionEvent 

type CustomerSubscriptionEvent struct {
	StripeSubscriptionID     string
	StripeCustomerID         string
	AppID                    string
	PlanName                 string
	StripeSubscriptionStatus stripe.SubscriptionStatus
}

func (*CustomerSubscriptionEvent) IsSubscriptionActive 

func (e *CustomerSubscriptionEvent) IsSubscriptionActive() bool

func (*CustomerSubscriptionEvent) IsSubscriptionCanceled 

func (e *CustomerSubscriptionEvent) IsSubscriptionCanceled() bool

func (*CustomerSubscriptionEvent) IsSubscriptionIncompleteExpired 

func (e *CustomerSubscriptionEvent) IsSubscriptionIncompleteExpired() bool

type CustomerSubscriptionUpdatedEvent 

type CustomerSubscriptionUpdatedEvent struct {
	*CustomerSubscriptionEvent
}

func (*CustomerSubscriptionUpdatedEvent) EventType 

func (e *CustomerSubscriptionUpdatedEvent) EventType() EventType

type EndpointsProvider 

type EndpointsProvider interface {
	BillingEndpointURL(relayGlobalAppID string) *url.URL
	BillingRedirectEndpointURL(relayGlobalAppID string) *url.URL
}

type Event 

type Event interface {
	EventType() EventType
}

type EventType 

type EventType string
const (
	EventTypeCheckoutSessionCompleted    EventType = "checkout.session.completed"
	EventTypeCustomerSubscriptionCreated EventType = "customer.subscription.created"
	EventTypeCustomerSubscriptionUpdated EventType = "customer.subscription.updated"
	EventTypeCustomerSubscriptionDeleted EventType = "customer.subscription.deleted"
)

type Logger 

type Logger struct{ *log.Logger }

func NewLogger 

func NewLogger(lf *log.Factory) Logger

type PlanService 

type PlanService interface {
	ListPlans() ([]*model.Plan, error)
}

type Service 

type Service struct {
	ClientAPI         *client.API
	Logger            Logger
	Context           context.Context
	Plans             PlanService
	GlobalRedisHandle *globalredis.Handle
	Cache             Cache
	Clock             clock.Clock
	StripeConfig      *portalconfig.StripeConfig
	Endpoints         EndpointsProvider
}

func (*Service) CancelSubscriptionImmediately 

func (s *Service) CancelSubscriptionImmediately(subscriptionID string) error

CancelSubscriptionImmediately removes the subscription immediately It should be used only for failed subscriptions To cancel normal subscription, SetSubscriptionCancelAtPeriodEnd should be used

func (*Service) ConstructEvent 

func (s *Service) ConstructEvent(r *http.Request) (Event, error)

func (*Service) CreateCheckoutSession 

func (s *Service) CreateCheckoutSession(appID string, customerEmail string, subscriptionPlan *model.SubscriptionPlan) (*CheckoutSession, error)

func (*Service) CreateSubscriptionIfNotExists 

func (s *Service) CreateSubscriptionIfNotExists(checkoutSessionID string, subscriptionPlans []*model.SubscriptionPlan) error

func (*Service) FetchCheckoutSession 

func (s *Service) FetchCheckoutSession(checkoutSessionID string) (*CheckoutSession, error)

func (*Service) FetchSubscriptionPlans 

func (s *Service) FetchSubscriptionPlans() (subscriptionPlans []*model.SubscriptionPlan, err error)

func (*Service) GenerateCustomerPortalSession 

func (s *Service) GenerateCustomerPortalSession(appID string, customerID string) (*stripe.BillingPortalSession, error)

func (*Service) GetLastPaymentError 

func (s *Service) GetLastPaymentError(stripeCustomerID string) (*stripe.Error, error)

func (*Service) GetSubscription 

func (s *Service) GetSubscription(stripeCustomerID string) (*stripe.Subscription, error)

func (*Service) GetSubscriptionPlan 

func (s *Service) GetSubscriptionPlan(planName string) (*model.SubscriptionPlan, error)

func (*Service) PreviewUpdateSubscription 

func (s *Service) PreviewUpdateSubscription(stripeSubscriptionID string, subscriptionPlan *model.SubscriptionPlan) (preview *model.SubscriptionUpdatePreview, err error)

func (*Service) SetSubscriptionCancelAtPeriodEnd 

func (s *Service) SetSubscriptionCancelAtPeriodEnd(stripeSubscriptionID string, cancelAtPeriodEnd bool) (*time.Time, error)

func (*Service) UpdateSubscription 

func (s *Service) UpdateSubscription(stripeSubscriptionID string, subscriptionPlan *model.SubscriptionPlan) (err error)

type StripeCache 

type StripeCache struct {
	*redisutil.Cache
}

func NewStripeCache 

func NewStripeCache() *StripeCache

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.