1 files changed, 69 insertions, 0 deletions
diff --git a/mailing.go b/mailing.go
new file mode 100644
index 0000000..a70138e
--- /dev/null
+++ b/mailing.go
@@ -0,0 +1,69 @@
+package main
+
+import (
+	"kch42.de/gostuff/mailremind/mailing"
+	"log"
+)
+
+var MailFrom string
+
+type email struct {
+	To, From string
+	Msg      []byte
+	OK       chan<- bool
+}
+
+var mailchan chan *email
+
+func Mail(to, from string, msg []byte) bool {
+	ok := make(chan bool)
+	mailchan <- &email{to, from, msg, ok}
+	return <-ok
+}
+
+func initMailing() {
+	meth, err := conf.GetString("mail", "method")
+	if err != nil {
+		log.Fatalf("Could not get mail.method from config: %s", err)
+	}
+
+	MailFrom, err = conf.GetString("mail", "addr")
+	if err != nil {
+		log.Fatalf("Could not get mail.addr from config: %s", err)
+	}
+
+	parallel, err := conf.GetInt("mail", "parallel")
+	if err != nil {
+		log.Fatalf("Could not get mail.parallel from config: %s", err)
+	}
+
+	if parallel <= 0 {
+		log.Fatalln("mail.parallel must be > 0")
+	}
+
+	mailchan = make(chan *email)
+
+	mc, ok := mailing.MailersByName[meth]
+	if !ok {
+		log.Fatalf("Unknown mail method: %s", meth)
+	}
+
+	for i := int64(0); i < parallel; i++ {
+		mailer, err := mc(conf)
+		if err != nil {
+			log.Fatalf("Error while initializing mail: %s", err)
+		}
+
+		go func(mailer mailing.Mailer) {
+			for {
+				mail := <-mailchan
+				if err := mailer.Mail(mail.To, mail.From, mail.Msg); err != nil {
+					log.Printf("Could not send mail to \"%s\": %s", mail.To, err)
+					mail.OK <- false
+				} else {
+					mail.OK <- true
+				}
+			}
+		}(mailer)
+	}
+}