refinement

type Action string

type AppendRequest struct {
	Key string `json:"key"`
	Plan
	Phase              Phase              `json:"phase"`
	Outcome            Outcome            `json:"outcome"`
	ParentRecordID     string             `json:"parent_record_id,omitempty"`
	RollbackOfRecordID string             `json:"rollback_of_record_id,omitempty"`
	TaskRef            *ExternalReference `json:"task_ref,omitempty"`
	ApprovalRef        *ExternalReference `json:"approval_ref,omitempty"`
	SchemaVersion      int                `json:"schema_version,omitempty"`
	Metadata           map[string]any     `json:"metadata,omitempty"`
}

type AppendResult struct {
	Record   Record
	Replayed bool
}

type ApplyRequest struct {
	OperationID      string
	ProposalRecordID string
	Approval         Approval
}

type ApplyResult struct {
	Assessment  Assessment `json:"assessment"`
	Decision    Record     `json:"decision"`
	Application *Record    `json:"application,omitempty"`
}

type Approval struct {
	Granted   bool
	Reference *ExternalReference
}

type Assessment struct {
	Risk             RiskLevel `json:"risk"`
	RequiresApproval bool      `json:"requires_approval"`
	Reasons          []string  `json:"reasons"`
}

type AuditAuthorizer interface {
	AuthorizeRefinementAudit(context.Context, protocol.MessageAddress, protocol.ChatMessage) error
}

type Edit struct {
	Action       Action       `json:"action"`
	ResourceKind ResourceKind `json:"resource_kind"`
	ResourceKey  string       `json:"resource_key"`
	ResourceID   string       `json:"resource_id,omitempty"`
	ExpectedETag string       `json:"expected_etag,omitempty"`
	BeforeETag   string       `json:"before_etag,omitempty"`
	AfterETag    string       `json:"after_etag,omitempty"`
	Reason       string       `json:"reason"`
	// Content is the desired authority-neutral resource document for create and
	// replace actions. Delete and restore actions leave it empty; restore asks
	// the authority to reactivate the exact tombstoned head.
	Content map[string]any    `json:"content,omitempty"`
	Before  *ResourceSnapshot `json:"before,omitempty"`
	After   *ResourceSnapshot `json:"after,omitempty"`
	Applied *bool             `json:"applied,omitempty"`
	Error   string            `json:"error,omitempty"`
}

type Evidence struct {
	Kind        EvidenceKind `json:"kind"`
	Reference   string       `json:"reference"`
	Description string       `json:"description"`
	ContentHash string       `json:"content_hash,omitempty"`
}

type EvidenceKind string

type ExternalReference struct {
	System    string `json:"system"`
	ID        string `json:"id"`
	AttemptID string `json:"attempt_id,omitempty"`
}

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

type Mutation struct {
	Before   *ResourceSnapshot `json:"before,omitempty"`
	After    *ResourceSnapshot `json:"after,omitempty"`
	Replayed bool              `json:"replayed,omitempty"`
}

type Outcome string

type Page struct {
	Records       []Record `json:"records"`
	NextPageToken string   `json:"next_page_token,omitempty"`
	ScannedCount  int      `json:"scanned_count"`
	ScanTruncated bool     `json:"scan_truncated,omitempty"`
}

type Phase string

type Plan struct {
	RefinementID    string     `json:"refinement_id"`
	Trigger         string     `json:"trigger"`
	Scope           Scope      `json:"scope"`
	Summary         string     `json:"summary"`
	Rationale       string     `json:"rationale"`
	ExpectedOutcome string     `json:"expected_outcome"`
	Evidence        []Evidence `json:"evidence"`
	Edits           []Edit     `json:"edits"`
}

type Policy struct {
	AllowSessionLowRiskWithoutApproval bool
}

type ProposalResult struct {
	Record     Record     `json:"record"`
	Assessment Assessment `json:"assessment"`
	Replayed   bool       `json:"replayed"`
}

type ProposeRequest struct {
	OperationID        string
	Key                string
	Plan               Plan
	RollbackOfRecordID string
	TaskRef            *ExternalReference
	Metadata           map[string]any
}

type Query struct {
	Phases        []Phase        `json:"phases,omitempty"`
	Outcomes      []Outcome      `json:"outcomes,omitempty"`
	Scopes        []Scope        `json:"scopes,omitempty"`
	ResourceKinds []ResourceKind `json:"resource_kinds,omitempty"`
	RefinementID  string         `json:"refinement_id,omitempty"`
	Text          string         `json:"text,omitempty"`
	Limit         int            `json:"limit,omitempty"`
	PageToken     string         `json:"page_token,omitempty"`
}

type Record struct {
	ID          string `json:"id"`
	WorkspaceID string `json:"workspace_id"`
	AppendRequest
	Revision  int    `json:"revision"`
	ETag      string `json:"etag"`
	CreatedAt string `json:"created_at"`
}

type ResourceEditor interface {
	Apply(ctx context.Context, workspaceID, operationID string, edit Edit) (Mutation, error)
}

type ResourceKind string

type ResourceSnapshot struct {
	ResourceID    string         `json:"resource_id,omitempty"`
	ResourceKey   string         `json:"resource_key"`
	ETag          string         `json:"etag,omitempty"`
	SchemaVersion int            `json:"schema_version,omitempty"`
	Content       map[string]any `json:"content,omitempty"`
	Metadata      map[string]any `json:"metadata,omitempty"`
	Deleted       bool           `json:"deleted,omitempty"`
}

type RiskLevel string

type Scope string

type Service struct {
	Store           Store
	Editors         map[ResourceKind]ResourceEditor
	Policy          Policy
	AuditAuthority  string
	AuditAuthorizer AuditAuthorizer
}

type Store interface {
	Append(ctx context.Context, workspaceID, operationID string, request AppendRequest) (AppendResult, error)
	Get(ctx context.Context, workspaceID, recordID string) (Record, error)
	// Query returns one bounded newest-first authority page.
	Query(ctx context.Context, workspaceID string, query Query) (Page, error)
}