app

type Application struct {
	PromptManager   prompt.ManagerInterface
	ToolManager     tool.ManagerInterface
	ResourceManager resource.ManagerInterface
	ServiceRegistry serviceregistry.ServiceRegistryInterface
	TopologyManager *topology.Manager
	UpstreamFactory factory.Factory

	Storage         storage.Storage
	TemplateManager *TemplateManager

	// SkillManager manages agent skills
	SkillManager *skill.Manager

	// AlertsManager manages system alerts
	AlertsManager *alerts.Manager

	// Settings Manager for global settings (dynamic updates)
	SettingsManager *GlobalSettingsManager
	// Profile Manager for dynamic profile updates
	ProfileManager *profile.Manager
	// Auth Manager (stored here for access in runServerMode, though it is also passed to serviceregistry)
	// We need to keep a reference to update it on reload.
	AuthManager *auth.Manager

	// BoundHTTPPort stores the actual port the HTTP server is listening on.
	BoundHTTPPort atomic.Int32
	// BoundGRPCPort stores the actual port the gRPC server is listening on.
	BoundGRPCPort atomic.Int32

	// RegistrationRetryDelay allows configuring the retry delay for service registration.
	// If 0, it defaults to 5 seconds (in the worker).
	RegistrationRetryDelay time.Duration
	// contains filtered or unexported fields
}

type AuthTestRequest struct {
	CredentialID  string         `json:"credential_id"`
	ServiceType   string         `json:"service_type"`
	ServiceConfig map[string]any `json:"service_config"`
}

type AuthTestResponse struct {
	Success bool   `json:"success"`
	Message string `json:"message"`
}

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

type Metric struct {
	Label    string `json:"label"`
	Value    string `json:"value"`
	Change   string `json:"change"`
	Trend    string `json:"trend"` // "up" | "down" | "neutral"
	Icon     string `json:"icon"`
	SubLabel string `json:"subLabel"`
}

type RunOptions struct {
	Ctx             context.Context
	Fs              afero.Fs
	Stdio           bool
	JSONRPCPort     string
	GRPCPort        string
	ConfigPaths     []string
	APIKey          string
	ShutdownTimeout time.Duration
	TLSCert         string
	TLSKey          string
	TLSClientCA     string
}

type Runner interface {
	// Run starts the application with the given options.
	Run(opts RunOptions) error

	// ReloadConfig reloads the application configuration from the provided file system
	// and paths. It updates the internal state of the application, such as
	// service registries and managers, to reflect changes in the configuration files.
	//
	// Parameters:
	//   - fs: The filesystem interface for reading configuration files.
	//   - configPaths: A slice of paths to configuration files to reload.
	//
	// Returns:
	//   - An error if the configuration reload fails.
	//   - ctx: The context for the reload operation.
	//   - fs: The filesystem interface for reading configuration files.
	//   - configPaths: A slice of paths to configuration files to reload.
	//
	// Returns:
	//   - An error if the configuration reload fails.
	ReloadConfig(ctx context.Context, fs afero.Fs, configPaths []string) error
}

type SkillServiceServer struct {
	pb.UnimplementedSkillServiceServer
	// contains filtered or unexported fields
}

type SystemStatusResponse struct {
	UptimeSeconds     int64    `json:"uptime_seconds"`
	ActiveConnections int32    `json:"active_connections"`
	BoundHTTPPort     int      `json:"bound_http_port"`
	BoundGRPCPort     int      `json:"bound_grpc_port"`
	Version           string   `json:"version"`
	SecurityWarnings  []string `json:"security_warnings"`
}

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

type TestAuthRequest struct {
	// The credential to use (can be a reference ID or inline Credential).
	CredentialID string `json:"credential_id"`
	// OR inline authentication config
	Authentication *configv1.Authentication `json:"authentication"`
	// OR inline user token (for ad-hoc testing)
	UserToken *configv1.UserToken `json:"user_token"`

	// The URL to test against.
	TargetURL string `json:"target_url"`
	// HTTP Method (GET, POST, etc.)
	Method string `json:"method"`
}

type TestAuthResponse struct {
	Status     int               `json:"status"`
	StatusText string            `json:"status_text"`
	Headers    map[string]string `json:"headers"`
	Body       string            `json:"body"`
	Error      string            `json:"error,omitempty"`
}

type ToolUsageStats struct {
	Name      string `json:"name"`
	ServiceID string `json:"serviceId"`
	Count     int64  `json:"count"`
}

type ValidateRequest struct {
	Content string `json:"content"`
	Format  string `json:"format"` // "json" or "yaml"
}

type ValidateResponse struct {
	Valid   bool   `json:"valid"`
	Error   string `json:"error,omitempty"`
	Message string `json:"message,omitempty"`
}