sync

type ChunkData struct {
	Sessions     []store.Session      `json:"sessions"`
	Observations []store.Observation  `json:"observations"`
	Prompts      []store.Prompt       `json:"prompts"`
	Mutations    []store.SyncMutation `json:"mutations,omitempty"`
}

type ChunkEntry struct {
	ID        string `json:"id"`         // SHA-256 hash prefix (8 chars) of content
	CreatedBy string `json:"created_by"` // Username or machine identifier
	CreatedAt string `json:"created_at"` // ISO timestamp
	Sessions  int    `json:"sessions"`   // Number of sessions in chunk
	Memories  int    `json:"memories"`   // Number of observations in chunk
	Prompts   int    `json:"prompts"`    // Number of prompts in chunk
}

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

type ImportProgress struct {
	LocalChunks   int
	RemoteChunks  int
	PendingChunks int
	Percentage    int
}

type ImportResult struct {
	ChunksImported       int `json:"chunks_imported"`
	ChunksSkipped        int `json:"chunks_skipped"` // Already imported
	SessionsImported     int `json:"sessions_imported"`
	ObservationsImported int `json:"observations_imported"`
	PromptsImported      int `json:"prompts_imported"`
	RelationsReplayed    int `json:"relations_replayed"`
	RelationsDeferred    int `json:"relations_deferred"`
	RelationsDead        int `json:"relations_dead"`
	// SkippedRelations records relation upserts that were provably
	// unsatisfiable (their referenced observations are permanently absent)
	// and were skipped instead of stalling the import. One entry per edge.
	SkippedRelations []string `json:"skipped_relations,omitempty"`
}

type Manifest struct {
	Version int          `json:"version"`
	Chunks  []ChunkEntry `json:"chunks"`
}

type SyncResult struct {
	ChunkID              string `json:"chunk_id,omitempty"`
	ChunksExported       int    `json:"chunks_exported,omitempty"`
	SessionsExported     int    `json:"sessions_exported"`
	ObservationsExported int    `json:"observations_exported"`
	PromptsExported      int    `json:"prompts_exported"`
	MutationsExported    int    `json:"mutations_exported"`
	IsEmpty              bool   `json:"is_empty"` // true if nothing new to sync
}

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

type Transport interface {
	// ReadManifest returns the manifest (chunk index).
	// Returns an empty manifest if none exists yet.
	ReadManifest() (*Manifest, error)

	// WriteManifest persists the manifest.
	WriteManifest(m *Manifest) error

	// WriteChunk writes a compressed chunk to the transport.
	// chunkID is the content-addressed ID (8 hex chars).
	// data is the raw JSON bytes (FileTransport gzips them; remote sends as-is).
	// entry contains metadata about the chunk.
	WriteChunk(chunkID string, data []byte, entry ChunkEntry) error

	// ReadChunk reads a compressed chunk from the transport.
	// Returns the raw bytes (gzipped for FileTransport, JSON for remote).
	ReadChunk(chunkID string) ([]byte, error)
}

type UpgradeBootstrapOptions struct {
	Project   string
	CreatedBy string
}

type UpgradeBootstrapResult struct {
	Project string
	Stage   string
	Resumed bool
	NoOp    bool
}

type UpgradeDiagnosisInput struct {
	Project         string
	CloudConfigured bool
	ProjectEnrolled bool
	PolicyDenied    bool
}

type UpgradeDiagnosisReport struct {
	Status  string
	Class   string
	Code    string
	Message string
}

type UpgradeLifecycleHooks interface {
	StopForUpgrade(project string) error
	ResumeAfterUpgrade(project string) error
}

type UpgradeRollbackOptions struct {
	Project string
	Hooks   UpgradeLifecycleHooks
}