storage

type APIStorage interface {
	GetClaimedJobs(limit int, offset int) []*job.Job
	GetClaimedJobsExecutions(jobId uuid.UUID, limit int, offset int) []*job.JobExecution
	Connected() bool
	GetSSLVersion() (bool, string)
	CreateJob(j CreateJobInput) error
	UpdateJob(j UpdateJobInput) error
}

type Closer func()

type CreateJobInput struct {
	Name            string            `json:"name"`
	CronExpString   string            `json:"cronexp"`
	MaxRetries      int               `json:"maxRetries"`
	Endpoint        string            `json:"endpoint"`
	HttpMethod      string            `json:"httpmethod"`
	Headers         map[string]string `json:"headers"`
	SuccessStatuses []int             `json:"successStatuses"`
	AlertStrategy   string            `json:"alertStrategy"`
	AlertMethod     string            `json:"alertMethod"`
	AlertEndpoint   string            `json:"alertEndpoint"`
	AlertPayload    string            `json:"alertPayload"`
	AlertHeaders    map[string]string `json:"alertHeaders"`
}

type JobUpdates struct {
	Job_name         string
	Cron_exp_string  string
	Endpoint         string
	Httpmethod       string
	Max_retries      int
	Headers_string   string
	Success_statuses []int
	Tls_client_cert  string
	Alert_strategy   string
	Alert_endpoint   string
	Alert_method     string
	Updated_at       int64
}

type SQLStorage struct {
	Db *pgxpool.Pool
}

type SchedulerStorage interface {
	ListenForChanges(ch chan uuid.UUID, ctx context.Context)
	StopListeningForChanges() error
	GetJobUpdates(jobId uuid.UUID) *JobUpdates
	GetAvailableJobs(limit int) []*job.Job
	WriteDone(*job.Job) error
	RegisterSelf()
	GetClient() *pgxpool.Pool
	ReleaseAll(j []*job.Job) error
}

type Storage interface {
	SchedulerStorage
	APIStorage
}

type UpdateJobInput struct {
	Id              uuid.UUID         `json:"id"`
	Name            string            `json:"name"`
	CronExpString   string            `json:"cronexp"`
	MaxRetries      int               `json:"maxRetries"`
	Endpoint        string            `json:"endpoint"`
	HttpMethod      string            `json:"httpmethod"`
	Headers         map[string]string `json:"headers"`
	SuccessStatuses []int             `json:"successStatuses"`
	AlertStrategy   string            `json:"alertStrategy"`
	AlertMethod     string            `json:"alertMethod"`
	AlertEndpoint   string            `json:"alertEndpoint"`
	AlertPayload    string            `json:"alertPayload"`
	AlertHeaders    map[string]string `json:"alertHeaders"`
}