lib

type CheckTask struct {
	Error string
	Done  bool
}

type Config struct {
	Amqp         string
	QueueSuffix  string
	ConsumeQueue string
	ResultsQueue string
	FailedQueue  string

	LogFile   string
	LogLevel  string
	VerifySSL bool

	Services map[string][]string

	// stuff for feed
	FeedPrefetchCount int

	// stuff for check
	CheckPrefetchCount  int
	WaitBetweenRequests int

	// stuff for submit
	SubmitPrefetchCount int
}

type Ctx struct {
	Config *Config

	Debug   *log.Logger
	Info    *log.Logger
	Warning *log.Logger

	AmqpConn *amqp.Connection
	Client   *http.Client

	Failed *QueueHandler
}

type ExternalRequest struct {
	PrimaryURI   string              `json:"primaryURI"`
	SecondaryURI string              `json:"secondaryURI"`
	Filename     string              `json:"filename"`
	Tasks        map[string][]string `json:"tasks"`
	Tags         []string            `json:"tags"`
	Comment      string              `json:"comment"`
	Download     bool                `json:"download"`
	Source       string              `json:"source"`
	Attempts     int                 `json:"attempts"`
}

type FailedMsg struct {
	Queue string
	Error string
	Desc  string
	Msg   string
}

type InternalRequest struct {
	Service         string
	URL             string
	TaskID          string
	FilePath        string
	Started         time.Time
	OriginalRequest *ExternalRequest
}

type NewTask struct {
	Error  string
	TaskID string
}

type QueueHandler struct {
	Queue   string
	Channel *amqp.Channel
	C       *Ctx
}

type Service struct {
	Name   string
	URL    string
	Client *http.Client
}

type Status struct {
	Degraded  bool
	Error     string
	FreeSlots int
}

type TaskResults struct {
	Error   string
	Results interface{}
}