gateways

type BaseService struct {
	Client *http.Client
}

type Bloodlines interface {
	GetAllContent(offset int, limit int) ([]*models.Content, error)
	NewContent(newContent *models.Content) (*models.Content, error)
	GetContentByID(id uuid.UUID) (*models.Content, error)
	UpdateContent(update *models.Content) (*models.Content, error)
	DeleteContent(id uuid.UUID) error
	GetAllReceipts(offset int, limit int) ([]*models.Receipt, error)
	SendReceipt(receipt *models.Receipt) (*models.Receipt, error)
	GetReceiptByID(id uuid.UUID) (*models.Receipt, error)
	GetAllTriggers(offset int, limit int) ([]*models.Trigger, error)
	NewTrigger(t *models.Trigger) (*models.Trigger, error)
	GetTriggerByKey(key string) (*models.Trigger, error)
	UpdateTrigger(update *models.Trigger) (*models.Trigger, error)
	DeleteTrigger(key string) error
	ActivateTrigger(key string, receipt *models.Receipt) (*models.SendRequest, error)
	NewPreference(id uuid.UUID) (*models.Preference, error)
	GetPreference(id uuid.UUID) (*models.Preference, error)
	UpdatePreference(*models.Preference) (*models.Preference, error)
	DeletePreference(id uuid.UUID) error
}

type MySQL struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

type Rabbit struct {
	Conn    *amqp.Connection
	Channel *amqp.Channel
	Queue   *amqp.Queue
	Config  config.Rabbit
}

type RabbitI interface {
	Produce(interface{}) error
	Consume() (<-chan amqp.Delivery, error)
	Destroy()
}

type S3 interface {
	Upload(bucket, name string, body io.Reader) (string, error)
}

type SQL interface {
	Modify(string, ...interface{}) error
	Select(string, ...interface{}) (*sql.Rows, error)
	Destroy()
}

type Sendgrid struct {
	// contains filtered or unexported fields
}

type SendgridI interface {
	SendEmail(string, string, string) error
}

type ServiceResponse struct {
	Msg     string      `json:"message,omitempty"`
	Data    interface{} `json:"data,omitempty"`
	Success bool        `json:"success,omitempty"`
}