notifications

type DeliveryJob struct {
	ID        string
	TenantID  string
	Channel   string
	Status    string
	CreatedAt time.Time
	UpdatedAt time.Time
}

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

type EmailMessage struct {
	To      string
	Subject string
	Body    string
}

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

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

type Provider interface {
	SendEmail(ctx context.Context, in EmailMessage) error
}

type QueueEmailInput struct {
	TenantID string
	To       string
	Subject  string
	Body     string
}

type Repository interface {
	CreateDelivery(ctx context.Context, in DeliveryJob) (DeliveryJob, error)
	MarkDelivered(ctx context.Context, jobID string) error
	MarkFailed(ctx context.Context, jobID string, reason string) error
}

type Service interface {
	QueueEmail(ctx context.Context, in QueueEmailInput) (DeliveryJob, error)
}