subscribe

package

v1.0.7 Latest Latest Go to latest Published: Jun 23, 2026 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/npanel-dev/NPanel-backend

Links

Open Source Insights

Documentation ¶

Index ¶

type SubscribeRepo
type SubscribeUseCase
- func NewSubscribeUseCase(repo SubscribeRepo, logger log.Logger) *SubscribeUseCase

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type SubscribeRepo ¶

type SubscribeRepo interface {
	// Subscribe operations
	CreateSubscribe(ctx context.Context, sub *model.Subscribe) error
	GetSubscribeByID(ctx context.Context, id int) (*ent.ProxySubscribe, error)
	UpdateSubscribe(ctx context.Context, sub *model.Subscribe) error
	DeleteSubscribe(ctx context.Context, id int) error
	GetSubscribeList(ctx context.Context, req *model.SubscribeListParams) ([]*ent.ProxySubscribe, int32, error)
	CheckSubscribeInUse(ctx context.Context, subscribeID int) (bool, error)
	BatchDeleteSubscribe(ctx context.Context, ids []int) error
	GetSubscribeMinSort(ctx context.Context, ids []int) (int64, error)
	BatchUpdateSubscribeSort(ctx context.Context, subscribes []*ent.ProxySubscribe) error

	// Subscribe group operations
	CreateSubscribeGroup(ctx context.Context, group *model.SubscribeGroup) error
	GetSubscribeGroupByID(ctx context.Context, id int) (*ent.ProxySubscribeGroup, error)
	UpdateSubscribeGroup(ctx context.Context, group *model.SubscribeGroup) error
	DeleteSubscribeGroup(ctx context.Context, id int) error
	GetSubscribeGroupList(ctx context.Context) ([]*ent.ProxySubscribeGroup, int32, error)
	BatchDeleteSubscribeGroup(ctx context.Context, ids []int) error

	// User subscription query (for checking if subscribe is in use)
	GetActiveUserSubscriptionCount(ctx context.Context, subscribeID int) (int64, error)
	GetActiveUserSubscriptionCountByIDs(ctx context.Context, subscribeIDs []int64) (map[int64]int64, error)
	ResetAllSubscribeToken(ctx context.Context) error
}

SubscribeRepo subscribe repository interface

type SubscribeUseCase ¶

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

SubscribeUseCase subscribe use case

func NewSubscribeUseCase ¶

func NewSubscribeUseCase(repo SubscribeRepo, logger log.Logger) *SubscribeUseCase

NewSubscribeUseCase create subscribe use case

func (*SubscribeUseCase) BatchDeleteSubscribe ¶

func (uc *SubscribeUseCase) BatchDeleteSubscribe(ctx context.Context, ids []int) error

BatchDeleteSubscribe batch delete subscribes

func (*SubscribeUseCase) BatchDeleteSubscribeGroup ¶

func (uc *SubscribeUseCase) BatchDeleteSubscribeGroup(ctx context.Context, ids []int) error

BatchDeleteSubscribeGroup batch delete subscribe groups

func (*SubscribeUseCase) CreateSubscribe ¶

func (uc *SubscribeUseCase) CreateSubscribe(ctx context.Context, req *v1.CreateSubscribeRequest) error

CreateSubscribe create subscribe

func (*SubscribeUseCase) CreateSubscribeGroup ¶

func (uc *SubscribeUseCase) CreateSubscribeGroup(ctx context.Context, req *v1.CreateSubscribeGroupRequest) error

CreateSubscribeGroup create subscribe group

func (*SubscribeUseCase) DeleteSubscribe ¶

func (uc *SubscribeUseCase) DeleteSubscribe(ctx context.Context, id int) error

DeleteSubscribe delete subscribe

func (*SubscribeUseCase) DeleteSubscribeGroup ¶

func (uc *SubscribeUseCase) DeleteSubscribeGroup(ctx context.Context, id int) error

DeleteSubscribeGroup delete subscribe group

func (*SubscribeUseCase) GetSubscribeDetails ¶

func (uc *SubscribeUseCase) GetSubscribeDetails(ctx context.Context, id int) (*v1.SubscribeInfo, error)

GetSubscribeDetails get subscribe details

func (*SubscribeUseCase) GetSubscribeGroupList ¶

func (uc *SubscribeUseCase) GetSubscribeGroupList(ctx context.Context) (*v1.GetSubscribeGroupListData, error)

GetSubscribeGroupList get subscribe group list

func (*SubscribeUseCase) GetSubscribeList ¶

func (uc *SubscribeUseCase) GetSubscribeList(ctx context.Context, req *v1.GetSubscribeListRequest) (*v1.GetSubscribeListData, error)

GetSubscribeList get subscribe list

func (*SubscribeUseCase) ResetAllSubscribeToken ¶

func (uc *SubscribeUseCase) ResetAllSubscribeToken(ctx context.Context) error

func (*SubscribeUseCase) SubscribeSort ¶

func (uc *SubscribeUseCase) SubscribeSort(ctx context.Context, req *v1.SubscribeSortRequest) error

SubscribeSort subscribe sort

func (*SubscribeUseCase) UpdateSubscribe ¶

func (uc *SubscribeUseCase) UpdateSubscribe(ctx context.Context, req *v1.UpdateSubscribeRequest) error

UpdateSubscribe update subscribe

func (*SubscribeUseCase) UpdateSubscribeGroup ¶

func (uc *SubscribeUseCase) UpdateSubscribeGroup(ctx context.Context, req *v1.UpdateSubscribeGroupRequest) error

UpdateSubscribeGroup update subscribe group

Source Files ¶

View all Source files

subscribe.go

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