all repos — navani @ ac7cf9514f9fa09c55057e16de23c946e6abcb05

forlater's primary mail processing service

main.go (view raw)

 1
 2
 3
 4
 5
 6
 7
 8
 9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
package main

import (
	"encoding/json"
	"log"
	"net/http"
	"net/url"

	"git.icyphox.sh/forlater/navani/mail"
	"git.icyphox.sh/forlater/navani/reader"
)

func main() {
	http.HandleFunc("/webhook", func(w http.ResponseWriter, r *http.Request) {
		m := mail.Mail{}
		json.NewDecoder(r.Body).Decode(&m)
		body, err := mail.MailBody(m.Parts)
		if err != nil {
			log.Println(err)
		}

		for _, u := range distinct(mail.ExtractURLs(body)) {
			parsedURL, err := url.Parse(u)
			if err != nil {
				log.Println(err)
			}

			f, err := reader.Fetch(parsedURL.String())
			if err != nil {
				log.Println(err)
			}

			article, err := reader.Readable(f, parsedURL)
			if err != nil {
				log.Println(err)
			}

			err = mail.SendArticle(&article, m.From)
			if err != nil {
				log.Println(err)
			}
		}
		log.Printf("sent mail to %s\n", m.From)
		w.WriteHeader(204)
	})

	http.ListenAndServe(":8001", nil)
}