write

type DeleteHandler struct{}

type DeleteInput struct {
	Rows []*MutableRunView `parameter:",kind=body,in=data"`
}

type DeleteOutput struct {
	response.Status `parameter:",kind=output,in=status" json:",omitempty"`
}

type Handler struct{}

type Input struct {
	Runs []*MutableRunView `parameter:",kind=body,in=data"`

	CurIDs *struct{ Values []string } `parameter:",kind=param,in=Runs,dataType=run/write.MutableRunViews" codec:"structql,uri=sql/cur_ids.sql"`

	Cur []*MutableRunView `parameter:",kind=view,in=Cur" view:"Cur" sql:"uri=sql/cur_run.sql"`

	CurByID map[string]*MutableRunView
}

type MutableRunView struct {
	Id                    string     `sqlx:"id,primaryKey" validate:"required"`
	TurnID                *string    `sqlx:"turn_id" json:",omitempty"`
	ScheduleID            *string    `sqlx:"schedule_id" json:",omitempty"`
	ConversationID        *string    `sqlx:"conversation_id" json:",omitempty"`
	ConversationKind      *string    `sqlx:"conversation_kind" json:",omitempty"`
	Attempt               *int       `sqlx:"attempt" json:",omitempty"`
	ResumedFromRunID      *string    `sqlx:"resumed_from_run_id" json:",omitempty"`
	Status                string     `sqlx:"status" validate:"required"`
	ErrorCode             *string    `sqlx:"error_code" json:",omitempty"`
	ErrorMessage          *string    `sqlx:"error_message" json:",omitempty"`
	Iteration             *int       `sqlx:"iteration" json:",omitempty"`
	MaxIterations         *int       `sqlx:"max_iterations" json:",omitempty"`
	CheckpointResponseID  *string    `sqlx:"checkpoint_response_id" json:",omitempty"`
	CheckpointMessageID   *string    `sqlx:"checkpoint_message_id" json:",omitempty"`
	CheckpointData        *string    `sqlx:"checkpoint_data" json:",omitempty"`
	AgentID               *string    `sqlx:"agent_id" json:",omitempty"`
	ModelProvider         *string    `sqlx:"model_provider" json:",omitempty"`
	Model                 *string    `sqlx:"model" json:",omitempty"`
	WorkerID              *string    `sqlx:"worker_id" json:",omitempty"`
	WorkerPID             *int       `sqlx:"worker_pid" json:",omitempty"`
	WorkerHost            *string    `sqlx:"worker_host" json:",omitempty"`
	LeaseOwner            *string    `sqlx:"lease_owner" json:",omitempty"`
	LeaseUntil            *time.Time `sqlx:"lease_until" json:",omitempty"`
	LastHeartbeatAt       *time.Time `sqlx:"last_heartbeat_at" json:",omitempty"`
	SecurityContext       *string    `sqlx:"security_context" json:",omitempty"`
	UserCredURL           *string    `sqlx:"user_cred_url" json:",omitempty"`
	EffectiveUserID       *string    `sqlx:"effective_user_id" json:",omitempty"`
	AuthAuthority         *string    `sqlx:"auth_authority" json:",omitempty"`
	AuthAudience          *string    `sqlx:"auth_audience" json:",omitempty"`
	HeartbeatIntervalSec  *int       `sqlx:"heartbeat_interval_sec" json:",omitempty"`
	ScheduledFor          *time.Time `sqlx:"scheduled_for" json:",omitempty"`
	PreconditionRanAt     *time.Time `sqlx:"precondition_ran_at" json:",omitempty"`
	PreconditionPassed    *int       `sqlx:"precondition_passed" json:",omitempty"`
	PreconditionResult    *string    `sqlx:"precondition_result" json:",omitempty"`
	UsagePromptTokens     *int       `sqlx:"usage_prompt_tokens" json:",omitempty"`
	UsageCompletionTokens *int       `sqlx:"usage_completion_tokens" json:",omitempty"`
	UsageTotalTokens      *int       `sqlx:"usage_total_tokens" json:",omitempty"`
	UsageCost             *float64   `sqlx:"usage_cost" json:",omitempty"`
	CreatedAt             *time.Time `sqlx:"created_at" json:",omitempty"`
	UpdatedAt             *time.Time `sqlx:"updated_at" json:",omitempty"`
	StartedAt             *time.Time `sqlx:"started_at" json:",omitempty"`
	CompletedAt           *time.Time `sqlx:"completed_at" json:",omitempty"`
	Has                   *RunHas    `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
	// Condition, when set, turns this sparse update into an atomic
	// compare-and-set (see RunPatchCondition). It is not a column.
	Condition *RunPatchCondition `sqlx:"-" diff:"-" json:",omitempty"`
}

type MutableRunViewOption func(*MutableRunView)

type MutableRunViews struct {
	Runs []*MutableRunView
}

type Output struct {
	response.Status `parameter:",kind=output,in=status" anonymous:"true"`
	Data            []*MutableRunView      `parameter:",kind=body"`
	Violations      []*validator.Violation `parameter:",kind=transient"`
}

type RunHas struct {
	Id                    bool
	TurnID                bool
	ScheduleID            bool
	ConversationID        bool
	ConversationKind      bool
	Attempt               bool
	ResumedFromRunID      bool
	Status                bool
	ErrorCode             bool
	ErrorMessage          bool
	Iteration             bool
	MaxIterations         bool
	CheckpointResponseID  bool
	CheckpointMessageID   bool
	CheckpointData        bool
	AgentID               bool
	ModelProvider         bool
	Model                 bool
	WorkerID              bool
	WorkerPID             bool
	WorkerHost            bool
	LeaseOwner            bool
	LeaseUntil            bool
	LastHeartbeatAt       bool
	HeartbeatIntervalSec  bool
	SecurityContext       bool
	UserCredURL           bool
	EffectiveUserID       bool
	ScheduledFor          bool
	PreconditionRanAt     bool
	PreconditionPassed    bool
	PreconditionResult    bool
	UsagePromptTokens     bool
	UsageCompletionTokens bool
	UsageTotalTokens      bool
	UsageCost             bool
	CreatedAt             bool
	UpdatedAt             bool
	StartedAt             bool
	CompletedAt           bool
}

type RunPatchCondition struct {
	// Status is the expected current run status (required for claim shapes).
	Status string `json:",omitempty"`
	// LeaseOwner is the expected current lease owner. nil means "no owner
	// criterion" (legacy rows with NULL lease_owner); it must be combined
	// with Status and Attempt.
	LeaseOwner *string `json:",omitempty"`
	// Attempt is the expected current attempt.
	Attempt *int `json:",omitempty"`
}