tasks

var Send = delay.Func("email-send", func(c context.Context, in integration.Integration, message *email.Message) error {
	log.Debug("Sending email to %s, %v", message.To[0], message, c)

	provider, err := getEmailSender(c, in)
	if err != nil {
		return log.Error("Email provider integration not found: %v", err, c)
	}

	err = provider.Send(message)
	if err != nil {
		return log.Error("Email provider error: %v", err, c)
	}

	return nil
})

var Subscribe = delay.Func("email-subscribe", func(c context.Context, in integration.Integration, l email.List, sub email.Subscriber) {
	log.Debug("Adding subscriber %s to external email list %s", sub.Email, l, c)
	provider, err := getEmailMarketer(c, in)
	if err != nil {
		log.Error("Email provider integration not found: %v", err, c)
		panic(err)
	}
	err = provider.Subscribe(&l, &sub)
	if err != nil {
		log.Error("Email provider error: %v", err, c)

	}
})