domain

type ArtifactIn struct {
	Name          string `json:"name" binding:"required"`
	URL           string `json:"url,omitempty"`
	ContentBase64 string `json:"contentBase64,omitempty"`
	ContentType   string `json:"contentType,omitempty"`
}

type ArtifactOut struct {
	Name string `json:"name"`
	URL  string `json:"url"`
}

type Command string

type QueueStats struct {
	Command    Command `json:"command"`
	Ready      int64   `json:"ready"`
	Delayed    int64   `json:"delayed"`
	InProgress int64   `json:"inProgress"`
	DLQ        int64   `json:"dlq"`
}

type ResultRecord struct {
	TaskID      string         `json:"taskId"`
	Status      TaskStatus     `json:"status"`
	Result      map[string]any `json:"result,omitempty"`
	Error       string         `json:"error,omitempty"`
	Artifacts   []ArtifactOut  `json:"artifacts,omitempty"`
	CompletedAt time.Time      `json:"completedAt"`
}

type SubmitResultRequest struct {
	WorkerID  string         `json:"workerId,omitempty"`
	Status    TaskStatus     `json:"status" binding:"required"`
	Result    map[string]any `json:"result,omitempty"`
	Error     string         `json:"error,omitempty"`
	Artifacts []ArtifactIn   `json:"artifacts,omitempty"`
}

type Subscription struct {
	ID                 string    `json:"id"`
	CallbackURL        string    `json:"callbackUrl"`
	EventTypes         []Command `json:"eventTypes"`
	DeliveryMode       string    `json:"deliveryMode"`
	GroupID            string    `json:"groupId,omitempty"`
	MinIntervalSeconds int       `json:"minIntervalSeconds"`
	ExpiresAt          time.Time `json:"expiresAt"`
	CreatedAt          time.Time `json:"createdAt"`
}

type Task struct {
	ID          string     `json:"id"`
	Command     Command    `json:"command"`
	Payload     string     `json:"payload"` // JSON string opaco
	Priority    int        `json:"priority,omitempty"`
	Webhook     string     `json:"webhook,omitempty"`
	Status      TaskStatus `json:"status"`
	WorkerID    string     `json:"workerId,omitempty"`
	LeaseUntil  string     `json:"leaseUntil,omitempty"` // RFC3339
	Attempts    int        `json:"attempts,omitempty"`
	MaxAttempts int        `json:"maxAttempts,omitempty"`
	Error       string     `json:"error,omitempty"`
	ResultKey   string     `json:"resultKey,omitempty"`
	CreatedAt   time.Time  `json:"createdAt"`
	UpdatedAt   time.Time  `json:"updatedAt"`
}

type TaskStatus string