compensation

type APIRollbackHandler interface {
	RollbackAPI(ctx context.Context, input APIRollbackInput) error
}

type APIRollbackInput struct {
	RollbackInput
	Endpoint         string            `json:"endpoint"`
	Method           string            `json:"method"`
	RequestID        string            `json:"requestId,omitempty"`
	CompensateURL    string            `json:"compensateUrl,omitempty"`
	CompensateMethod string            `json:"compensateMethod,omitempty"`
	Headers          map[string]string `json:"headers,omitempty"`
}

type AgentRollbackHandler interface {
	RollbackAgent(ctx context.Context, input AgentRollbackInput) error
}

type AgentRollbackInput struct {
	RollbackInput
	AgentType  string          `json:"agentType"`
	AgentName  string          `json:"agentName"`
	OutputPath string          `json:"outputPath,omitempty"`
	Output     json.RawMessage `json:"output,omitempty"`
}

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

type DatabaseRollbackHandler interface {
	RollbackDatabase(ctx context.Context, input DatabaseRollbackInput) error
}

type DatabaseRollbackInput struct {
	RollbackInput
	Collection   string          `json:"collection"`
	DocumentID   string          `json:"documentId"`
	Operation    string          `json:"operation"` // "insert", "update", "delete"
	PreviousData json.RawMessage `json:"previousData,omitempty"`
}

type DefaultAPIRollbackHandler struct{}

type DefaultAgentRollbackHandler struct{}

type DefaultDatabaseRollbackHandler struct{}

type DefaultFileRollbackHandler struct{}

type DefaultNotificationRollbackHandler struct{}

type FileRollbackHandler interface {
	RollbackFile(ctx context.Context, input FileRollbackInput) error
}

type FileRollbackInput struct {
	RollbackInput
	FilePath        string          `json:"filePath"`
	Operation       string          `json:"operation"` // "create", "update", "delete"
	OriginalContent json.RawMessage `json:"originalContent,omitempty"`
	BackupPath      string          `json:"backupPath,omitempty"`
}

type NotificationRollbackHandler interface {
	RollbackNotification(ctx context.Context, input NotificationRollbackInput) error
}

type NotificationRollbackInput struct {
	RollbackInput
	NotificationType string   `json:"notificationType"` // "email", "webhook", "sms"
	NotificationID   string   `json:"notificationId"`
	Recipients       []string `json:"recipients,omitempty"`
}

type RollbackInput struct {
	WorkflowID   string            `json:"workflowId"`
	ActivityName string            `json:"activityName"`
	ResourceID   string            `json:"resourceId,omitempty"`
	ResourceType string            `json:"resourceType,omitempty"`
	Metadata     map[string]string `json:"metadata,omitempty"`
	OriginalData json.RawMessage   `json:"originalData,omitempty"`
}

type RollbackOutput struct {
	Success  bool   `json:"success"`
	Message  string `json:"message,omitempty"`
	Error    string `json:"error,omitempty"`
	Rollback bool   `json:"rollback"` // Indicates this was a rollback operation
}