session

type HostsLine struct {
	Hostname string
	IP       string
}

type IPInfoOptions struct {
	Disable    bool     `yaml:"disable,omitempty"`
	MaxmindKey string   `yaml:"maxmind,omitempty"`
	Mark       []string `yaml:"mark,omitempty"`
}

type IPInfoQuery struct {
	IP string `json:"ip"`
}

type IPInfoResult struct {
	IP      string `json:"ip"`
	ASN     uint32 `json:"asn"`
	Desc    string `json:"desc"`
	Country string `json:"country"`
	Flags   uint32 `json:"flags"`
}

type JetManifest struct {
	Streams map[string]JetStreamManifest           `yaml:"streams,omitempty"`
	KV      map[string]jetstream.KeyValueConfig    `yaml:"kv,omitempty"`
	Obj     map[string]jetstream.ObjectStoreConfig `yaml:"obj,omitempty"`
}

type JetStreamManifest struct {
	Stream    jetstream.StreamConfig              `yaml:"stream"`
	Consumers map[string]jetstream.ConsumerConfig `yaml:"consumers"`
}

type KVCompareAndSwap struct {
	Expected json.RawMessage `json:"expected"`
	Desired  json.RawMessage `json:"desired"`
}

type KVCompareAndSwapResult struct {
	OK       bool            `json:"ok"`
	Diff     json.RawMessage `json:"diff"`
	Revision uint64          `json:"revision"`
	Value    json.RawMessage `json:"value"`
}

type KVSetIf struct {
	Revision uint64          `json:"revision"`
	Value    json.RawMessage `json:"value"`
}

type KVState struct {
	Revision uint64          `json:"revision"`
	Value    json.RawMessage `json:"value"`
}

type Lambda struct {
	ID        string      `json:"id"`
	Timestamp time.Time   `json:"timestamp"`
	Code      string      `json:"code"`
	Headers   http.Header `json:"headers"`
	// contains filtered or unexported fields
}

type LambdaID struct {
	MachineID config.MachineID
	UID       snowflake.ID
}

type LockedHandler struct {
	Handler http.Handler
}

type Manifest struct {
	Root         string                              `yaml:"root,omitempty"`          // Root directory
	ServiceRoot  string                              `yaml:"service_root,omitempty"`  // Service root directory
	Services     OrderedMap[string, service.Service] `yaml:"services,omitempty"`      // Services
	Server       map[string]*Server                  `yaml:"server,omitempty"`        // Virtual hosts
	IPInfo       IPInfoOptions                       `yaml:"ipinfo,omitempty"`        // IP information provider
	Env          map[string]string                   `yaml:"env,omitempty"`           // Environment variables
	Runners      map[string]*Runner                  `yaml:"runners,omitempty"`       // Runners
	Jet          JetManifest                         `yaml:"jet,omitempty"`           // JetStream configuration
	Hosts        []HostsLine                         `yaml:"hosts,omitempty"`         // Hostname to IP mapping
	CustomErrors string                              `yaml:"custom_errors,omitempty"` // Path to custom error pages
}

type OrderedMap[K comparable, V any] []lo.Tuple2[K, V]

type PullResult struct {
	From    revision.Reference `json:"from"`    // From reference
	To      revision.Reference `json:"to"`      // To reference
	Changed bool               `json:"changed"` // True if the repository was changed
}

type RepoInfo struct {
	Sys    string             `json:"sys"`    // Repository system
	Ref    revision.Reference `json:"ref"`    // Repository reference
	Remote revision.Reference `json:"remote"` // Remote repository reference
	URL    string             `json:"url"`    // Remote repository URL
}

type Runner struct {
	Route    vhttp.HandleMux   `yaml:"route,omitempty"`     // HTTP route for the task
	Content  string            `yaml:"content,omitempty"`   // Content type for the task
	Method   string            `yaml:"method,omitempty"`    // HTTP method for the task
	Schedule []ScheduledRunner `yaml:"schedule,omitempty"`  // Schedule for the task
	Timeout  util.Duration     `yaml:"timeout,omitempty"`   // Timeout for the task
	NakDelay util.Duration     `yaml:"nak_delay,omitempty"` // Delay before NAKing a message
	Rate     rate.Rate         `yaml:"rate,omitempty"`      // Rate limit for the task
	Serial   bool              `yaml:"serial,omitempty"`    // Process messages serially
	Oneshot  bool              `yaml:"oneshot,omitempty"`   // Terminate after the first message
	NoMeta   bool              `yaml:"no_meta,omitempty"`   // Do not include metadata in the request
	Verbose  bool              `yaml:"verbose,omitempty"`   // Log verbose messages
}

type ScheduledRunner struct {
	Interval util.Duration `yaml:"interval,omitempty"`
	Topic    string        `yaml:"topic,omitempty"`
	Payload  any           `yaml:"payload,omitempty"`
}

type Server struct {
	vhttp.VirtualHostOptions `yaml:",inline"`
	Router                   vhttp.HandleMux `yaml:"router,omitempty"`
}

type ServiceCommandResult struct {
	Count int `json:"count"`
}

type ServiceEntry struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type ServiceHealth struct {
	Status  string `json:"status"`        // Status
	Healthy int    `json:"healthy"`       // Number of healthy instances
	Total   int    `json:"total"`         // Total number of instances
	Err     string `json:"err,omitempty"` // Error message
}

type ServiceInfo struct {
	ServiceMetrics
	ServiceHealth
}

type ServiceInvalidate struct {
	Invalidate bool `json:"invalidate"`
}

type ServiceList struct {
	Services []ServiceEntry `json:"services"`
}

type ServiceMetrics struct {
	ID        snowflake.ID              `json:"id"`
	Type      string                    `json:"type"`
	Server    lb.LoadBalancerMetrics    `json:"server"`
	Processes []service.ProcTreeMetrics `json:"processes"`
}

type ServiceState struct {
	service.Instance

	ID snowflake.ID
	// contains filtered or unexported fields
}

type Session struct {
	ID      snowflake.ID
	Context context.Context
	Cancel  context.CancelFunc
	Server  *vhttp.Server

	Nats     *enats.Gateway
	Peerlist *xpost.Peerlist

	ManifestPath      string // immut
	ServiceMap        concurrent.Map[string, *ServiceState]
	TaskSubscriptions []context.CancelFunc
	util.TimedMutex
	// contains filtered or unexported fields
}

type SessionMetrics struct {
	NumClients int                            `json:"num_clients"`
	Clients    map[string]vhttp.ClientMetrics `json:"sessions"`
}

type SystemMetrics struct {
	MachineID            string             `json:"machine_id"`
	CPU                  cpu.InfoStat       `json:"cpu"`
	Load                 float64            `json:"load"`
	Rx                   float64            `json:"rx"`
	Tx                   float64            `json:"tx"`
	FreeDisk             uint64             `json:"freedisk"`
	FreeMem              uint64             `json:"freemem"`
	TotalDisk            uint64             `json:"totaldisk"`
	TotalMem             uint64             `json:"totalmem"`
	Uptime               uint64             `json:"uptime"` // seconds
	Hostname             string             `json:"hostname"`
	UID                  string             `json:"uid"`
	ProcessCount         uint64             `json:"process_count"`
	OS                   string             `json:"os"`
	KernelVersion        string             `json:"kernel_version"`
	KernelArch           string             `json:"kernel_arch"`
	VirtualizationSystem string             `json:"virtualization_system"`
	VirtualizationRole   string             `json:"virtualization_role"`
	RTT                  map[string]float64 `json:"rtt"`
}

type TypedHandler[T any, U any] struct {
	Callback func(*Session, *http.Request, T) (U, error)
}

type UpdateParams struct {
	Invalidate bool `json:"invalidate"` // True if the session should be invalidated
}