mailbus

type Config struct {
	DB struct {
		Type string // "bolt", "sqlite", etc.
		Path string
	}

	HTTP struct {
		Addr string
	}

	SMTP struct {
		Host     string
		Port     int
		Username string
		Password string
	}

	Newsletter struct {
		From      string
		Frequency int
		Cron      struct {
			Spec string
		}
		Product struct {
			Name string
		}
		HMAC struct {
			Secret string
		}
	}

	Sentry struct {
		DSN string
	}

	AMQP struct {
		URL string
	}
}

type Database interface {
	Open() error
	Close() error
}

type EmailNewsletterRequest struct {
	Subject string `json:"subject"`
	Body    string `json:"body"`
}

type Error struct {
	Code    string
	Message string
	Op      string
	Err     error
}

type NewsletterService interface {
	SendConfirmationEmail(to, url, token string) error
	SendThankYouEmail(to string) error
	SendNewsletter(subscribers []Subscriber, subject, body string)
	GenerateNewUUID() string
	GetHMACSecret() string
}

type QueueService interface {
	Consume(ctx context.Context, topic string) (<-chan []byte, error)
}

type Subscriber struct {
	ID           int    `storm:"id,increment"`
	Email        string `storm:"unique"`
	Status       string `storm:"index"`
	SubscribedAt time.Time
}

type Subscription struct {
	Email  string
	Status string
	Token  string
}

type SubscriptionRequest struct {
	URL   string `json:"url"`
	Email string `json:"email"`
}

type SubscriptionService interface {
	FindByEmail(email string) (*Subscriber, error)
	Insert(s *Subscription) error
	Update(email, token string) error
	FindByStatus(status string) ([]Subscriber, error)
	Confirm(token string) (string, error)
	Unsubscribe(email string) error
}