controller

package

Go to main page

Versions in this module

v1

v1.3.3

Jun 20, 2025

v1.3.2

Jun 5, 2025

v1.3.1

Jun 4, 2025

v1.3.0

May 21, 2025

v1.2.1

Mar 11, 2025

Changes in this version

type Controller

+ func (c *Controller) AvailableUserList() []string

+ func (c *Controller) GetAllUserList(in *[]int64) error

type Overview

+ MonthLimitedUser int64

v1.2.0

Mar 1, 2025

Changes in this version

type Controller

+ UpdateCounter *atomic.Int64

+ func (c *Controller) RemoveAllLimits() error

type Metadata

+ CommonWarnRate int16

+ func (mn *Metadata) GetWarnRate() int16

type MetadataConf

+ CommonWarnRatio int16

+ Langs []string

type Overview

+ ActiveConfCount int64

+ CUser int64

+ Restricte int64

+ TempLimitedUser int64

+ TotalConfCount int64

+ TotalUpdates int64

+ func (o *Overview) String() string

v1.0.0

Feb 9, 2025

Changes in this version

+ type Allconfigs []*db.Config

+ func (a Allconfigs) Appendconf(conf *sbox.Userconfig, userid int64)

+ func (a Allconfigs) RemoveAll()

+ type BroadcastSig string

+ type Controller struct

+ Lockval *atomic.Int32

+ Metaconfig *MetadataConf

+ Overview *Overview

+ Usermgrsession *sync.Map

+ func New(ctx context.Context, db *db.Database, logger *zap.Logger, ...) (*Controller, error)

+ func (c *Controller) AddEvent(userId int64, name string) error

+ func (c *Controller) AddResetUserSbox(conf *sbox.Userconfig) (sbox.Sboxstatus, error)

+ func (c *Controller) Addsession(closefunc ForceCloser, UserId int64)

+ func (c *Controller) AdduserSbox(conf *sbox.Userconfig) (sbox.Sboxstatus, error)

+ func (c *Controller) CancleUpdateContexs()

+ func (c *Controller) CheckLock() bool

+ func (c *Controller) Checksession(UserId int64) (any, bool)

+ func (c *Controller) ClaimReferVerified(owenerid int64) (int, error)

+ func (c *Controller) Close() error

+ func (c *Controller) CreateRefrral(owenerid, userid int64) (*db.Reffral, error)

+ func (c *Controller) CreateSboxConf(userId int64, name string) (db.SboxConfigs, error)

+ func (c *Controller) DecCriticalOp()

+ func (c *Controller) DeleteConf(confId int64) error

+ func (c *Controller) DirectMg(text string, UserId int64, ChatID int64) error

+ func (c *Controller) GetBaseContext() context.Context

+ func (c *Controller) GetHelepCmdInfo() bottype.HelpCommandInfo

+ func (c *Controller) GetLastRefreshtime() time.Time

+ func (c *Controller) GetSboxConfig(userID int64) ([]db.SboxConfigs, error)

+ func (c *Controller) GetSpecificConf(userId int64, name string) (db.SboxConfigs, error)

+ func (c *Controller) GetUnVerifiedUserList(in *[]int64) error

+ func (c *Controller) GetUser(user *tgbotapi.User) (*bottype.User, bool, error)

+ func (c *Controller) GetUserById(userId int64) (*db.User, error)

+ func (c *Controller) GetUserByUserName(userName string) (*db.User, error)

+ func (c *Controller) GetUserConfigs(userID int64) ([]db.Config, error)

+ func (c *Controller) GetUserList(in *[]int64) error

+ func (c *Controller) GetVerifiedUserList(in *[]int64) error

+ func (c *Controller) Getadminchat() (map[int64]string, error)

+ func (c *Controller) Getmgque() chan any

+ func (c *Controller) GetstatusUserSbox(conf *sbox.Userconfig) (sbox.Sboxstatus, error)

+ func (c *Controller) Gift(upx *update.Updatectx, to any, quota C.Bwidth) (*db.User, error)

+ func (c *Controller) IncCriticalOp()

+ func (c *Controller) IncreaseUserCount(count int)

+ func (c *Controller) Init() error

+ func (c *Controller) LoadEvents(userID int64) (map[string]db.Event, error)

+ func (c *Controller) Newuser(user *tgbotapi.User, chat *tgbotapi.Chat) (*bottype.User, error)

+ func (c *Controller) RecalculateConfigquotas(user *db.User) error

+ func (c *Controller) ReffralCount(owenerid int64) (int64, int64, error)

+ func (c *Controller) RefreshUrlTest()

+ func (c *Controller) RefreshUser(ctx context.Context, dbuser *db.User) error

+ func (c *Controller) RemoveSesion(UserId int64)

+ func (c *Controller) RemoveUserSbox(conf *sbox.Userconfig) (sbox.Sboxstatus, error)

+ func (c *Controller) SearchUserByUsername(username string) (*db.User, bool, error)

+ func (c *Controller) SendMsgContext(ctx context.Context, msg any) (*tgbotapi.Message, error)

+ func (c *Controller) SetIsbotarted(userID int64, val bool) error

+ func (c *Controller) SetLastRefreshtime()

+ func (c *Controller) UpdatePoint(newpointCount int64, userId int64) error

+ func (c *Controller) UrlTestOut(tag string) (int16, error)

+ func (c *Controller) WaitCriticalop()

+ func (c *Controller) WatchmanLock()

+ func (c *Controller) WatchmanUnlock()

+ func (w *Controller) Addquemg(upxctx context.Context, msg any)

+ type CtrlSession struct

+ func NewctrlSession(ctrl *Controller, upx *update.Updatectx, ForceCloseOldSession bool) (*CtrlSession, error)

+ func (c *CtrlSession) ActivateAll() error

+ func (c *CtrlSession) ActivateConfig(confid int64) (sbox.Sboxstatus, error)

+ func (c *CtrlSession) AddNewConfig(inboundid int16, outboundid int16, Quota C.Bwidth, login int16, name string) (*sbox.Userconfig, error)

+ func (c *CtrlSession) Banuser(chat string)

+ func (c *CtrlSession) ChangeIO(ioboundname string, confid, ioid int64) error

+ func (c *CtrlSession) ChangeInbound(confid, inboundid int64) error

+ func (c *CtrlSession) ChangeLoginLimit(confid int64, newlimit int32) (sbox.Sboxstatus, error)

+ func (c *CtrlSession) ChangeOutbound(confid, inboundid int64) error

+ func (c *CtrlSession) Chatupdate(chat string, val bool)

+ func (c *CtrlSession) Close() error

+ func (c *CtrlSession) ConfigCloseConn(confid int64) error

+ func (c *CtrlSession) CreateUsagehistory(status sbox.Sboxstatus, confid int64) error

+ func (c *CtrlSession) DeactivateAll() error

+ func (c *CtrlSession) DeactivateConfig(configID int64) (sbox.Sboxstatus, error)

+ func (c *CtrlSession) DeleteConfig(configID int64) error

+ func (c *CtrlSession) ForceClose() error

+ func (c *CtrlSession) FullUsageHistory()

+ func (c *CtrlSession) GetConfig(confid int64) (*db.Config, error)

+ func (c *CtrlSession) GetConfigFullUsage(confid int64) (bottype.FullUsage, sbox.Sboxstatus)

+ func (c *CtrlSession) GetFullUsage() bottype.FullUsage

+ func (c *CtrlSession) GetUsage() (C.Bwidth, C.Bwidth)

+ func (c *CtrlSession) GetUser() *db.User

+ func (c *CtrlSession) GetconfigQuota(confid int64) C.Bwidth

+ func (c *CtrlSession) GetconfigUsage(confid int64) (C.Bwidth, C.Bwidth, error)

+ func (c *CtrlSession) GetconfigUsageTotal(confid int64) C.Bwidth

+ func (c *CtrlSession) Getstatus(confid int64) (sbox.Sboxstatus, error)

+ func (c *CtrlSession) LeftQuota() C.Bwidth

+ func (c *CtrlSession) LeftQuotaFromOrigin() C.Bwidth

+ func (c *CtrlSession) LeftUsage() C.Bwidth

+ func (c *CtrlSession) ReActivateConfig(confid int64) (sbox.Sboxstatus, error)

+ func (c *CtrlSession) RemoveRestrict()

+ func (c *CtrlSession) Restrict()

+ func (c *CtrlSession) Save() error

+ func (c *CtrlSession) SaveConfigs() error

+ func (c *CtrlSession) TotalUsage() C.Bwidth

+ type ForceCloser interface

+ ForceClose func() error

+ type ForceResetUsage uint16

+ type Metadata struct

+ BandwidthAvelable C.Bwidth

+ BotName string

+ Botlink string

+ ChannelId int64

+ ChannelName string

+ Channelink string

+ CheckCount *atomic.Int32

+ CommonQuota *atomic.Int64

+ ConfigFolder string

+ Dbusercount *atomic.Int32

+ DefaultDomain string

+ DefaultPubip string

+ GroupID int64

+ GroupLink string

+ GroupName string

+ HelperInfo bottype.HelpCommandInfo

+ Inbounds []sbox.Inboud

+ LoginLimit int32

+ MaxRecurtion int

+ Maxconfigcount int16

+ Outbounds []sbox.Outbound

+ RefreshRate int32

+ ResetCount int32

+ SudoAdmin int64

+ VerifiedUserCount *atomic.Int32

+ func (m *Metadata) ConfFolder() string

+ func (m *Metadata) DefaultInboud() (sbox.Inboud, db.Inbound)

+ func (m *Metadata) Defaultoutboud() (sbox.Outbound, db.Outbound)

+ func (m *Metadata) GetInlinePost() []string

+ func (m *Metadata) GetdbInbound(id int) (db.Inbound, error)

+ func (m *Metadata) GetdbOutbound(id int) (db.Outbound, error)

+ func (m *Metadata) Getinbound(id int) (sbox.Inboud, bool)

+ func (m *Metadata) Getinbounds() []sbox.Inboud

+ func (m *Metadata) Getoutbound(id int) (sbox.Outbound, bool)

+ func (m *Metadata) Getoutbounds() []sbox.Outbound

+ func (m *Metadata) Init(metaconf MetadataConf) error

+ func (m *Metadata) StorePath() string

+ type MetadataConf struct

+ BandwidthAvelable string

+ BotName string

+ Botlink string

+ ChannelID int64

+ ChannelName string

+ Channelink string

+ ConfigFolder string

+ DefaultDomain string

+ DefaultPublicIp string

+ GroupID int64

+ GroupLink string

+ GroupName string

+ HelperInfo bottype.HelpCommandInfo

+ InlinePost []string

+ LoginLimit int16

+ Maxconfigcount int16

+ RefreshRate int32

+ StorePath string

+ SudoAdmin int64

+ WatchMgbuf int

+ type Overview struct

+ AllTime C.Bwidth

+ BandwidthAvailable C.Bwidth

+ CappedUser int64

+ DistributedUser int64

+ Error error

+ LastRefresh time.Time

+ MonthTotal C.Bwidth

+ Mu *sync.RWMutex

+ QuotaForEach C.Bwidth

+ Restricted int64

+ TotalUser int32

+ VerifiedUserCount int64

+ type RefreshSignal uint16

+ type SboxIO struct

+ Inbounds []option.Inbound

+ type UserCount int

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