execution

type Actor struct {
	UserID  uint64
	IsAdmin bool
}

type ActorType string

type AuthorizationInput struct {
	OperationID    string
	RiskLevel      RiskLevel
	Impact         string
	IdempotencyKey string
	RequestHash    string
	Confirmed      bool
	ConfirmationID string
}

type CancelResult struct {
	Status            Status
	Cancellable       bool
	CancellableReason string
}

type CancellationProvider interface {
	RequestCancel(ctx context.Context, execution *Execution, actor Actor) (CancelResult, error)
}

type Confirmation struct {
	ID                 uint64     `json:"-" gorm:"primaryKey;autoIncrement"`
	ConfirmationHash   string     `json:"-" gorm:"size:64;uniqueIndex;not null"`
	OwnerUserID        uint64     `json:"owner_user_id" gorm:"not null;index"`
	OperationID        string     `json:"operation_id" gorm:"size:160;not null;index"`
	IdempotencyKeyHash string     `json:"-" gorm:"size:64;not null"`
	RequestHash        string     `json:"-" gorm:"size:64;not null"`
	RiskLevel          RiskLevel  `json:"risk_level" gorm:"size:4;not null"`
	Impact             string     `json:"impact" gorm:"type:text"`
	ExpiresAt          time.Time  `json:"expires_at" gorm:"not null;index"`
	ConsumedAt         *time.Time `json:"consumed_at,omitempty"`
	CreatedAt          time.Time  `json:"created_at" gorm:"autoCreateTime"`
}

type ConfirmationData struct {
	ConfirmationRequired bool      `json:"confirmation_required"`
	ConfirmationID       string    `json:"confirmation_id"`
	RiskLevel            RiskLevel `json:"risk_level"`
	Impact               string    `json:"impact"`
	ExpiresAt            time.Time `json:"expires_at"`
}

type ConfirmationRequiredError struct {
	ConfirmationID string
	RiskLevel      RiskLevel
	Impact         string
	ExpiresAt      time.Time
}

type CreateInput struct {
	OperationID       string
	OwnerUserID       uint64
	ActorType         ActorType
	Module            string
	ModuleRef         string
	RequestID         string
	IdempotencyKey    string
	RequestHash       string
	RiskLevel         RiskLevel
	Status            Status
	Cancellable       bool
	CancellableReason string
	ClientType        string
	ActorTokenID      *uint64
	TokenPrefix       string
	TokenName         string
	ClientIP          string
	UserAgent         string
	TriggerSource     string
}

type Execution struct {
	ID          uint64    `json:"-" gorm:"primaryKey;autoIncrement"`
	ExecutionID string    `json:"execution_id" gorm:"size:36;uniqueIndex;not null"`
	OperationID string    `json:"operation_id" gorm:"size:160;not null;index;uniqueIndex:idx_execution_idempotency"`
	OwnerUserID uint64    `json:"owner_user_id" gorm:"not null;index;uniqueIndex:idx_execution_idempotency"`
	ActorType   ActorType `json:"actor_type" gorm:"size:16;not null"`
	Module      string    `json:"module" gorm:"size:64;not null;index"`
	ModuleRef   string    `json:"module_ref" gorm:"size:160;index"`
	RequestID   string    `json:"request_id" gorm:"size:64;index"`
	// ClientType 记录发起端（cli/web/api/system），后续 start/result 审计沿用，避免被改写成 system。
	// ClientType records the originating client so later start/result audits keep it instead of rewriting system.
	ClientType string `json:"client_type,omitempty" gorm:"size:20"`
	// ActorTokenID / TokenPrefix / TokenName 保存创建时的 CLI 令牌，供异步 start/result 审计复用。
	// ActorTokenID / TokenPrefix / TokenName keep the creating CLI token for async start/result audits.
	ActorTokenID *uint64 `json:"actor_token_id,omitempty" gorm:"index"`
	TokenPrefix  string  `json:"token_prefix,omitempty" gorm:"size:16"`
	TokenName    string  `json:"token_name,omitempty" gorm:"size:100"`
	// ClientIP / UserAgent 保存创建时的请求归因，供异步审计复用。
	// ClientIP / UserAgent keep create-time request attribution for async audits.
	ClientIP  string `json:"client_ip,omitempty" gorm:"size:45"`
	UserAgent string `json:"user_agent,omitempty" gorm:"size:500"`
	// TriggerSource 区分写入方：request / reconciler / scheduler / dolphin_worker / agent_callback。
	// TriggerSource identifies the writer: request / reconciler / scheduler / dolphin_worker / agent_callback.
	TriggerSource      string     `json:"trigger_source,omitempty" gorm:"size:32"`
	IdempotencyKeyHash *string    `json:"-" gorm:"size:64;uniqueIndex:idx_execution_idempotency"`
	RequestHash        string     `json:"-" gorm:"size:64"`
	RiskLevel          RiskLevel  `json:"risk_level" gorm:"size:4;not null"`
	Status             Status     `json:"status" gorm:"size:32;not null;index"`
	Cancellable        bool       `json:"cancellable" gorm:"not null;default:false"`
	CancellableReason  string     `json:"cancellable_reason,omitempty" gorm:"size:160"`
	Progress           int        `json:"progress" gorm:"not null;default:0"`
	ResultRef          string     `json:"result_ref,omitempty" gorm:"size:500"`
	ErrorCode          string     `json:"error_code,omitempty" gorm:"size:80"`
	ErrorMessage       string     `json:"error_message,omitempty" gorm:"type:text"`
	StartedAt          *time.Time `json:"started_at,omitempty"`
	FinishedAt         *time.Time `json:"finished_at,omitempty"`
	CreatedAt          time.Time  `json:"created_at" gorm:"autoCreateTime;index"`
	UpdatedAt          time.Time  `json:"updated_at" gorm:"autoUpdateTime"`
}

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

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

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

type RequestMetadata struct {
	RequestID      string
	IdempotencyKey string
	Confirmed      bool
	ConfirmationID string
	ClientType     string
}

type Response struct {
	ErrorCode string `json:"error_code,omitempty"`
	ErrorMsg  string `json:"error_msg,omitempty"`
	Data      any    `json:"data,omitempty"`
}

type RiskLevel string

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

type Status string

type SynchronousInput struct {
	OperationID    string
	Module         string
	ModuleRef      string
	RequestID      string
	IdempotencyKey string
	RequestHash    string
	RiskLevel      RiskLevel
	Impact         string
	Confirmed      bool
	ConfirmationID string
	ClientType     string
}

type WaitData struct {
	Execution *Execution `json:"execution"`
	TimedOut  bool       `json:"wait_timed_out"`
}