backfill

type PreviewOptions struct {
	// Store serves the rows without previews and takes the previews back.
	Store storage.PreviewBackfiller

	// SessionID restricts the scan to one session; empty means every
	// session.
	SessionID string

	// BatchSize bounds every read and every write transaction. Zero
	// means DefaultPreviewBatch.
	BatchSize int

	// Pause is the sleep between batches; zero or negative means none. The
	// CLI defaults it to DefaultPreviewPause.
	Pause time.Duration

	// DryRun scans and counts but writes nothing.
	DryRun bool

	Logf func(format string, args ...any)

	// AfterBatch, when set, runs after each batch has been applied (or
	// counted, in a dry run) and before the pause. It exists so a caller
	// can observe or interrupt progress at a batch boundary.
	AfterBatch func(progress PreviewProgress)
}

type PreviewProgress struct {
	// Batch is the rows the batch read.
	Batch []storage.SpanBackfillRow
	// Backfilled is the running total of rows written (or, in a dry
	// run, rows that would have been).
	Backfilled int
	// Last is the keyset cursor the next batch starts after.
	Last storage.SpanBackfillCursor
}

type PreviewResult struct {
	// Batches is the number of non-empty pages read.
	Batches int `json:"batches"`
	// Backfilled is the number of spans whose previews were written
	// (counted but not written in a dry run).
	Backfilled int `json:"backfilled"`
	// Last is the key of the last span the run reached; zero when the
	// scan found nothing.
	Last storage.SpanBackfillCursor `json:"last"`
	// DryRun echoes the option so a report is self-describing.
	DryRun bool `json:"dry_run"`
}

type TranscriptUploadOptions struct {
	// ProjectDir is one Claude Code project directory
	// (~/.claude/projects/<flattened-cwd>) holding <session>.jsonl
	// files and per-session subagents/ directories.
	ProjectDir string

	// SessionIDs filters which sessions upload; empty means every
	// .jsonl in the directory.
	SessionIDs []string

	// IngestURL is the tapes-ingest base URL.
	IngestURL string

	// HarnessID tags the session envelope; Claude Code transcripts are
	// "claude".
	HarnessID string

	Verbose bool
	Logf    func(format string, args ...any)
}

type TranscriptUploadResult struct {
	Sessions int      `json:"sessions"`
	Files    int      `json:"files"`
	Uploaded int      `json:"uploaded"`
	Deduped  int      `json:"deduped"`
	Failed   int      `json:"failed"`
	Failures []string `json:"failures,omitempty"`
}

type WireTraceOptions struct {
	// CapturesDir is the paperd wire-trace root holding turn-* bundles
	// (request.json + response.sse + meta.json per turn).
	CapturesDir string

	// IngestURL is the base URL of a tapes-ingest server, e.g.
	// "http://127.0.0.1:8090". The backfill POSTs one envelope per
	// captured turn to {IngestURL}/v1/ingest.
	IngestURL string

	// SessionIDs filters replay to bundles whose captured
	// X-Tapes-Harness-Session-Id matches; empty replays everything.
	SessionIDs []string

	// DryRun parses and reduces every bundle but skips the POST.
	DryRun bool

	// Verbose logs each turn's outcome to Logf.
	Verbose bool

	// Logf receives progress output; defaults to a no-op.
	Logf func(format string, args ...any)
}

type WireTraceResult struct {
	Scanned  int      `json:"scanned"`
	Posted   int      `json:"posted"`
	RawOnly  int      `json:"raw_only"`
	Skipped  int      `json:"skipped"`
	Failed   int      `json:"failed"`
	Failures []string `json:"failures,omitempty"`
}