queues

type Config struct {
	AwsKey               string
	AwsSecret            string
	AwsRegion            string
	GdprQueueUrl         string
	CmsQueueUrl          string
	GdprCallbackQueueUrl string
	GdprBucket           string
	GdprBasePath         string
	SqsMaxMessages       int
	TimeWaitSeconds      int
}

type Context struct {
	Logger       logrus.FieldLogger
	Database     *db.Database
	UserPlayhead *model.UserPlayhead
	User         *model.User
}

type PublishMessage struct {
	UserUUID     string `json:"user_uuid" binding:"required"`
	S3Location   string `json:"s3_url" binding:"required"`
	RequestID    string `json:"request_id" binding:"required"`
	RequestType  string `json:"request_type" binding:"required"`
	ServiceName  string `json:"service_name" binding:"required"`
	ErrorMessage string `json:"error_message"`
	Success      bool   `json:"success" binding:"required"` // "true" || "false"
}

type QMessage struct {
	Subject     string `json:"Subject"`
	Message     string `json:"Message"`
	MessageBody QMessageBody
}

type QMessageBody struct {
	UserUUID    string `json:"user_uuid" binding:"required"`
	RequestID   string `json:"request_id" binding:"required"`
	RequestType string `json:"request_type" binding:"required"`
	ServiceName string `json:"service_name" binding:"required"`
}

type Queue struct {
	Config   *Config
	Database *db.Database
	Context  *Context
}