const DefaultQueueName = QueueName("Default")

var ErrJobLockedAlready = fmt.Errorf("%w: job might be processing already", postgres.ErrQueryFailed)

type Filter struct {
	Queue   QueueName
	JobType JobType
}

type FinishedJob struct {
	ID         string
	CreatedAt  time.Time
	UpdatedAt  time.Time
	RunAt      time.Time
	Type       JobType
	Queue      QueueName
	Payload    string
	Priority   int16
	RunCount   int32
	RunError   string
	Success    bool
	FinishedAt time.Time
	// contains filtered or unexported fields
}

type Job struct {
	ID         string
	CreatedAt  time.Time
	UpdatedAt  time.Time
	RunAt      time.Time
	Type       JobType
	Queue      QueueName
	Payload    string
	LastError  string
	ErrorCount int32
	Priority   int16
}

type JobType string

type QueueKPIs struct {
	PendingJobsPerType map[string]int
	PendingJobs        int
	FailedJobs         int
	ProcessedJobs      int
	AvailableWorkers   int
	AverageTimePerJob  time.Duration
}

type QueueName string

type QueueNames []QueueName

type QueueStats struct {
	QueueName            QueueName
	PendingJobs          int
	PendingJobsPerType   map[string]int
	FailedJobs           int
	ProcessedJobs        int
	AvailableWorkers     int
	PendingJobsErrorRate float64 // can be calculated: FailedJobs * 100 / PendingJobs
	AverageTimePerJob    time.Duration
	EstimateUntilEmpty   time.Duration // can be calculated
}

type Repository interface {
	FindAllQueueNames(ctx context.Context) (QueueNames, error)
	PendingJobs(ctx context.Context, queue QueueName) ([]Job, error)
	QueueKPIs(ctx context.Context, queue QueueName) (QueueKPIs, error)
	DeleteByID(ctx context.Context, jobID string) error
	RunJobAt(ctx context.Context, jobID string, runAt time.Time) error
	WorkerPools(ctx context.Context) ([]WorkerPool, error)
	Schedules(ctx context.Context) ([]Schedule, error)
	FinishedJobs(ctx context.Context, f Filter) ([]Job, error)
	FinishedJobsTotal(ctx context.Context, f Filter) (int64, error)
}

type Schedule struct {
	Queue   QueueName
	Spec    string
	JobType JobType
	Args    any
}

type WorkerPool struct {
	InstanceName string
	Version      string
	Queue        QueueName
	LastSeenAt   time.Time
	JobTypes     []JobType
	Workers      int
}