services

type ConnectionServiceConfig struct {
	// ConnectionStore manages connection persistence.
	ConnectionStore driven.ConnectionStore

	// SourceStore manages source persistence (for checking usage).
	SourceStore driven.SourceStore

	// ContainerListerFactory creates container listers for providers.
	ContainerListerFactory driven.ContainerListerFactory

	// TokenProviderFactory creates token providers for testing connections.
	TokenProviderFactory driven.TokenProviderFactory
}

type OAuthServiceConfig struct {
	// ConfigProvider retrieves OAuth app credentials from environment variables.
	ConfigProvider driven.ConfigProvider

	// OAuthStateStore manages OAuth flow state.
	OAuthStateStore driven.OAuthStateStore

	// ConnectionStore persists connector installations.
	ConnectionStore driven.ConnectionStore

	// OAuthHandlerFactory provides OAuth handlers per provider.
	// Port interface - abstracts connector factory.
	OAuthHandlerFactory driven.OAuthHandlerFactory
}

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

type SchedulerConfig struct {
	Store        driven.SchedulerStore
	TaskQueue    driven.TaskQueue
	Lock         driven.DistributedLock // Optional: distributed lock for multi-instance coordination
	Logger       *slog.Logger
	PollInterval time.Duration // How often to check for due tasks (default: 30s)
	LockTTL      time.Duration // TTL for the distributed lock (default: 60s)
	LockRequired bool          // If true, skip scheduling when lock cannot be acquired (default: true)
}

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

type SyncOrchestratorConfig struct {
	SourceStore      driven.SourceStore
	DocumentStore    driven.DocumentStore
	ChunkStore       driven.ChunkStore
	SyncStore        driven.SyncStateStore
	SearchEngine     driven.SearchEngine
	VectorIndex      driven.VectorIndex
	ConnectorFactory driven.ConnectorFactory
	NormaliserReg    driven.NormaliserRegistry
	Services         *runtime.Services
	Logger           *slog.Logger
	IndexingExecutor pipelineport.IndexingExecutor // Required pipeline executor
	CapabilitySet    *pipeline.CapabilitySet       // Capabilities for pipeline
	CapabilityStore  driven.CapabilityStore        // For fetching capability preferences
	SettingsStore    driven.SettingsStore          // For loading team settings
	TeamID           string                        // Team ID for settings lookup
}