subscription

Documentation

Index

• Constants
• Variables
• type ChangeRequest
• type CreditService
• type CustomerService
• type Filter
• type OrganizationService
• type Phase
• type PlanService
• type ProductService
• type Repository
• type Service
  • func NewService(stripeClient *client.API, config billing.Config, repository Repository, ...) *Service
  • func (s *Service) Cancel(ctx context.Context, id string, immediate bool) (Subscription, error)
  • func (s *Service) CancelUpcomingPhase(ctx context.Context, sub Subscription) error
  • func (s *Service) ChangePlan(ctx context.Context, id string, changeRequest ChangeRequest) (Phase, error)
  • func (s *Service) Close() error
  • func (s *Service) Create(ctx context.Context, sub Subscription) (Subscription, error)
  • func (s *Service) DeleteByCustomer(ctx context.Context, customr customer.Customer) error
  • func (s *Service) GetByID(ctx context.Context, id string) (Subscription, error)
  • func (s *Service) GetByProviderID(ctx context.Context, id string) (Subscription, error)
  • func (s *Service) HasUserSubscribedBefore(ctx context.Context, customerID string, planID string) (bool, error)
  • func (s *Service) Init(ctx context.Context) error
  • func (s *Service) List(ctx context.Context, filter Filter) ([]Subscription, error)
  • func (s *Service) SyncWithProvider(ctx context.Context, customr customer.Customer) error
  • func (s *Service) TriggerSyncByProviderID(ctx context.Context, id string) error
  • func (s *Service) UpdateProductQuantity(ctx context.Context, orgID string, currentPlan plan.Plan, ...) error
• type State
  • func (s State) String() string
• type Subscription
  • func (s Subscription) IsActive() bool

Constants

const (
	SyncDelay = time.Second * 60

	InitiatorIDMetadataKey = "initiated_by"
)

Variables

var (
	ErrNotFound                       = fmt.Errorf("subscription not found")
	ErrInvalidUUID                    = fmt.Errorf("invalid syntax of uuid")
	ErrInvalidID                      = fmt.Errorf("invalid subscription id")
	ErrInvalidDetail                  = fmt.Errorf("invalid subscription detail")
	ErrAlreadyOnSamePlan              = fmt.Errorf("already on the same plan")
	ErrNoPhaseActive                  = fmt.Errorf("no phase active")
	ErrPhaseIsUpdating                = fmt.Errorf("phase is in the middle of a change, please try again later")
	ErrSubscriptionOnProviderNotFound = fmt.Errorf("failed to get subscription from billing provider")
)

Types

type ChangeRequest

type ChangeRequest struct {
	PlanID    string
	Immediate bool

	CancelUpcoming bool
}

type CreditService

type CreditService interface {
	Add(ctx context.Context, cred credit.Credit) error
	GetByID(ctx context.Context, id string) (credit.Transaction, error)
}

type CustomerService

type CustomerService interface {
	GetByID(ctx context.Context, id string) (customer.Customer, error)
	List(ctx context.Context, filter customer.Filter) ([]customer.Customer, error)
}

type Filter

type Filter struct {
	CustomerID string
	ProviderID string
	PlanID     string
	State      string
}

type OrganizationService

type OrganizationService interface {
	MemberCount(ctx context.Context, orgID string) (int64, error)
}

type Phase

type Phase struct {
	EffectiveAt time.Time
	EndsAt      time.Time
	PlanID      string
}

type PlanService

type PlanService interface {
	List(ctx context.Context, filter plan.Filter) ([]plan.Plan, error)
	GetByID(ctx context.Context, id string) (plan.Plan, error)
}

type ProductService

type ProductService interface {
	GetByProviderID(ctx context.Context, id string) (product.Product, error)
}

type Repository

type Repository interface {
	GetByID(ctx context.Context, id string) (Subscription, error)
	Create(ctx context.Context, subs Subscription) (Subscription, error)
	UpdateByID(ctx context.Context, subs Subscription) (Subscription, error)
	List(ctx context.Context, filter Filter) ([]Subscription, error)
	GetByProviderID(ctx context.Context, id string) (Subscription, error)
	Delete(ctx context.Context, id string) error
}

type Service

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

func NewService

func NewService(stripeClient *client.API, config billing.Config, repository Repository,
	customerService CustomerService, planService PlanService,
	orgService OrganizationService, productService ProductService,
	creditService CreditService) *Service

func (*Service) Cancel

func (s *Service) Cancel(ctx context.Context, id string, immediate bool) (Subscription, error)

func (*Service) CancelUpcomingPhase

func (s *Service) CancelUpcomingPhase(ctx context.Context, sub Subscription) error

CancelUpcomingPhase cancels the scheduled phase of the subscription

func (*Service) ChangePlan

func (s *Service) ChangePlan(ctx context.Context, id string, changeRequest ChangeRequest) (Phase, error)

ChangePlan changes the plan of the subscription by creating a subscription schedule it first checks if the schedule is already created, if not it creates a new schedule using the current subscription as the base and the new plan as the target in upcoming phase. Phases can be immediately changed or at the end of the current period.

func (*Service) Close

func (s *Service) Close() error

func (*Service) Create

func (s *Service) Create(ctx context.Context, sub Subscription) (Subscription, error)

func (*Service) DeleteByCustomer

func (s *Service) DeleteByCustomer(ctx context.Context, customr customer.Customer) error

func (*Service) GetByID

func (s *Service) GetByID(ctx context.Context, id string) (Subscription, error)

func (*Service) GetByProviderID

func (s *Service) GetByProviderID(ctx context.Context, id string) (Subscription, error)

func (*Service) HasUserSubscribedBefore

func (s *Service) HasUserSubscribedBefore(ctx context.Context, customerID string, planID string) (bool, error)

func (*Service) Init

func (s *Service) Init(ctx context.Context) error

func (*Service) List

func (s *Service) List(ctx context.Context, filter Filter) ([]Subscription, error)

func (*Service) SyncWithProvider

func (s *Service) SyncWithProvider(ctx context.Context, customr customer.Customer) error

SyncWithProvider syncs the subscription state with the billing provider

func (*Service) TriggerSyncByProviderID

func (s *Service) TriggerSyncByProviderID(ctx context.Context, id string) error

func (*Service) UpdateProductQuantity

func (s *Service) UpdateProductQuantity(ctx context.Context, orgID string, currentPlan plan.Plan,
	stripeSubscription *stripe.Subscription, stripeSchedule *stripe.SubscriptionSchedule) error

UpdateProductQuantity updates the quantity of the product in the subscription Note: check if we need to handle subscription schedule

type State

type State string

const (
	StateActive   State = "active"
	StateTrialing State = "trialing"
	StatePastDue  State = "past_due"
)

func (State) String

func (s State) String() string

type Subscription

type Subscription struct {
	ID         string
	ProviderID string // identifier set by the billing engine provider
	CustomerID string
	PlanID     string

	State string

	Metadata metadata.Metadata

	Phase       Phase
	PlanHistory []Phase

	CreatedAt            time.Time
	UpdatedAt            time.Time
	CanceledAt           time.Time
	DeletedAt            time.Time
	EndedAt              time.Time
	TrialEndsAt          time.Time
	CurrentPeriodStartAt time.Time
	CurrentPeriodEndAt   time.Time
	BillingCycleAnchorAt time.Time
}

func (Subscription) IsActive

func (s Subscription) IsActive() bool