queryservice

type CodexCaptureDiagnosticQueryService interface {
	LoadCodexCaptureDiagnostic(
		context.Context,
		apptypes.CodexCaptureDiagnosticCriteria,
	) (apptypes.CodexCaptureDiagnosticEvidence, error)
}

type CommandAuditQueryService interface {
	// ListReportWindow returns every command audit matching the report event
	// criteria under one SQLite read snapshot. Limit is the internal page size.
	ListReportWindow(ctx context.Context, criteria apptypes.EventListCriteria) ([]apptypes.ReportCommandRecord, error)
}

type EventMetadataQueryService interface {
	// ListRecentMetadata returns body-free events in descending time order.
	ListRecentMetadata(ctx context.Context, criteria apptypes.EventListCriteria) ([]apptypes.EventMetadata, error)
	// ListWindowMetadata returns every matching body-free event under one
	// read snapshot. criteria.Limit() controls the internal page size.
	ListWindowMetadata(ctx context.Context, criteria apptypes.EventListCriteria) ([]apptypes.EventMetadata, error)
	// SearchMetadata searches event and command content in SQLite but returns
	// only body-free event metadata to the caller.
	SearchMetadata(ctx context.Context, criteria apptypes.EventSearchCriteria) ([]apptypes.EventMetadata, error)
	// GetContextMetadata returns body-free context membership in descending
	// time order.
	GetContextMetadata(ctx context.Context, criteria apptypes.EventContextCriteria) ([]apptypes.EventMetadata, error)
}

type EventPreviewQueryService interface {
	ListRecentCommandPreviews(ctx context.Context, sessionID types.SessionID, limit, bodyRuneLimit int) ([]apptypes.EventBodyPreview, error)
}

type EventQueryService interface {
	// ListRecent returns events in descending time order.
	ListRecent(ctx context.Context, limit, offset int, kind types.EventKind, client types.Client, agent types.Agent, sessionID types.SessionID, workspace types.Workspace, failuresOnly bool, from, to time.Time, sourceHook string) ([]*model.Event, error)
	// ListWindow returns every event matching the criteria whose created_at
	// falls in [From, To) under a single read snapshot so concurrent writers
	// cannot cause the scan to drop events. Callers supply the batch size via
	// criteria.Limit(); offset is ignored.
	ListWindow(ctx context.Context, criteria apptypes.EventListCriteria) ([]*model.Event, error)
	// Search performs full-text search across events.
	Search(ctx context.Context, query string, workspace types.Workspace, sessionID types.SessionID, client types.Client, agent types.Agent, kind types.EventKind, from, to time.Time, limit, offset int, failuresOnly bool) ([]*model.Event, error)
	// GetContext returns recent events for context retrieval.
	GetContext(ctx context.Context, workspace types.Workspace, sessionID types.SessionID, limit int) ([]*model.Event, error)
	// GetDetails returns the details for a single event.
	GetDetails(ctx context.Context, eventID types.EventID) (apptypes.EventDetails, error)
	// ListTimelineBlocks returns work blocks separated by idle gaps.
	ListTimelineBlocks(ctx context.Context, workspace types.Workspace, from, to time.Time, gapSeconds, limit int) ([]apptypes.TimelineBlock, error)
}

type MemoryQueryService interface {
	// List returns memory summaries matching the provided criteria.
	List(ctx context.Context, criteria apptypes.MemoryListCriteria) ([]apptypes.MemorySummary, error)
	// Search performs text search across durable memories and their refs.
	Search(ctx context.Context, criteria apptypes.MemorySearchCriteria) ([]apptypes.MemorySummary, error)
	// GetDetails returns the details for a single memory.
	GetDetails(ctx context.Context, memoryID types.MemoryID) (apptypes.MemoryDetails, error)
}

type MemoryStatusCountQueryService interface {
	// CountByStatus returns the true per-status row counts matching the
	// criteria, ignoring its Limit/Offset.
	CountByStatus(ctx context.Context, criteria apptypes.MemoryListCriteria) (apptypes.MemoryStatusCounts, error)
}

type ReportQueryService interface {
	LoadReportWindow(ctx context.Context, criteria apptypes.ReportCriteria) (apptypes.ReportWindow, error)
}

type SessionQueryService interface {
	// FindLatest returns the session_started event for the latest matching session.
	// Returns an empty Optional when no matching session exists.
	FindLatest(ctx context.Context, client types.Client, agent types.Agent, workspace types.Workspace, activeOnly bool) (types.Optional[*model.Event], error)
	// ListSummaries returns session summaries matching the criteria.
	ListSummaries(ctx context.Context, limit, offset int, sessionID types.SessionID, workspace types.Workspace, client types.Client, agent types.Agent, label string, activeOnly bool, from, to types.Optional[time.Time]) ([]apptypes.SessionSummary, error)
	// ListTreeSummaries returns sessions for the tree view. When rootSessionID is set,
	// the root session and its descendants are returned without applying the recent-session limit.
	ListTreeSummaries(ctx context.Context, limit int, workspace types.Workspace, rootSessionID types.SessionID) ([]apptypes.SessionSummary, error)
	// LineageOf returns the full session tree rooted at the topmost ancestor of sessionID.
	LineageOf(ctx context.Context, sessionID types.SessionID) ([]apptypes.SessionSummary, error)
}

type StaleMemoryQueryService interface {
	// ListStale returns stale durable-memory rows plus the total count before
	// paging.
	ListStale(ctx context.Context, criteria apptypes.StaleMemoryListCriteria) (apptypes.StaleMemoryListResult, error)
}

type WorkspaceIdentityQueryService interface {
	WorkspaceIdentityReport(ctx context.Context, conflictSampleLimit int) (apptypes.WorkspaceIdentityReport, error)
}

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

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