storage

type Batcher interface {
	BatchCreate(ctx context.Context, entity string, items []map[string]interface{}) ([]int, error)
	BatchDelete(ctx context.Context, entity string, ids []int) error
}

type GraphIntegrity interface {
	VerifyGraphIntegrity(ctx context.Context) error
	RebuildGraph(ctx context.Context) error
}

type GraphNeighbors interface {
	GetNeighbors(ctx context.Context, entity string, id int, direction string) ([]map[string]interface{}, error)
}

type IDGenerator interface {
	NextID(ctx context.Context, entity string) (int, error)
}

type InfoProvider interface {
	Info() StoreInfo
}

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

type Migrator interface {
	Migrate(ctx context.Context) error
	Version(ctx context.Context) (int, error)
}

type SQLiteConfig struct {
	DBPath            string
	EnableWAL         bool // Write-Ahead Logging for better concurrency
	EnableForeignKeys bool
	CacheSize         int  // Page cache size in KB
	BusyTimeout       int  // Milliseconds to wait on locked database
	FullTextEnabled   bool // Enable FTS5 full-text search indexing
}

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

type Searcher interface {
	Search(ctx context.Context, entity string, field string, query string, matchType string) ([]map[string]interface{}, error)
}

type Store interface {
	// Entity CRUD operations
	Create(ctx context.Context, entity string, data map[string]interface{}) (int, error)
	Get(ctx context.Context, entity string, id int) (map[string]interface{}, error)
	Update(ctx context.Context, entity string, id int, data map[string]interface{}) error
	Patch(ctx context.Context, entity string, id int, data map[string]interface{}) error
	Delete(ctx context.Context, entity string, id int) error
	Save(ctx context.Context, entity string, id int, data map[string]interface{}) error

	// Query operations
	List(ctx context.Context, entity string) ([]map[string]interface{}, error)
	Exists(ctx context.Context, entity string, id int) bool
	Search(ctx context.Context, entity string, field string, query string, matchType string) ([]map[string]interface{}, error)

	// Full-text search (optional - may return empty if not supported)
	FullTextSearch(ctx context.Context, query string, entity string) ([]map[string]interface{}, error)

	// Lifecycle
	Close() error
}

type StoreFactory func(config map[string]interface{}) (Store, error)

type StoreInfo struct {
	Type                string // "jsonfile", "sqlite", "postgres", etc.
	Version             string
	SupportsSearch      bool
	SupportsBatch       bool
	SupportsTransaction bool
}

type Transaction interface {
	Store
	Commit() error
	Rollback() error
}

type Transactional interface {
	Store
	Begin(ctx context.Context) (Transaction, error)
}