serverapi

type AccountReader interface {
	FindEnabledUserIDs(ctx context.Context, ids []int64) ([]int64, error)
}

type AnyTLSNode struct {
	Port           uint16          `json:"port"`
	SecurityConfig *SecurityConfig `json:"security_config"`
}

type Deps struct {
	TrafficUsage subscription.TrafficUsage
	Redis        *redis.Client
	// Config snapshots the runtime-mutable settings per request.
	Config func() Snapshot
	// Multiplier returns the node traffic multiplier in effect at the given
	// time; nil means no multiplier is configured.
	Multiplier func(at time.Time) float32

	// The ports list only what the node API uses of each dependency, so a
	// fake implements exactly that. Servers reads the server rows,
	// Overrides their configuration overrides and Nodes a server's nodes.
	Servers   ServerReader
	Overrides OverrideReader
	Nodes     NodeLister
	// Caches keeps a server's node-facing responses under its cache
	// generation.
	Caches ServerCache
	// Status records the status reports, Online the online users.
	Status StatusRecorder
	Online OnlineRecorder
	// Subscriptions is the subscription read port (the subscription
	// facade): the subscriptions a server's nodes serve.
	Subscriptions SubscriptionReader
	// Accounts is the identity read port: which subscription owners have
	// an enabled account.
	Accounts AccountReader
}

type Hysteria2Node struct {
	Port           uint16          `json:"port"`
	HopPorts       string          `json:"hop_ports"`
	HopInterval    int             `json:"hop_interval"`
	ObfsPassword   string          `json:"obfs_password"`
	SecurityConfig *SecurityConfig `json:"security_config"`
}

type NodeLister interface {
	ListNodes(ctx context.Context, params *node.FilterNodeParams) ([]*node.Node, error)
}

type OnlineRecorder interface {
	UpdateOnlineUserSubscribe(ctx context.Context, serverId int64, protocol string, subscribe node.OnlineUserSubscribe) error
	UpdateOnlineUserSubscribeGlobal(ctx context.Context, subscribe node.OnlineUserSubscribe) error
}

type OverrideReader interface {
	FindServerConfigOverride(ctx context.Context, serverId int64) (*node.ServerConfigOverride, error)
}

type RequestMeta struct {
	// IfNoneMatch is the ETag of the node's cached copy, if any.
	IfNoneMatch string
}

type ResponseMeta struct {
	Headers map[string]string
}

type SecurityConfig struct {
	SNI                  string `json:"sni"`
	AllowInsecure        *bool  `json:"allow_insecure"`
	Fingerprint          string `json:"fingerprint"`
	RealityServerAddress string `json:"reality_server_addr"`
	RealityServerPort    int    `json:"reality_server_port"`
	RealityPrivateKey    string `json:"reality_private_key"`
	RealityPublicKey     string `json:"reality_public_key"`
	RealityShortId       string `json:"reality_short_id"`
	RealityMldsa65seed   string `json:"reality_mldsa65seed"`
	PaddingScheme        string `json:"padding_scheme"`
}

type ServerCache interface {
	ServerCacheGeneration(ctx context.Context, serverId int64) (int64, error)
	SetServerCache(ctx context.Context, serverId int64, key string, value any, generation int64) error
}

type ServerReader interface {
	FindOneServer(ctx context.Context, id int64) (*node.Server, error)
}

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

type ShadowsocksNode struct {
	Port      uint16 `json:"port"`
	Cipher    string `json:"method"`
	ServerKey string `json:"server_key"`
}

type Snapshot struct {
	Node      config.NodeConfig
	Subscribe config.SubscribeConfig
}

type StatusRecorder interface {
	UpdateStatusCache(ctx context.Context, serverId int64, status *node.Status) error
	UpdateServerProtocolsIfCurrent(ctx context.Context, id int64, current, updated string) (bool, error)
	ClearServerCache(ctx context.Context, serverId int64) error
}

type SubscriptionReader interface {
	ServableSubscriptionsByNodeScope(ctx context.Context, nodeIDs []int64, tags []string) ([]subscription.ServedSubscription, error)
	SubscriptionByID(ctx context.Context, id int64) (*usersub.Subscribe, error)
}

type TransportConfig struct {
	Path                 string `json:"path"`
	Host                 string `json:"host"`
	ServiceName          string `json:"service_name"`
	DisableSNI           bool   `json:"disable_sni"`
	ReduceRtt            bool   `json:"reduce_rtt"`
	UDPRelayMode         string `json:"udp_relay_mode"`
	CongestionController string `json:"congestion_controller"`
}

type TrojanNode struct {
	Port            uint16           `json:"port"`
	Network         string           `json:"transport"`
	TransportConfig *TransportConfig `json:"transport_config"`
	Security        string           `json:"security"`
	SecurityConfig  *SecurityConfig  `json:"security_config"`
}

type TuicNode struct {
	Port           uint16          `json:"port"`
	SecurityConfig *SecurityConfig `json:"security_config"`
}

type VlessNode struct {
	Port            uint16           `json:"port"`
	Flow            string           `json:"flow"`
	Network         string           `json:"transport"`
	TransportConfig *TransportConfig `json:"transport_config"`
	Security        string           `json:"security"`
	SecurityConfig  *SecurityConfig  `json:"security_config"`
}

type VmessNode struct {
	Port            uint16           `json:"port"`
	Network         string           `json:"transport"`
	TransportConfig *TransportConfig `json:"transport_config"`
	Security        string           `json:"security"`
	SecurityConfig  *SecurityConfig  `json:"security_config"`
}