contracts

type CapabilityRuntime interface {
	Execute(ctx context.Context, execution ExecutionContext) (map[string]any, error)
}

type CapabilityRuntimeCloser interface {
	Close() error
}

type CapabilityRuntimeRegistry interface {
	Register(runtimeType core2.CapabilityRuntimeType, runtime CapabilityRuntime) error
	Resolve(runtimeType core2.CapabilityRuntimeType) (CapabilityRuntime, error)
}

type Compiler interface {
	Compile(assembly shared.Assembly) (*types.ExecutionBlueprint, error)
}

type EventBus interface {
	Subscribe(eventType event.Type, buffer int) (event.Subscription, error)
	Publish(ctx context.Context, event event.Event) error
	Close() error
}

type ExecutionContext struct {
	ExecutionID   core2.ID
	CorrelationID core2.ID

	Capability core2.Capability
	Params     map[string]any

	// CapabilityConfigurations contains the fully resolved configuration for
	// this single Capability execution. It contains no {{ ... }} placeholders.
	//
	// This is user-authored input to the capability and is deliberately
	// distinct from RuntimeConfig.
	CapabilityConfigurations map[string]any

	// RuntimeConfig is the effective runtime configuration for this single
	// capability invocation: how N.O.R.E. should drive the capability through
	// its declared Capability Runtime. Defaults are already resolved, so every
	// field is populated.
	//
	// It belongs to the runtime engine, not to the capability. Implementations
	// must never merge it into Params or CapabilityConfigurations, and it is
	// never sent to the capability runtime as capability input.
	RuntimeConfig *core2.RuntimeConfig

	// Logger is bound to this capability execution. Use it for any diagnostic
	// output instead of writing to stdout.
	Logger Logger
}

type ExecutionRepository interface {
	Add(execution *executionmodel.Execution) error
	Get(executionID core.ID) (*executionmodel.Execution, bool)
	Save(ctx context.Context, execution *executionmodel.Execution) error
	Delete(executionID core.ID)
	List() []*executionmodel.Execution
	ListByInstance(instanceID core.ID) []*executionmodel.Execution
}

type Field struct {
	Key   string
	Value any
}

type Logger interface {
	Debug(ctx context.Context, message string, fields ...Field)
	Info(ctx context.Context, message string, fields ...Field)
	Warn(ctx context.Context, message string, fields ...Field)
	Error(ctx context.Context, message string, fields ...Field)
}