workspace

type BatchStatusResult struct {
	Path      string        // Workspace path
	Status    *vc.VCSStatus // VCS status (nil if error)
	Error     error         // Error (nil if success)
	Duration  time.Duration // How long the operation took
	IsPartial bool          // True if status is incomplete
}

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

type CacheInvalidationNotifier interface {
	// Subscribe starts listening for invalidation events.
	// The handler is called for each invalidation with the workspace path.
	// Runs until context is cancelled.
	Subscribe(ctx context.Context, handler func(workspacePath string)) error

	// Publish broadcasts an invalidation event to all subscribers.
	// workspacePath can be empty string to invalidate all caches.
	Publish(ctx context.Context, workspacePath string) error

	// Close stops listening and releases resources.
	Close() error
}

type ChangesSummary struct {
	TotalRepositories  int // Distinct repository roots
	TotalWorkspaces    int // All tracked workspaces
	TotalUncommitted   int // Files with uncommitted changes
	TotalUntracked     int // Untracked files
	TotalStaged        int // Staged files
	TotalConflicts     int // Conflicted files
	WorkspacesWithWork int // Workspaces with any pending changes
	OrphanedWorkspaces int // Workspaces without active sessions
}

type DistributedLock interface {
	// Acquire obtains an exclusive lock for the given resource.
	// Blocks until the lock is acquired or context is cancelled/times out.
	// Returns a handle that must be released when done.
	Acquire(ctx context.Context, resource string, timeout time.Duration) (LockHandle, error)

	// TryAcquire attempts to acquire lock without blocking.
	// Returns (handle, true) if acquired, (nil, false) if unavailable.
	TryAcquire(ctx context.Context, resource string) (LockHandle, bool, error)

	// Close releases any resources held by the lock implementation
	Close() error
}

type LockError struct {
	Op       string // Operation: "acquire", "release", "extend"
	Resource string // Resource being locked
	Err      error  // Underlying error
}

type LockHandle interface {
	// Release releases the lock. Must be called when done.
	// Safe to call multiple times (subsequent calls are no-ops).
	Release() error

	// Extend extends the lock TTL for long-running operations.
	// Not all implementations support this (may return ErrNotSupported).
	Extend(duration time.Duration) error

	// IsValid checks if the lock is still held.
	// Returns false if lock was released or expired.
	IsValid() bool

	// Resource returns the resource name this lock is for.
	Resource() string
}

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

type NoOpNotifier struct{}

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

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

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

type Registry interface {
	// Registration
	Register(ctx context.Context, workspace *TrackedWorkspace) error
	Unregister(ctx context.Context, path string) error
	MarkOrphaned(ctx context.Context, path string) error

	// Query
	Get(ctx context.Context, path string) (*TrackedWorkspace, error)
	List(ctx context.Context, filter *WorkspaceFilter) ([]*TrackedWorkspace, error)
	ListByRepository(ctx context.Context, repoRoot string) ([]*TrackedWorkspace, error)

	// Status
	GetStatus(ctx context.Context, path string, opts StatusRefreshOptions) (*WorkspaceStatus, error)
	GetAllStatuses(ctx context.Context, opts StatusRefreshOptions) ([]*WorkspaceStatus, error)
	GetSummary(ctx context.Context) (*ChangesSummary, error)

	// Batch operations
	RefreshStatuses(ctx context.Context, paths []string, opts StatusRefreshOptions) ([]*WorkspaceStatus, error)

	// Lifecycle
	Close() error
}

type RegistryConfig struct {
	// Distributed lock for multi-pod coordination
	Lock DistributedLock

	// Cache invalidation for cross-pod coordination
	Notifier CacheInvalidationNotifier

	// Cache settings
	CacheTTL         time.Duration // How long to cache status (default: 30s)
	MaxCacheSize     int           // Maximum cached entries (default: 1000)
	RefreshBatchSize int           // Max concurrent status refreshes (default: 10)

	// Timeouts
	LockTimeout      time.Duration // Lock acquisition timeout (default: 10s)
	OperationTimeout time.Duration // Individual operation timeout (default: 5s)
}

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

type StatusRefreshOptions struct {
	// Force refresh even if cache is fresh
	Force bool

	// Maximum age for cached status to be considered fresh
	MaxAge time.Duration

	// Timeout for individual git operations
	Timeout time.Duration

	// Continue on errors (return partial results)
	ContinueOnError bool
}

type TrackedWorkspace struct {
	// Identity
	Path           string // Absolute path to workspace
	RepositoryRoot string // Root of the git/jj repository
	WorktreePath   string // Path if this is a worktree (empty if not)
	MainRepoPath   string // Main repo path if this is a worktree

	// Session association
	SessionTitle  string         // Title of associated session (empty if orphaned)
	SessionStatus session.Status // Status of associated session
	IsOrphaned    bool           // True if no active session owns this workspace

	// VCS information
	VCSType vc.VCSType // Git or Jujutsu

	// Timestamps
	LastChecked  time.Time // When VCS status was last refreshed
	LastActivity time.Time // Last file modification detected

	// Attention flags
	NeedsAttention  bool   // Has issues requiring action
	AttentionReason string // Why attention is needed
}

type WorkspaceFilter struct {
	// Path filters
	RepositoryRoot string // Filter by repository root
	PathPrefix     string // Filter by path prefix

	// Status filters
	IncludeOrphaned  bool // Include orphaned workspaces
	OnlyWithChanges  bool // Only workspaces with uncommitted changes
	OnlyWithConflict bool // Only workspaces with conflicts

	// Session filters
	SessionStatus *session.Status // Filter by session status
}

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

type WorkspaceStatus struct {
	// Embedded VCS status
	VCSStatus *vc.VCSStatus

	// Workspace context
	WorkspacePath string         // Path to this workspace
	SessionTitle  string         // Associated session (if any)
	SessionStatus session.Status // Session state
	IsOrphaned    bool           // No active session
	IsWorktree    bool           // Is a git worktree

	// Activity tracking
	LastActivity time.Time // Last file modification
	LastChecked  time.Time // When status was collected

	// Attention flags
	NeedsAttention  bool   // Has issues requiring action
	AttentionReason string // Why attention is needed

	// Error state
	Error     error  // Error during status collection (nil if success)
	ErrorMsg  string // Human-readable error message
	IsPartial bool   // True if status is incomplete due to errors
}