fabriq

type BlobRef struct {
	ID      string `json:"id"`
	Hash    string `json:"hash"`
	Size    int64  `json:"size"`
	Version int64  `json:"version"`
}

type BlobSourceView struct {
	ID          string            `json:"id"`
	ProjectID   string            `json:"projectId"`
	Name        string            `json:"name"`
	Provider    string            `json:"provider"`
	Endpoint    string            `json:"endpoint"`
	BasePath    string            `json:"basePath"`
	Auth        map[string]any    `json:"auth"`
	WatchConfig map[string]any    `json:"watchConfig"`
	FileFilter  map[string]any    `json:"fileFilter"`
	Tags        map[string]string `json:"tags"`
	Enabled     bool              `json:"enabled"`
	Version     int64             `json:"version"`
}

type CacheConfig struct {
	// L1Enabled gates the per-node LRU tier. Requires Redis.Addr to be set.
	L1Enabled bool `yaml:"l1_enabled" json:"l1_enabled"`
	// L1Size is the maximum number of entries the LRU holds (default 0 = no
	// entries, so always set a positive value when L1Enabled is true).
	L1Size int `yaml:"l1_size" json:"l1_size"`
	// L1TTL is the per-entry time-to-live in the in-process store. It also
	// bounds the cold-start cross-node staleness window: commits that land
	// between Open() returning and the L1 evict tailer's first XRead attach
	// are missed on this node and will remain stale until at most L1TTL
	// elapses. Defaults to 5 minutes when L1Enabled is true and this is <= 0.
	L1TTL time.Duration `yaml:"l1_ttl" json:"l1_ttl"`
}

type Config struct {
	Postgres      PostgresConfig      `yaml:"postgres" json:"postgres"`
	Shards        []ShardConfig       `yaml:"shards" json:"shards"`
	Redis         RedisConfig         `yaml:"redis" json:"redis"`
	FalkorDB      FalkorDBConfig      `yaml:"falkordb" json:"falkordb"`
	Elasticsearch ElasticsearchConfig `yaml:"elasticsearch" json:"elasticsearch"`
	Storage       StorageConfig       `yaml:"storage" json:"storage"`
	Projections   ProjectionsConfig   `yaml:"projections" json:"projections"`
	Subscriptions SubscriptionsConfig `yaml:"subscriptions" json:"subscriptions"`
	Cache         CacheConfig         `yaml:"cache" json:"cache"`
	Encryption    EncryptionConfig    `yaml:"encryption" json:"encryption"`
	// CustomAppliers are consumer-supplied projection appliers, unioned after
	// the built-in declarative applier for their Target. They MUST be pure (see
	// projection.CustomApplier). The same set feeds both the live engines and
	// the rebuilders, so live and rebuilt projections stay identical.
	CustomAppliers []projection.CustomApplier `yaml:"-" json:"-"`
}

type CreateFileOpts struct {
	ContentType string `json:"contentType"`
}

type CreateShareInput struct {
	NodeID       string     `json:"nodeId"`
	Token        string     `json:"token"`
	Permission   string     `json:"permission"`
	ExpiresAt    *time.Time `json:"expiresAt"`
	MaxDownloads *int       `json:"maxDownloads"`
	PasswordHash string     `json:"-"`
	CreatedBy    string     `json:"createdBy"`
}

type ElasticsearchConfig struct {
	Addrs    []string `yaml:"addrs" json:"addrs"`
	Username string   `yaml:"username" json:"username"`
	Password string   `yaml:"password" json:"password"`
}

type EncryptionConfig struct {
	Key string `yaml:"key" json:"key"`
}

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

type FalkorDBConfig struct {
	Addr     string `yaml:"addr" json:"addr"`
	Username string `yaml:"username" json:"username"`
	Password string `yaml:"password" json:"password"`
}

type FsRef struct {
	ID       string `json:"id"`
	ParentID string `json:"parentId"`
	Name     string `json:"name"`
	Path     string `json:"path"`
	NodeType string `json:"nodeType"`
	Version  int64  `json:"version"`
}

type LiveReader interface {
	livequery.Snapshotter
	livequery.Refiller
}

type NotFoundError = fabriqerr.NotFoundError

type Option func(*settings)

type Ports struct {
	Store      command.Store
	Relational query.RelationalQuerier
	Graph      query.GraphQuerier
	Search     query.SearchQuerier
	Timeseries query.TSQuerier
	Vector     query.VectorQuerier
	Spatial    query.SpatialQuerier
	Documents  document.Store
	// Blob is the byte-plane port; nil degrades to ErrStoreNotConfigured.
	Blob blob.Store
	// CAS is the content-addressable store port; nil when EnableCas is false.
	CAS             blob.CAS
	ProjectionState projection.StateReader

	// Live is the snapshot/refill oracle for live queries; when set (and a
	// tailer is configured) the facade exposes LiveQuery.
	Live LiveReader

	// Cache is the engine cache (nil when not configured); enables result-set
	// caching at Repo[T] for opted-in entities.
	Cache cache.Cache
}

type PostgresConfig struct {
	DSN      string `yaml:"dsn" json:"dsn"`
	PoolSize int    `yaml:"pool_size" json:"pool_size"`
}

type ProjectionsConfig struct {
	Graph  bool `yaml:"graph" json:"graph"`
	Search bool `yaml:"search" json:"search"`
}

type PutBlobOpts struct {
	ContentType string `json:"contentType"`
}

type RedisConfig struct {
	Addr     string `yaml:"addr" json:"addr"`
	DB       int    `yaml:"db" json:"db"`
	Username string `yaml:"username" json:"username"`
	Password string `yaml:"password" json:"password"`
}

type ShardConfig struct {
	ID       string `yaml:"id" json:"id"`
	DSN      string `yaml:"dsn" json:"dsn"`
	PoolSize int    `yaml:"pool_size" json:"pool_size"`
}

type ShardPG struct {
	ID string
	PG *postgres.Adapter
}

type SourceInput struct {
	ProjectID   string            `json:"projectId"`
	Name        string            `json:"name"`
	Provider    string            `json:"provider"`
	Endpoint    string            `json:"endpoint"`
	BasePath    string            `json:"basePath"`
	Auth        map[string]any    `json:"auth"`
	WatchConfig map[string]any    `json:"watchConfig"`
	FileFilter  map[string]any    `json:"fileFilter"`
	Tags        map[string]string `json:"tags"`
	Enabled     bool              `json:"enabled"`
}

type SourceRef struct {
	ID      string `json:"id"`
	Version int64  `json:"version"`
}

type StorageConfig struct {
	StorageDriver string `yaml:"storageDriver" json:"storageDriver"`
	DefaultBucket string `yaml:"defaultBucket" json:"defaultBucket"`
	// EnableCas gates the content-addressable store layer. When true, Open()
	// will wire a CASStore backed by the blob_cas ledger (requires a Postgres
	// adapter). The open.go wiring that reads this field lands in Phase 3b.
	EnableCas bool `yaml:"enableCas" json:"enableCas"`
}

type Stores struct {
	// Postgres is the PRIMARY shard: health checks, the migrations CLI, and
	// the document plane (which stays single-shard in step 2) use it. For
	// per-tenant work use Shards / ShardPGs.
	Postgres *postgres.Adapter
	Redis    *redis.Adapter
	Falkor   *falkordb.Adapter
	Elastic  *elastic.Adapter
	Blob     *trovestore.Adapter // nil when Storage not configured
	// CAS is the content-addressable store (nil when EnableCas is false).
	CAS *trovestore.CASStore
	// Cache is the engine cache (nil when Redis is not configured).
	Cache corecache.Cache
	// Shards is the tenant -> source-of-truth routing table backing the
	// facade's relational/command/vector/timeseries/spatial ports (ADR 0007).
	Shards *shard.Set
	// contains filtered or unexported fields
}

type SubscriptionsConfig struct {
	ConflationWindow time.Duration `yaml:"conflation_window" json:"conflation_window"`
	StreamMaxLen     int64         `yaml:"stream_max_len" json:"stream_max_len"`
	SubscribeBuffer  int           `yaml:"subscribe_buffer" json:"subscribe_buffer"`
}

type VersionConflictError = fabriqerr.VersionConflictError