var ErrDeleteJobFailed = errors.New("delete job failed")

var ErrGetQueueFailed = errors.New("get queue failed")

var ErrGetWorkersFailed = errors.New("get workers failed")

var ErrJobTypesForQueueFailed = errors.New("job types for queue failed")

var ErrListAllQueuesFailed = errors.New("list all queues failed")

var ErrPruneJobHistoryFailed = errors.New("prune job history failed")

var ErrScheduleJobsFailed = errors.New("schedule jobs failed")

var ErrVacuumJobTableFailed = errors.New("vacuum job table failed")

type App struct {
	PruneJobHistory  app.Request[PruneJobHistoryRequest, PruneJobHistoryResponse]
	VacuumJobTable   app.Request[VacuumJobTableRequest, VacuumJobTableResponse]
	DeleteJob        app.Command[DeleteJobCommand]
	GetQueue         app.Query[GetQueueQuery, GetQueueResponse]
	GetWorkers       app.Query[GetWorkersQuery, GetWorkersResponse]
	JobTypesForQueue app.Query[JobTypesForQueueQuery, []jobs.JobType]
	ListAllQueues    app.Query[ListAllQueuesQuery, ListAllQueuesResponse]
	ScheduleJobs     app.Command[ScheduleJobsCommand]
}

type DeleteJobCommand struct {
	JobID string
}

type GetQueueQuery struct {
	QueueName jobs.QueueName
}

type GetQueueResponse struct {
	Jobs []jobs.Job
	Kpis jobs.QueueKPIs
}

type GetWorkersQuery struct{}

type GetWorkersResponse struct {
	Pool      []jobs.WorkerPool
	Schedules []jobs.Schedule
}

type JobPayload struct {
	// Carrier contains the otel tracing information.
	Carrier propagation.MapCarrier `json:"carrier"`
	// JobData is the actual data as string instead of []byte,
	// so that it is readable more easily when assessing it via psql directly.
	JobData interface{} `json:"jobData"`
}

type JobTypesForQueueQuery struct {
	Queue jobs.QueueName
}

type ListAllQueuesQuery struct{}

type ListAllQueuesResponse struct {
	QueueStats map[jobs.QueueName]jobs.QueueStats
}

type PruneJobHistoryRequest struct {
	Days int
}

type PruneJobHistoryRequestHandler app.Request[PruneJobHistoryRequest, PruneJobHistoryResponse]

type PruneJobHistoryResponse struct {
	Jobs    string
	History string
}

type ScheduleJobsCommand struct {
	RunAt    time.Time
	Queue    string
	JobType  string
	Payload  string
	Count    int
	Priority int16
}

type VacuumJobTableRequest struct {
	Table string
}

type VacuumJobTableResponse struct {
	Jobs    string
	History string
}