service

type ACOConfig struct {
	Model              string
	Pattern            string   `conf:"name_pattern"`
	PerfYearTransition string   `conf:"performance_year_transition"`
	LookbackYears      int      `conf:"lookback_period"`
	Disabled           bool     `conf:"disabled" conf_default:"false"`
	Data               []string `conf:"data"`
	// contains filtered or unexported fields
}

type CCLFNotFoundError struct {
	FileNumber int
	CMSID      string
	FileType   models.CCLFFileType
	CutoffTime time.Time
}

type Config struct {
	SuppressionLookbackDays int `conf:"BCDA_SUPPRESSION_LOOKBACK_DAYS" conf_default:"60"`
	CutoffDurationDays      int `conf:"CCLF_CUTOFF_DATE_DAYS" conf_default:"45"`

	AlrJobSize uint `conf:"alr_job_size" conf_default:"1000"` // Number of entries to put in a single ALR job

	// Use the squash tag to allow the RunoutConfigs to avoid requiring the parameters
	// to be defined as a child of RunoutConfig.
	// Ex: Without the ,squash, we would have to have RunoutConfig.RUNOUT_CUTOFF_DATE_DAYS
	// With the ,squash, we would have RUNOUT_CUTOFF_DATE_DAYS.
	RunoutConfig RunoutConfig `conf:",squash"`

	ACOConfigs []ACOConfig `conf:"aco_config"`
	// contains filtered or unexported fields
}

type DataType struct {
	Adjudicated          bool
	PartiallyAdjudicated bool
}

type JobsNotFoundError struct {
	ACOID       uuid.UUID
	StatusTypes []models.JobStatus
}

type MockService struct {
	mock.Mock
}

type RequestConditions struct {
	ReqType   RequestType
	Resources []string

	CMSID string
	ACOID uuid.UUID

	JobID           uint
	Since           time.Time
	TransactionTime time.Time
	CreationTime    time.Time
	// contains filtered or unexported fields
}

type RequestType uint8

type RunoutConfig struct {
	CutoffDurationDays int    `conf:"RUNOUT_CUTOFF_DATE_DAYS" conf_default:"180"`
	ClaimThruDate      string `conf:"RUNOUT_CLAIM_THRU_DATE" conf_default:"2020-12-31"`
	// contains filtered or unexported fields
}

type Service interface {
	GetQueJobs(ctx context.Context, conditions RequestConditions) (queJobs []*models.JobEnqueueArgs, err error)

	GetAlrJobs(ctx context.Context, alrMBI *models.AlrMBIs) []*models.JobAlrEnqueueArgs

	GetJobAndKeys(ctx context.Context, jobID uint) (*models.Job, []*models.JobKey, error)

	GetJobKey(ctx context.Context, jobID uint, filename string) (*models.JobKey, error)

	GetJobs(ctx context.Context, acoID uuid.UUID, statuses ...models.JobStatus) ([]*models.Job, error)

	CancelJob(ctx context.Context, jobID uint) (uint, error)

	GetJobPriority(acoID string, resourceType string, sinceParam bool) int16

	GetLatestCCLFFile(ctx context.Context, cmsID string, fileType models.CCLFFileType) (*models.CCLFFile, error)

	GetACOConfigForID(cmsID string) (*ACOConfig, bool)
}