datastore

type ArtifactTypeMap map[string]int32

type Connector interface {
	Type() string
	Connect(spec *Spec) (RepoSet, error)
	RunMigrations(spec *Spec) error
	// Reconnect creates a fresh RepoSet after the database has been recreated
	// (e.g., by RunMigrations recovering from data loss). It must not re-run
	// migrations; callers are responsible for calling RunMigrations first.
	Reconnect(spec *Spec) (RepoSet, error)
}

type ContextTypeMap map[string]int32

type ExecutionTypeMap map[string]int32

type PropertyType int32

type RepoSet interface {
	// TypeMap returns a map of type names to IDs
	TypeMap() map[string]int32
	Repository(t reflect.Type) (any, error)
}

type Spec struct {
	// Maps artifact type names to an initializer.
	ArtifactTypes map[string]*SpecType

	// Maps context type names to an initializer.
	ContextTypes map[string]*SpecType

	// Maps execution type names to an initializer.
	ExecutionTypes map[string]*SpecType

	// Any repo initialization functions that don't map to a type can be
	// added here.
	Others []any
}

type SpecType struct {
	// InitFn is a pointer to an initialization function that returns the
	// repository instance and an optional error.
	//
	// Data Store implementations must pass arguments to the initialization
	// functions that are required by the repository (database handles,
	// HTTP clients, etc.) and should also provide values for the following
	// types:
	//
	//   - int64: type id
	//   - ArtifactTypeMap: Map of all artifact names to type IDs
	//   - ContextTypeMap: Map of all context names to type IDs
	//   - ExecutionTypeMap: Map of all execution names to type IDs
	InitFn any

	// Defined (non-custom) properties of the type.
	Properties map[string]PropertyType
}