agent

type AgentDetailResponse struct {
	models.Agent
	Runtime                 *RuntimeInfo                    `json:"runtime"`
	Connection              connectivity.ConnectionSnapshot `json:"connection"`
	RouteTargets            connectivity.RouteTargetsPage   `json:"route_targets"`
	ConfiguredHTTPAddresses string                          `json:"configured_http_addresses,omitempty"`
	EffectiveHTTPAddresses  string                          `json:"effective_http_addresses,omitempty"`
}

type AgentIDQuery struct {
	ID string `form:"id" binding:"required"`
}

type AgentOperationRequest struct {
	ID     string `uri:"id" binding:"required"`
	Action string `uri:"operation" binding:"required"`
	protocol.OperationRequest
}

type AgentOperationResponse struct {
	protocol.OperationAck
}

type AgentPatch struct {
	Name                  *string `json:"name"`
	Status                *int    `json:"status"`
	Tags                  *string `json:"tags"`
	HTTPAddresses         *string `json:"http_addresses"`
	ProxyURL              *string `json:"proxy_url"`
	RelayMode             *string `json:"relay_mode"`
	RelayURI              *string `json:"relay_uri"`
	DirectInboundEnabled  *bool   `json:"direct_inbound_enabled"`
	DirectOutboundEnabled *bool   `json:"direct_outbound_enabled"`
	RelayInboundEnabled   *bool   `json:"relay_inbound_enabled"`
	RelayOutboundEnabled  *bool   `json:"relay_outbound_enabled"`
}

type AgentResponse struct {
	ID                      uint                           `json:"id"`
	AgentID                 string                         `json:"agent_id"`
	Name                    string                         `json:"name"`
	Status                  int                            `json:"status"`
	LastSeen                int64                          `json:"last_seen"`
	CreatedAt               int64                          `json:"created_at"`
	HTTPAddresses           string                         `json:"http_addresses,omitempty"`            // Legacy: effective addresses
	ConfiguredHTTPAddresses string                         `json:"configured_http_addresses,omitempty"` // DB-configured addresses
	EffectiveHTTPAddresses  string                         `json:"effective_http_addresses,omitempty"`  // Merged effective addresses
	Tags                    string                         `json:"tags"`
	ProxyURL                string                         `json:"proxy_url"`
	RelayMode               string                         `json:"relay_mode"`
	DirectInboundEnabled    bool                           `json:"direct_inbound_enabled"`
	DirectOutboundEnabled   bool                           `json:"direct_outbound_enabled"`
	RelayInboundEnabled     bool                           `json:"relay_inbound_enabled"`
	RelayOutboundEnabled    bool                           `json:"relay_outbound_enabled"`
	Connection              connectivity.ConnectionSummary `json:"connection"`
}

type AllInflightResponse struct {
	Requests     []GlobalInflightRow `json:"requests"`
	FailedAgents []FailedAgent       `json:"failed_agents"`
}

type ConnectionDiagnosticsResponse struct {
	SnapshotEpoch string                                `json:"snapshot_epoch"`
	SnapshotSeq   uint64                                `json:"snapshot_seq"`
	ObservedAt    int64                                 `json:"observed_at"`
	Control       ControlDiagnostics                    `json:"control"`
	Relay         RelayDiagnostics                      `json:"relay"`
	Direct        DirectDiagnostics                     `json:"direct"`
	RouteFailures []connectivity.RouteFailureDiagnostic `json:"route_failures"`
}

type ConnectivityProgressRequest struct {
	ID      string `uri:"id" binding:"required"`
	ProbeID string `form:"probe_id"`
}

type ConnectivityRequest struct {
	ID                        string              `uri:"id" binding:"required"`
	Scope                     protocol.ProbeScope `json:"scope"`
	ExpectedEpoch             string              `json:"expected_epoch"`
	ExpectedControlGeneration uint64              `json:"expected_control_generation,omitempty"`
	ExpectedRelayGeneration   uint64              `json:"expected_relay_generation,omitempty"`
}

type ControlDiagnostics struct {
	State             string                     `json:"state"`
	Health            string                     `json:"health"`
	ReasonCodes       []string                   `json:"reason_codes"`
	SessionGeneration uint64                     `json:"session_generation"`
	ConnectedAt       int64                      `json:"connected_at"`
	HeartbeatAt       int64                      `json:"heartbeat_at"`
	RuntimeReportedAt int64                      `json:"runtime_reported_at"`
	LastSeen          int64                      `json:"last_seen"`
	RecentErrors      []connectivity.RecentError `json:"recent_errors"`
}

type CreateRequest struct {
	AgentID               string `json:"agent_id"`
	Secret                string `json:"secret"`
	Name                  string `json:"name" binding:"required"`
	HTTPAddresses         string `json:"http_addresses"`
	Tags                  string `json:"tags"`
	ProxyURL              string `json:"proxy_url"`
	RelayMode             string `json:"relay_mode"`
	RelayURI              string `json:"relay_uri"`
	DirectInboundEnabled  *bool  `json:"direct_inbound_enabled"`
	DirectOutboundEnabled *bool  `json:"direct_outbound_enabled"`
	RelayInboundEnabled   *bool  `json:"relay_inbound_enabled"`
	RelayOutboundEnabled  *bool  `json:"relay_outbound_enabled"`
}

type DetailRequest struct {
	ID string `uri:"id" binding:"required"`
}

type DiagnosticsRequest struct {
	ID string `uri:"id" binding:"required"`
}

type DirectDiagnostics struct {
	Summary      connectivity.DirectSummary `json:"summary"`
	RecentErrors []connectivity.RecentError `json:"recent_errors"`
}

type EnrollRequest struct {
	EnrollmentToken string `json:"enrollment_token" binding:"required"`
	Name            string `json:"name"`
}

type EnrollResponse struct {
	AgentID string `json:"agent_id"`
	Secret  string `json:"secret"`
}

type FailedAgent struct {
	AgentID   uint   `json:"agent_id"`
	AgentName string `json:"agent_name"`
	Error     string `json:"error"`
}

type FullSyncRequest struct {
	AgentIDs []string `json:"agent_ids"`
	All      bool     `json:"all"`
}

type FullSyncResponse struct {
	Results []FullSyncResult `json:"results"`
}

type FullSyncResult struct {
	AgentID    string `json:"agent_id"`
	Success    bool   `json:"success"`
	Version    int64  `json:"version,omitempty"`
	DurationMs int64  `json:"duration_ms,omitempty"`
	Error      string `json:"error,omitempty"`
}

type GenerateEnrollmentTokenRequest struct {
	TTL int64 `json:"ttl"`
}

type GenerateEnrollmentTokenResponse struct {
	EnrollmentToken string `json:"enrollment_token"`
	ExpiresAt       int64  `json:"expires_at"`
}

type GlobalInflightRow struct {
	inflight.Snapshot
	AgentID   uint   `json:"agent_id"`
	AgentName string `json:"agent_name"`
}

type Handler struct {
	GetOnlineAgentIDs    func() []string
	GetRuntime           func(agentID string) *msync.AgentRuntime
	RevokeControlSession func(agentID string) bool
	GetProbeProgress     func(sourceID, probeID string) (protocol.ManualProbeProgress, bool)
	Connections          *connectivity.Service
	ControlSessions      connectivity.ControlSource
	Operations           *masteroperations.Service
	HubCallSession       func(agentID string, generation uint64, method string, params any, timeout time.Duration) (json.RawMessage, error)
	Hub                  *msync.Hub // 用于获取合并后的地址
	Now                  func() time.Time
	// contains filtered or unexported fields
}

type InterruptRequest struct {
	AgentID uint  `json:"agent_id" binding:"required"`
	ID      int64 `json:"id" binding:"required"`
}

type InterruptResponse struct {
	Interrupted bool `json:"interrupted"`
}

type ListRequest struct {
	api.PaginationQuery
	Search string `form:"search"`
	Status string `form:"status"`
}

type ManualProbeProgress = protocol.ManualProbeProgress

type OnlineAgentInfo struct {
	AgentID                 string                         `json:"agent_id"`
	Name                    string                         `json:"name"`
	Tags                    string                         `json:"tags"`
	HTTPAddresses           string                         `json:"http_addresses,omitempty"`            // Legacy: effective addresses
	ConfiguredHTTPAddresses string                         `json:"configured_http_addresses,omitempty"` // DB-configured addresses
	EffectiveHTTPAddresses  string                         `json:"effective_http_addresses,omitempty"`  // Merged effective addresses
	LastSeen                int64                          `json:"last_seen"`
	PendingUsage            int                            `json:"pending_usage"` // admin-only,见 pendingFromRuntime
	Connection              connectivity.ConnectionSummary `json:"connection"`
}

type ProbeAck = protocol.ProbeAck

type RelayDiagnostics struct {
	Support             string                            `json:"support"`
	Config              string                            `json:"config"`
	Availability        string                            `json:"availability"`
	AcceptingNewStreams bool                              `json:"accepting_new_streams"`
	Convergence         string                            `json:"convergence"`
	Desired             connectivity.RelayDesiredSnapshot `json:"desired"`
	Active              connectivity.RelayActiveSnapshot  `json:"active"`
	RecentErrors        []connectivity.RecentError        `json:"recent_errors"`
}

type RouteTargetsRequest struct {
	ID                    string `uri:"id" binding:"required"`
	Cursor                string `form:"cursor"`
	Limit                 int    `form:"limit"`
	ExpectedSnapshotEpoch string `form:"expected_snapshot_epoch"`
	ExpectedSnapshotSeq   uint64 `form:"expected_snapshot_seq"`
}

type RuntimeInfo struct {
	Uptime            int64                                `json:"uptime"`
	CachedTokens      int                                  `json:"cached_tokens"`
	CachedChannels    int                                  `json:"cached_channels"`
	CachedModels      int                                  `json:"cached_models"`
	ActiveConnections int                                  `json:"active_connections"`
	Version           int64                                `json:"version"`
	MasterVersion     int64                                `json:"master_version"`
	PendingUsage      int                                  `json:"pending_usage"`
	CacheStats        map[string]protocol.CacheEntityStats `json:"cache_stats,omitempty"`
}

type UpdateRequest struct {
	ID string `uri:"id" binding:"required"`
	AgentPatch
}