server

type MigrationRepo interface {
	HasMigrateServerNode(ctx context.Context) (bool, error)
	MigrateServerNode(ctx context.Context) (uint64, uint64, string, error)
}

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

type Node struct {
	ID           int64
	Name         string
	Tags         []string
	Port         uint16
	Address      string
	ServerID     int64
	Protocol     string
	Enabled      *bool
	NodeType     string
	IsHidden     *bool
	Sort         uint32
	NodeGroupID  int64
	NodeGroupIDs []int64
	CreatedAt    int64
	UpdatedAt    int64
}

type NodeRepo interface {
	CreateNode(ctx context.Context, node *Node) (*Node, error)
	UpdateNode(ctx context.Context, node *Node) (*Node, error)
	DeleteNode(ctx context.Context, id int) error
	FilterNodeList(ctx context.Context, page, size int32, search string, nodeGroupID *int64) (int32, []*Node, error)
	ToggleNodeStatus(ctx context.Context, id int, enable *bool) (*Node, error)
	QueryNodeTags(ctx context.Context) ([]string, error)
	ResetNodeSort(ctx context.Context, sortItems []*SortItem) error
	ClearNodeCache(ctx context.Context, serverIDs []int) error
	GetServerProtocols(ctx context.Context, id int) ([]*server.Protocol, error)
}

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

type Server struct {
	ID             int64
	Name           string
	Country        string
	City           string
	Address        string
	Sort           int
	Protocols      []*server.Protocol
	LastReportedAt int64
	Status         *ServerStatus
	CreatedAt      int64
	UpdatedAt      int64
}

type ServerOnlineIP struct {
	IP       string
	Protocol string
}

type ServerOnlineUser struct {
	IP          []*ServerOnlineIP
	UserID      int64
	Subscribe   string
	SubscribeID int64
	Traffic     int64
	ExpiredAt   int64
}

type ServerRepo interface {
	CreateServer(ctx context.Context, server *Server) (*Server, error)
	UpdateServer(ctx context.Context, server *Server) (*Server, error)
	DeleteServer(ctx context.Context, id int) error
	GetServerByID(ctx context.Context, id int) (*Server, error)
	FilterServerList(ctx context.Context, page, size int32, search string) (int32, []*Server, error)
	GetServerProtocols(ctx context.Context, id int) ([]*server.Protocol, error)
	ResetServerSort(ctx context.Context, sortItems []*SortItem) error
	GetServerStatus(ctx context.Context, serverID int) (*ServerResourceStatus, error)
	GetOnlineUsers(ctx context.Context, serverID int64, protocol string, port uint16) (map[int64][]string, error)
	GetOnlineUsersByServer(ctx context.Context, serverID int64) (map[string]map[int64][]string, error)
	GetUserSubscribeInfo(ctx context.Context, subscribeID int) (*UserSubscribeInfo, error)
}

type ServerResourceStatus struct {
	Cpu  float64
	Mem  float64
	Disk float64
}

type ServerStatus struct {
	Cpu      float64
	Mem      float64
	Disk     float64
	Protocol string
	Online   []*ServerOnlineUser
	Status   string
}

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

type SortItem struct {
	ID   int64
	Sort int
}

type UserSubscribeInfo struct {
	UserID      int64
	SubscribeID int64
	Subscribe   string
	Download    int64
	Upload      int64
	ExpireTime  int64
}