ingest

type Incremental interface {
	Source
	// ChangedSessions itera solo las sesiones para las que changed(clave,
	// huella) devuelve true; las demás se saltan sin leerse. La clave es
	// estable por sesión (la ruta del transcript, o db#id si varias sesiones
	// comparten archivo).
	ChangedSessions(changed func(key, fingerprint string) bool) iter.Seq2[*ParsedChat, error]
}

type OpencodeStamp struct {
	ID      string
	Updated time.Time
}

type Option func(*config) error

type ParsedChat struct {
	Chat     db.Chat
	Messages []db.Message
	// CursorKey y Fingerprint identifican la sesión en su fuente y su huella
	// al leerla ("" = la fuente no es Incremental). Ingest los registra tras
	// persistir la sesión.
	CursorKey   string
	Fingerprint string
}

type Parser interface {
	// Source identifica al agente: "codex" | "claude" | "antigravity".
	Source() string
	// DefaultRoot devuelve el directorio raíz por defecto de las sesiones.
	DefaultRoot() (string, error)
	// Parse parsea el contenido de un archivo de sesión.
	Parse(r io.Reader, sessionPath string) (*ParsedChat, error)
}

type Report struct {
	Source    string
	Scanned   int // sesiones examinadas (archivos o filas, según la fuente)
	Chats     int
	Messages  int64
	Skipped   int
	Unchanged int // sesiones saltadas sin parsear (huella igual a la ingestada)
	Errors    []string
}

type Source interface {
	// Name identifica al agente: "codex" | "claude" | "antigravity" | "opencode".
	Name() string
	// Sessions itera las sesiones de la fuente. Cada elemento es una sesión
	// parseada o un error de esa sesión; los errores por sesión no abortan la
	// iteración. Una fuente cuyo agente no está instalado itera vacío.
	Sessions() iter.Seq2[*ParsedChat, error]
}