sdk

type AComponentController = ComponentController[RawJSON]

type AResourceController = ResourceController[RawJSON]

type ComponentConfig struct {
	ID   string `json:"id"`
	Type string `json:"type"`
	Name string `json:"name"`

	RawSpec  cue.Value `json:"spec"`
	RawModel RawJSON   `json:"model"`

	Run         bool
	Environment map[string]string `json:"environment"`

	Resources map[string]ComponentConfigResource `json:"resources"`
}

type ComponentConfigResource struct {
	ID   string  `json:"id"`
	Type string  `json:"type"`
	IRI  *string `json:"iri,omitempty"`
}

type ComponentController[Model any] interface {
	// Returns a list of desired child components.
	// Called on each iteration of the reconciliation loop.
	RenderComponent(context.Context, *ComponentConfig, *Model) ([]RenderedComponent, error)
	// Called periodically to read state from underlying resources.
	RefreshComponent(context.Context, *ComponentConfig, *Model) error
	// Called after a component has been changed, but before reconciling children.
	ComponentUpdated(context.Context, *ComponentConfig, *Model) error
	// Called when a batch of one or more children have processed the
	// ComponentUpdated hook.
	ChildrenUpdated(context.Context, *ComponentConfig, *Model) error
	// Perform a blocking graceful shutdown of a component.
	ShutdownComponent(context.Context, *ComponentConfig, *Model) error
	// Deletes any associated external resources.
	DeleteComponent(context.Context, *ComponentConfig, *Model) error
}

type ComponentControllerAdapter[Model any] struct {
	// contains filtered or unexported fields
}

type PureComponentController[Model any] struct{}

type RenderedComponent struct {
	Type        string
	Name        string
	Key         string
	Spec        any
	Environment JSONObject
}

type ResourceComponentController struct {
	AResourceController
	// contains filtered or unexported fields
}

type ResourceConfig struct {
	ID   string  `json:"id"`
	Type string  `json:"type"`
	IRI  *string `json:"iri,omitempty"`
}

type ResourceController[Model any] interface {
	IdentifyResource(context.Context, *ResourceConfig, *Model) (string, error)
	CreateResource(context.Context, *ResourceConfig, *Model) error
	ReadResource(context.Context, *ResourceConfig, *Model) error
	UpdateResource(ctx context.Context, cfg *ResourceConfig, prev *Model, next *Model) error
	ShutdownResource(context.Context, *ResourceConfig, *Model) error
	DeleteResource(context.Context, *ResourceConfig, *Model) error
}

type ResourceControllerAdapater[Model any] struct {
	// contains filtered or unexported fields
}