plan

package
v1.17.0 Latest Latest
Warning

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

Go to latest
Published: Aug 7, 2026 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Overview

Package plan implements the subscription plan management subdomain of the subscription module: plan and group CRUD, ordering and token resets. Only the module facade may reach it.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchDeleteSubscribeGroupLogic

type BatchDeleteSubscribeGroupLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*BatchDeleteSubscribeGroupLogic) BatchDeleteSubscribeGroup

func (l *BatchDeleteSubscribeGroupLogic) BatchDeleteSubscribeGroup(req *dto.BatchDeleteSubscribeGroupRequest) error

type BatchDeleteSubscribeLogic

type BatchDeleteSubscribeLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*BatchDeleteSubscribeLogic) BatchDeleteSubscribe

func (l *BatchDeleteSubscribeLogic) BatchDeleteSubscribe(req *dto.BatchDeleteSubscribeRequest) error

type CreateSubscribeGroupLogic

type CreateSubscribeGroupLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*CreateSubscribeGroupLogic) CreateSubscribeGroup

func (l *CreateSubscribeGroupLogic) CreateSubscribeGroup(req *dto.CreateSubscribeGroupRequest) error

type CreateSubscribeLogic

type CreateSubscribeLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*CreateSubscribeLogic) CreateSubscribe

func (l *CreateSubscribeLogic) CreateSubscribe(req *dto.CreateSubscribeRequest) error

type DeleteSubscribeGroupLogic

type DeleteSubscribeGroupLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*DeleteSubscribeGroupLogic) DeleteSubscribeGroup

func (l *DeleteSubscribeGroupLogic) DeleteSubscribeGroup(req *dto.DeleteSubscribeGroupRequest) error

type DeleteSubscribeLogic

type DeleteSubscribeLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*DeleteSubscribeLogic) DeleteSubscribe

func (l *DeleteSubscribeLogic) DeleteSubscribe(req *dto.DeleteSubscribeRequest) error

type Deps

type Deps struct {
	Plans    repository.SubscribeRepo
	UserSubs repository.UserSubscriptionRepo
	Store    SubscriptionTransactor
	// NotifyPlanChanged broadcasts a plan update to connected devices.
	NotifyPlanChanged func()
}

type GetSubscribeDetailsLogic

type GetSubscribeDetailsLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*GetSubscribeDetailsLogic) GetSubscribeDetails

func (l *GetSubscribeDetailsLogic) GetSubscribeDetails(req *dto.GetSubscribeDetailsRequest) (resp *dto.Subscribe, err error)

type GetSubscribeGroupListLogic

type GetSubscribeGroupListLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*GetSubscribeGroupListLogic) GetSubscribeGroupList

func (l *GetSubscribeGroupListLogic) GetSubscribeGroupList() (resp *dto.GetSubscribeGroupListResponse, err error)

type GetSubscribeListLogic

type GetSubscribeListLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*GetSubscribeListLogic) GetSubscribeList

func (l *GetSubscribeListLogic) GetSubscribeList(req *dto.GetSubscribeListRequest) (resp *dto.GetSubscribeListResponse, err error)

type ResetAllSubscribeTokenLogic

type ResetAllSubscribeTokenLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*ResetAllSubscribeTokenLogic) ResetAllSubscribeToken

func (l *ResetAllSubscribeTokenLogic) ResetAllSubscribeToken() (resp *dto.ResetAllSubscribeTokenResponse, err error)

type Service

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

func NewService

func NewService(deps Deps) *Service

func (*Service) BatchDeleteSubscribe

func (s *Service) BatchDeleteSubscribe(ctx context.Context, req *dto.BatchDeleteSubscribeRequest) error

func (*Service) BatchDeleteSubscribeGroup

func (s *Service) BatchDeleteSubscribeGroup(ctx context.Context, req *dto.BatchDeleteSubscribeGroupRequest) error

func (*Service) CreateSubscribe

func (s *Service) CreateSubscribe(ctx context.Context, req *dto.CreateSubscribeRequest) error

func (*Service) CreateSubscribeGroup

func (s *Service) CreateSubscribeGroup(ctx context.Context, req *dto.CreateSubscribeGroupRequest) error

func (*Service) DeleteSubscribe

func (s *Service) DeleteSubscribe(ctx context.Context, req *dto.DeleteSubscribeRequest) error

func (*Service) DeleteSubscribeGroup

func (s *Service) DeleteSubscribeGroup(ctx context.Context, req *dto.DeleteSubscribeGroupRequest) error

func (*Service) GetSubscribeDetails

func (s *Service) GetSubscribeDetails(ctx context.Context, req *dto.GetSubscribeDetailsRequest) (*dto.Subscribe, error)

func (*Service) GetSubscribeGroupList

func (s *Service) GetSubscribeGroupList(ctx context.Context) (*dto.GetSubscribeGroupListResponse, error)

func (*Service) GetSubscribeList

func (*Service) ResetAllSubscribeToken

func (s *Service) ResetAllSubscribeToken(ctx context.Context) (*dto.ResetAllSubscribeTokenResponse, error)

func (*Service) SubscribeSort

func (s *Service) SubscribeSort(ctx context.Context, req *dto.SubscribeSortRequest) error

func (*Service) UpdateSubscribe

func (s *Service) UpdateSubscribe(ctx context.Context, req *dto.UpdateSubscribeRequest) error

func (*Service) UpdateSubscribeGroup

func (s *Service) UpdateSubscribeGroup(ctx context.Context, req *dto.UpdateSubscribeGroupRequest) error

type SubscribeSortLogic

type SubscribeSortLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*SubscribeSortLogic) SubscribeSort

func (l *SubscribeSortLogic) SubscribeSort(req *dto.SubscribeSortRequest) error

type SubscriptionTransactor

type SubscriptionTransactor interface {
	InSubscriptionTx(ctx context.Context, fn func(repository.SubscriptionStore) error) error
}

SubscriptionTransactor mirrors the store's subscription-scoped transaction.

type UpdateSubscribeGroupLogic

type UpdateSubscribeGroupLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*UpdateSubscribeGroupLogic) UpdateSubscribeGroup

func (l *UpdateSubscribeGroupLogic) UpdateSubscribeGroup(req *dto.UpdateSubscribeGroupRequest) error

type UpdateSubscribeLogic

type UpdateSubscribeLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

func (*UpdateSubscribeLogic) UpdateSubscribe

func (l *UpdateSubscribeLogic) UpdateSubscribe(req *dto.UpdateSubscribeRequest) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL