engine

type Cardinality string

type Confidence string

type Discriminator struct {
	PropertyName string `json:"propertyName,omitempty"`
}

type DuplicateIDError struct {
	Entity string
	ID     string
}

type Entity struct {
	Name   string      `json:"name"`
	Fields []Field     `json:"fields"`
	Schema *JSONSchema `json:"schema,omitempty"`
}

type EntityModel struct {
	Entities  []Entity   `json:"entities"`
	Relations []Relation `json:"relations"`
}

type Field struct {
	Name     string      `json:"name"`
	Type     string      `json:"type"` // string|number|integer|boolean|object|array|null
	Format   string      `json:"format,omitempty"`
	IsArray  bool        `json:"isArray"`
	Required bool        `json:"required"`
	Schema   *JSONSchema `json:"schema,omitempty"` // raw (still $ref-bearing) schema
}

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

type JSONSchema struct {
	Ref           string         `json:"$ref,omitempty"`       // e.g. "#/components/schemas/User"; empty if none
	Type          []string       `json:"type,omitempty"`       // normalized to a slice: nil, ["string"], or ["string","null"]
	Format        string         `json:"format,omitempty"`     // "uuid", "email", "date-time", …
	Enum          []any          `json:"enum,omitempty"`       // non-nil ⇒ a closed value set
	Properties    []SchemaProp   `json:"properties,omitempty"` // ordered object properties
	Required      []string       `json:"required,omitempty"`
	Items         *JSONSchema    `json:"items,omitempty"` // element schema when Type includes "array"
	OneOf         []*JSONSchema  `json:"oneOf,omitempty"`
	AnyOf         []*JSONSchema  `json:"anyOf,omitempty"`
	AllOf         []*JSONSchema  `json:"allOf,omitempty"`
	Minimum       *float64       `json:"minimum,omitempty"`
	Maximum       *float64       `json:"maximum,omitempty"`
	MinLength     *int           `json:"minLength,omitempty"`
	MaxLength     *int           `json:"maxLength,omitempty"`
	MinItems      *int           `json:"minItems,omitempty"`
	MaxItems      *int           `json:"maxItems,omitempty"`
	Nullable      bool           `json:"nullable,omitempty"`
	Default       any            `json:"default,omitempty"`
	XRelation     string         `json:"x-relation,omitempty"` // x-relation extension: explicit target entity name
	Discriminator *Discriminator `json:"discriminator,omitempty"`
}

type MaterializeOptions struct {
	Count int // rows per entity; <=0 means the default (5)
}

type MaterializedData = map[string][]Row

type RefIntegrityError struct {
	Entity    string
	Field     string
	MissingID string
	Target    string
}

type Relation struct {
	From        string      `json:"from"`
	Field       string      `json:"field"`
	To          string      `json:"to"`
	Cardinality Cardinality `json:"cardinality"`
	Confidence  Confidence  `json:"confidence"`
	Via         Via         `json:"via"`
	Candidates  []string    `json:"candidates,omitempty"` // abstain edges: targets that could not be disambiguated
}

type RelationShapeError struct {
	Entity string
	Field  string
	Reason string
}

type Row = map[string]any

type SchemaProp struct {
	Name   string      `json:"name"`
	Schema *JSONSchema `json:"schema"`
}

type Snapshot struct {
	Meta SnapshotMeta     `json:"meta"`
	Data MaterializedData `json:"data"`
}

type SnapshotIntegrityError struct {
	Entity string
	Field  string // empty ⇒ omitted from the message
	Reason string
}

type SnapshotMeta struct {
	FormatVersion int            `json:"formatVersion"`
	Fingerprint   string         `json:"fingerprint"`
	SpecVersion   string         `json:"specVersion,omitempty"`
	GeneratedAt   string         `json:"generatedAt"`
	Counts        map[string]int `json:"counts"`
}

type SnapshotVersionError struct {
	Reason string
	Detail string // optional
}

type SpecParseError struct{ Reason string }

type StateStore interface {
	// Model returns the model this store was built from.
	Model() EntityModel
	// Collections returns entity names that have a collection.
	Collections() []string
	// List returns all rows for an entity (clones). Errors on an unknown entity.
	List(ctx context.Context, entity string) ([]Row, error)
	// Get returns a single row by id (clone), or (nil,nil) when absent.
	Get(ctx context.Context, entity, id string) (Row, error)
	// Create inserts a row; a missing id is generated. FK fields are checked.
	Create(ctx context.Context, entity string, data Row) (Row, error)
	// Update shallow-merges a patch; returns (nil,nil) when no such row.
	Update(ctx context.Context, entity, id string, patch Row) (Row, error)
	// Delete removes a row, reporting whether it existed.
	Delete(ctx context.Context, entity, id string) (bool, error)
	// Reset restores every collection to the original materialized seed.
	Reset(ctx context.Context) error
	// Hydrate atomically replaces every collection with pre-validated snapshot
	// data. Callers MUST pass data already validated by DeserializeSnapshot. Does
	// NOT change the reset baseline.
	Hydrate(ctx context.Context, data MaterializedData) error
}

type UnknownEntityError struct{ Entity string }

type Via string