repository

type Entity interface {
	// TableName returns the database table name for this entity
	// This should match GORM's table naming convention
	// If not implemented, GORM's default naming will be used
	TableName() string

	// GetPrimaryKeyValue returns the actual value of the primary key
	// Used for cache invalidation and dependency tracking
	// If not implemented, reflection will be used to find 'ID' field
	GetPrimaryKeyValue() interface{}
}

type GenericRepository[T Entity] struct {
	// contains filtered or unexported fields
}

type RelatedEntity struct {
	EntityType string      // The related entity type (table name)
	EntityID   interface{} // The related entity ID (nil for has_many without specific ID)
}

type RelationshipAware interface {
	Entity

	// GetRelationships returns a map of relationship types to related entity info
	// Format: map[relationType][]RelatedEntity
	// Example: {"belongs_to": [{"customer", customerID}], "has_many": [{"orders", nil}]}
	GetRelationships() map[string][]RelatedEntity
}

type Repository[T any] interface {
	// Queries (Read Operations - Cache-First)
	// Returns: (result, cacheHit, cacheStored, error)
	// - cacheHit: true if data retrieved from Redis cache
	// - cacheStored: true if data successfully stored to Redis after DB query
	FindByID(ctx context.Context, id interface{}) (*T, bool, bool, error)
	FindAll(ctx context.Context) ([]T, bool, bool, error)
	FindWhere(ctx context.Context, query interface{}, args ...interface{}) ([]T, bool, bool, error)
	First(ctx context.Context, query interface{}, args ...interface{}) (*T, bool, bool, error)
	Count(ctx context.Context) (int64, bool, bool, error)
	Exists(ctx context.Context, id interface{}) (bool, bool, bool, error)

	// GORM Query Methods (Cached)
	Preload(ctx context.Context, associations ...string) Repository[T]
	Joins(ctx context.Context, query string, args ...interface{}) Repository[T]
	Order(ctx context.Context, value interface{}) Repository[T]
	Limit(ctx context.Context, limit int) Repository[T]
	Offset(ctx context.Context, offset int) Repository[T]

	// Commands (Write Operations - Relationship-Aware Cache Invalidation)
	// Returns: (cacheInvalidated, error)
	// - cacheInvalidated: true if related caches were successfully invalidated
	Create(ctx context.Context, entity *T) (bool, error)
	Update(ctx context.Context, entity *T) (bool, error)
	Delete(ctx context.Context, id interface{}) (bool, error)

	// Batch Operations
	CreateBatch(ctx context.Context, entities []*T) error
	UpdateBatch(ctx context.Context, entities []*T) error

	// Cache Management
	InvalidateCache(ctx context.Context) error
	WarmCache(ctx context.Context) error
}