protocol

type CancelExecutionRequest struct {
	// Reason is recorded on the cancellation. An empty reason is still a
	// legitimate cancellation; the handler substitutes its own wording.
	Reason string `json:"reason,omitempty"`
}

type CreateInstanceRequest struct {
	Key      InstanceKey    `json:"key"`
	Assembly *core.Assembly `json:"assemblies"`
}

type EventItem struct {
	ID           core.ID `json:"id"`
	Type         string  `json:"type"`
	CapabilityID core.ID `json:"capability_id"`
	Payload      any     `json:"payload"`
}

type ExecuteRequest struct {
	// Params is the free-form data passed to the execution's entry
	// capabilities.
	Params map[string]any `json:"params,omitempty"`
	// Mode selects how the server responds. "detach" returns immediately with
	// the execution accepted (HTTP 202); anything else (empty or "wait") waits
	// for the execution to finish and returns its final result (HTTP 200).
	Mode string `json:"mode,omitempty"`
}

type ExecuteResponse struct {
	ExecutionID core.ID   `json:"execution_id"`
	InstanceID  string    `json:"instance_id"`
	Status      string    `json:"status"`
	Time        time.Time `json:"time"`
}

type ExecutionItem struct {
	ID            core.ID `json:"id"`
	CorrelationID core.ID `json:"correlation_id"`
	Status        string  `json:"status"`
	StartedAt     *int64  `json:"started_at,omitempty"`
	CompletedAt   *int64  `json:"completed_at,omitempty"`
	Error         string  `json:"error,omitempty"`

	// ParentExecutionID is set when this execution took over detached work from
	// another execution in the same instance. It lets a caller walk from a
	// detached task back to the execution whose caller handed the work off.
	ParentExecutionID core.ID `json:"parent_execution_id,omitempty"`
}

type ExecutionResult struct {
	ExecutionID core.ID                   `json:"execution_id"`
	InstanceID  string                    `json:"instance_id"`
	Status      string                    `json:"status"`
	Error       string                    `json:"error,omitempty"`
	Results     map[string]map[string]any `json:"results,omitempty"`
}

type InstanceKey struct {
	AssemblyID string `json:"assembly_id"`
	Version    string `json:"version,omitempty"`
	Hash       string `json:"hash,omitempty"`
	Env        string `json:"env,omitempty"`
}

type InstanceResponse struct {
	ID                string        `json:"id"`
	BlueprintMetadata core.Metadata `json:"blueprint_metadata"`
	Status            string        `json:"status"`
	AssemblyID        string        `json:"assembly_id"`
	Version           string        `json:"version,omitempty"`
	Hash              string        `json:"hash,omitempty"`
	Env               string        `json:"env,omitempty"`
}

type ListOptions struct {
	Status string
	All    bool
}

type RegisterRequest struct {
	Assembly core.Assembly `json:"assembly"`

	// Key is the client-computed identity (AssemblyID, Version, Hash, Env). When
	// provided the server validates Hash matches the assembly content; when
	// empty the server derives the key from the assembly metadata.
	Key InstanceKey `json:"key,omitempty"`

	// ExecutionConfigurations carries opaque capability-runtime-requirement
	// metadata that N.O.R.E. persists alongside the assembly for later runtime
	// assembly.
	ExecutionConfigurations any `json:"execution_configurations,omitempty"`

	// Force clears the registered assembly for the resolved name:version — and
	// removes any instances built from it — before registering the new one.
	Force bool `json:"force,omitempty"`
}

type RegisterResponse struct {
	Key     InstanceKey    `json:"key"`
	Status  RegisterStatus `json:"status"`
	Message string         `json:"message,omitempty"`
}

type RegisterStatus string

type Response struct {
	Message string `json:"message"`
	Status  int    `json:"status"`
	Data    any    `json:"data,omitempty"`
}

type StreamEvent struct {
	ID            core.ID         `json:"id"`
	Type          string          `json:"type"`
	CorrelationID core.ID         `json:"correlation_id,omitempty"`
	CapabilityID  core.ID         `json:"capability_id,omitempty"`
	OccurredAt    int64           `json:"occurred_at"`
	Payload       json.RawMessage `json:"payload,omitempty"`
}