internal

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

type AttributeFallbackKind string

type AttributeFallbackMetadata struct {
	Enabled    bool                  `json:"enabled"`
	Kind       AttributeFallbackKind `json:"kind"`
	ColumnType MainColumnType        `json:"column_type"`
	Encoding   MainColumnEncoding    `json:"encoding"`
	Notes      string                `json:"notes"`
}

type AttributeMetadata struct {
	AttributeName string                    `json:"attr_name"`  // attr_name, JSON Path
	AttributeID   int16                     `json:"attr_id"`    // attr_id
	ValueType     ValueType                 `json:"value_type"` // 'text', 'numeric', 'date', 'bool'
	Storage       *AttributeStorageMetadata `json:"storage,omitempty"`
}

type AttributeOrder struct {
	AttrID          int16
	ValueType       ValueType
	SortOrder       forma.SortOrder
	StorageLocation AttributeStorageLocation // main or eav
	ColumnName      string                   // main table column name if StorageLocation == main
}

type AttributeQuery struct {
	SchemaID        int16            `json:"schemaId"`
	Condition       forma.Condition  `json:"condition,omitempty"`
	OrderBy         []forma.OrderBy  `json:"orderBy"`
	AttributeOrders []AttributeOrder `json:"attributeOrders"`
	Limit           int              `json:"limit"`
	Offset          int              `json:"offset"`
}

type AttributeStorageLocation string

type AttributeStorageMetadata struct {
	Location      AttributeStorageLocation  `json:"location"`
	ColumnBinding *MainColumnBinding        `json:"column_binding,omitempty"`
	Fallback      AttributeFallbackMetadata `json:"fallback"`
}

type EAVRecord struct {
	SchemaID     int16
	RowID        uuid.UUID // UUID v7, identifies data row
	AttrID       int16     // Attribute ID from schema definition
	ArrayIndices string    // Comma-separated array indices (e.g., "0", "1,2", or "" for non-arrays)
	ValueText    *string   // For valueType: "text"
	ValueNumeric *float64  // For valueType: "numeric"
}

type EntityAttribute struct {
	SchemaID     int16
	RowID        uuid.UUID // UUID v7, identifies data row
	AttrID       int16
	ArrayIndices string
	ValueType    ValueType
	Value        any
}

type JSONSchema struct {
	ID         int16                      `json:"id"`
	Name       string                     `json:"name"`
	Version    int                        `json:"version"`
	Schema     string                     `json:"schema"`
	Properties map[string]*PropertySchema `json:"properties"`
	Required   []string                   `json:"required"`
	CreatedAt  int64                      `json:"created_at"`
}

type MainColumn string

type MainColumnBinding struct {
	ColumnName MainColumn         `json:"col_name"`
	Encoding   MainColumnEncoding `json:"encoding,omitempty"`
}

type MainColumnEncoding string

type MainColumnType string

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

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

type PersistentRecord struct {
	SchemaID        int16
	RowID           uuid.UUID
	TextItems       map[string]string // e.g., "text_01" -> "Hello"
	Int16Items      map[string]int16
	Int32Items      map[string]int32
	Int64Items      map[string]int64
	Float64Items    map[string]float64
	CreatedAt       int64
	UpdatedAt       int64
	DeletedAt       *int64
	OtherAttributes []EAVRecord // EAV attributes not in hot table
}

type PersistentRecordPage struct {
	Records      []*PersistentRecord
	TotalRecords int64
	TotalPages   int
	CurrentPage  int
}

type PersistentRecordQuery struct {
	Tables          StorageTables
	SchemaID        int16
	Condition       forma.Condition
	AttributeOrders []AttributeOrder
	Limit           int
	Offset          int
}

type PersistentRecordRepository interface {
	InsertPersistentRecord(ctx context.Context, tables StorageTables, record *PersistentRecord) error
	UpdatePersistentRecord(ctx context.Context, tables StorageTables, record *PersistentRecord) error
	DeletePersistentRecord(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) error
	GetPersistentRecord(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) (*PersistentRecord, error)
	QueryPersistentRecords(ctx context.Context, query *PersistentRecordQuery) (*PersistentRecordPage, error)
}

type PersistentRecordTransformer interface {
	ToPersistentRecord(ctx context.Context, schemaID int16, rowID uuid.UUID, jsonData any) (*PersistentRecord, error)
	FromPersistentRecord(ctx context.Context, record *PersistentRecord) (map[string]any, error)
}

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

type PropertySchema struct {
	Name       string                     `json:"name"`
	Type       string                     `json:"type"` // "string", "integer", "number", "boolean", "array", "object", "null"
	Format     string                     `json:"format,omitempty"`
	Items      *PropertySchema            `json:"items,omitempty"`
	Properties map[string]*PropertySchema `json:"properties,omitempty"`
	Required   bool                       `json:"required"`
	Default    any                        `json:"default,omitempty"`
	Enum       []any                      `json:"enum,omitempty"`
	Minimum    *float64                   `json:"minimum,omitempty"`
	Maximum    *float64                   `json:"maximum,omitempty"`
	MinLength  *int                       `json:"minLength,omitempty"`
	MaxLength  *int                       `json:"maxLength,omitempty"`
	Pattern    string                     `json:"pattern,omitempty"`
	Relation   *RelationSchema            `json:"x-relation,omitempty"`
	Storage    string                     `json:"x-storage,omitempty"` // "json" for free-form objects
}

type RelationSchema struct {
	Target string `json:"target"` // Target schema name
	Type   string `json:"type"`   // "reference" for foreign key relationships
}

type SQLGenerator struct{}

type SchemaAttributeCache map[string]AttributeMetadata

type SchemaMetadata struct {
	SchemaName    string              `json:"schema_name"`
	SchemaID      int16               `json:"schema_id"`
	SchemaVersion int                 `json:"schema_version"`
	Attributes    []AttributeMetadata `json:"attributes"`
}

type SchemaRegistry interface {
	GetSchemaByName(name string) (int16, SchemaAttributeCache, error)
	GetSchemaByID(id int16) (string, SchemaAttributeCache, error)
	ListSchemas() []string
}

type Set[T comparable] struct {
	// contains filtered or unexported fields
}

type StorageTables struct {
	EntityMain string
	EAVData    string
}

type Transformer interface {
	// Single object conversion
	ToAttributes(ctx context.Context, schemaID int16, rowID uuid.UUID, jsonData any) ([]EntityAttribute, error)
	FromAttributes(ctx context.Context, attributes []EntityAttribute) (map[string]any, error)

	// Batch operations
	BatchToAttributes(ctx context.Context, schemaID int16, jsonObjects []any) ([]EntityAttribute, error)
	BatchFromAttributes(ctx context.Context, attributes []EntityAttribute) ([]map[string]any, error)

	// Validation
	ValidateAgainstSchema(ctx context.Context, jsonSchema any, jsonData any) error
}

type ValueType string