storage

type Agent struct {
	ID   string `json:"id"`
	Name string `json:"name,omitempty"`

	// Connection info
	Connected bool       `json:"connected"`
	LastSeen  *time.Time `json:"last_seen,omitempty"`
	PublicIP  string     `json:"public_ip,omitempty"`

	// Configuration
	DefaultTunnel string `json:"default_tunnel,omitempty"`

	// Status
	Status AgentStatus `json:"status"`

	// Timestamps
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type AgentStatus string

type ManagedResource struct {
	ID string `json:"id"`

	// Resource identification
	ResourceType ResourceType `json:"resource_type"`
	CFID         string       `json:"cf_id,omitempty"`

	// DNS record fields
	ZoneID     string `json:"zone_id,omitempty"`
	Hostname   string `json:"hostname"`
	RecordType string `json:"record_type,omitempty"`
	Content    string `json:"content,omitempty"`
	Proxied    bool   `json:"proxied,omitempty"`
	TTL        int    `json:"ttl,omitempty"`

	// Tunnel fields
	TunnelID string `json:"tunnel_id,omitempty"`
	Service  string `json:"service,omitempty"`
	Path     string `json:"path,omitempty"`

	// Access App fields
	AccessAppID      string `json:"access_app_id,omitempty"`      // Cloudflare Access Application ID
	AccountID        string `json:"account_id,omitempty"`         // Cloudflare Account ID
	AccessAppName    string `json:"access_app_name,omitempty"`    // CF Access Application display name
	AccessPolicyName string `json:"access_policy_name,omitempty"` // Labelgate policy template name
	AccessDecision   string `json:"access_decision,omitempty"`    // Policy decision (allow, block, bypass, service_auth)

	// Source information
	ContainerID   string `json:"container_id,omitempty"`
	ContainerName string `json:"container_name,omitempty"`
	ServiceName   string `json:"service_name"`
	AgentID       string `json:"agent_id,omitempty"`

	// Status
	Status         ResourceStatus `json:"status"`
	CleanupEnabled bool           `json:"cleanup_enabled"`
	LastError      string         `json:"last_error,omitempty"`

	// Timestamps
	CreatedAt time.Time  `json:"created_at"`
	UpdatedAt time.Time  `json:"updated_at"`
	DeletedAt *time.Time `json:"deleted_at,omitempty"`
}

type Migration struct {
	Version int
	SQL     string
}

type ResourceFilter struct {
	ResourceType ResourceType
	Hostname     string
	ContainerID  string
	ServiceName  string
	AgentID      string
	Status       ResourceStatus   // single status filter (for backwards compatibility)
	Statuses     []ResourceStatus // multi-status filter (takes precedence over Status)
	Limit        int
	Offset       int
}

type ResourceStatus string

type ResourceType string

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

type Storage interface {
	// Initialize initializes the storage (create tables, run migrations).
	Initialize(ctx context.Context) error

	// Close closes the storage connection.
	Close() error

	// Resource operations
	GetResource(ctx context.Context, id string) (*ManagedResource, error)
	GetResourceByHostname(ctx context.Context, hostname string, resourceType ResourceType) (*ManagedResource, error)
	GetResourceByContainerService(ctx context.Context, containerID, serviceName string) (*ManagedResource, error)
	ListResources(ctx context.Context, filter ResourceFilter) ([]*ManagedResource, error)
	SaveResource(ctx context.Context, resource *ManagedResource) error
	UpdateResourceStatus(ctx context.Context, id string, status ResourceStatus) error
	UpdateResourceError(ctx context.Context, id string, status ResourceStatus, lastError string) error
	DeleteResource(ctx context.Context, id string) error

	// Agent operations
	GetAgent(ctx context.Context, id string) (*Agent, error)
	ListAgents(ctx context.Context) ([]*Agent, error)
	SaveAgent(ctx context.Context, agent *Agent) error
	UpdateAgentStatus(ctx context.Context, id string, connected bool, status AgentStatus) error
	DeleteAgent(ctx context.Context, id string) error

	// Sync state operations
	GetSyncState(ctx context.Context, key string) (string, error)
	SetSyncState(ctx context.Context, key, value string) error

	// Maintenance operations
	CleanupDeletedResources(ctx context.Context, before time.Time) (int64, error)
	ListExpiredOrphans(ctx context.Context, olderThan time.Time) ([]*ManagedResource, error)
	ListOrphanedForCleanup(ctx context.Context, olderThan time.Time) ([]*ManagedResource, error)
	Vacuum(ctx context.Context) error
}

type StorageError struct {
	Code    string
	Message string
}