indexreader

type AcquireBundleOptions struct {
	IndexSetID        string
	RunID             string
	ProofThroughRunID string
	Destination       string
	Limits            AcquiredBundleLimits
	// Warning receives post-commit durability/cleanup warnings. A successful
	// no-replace rename remains authoritative and is never reported as failure.
	Warning func(message string)
}

type AcquiredArtifact struct {
	Path      string `json:"path"`
	Role      string `json:"role"`
	SizeBytes int64  `json:"size_bytes"`
	SHA256    string `json:"sha256"`
}

type AcquiredBundleLimits struct {
	MaxMarkerBytes    int64
	MaxManifestBytes  int64
	MaxIdentityBytes  int64
	MaxSegmentBytes   int64
	MaxSegments       int
	MaxLineageNodes   int
	MaxAggregateBytes int64
	MaxMetadataBytes  int64
}

type AcquiredBundleMarker struct {
	Type                        string                `json:"type"`
	Schema                      string                `json:"schema"`
	IndexSetID                  string                `json:"index_set_id"`
	RunID                       string                `json:"run_id"`
	ProofThroughRunID           string                `json:"proof_through_run_id,omitempty"`
	SourceIdentitySHA256        string                `json:"source_identity_sha256"`
	SourceIdentitySchema        string                `json:"source_identity_schema"`
	SourceIdentityProfile       string                `json:"source_identity_profile"`
	HubMarkerSchemaVersion      string                `json:"hub_marker_schema_version,omitempty"`
	RunStart                    *BridgeRunStart       `json:"run_start,omitempty"`
	SnapshotTime                *BridgeSnapshotTime   `json:"snapshot_time,omitempty"`
	ConversionIdentitySHA256    string                `json:"conversion_identity_sha256,omitempty"`
	SnapshotCompletedAt         string                `json:"snapshot_completed_at,omitempty"`
	SnapshotCompletionSemantics string                `json:"snapshot_completion_semantics,omitempty"`
	HubCommittedAt              string                `json:"hub_committed_at"`
	HubCompleteSHA256           string                `json:"hub_complete_sha256"`
	ManifestSHA256              string                `json:"manifest_sha256"`
	AcquiredAt                  string                `json:"acquired_at"`
	Lineage                     []AcquiredLineageNode `json:"lineage"`
	Artifacts                   []AcquiredArtifact    `json:"artifacts"`
}

type AcquiredLineageNode struct {
	IndexSetID               string `json:"index_set_id"`
	RunID                    string `json:"run_id"`
	MarkerSchemaVersion      string `json:"marker_schema_version,omitempty"`
	HubCompleteSHA256        string `json:"hub_complete_sha256"`
	ManifestSHA256           string `json:"manifest_sha256"`
	ConversionIdentitySHA256 string `json:"conversion_identity_sha256,omitempty"`
}

type AcquiredOpenOptions struct {
	Directory string
	Limits    AcquiredBundleLimits
}

type BridgeError struct {
	Code string
}

type BridgeLimits struct {
	MaxMarkerBytes     int64
	MaxManifestBytes   int64
	MaxIdentityBytes   int64
	MaxEvidenceBytes   int64
	MaxSegmentBytes    int64
	MaxSegments        int
	MaxAggregateBytes  int64
	MaxConversionBytes int64
}

type BridgeOptions struct {
	IndexSetID     string
	RunID          string
	Workspace      string
	Limits         BridgeLimits
	ExportedBy     string
	HubCommitClock func() time.Time
}

type BridgeResult struct {
	IndexSetID                string
	RunID                     string
	LegacyMarkerSHA256        string
	IdentitySHA256            string
	IdentitySchema            string
	IdentityProfile           string
	ManifestSHA256            string
	DeclaredRows              int
	DeclaredSegments          int
	SegmentsVerified          int
	BytesRead                 int64
	BytesConditionallyCreated int64
	RunStart                  BridgeRunStart
	SnapshotTime              BridgeSnapshotTime
	ConversionIdentitySHA256  string
	HubCommittedAt            string
	CompleteSHA256            string
	ExportedBy                string
	Disposition               string
}

type BridgeRunStart struct {
	Basis     string `json:"basis"`
	StartedAt string `json:"started_at"`
}

type BridgeSnapshotTime struct {
	Basis          string `json:"basis"`
	CompletedAt    string `json:"completed_at,omitempty"`
	EvidenceType   string `json:"evidence_type,omitempty"`
	EvidenceSHA256 string `json:"evidence_sha256,omitempty"`
}

type CanonicalIdentityAuthority struct {
	CanonicalJSONLF []byte
	DeclarationJSON []byte
}

type CanonicalLocalIdentityFile struct {
	Payload    indexstore.IndexSetIdentityPayload
	IndexSetID string
	Raw        []byte
	SHA256     string
}

type CoverageSummary struct {
	Entries          int
	CompleteEntries  int
	ConfirmedEntries int
	InferredEntries  int
	GapCount         int
}

type DeclaredSnapshotCounts struct {
	Rows          int
	ActiveRows    int
	Tombstones    int
	DistinctETags int
	Segments      int
}

type Format string

type HubConditionalCreatePublisher interface {
	HubExactObjectReader
	CreateExact(
		ctx context.Context,
		key string,
		body io.Reader,
		sizeBytes int64,
	) (created bool, err error)
}

type HubExactObjectReader interface {
	OpenExact(ctx context.Context, key string) (body io.ReadCloser, sizeBytes int64, err error)
}

type IdentityStatus string

type ListedIndex struct {
	Meta               Meta
	IdentityStatus     IdentityStatus
	IdentityDiagnostic string
}

type LocalIdentityFile struct {
	// Raw is the trimmed file content used for presentation hashing.
	Raw []byte
	// Payload is the parsed identity document.
	Payload indexstore.IndexSetIdentityPayload
	// IndexSetID is the recomputed full idx_<64hex> when ComputeIndexSetID succeeds.
	IndexSetID string
}

type Meta struct {
	Format     Format
	IndexSetID string
	BaseURI    string
	Provider   string
	// IdentityDir is the indexes/idx_* directory when known.
	IdentityDir string
	// SourcePath is the primary artifact path (index.db or latest.json).
	SourcePath string
	// RunID is the durable snapshot run id when Format is durable-v2.
	RunID string
}

type Reader interface {
	Meta() Meta
	// SQLiteDB returns the query-only authority-held connection for sqlite-v1;
	// durable-v2 readers return nil. It remains valid until Close.
	SQLiteDB() *sql.DB
	// WalkObjects streams matching object rows in rel_key order without
	// accumulating them. On durable-v2, each segment digest is verified before
	// that segment's rows are visited. A later-segment failure aborts with
	// error after any already-visited rows (callers may have emitted a prefix).
	WalkObjects(ctx context.Context, params indexstore.QueryParams, visit VisitObject) (indexstore.QueryStats, error)
	// QueryObjects is a convenience collector over WalkObjects. Prefer WalkObjects
	// for large durable snapshots — this materialises the full match set.
	QueryObjects(ctx context.Context, params indexstore.QueryParams) ([]indexstore.QueryResult, indexstore.QueryStats, error)
	// QueryObjectCount counts matches without requiring full materialisation
	// for plain (non-canonical) queries on durable; SQLite uses COUNT when possible.
	QueryObjectCount(ctx context.Context, params indexstore.QueryParams) (int64, error)
	// QueryCanonicalObjects applies the same filters as WalkObjects, then
	// groups by ETag. This path is intentionally non-constant-memory: it
	// materialises the filtered row set before grouping. Envelope is
	// O(matched rows) with selection/output bounded by O(distinct non-empty
	// ETags) plus alternates storage for non-canonical group members.
	QueryCanonicalObjects(ctx context.Context, params indexstore.QueryParams) ([]indexstore.CanonicalOutputRecord, indexstore.CanonicalQueryStats, error)
	// ResolveSinceRunFilter validates a --since-run boundary for this index.
	// Durable-v2 requires an exact pinned current run and digest-verified
	// continuous ancestry through the requested baseline.
	ResolveSinceRunFilter(ctx context.Context, runID string) (*indexstore.SinceRunFilter, error)
	Close() error
}

type ResolveOptions struct {
	// IndexesRoot is the indexes/ directory (contains idx_* identity dirs).
	IndexesRoot string
	// SegmentCacheRoot is the cache/segments/ directory (contains full index_set_id dirs).
	SegmentCacheRoot string
	// Authority optionally supplies caller-held whole-set authority for a
	// single-set resolution. It remains caller-owned.
	Authority *indexcoord.Lease
	// MaxMarkerBytes bounds latest/complete JSON reads (default: 1 MiB).
	MaxMarkerBytes int64
	// MaxManifestBytes bounds manifest JSON reads (default: 64 MiB).
	MaxManifestBytes int64
}

type ResolveTarget struct {
	// BaseURI selects by identity/base_uri when IndexSetID is empty.
	BaseURI string
	// IndexSetID is a full idx_<64hex> or a unique hex prefix / dir name.
	IndexSetID string
	// RunID, when set, pins a durable-v2 snapshot by complete marker and never
	// consults latest.json. Requires IndexSetID. SQLite cannot satisfy a pin.
	RunID string
}

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

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

type SQLiteSnapshotOptions struct {
	Path           string
	SegmentSetRoot string
	IndexSetID     string
	Authority      *indexcoord.Lease
}

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

type SQLiteVerificationTargetOptions struct {
	SegmentSetRoot string
	IndexSetID     string
	Authority      *indexcoord.Lease
	// AttemptName is the per-run attempt directory name (for example
	// run_<nano>). Each attempt must be new: a pre-existing attempt directory
	// is refused, never adopted.
	AttemptName string
}

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

type SQLiteWriteTargetOptions struct {
	Path           string
	IdentityPath   string
	SegmentSetRoot string
	IndexSetID     string
	Authority      *indexcoord.Lease
	MaxMarkerBytes int64
}

type SnapshotSourceKind string

type VerifiedAcquiredBundleReport struct {
	MarkerType             string
	MarkerSchema           string
	HubMarkerSchemaVersion string
	ManifestCreatedAt      time.Time
	IdentityPayload        indexstore.IndexSetIdentityPayload
	ManifestRaw            []byte
}

type VerifiedAcquiredBundleReporter interface {
	VerifiedAcquiredBundleReport() (VerifiedAcquiredBundleReport, error)
}

type VerifiedSnapshotMetadata struct {
	SourceKind                  SnapshotSourceKind
	IndexSetID                  string
	RunID                       string
	RunStart                    BridgeRunStart
	SnapshotTime                BridgeSnapshotTime
	RunStartedAt                time.Time
	SnapshotCompletedAt         time.Time
	SnapshotCompletionSemantics string
	HubCommittedAt              time.Time
	HubCompleteSHA256           string
	SourceIdentitySHA256        string
	SourceIdentitySchema        string
	SourceIdentityProfile       string
	ManifestSHA256              string
	CoverageSHA256              string
	Coverage                    CoverageSummary
	Declared                    DeclaredSnapshotCounts
}

type VerifiedSnapshotMetadataReader interface {
	VerifiedSnapshotMetadata() (VerifiedSnapshotMetadata, error)
}

type VisitObject func(result indexstore.QueryResult) error