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 EntityRegisterCleanupObserver struct {
	// contains filtered or unexported fields
}

type OAuthServerServiceConfig struct {
	ClientStore  driven.OAuthClientStore
	CodeStore    driven.AuthorizationCodeStore
	TokenStore   driven.OAuthTokenStore
	JWTSecret    string // For signing access tokens
	MCPServerURL string // For audience validation
}

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 SourceServiceConfig struct {
	SourceStore            driven.SourceStore
	DocumentStore          driven.DocumentStore
	SyncStore              driven.SyncStateStore
	SearchEngine           driven.SearchEngine
	VectorIndex            driven.VectorIndex
	TaskQueue              driven.TaskQueue
	TeamID                 string
	Logger                 *slog.Logger
	DocumentDeleteObserver driven.DocumentDeleteObserver // Optional; nil means no observer.
}

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

type SyncOrchestratorConfig struct {
	SourceStore               driven.SourceStore
	DocumentStore             driven.DocumentStore
	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
	SyncEventRepo             driven.SyncEventRepository    // For audit logging of sync events
	TeamID                    string                        // Team ID for settings lookup
	DocumentIngestObserver    driven.DocumentIngestObserver // Optional; nil means no observer.
	DocumentDeleteObserver    driven.DocumentDeleteObserver // Optional; nil means no observer.
	Lock                      driven.DistributedLock        // Optional. When set, SyncSource/SyncContainer acquire "sync:source:<id>" before running so concurrent invocations no-op (Skipped=true) instead of racing.
	LockTTL                   time.Duration                 // Optional. Defaults to 1h. Ignored by PG advisory locks (which release on connection close).
	Concurrency               int                           // Optional. Per-container doc-level worker count. Defaults to defaultDocConcurrency (1) when zero.
	OnDocumentIngestedTimeout time.Duration                 // Optional. Per-call timeout for the async DocumentIngestObserver. Defaults to 30s when zero.
	ObserverQueueDepth        int                           // Optional. Bounded goroutine pool depth for the async DocumentIngestObserver. Defaults to 32 when zero.

	// FailedDocStore enables the per-document skip-list / retry ledger.
	// When non-nil the orchestrator records per-doc failures here and
	// always advances the cursor on a fresh delta batch (failures are
	// retried independently). When nil the legacy "stall cursor on any
	// error" behaviour is retained — kept for test wiring and any
	// embedder that prefers the older semantics.
	FailedDocStore driven.SyncFailedDocStore
	// FailedDocBackoff overrides the default exponential schedule used
	// when recording new failures. Optional — defaults to a sensible
	// (5min base, 24h cap, 10 attempts) policy when the zero value is
	// passed.
	FailedDocBackoff driven.RetryBackoff
	// RetryBatchPerSync caps how many previously-failing docs the
	// pre-pass attempts per sync run. Defaults to 50 when zero.
	RetryBatchPerSync int
}

type UserServiceConfig struct {
	UserStore          driven.UserStore
	SessionStore       driven.SessionStore
	AuthAdapter        driven.AuthAdapter
	TeamID             string
	Logger             *slog.Logger
	UserCreateObserver driven.UserCreateObserver // Optional; nil means no observer.
	UserDeleteObserver driven.UserDeleteObserver // Optional; nil means no observer.
}