completioncandidate

type Candidate struct {
	ID                uuid.UUID
	WorkspaceID       *uuid.UUID
	TaskID            uuid.UUID
	RepoName          string
	Reason            Reason
	EvidenceRefs      []string
	Confidence        Confidence
	SuggestedArtifact string
	Status            Status
	DetectedAt        time.Time
	ResolvedAt        *time.Time
}

type Confidence string

type DetectParams struct {
	WorkspaceID    *uuid.UUID
	StaleThreshold time.Duration // default 24h; hours of inactivity before flagging in_progress task
	LookbackDays   int           // default 7, max 30; days of activity_log to scan
}

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

type Reason string

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

type Status string

type Store interface {
	// ListPendingCandidates returns all candidates with status='pending',
	// optionally filtered to the given workspace.
	ListPendingCandidates(ctx context.Context, workspaceID *uuid.UUID) ([]Candidate, error)

	// UpsertCandidate inserts or updates a candidate identified by (task_id, reason).
	// On conflict (task_id, reason) the detected_at is refreshed and confidence updated.
	UpsertCandidate(ctx context.Context, p UpsertParams) (*Candidate, error)

	// PruneResolved deletes resolved candidates older than olderThan. Returns the
	// number of rows deleted.
	PruneResolved(ctx context.Context, olderThan time.Duration) (int64, error)

	// DetectAndUpsert runs all 4 detection rules against the tasks / work_sessions /
	// activity_log tables and upserts any matches into completion_candidates.
	// Returns all upserted candidates (including previously pending ones that were
	// refreshed). Read-only for tasks; writes to completion_candidates only.
	DetectAndUpsert(ctx context.Context, p DetectParams) ([]Candidate, error)

	// WriteAutoApplied inserts a completion_candidates row recording an auto-apply
	// event (status='auto_applied', reason='artifact_evidence'). Used by the
	// reconcile_merged_prs flow (sprint feature/gtd-enforce-server-side
	// GTD-fix 9/12) to audit-log which task was auto-closed by which PR.
	//
	// On conflict (task_id, reason) the existing row is refreshed (detected_at
	// updated, evidence_refs replaced, suggested_artifact set, status forced to
	// auto_applied so a previously-pending candidate is closed). This mirrors
	// the UpsertCandidate ON CONFLICT semantics but additionally forces the
	// status column.
	WriteAutoApplied(ctx context.Context, taskID uuid.UUID, evidenceRefs []string, suggestedArtifact string) error
}

type UpsertParams struct {
	WorkspaceID       *uuid.UUID
	TaskID            uuid.UUID
	RepoName          string
	Reason            Reason
	EvidenceRefs      []string
	Confidence        Confidence
	SuggestedArtifact string
}