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)
		log.Printf("recieved webhook: %v\n", m)
		if err != nil {
			log.Println(err)
		}

		for _, u := range distinct(mail.ExtractURLs(body)) {
			parsedURL, err := url.Parse(u)
			if err != nil {
				log.Printf("url parse: %s\n", err)
			}

			f, err := reader.Fetch(parsedURL.String())
			if err != nil {
				log.Printf("reader fetch: %s\n", err)
			}

			article, err := reader.Readable(f, parsedURL)
			if err == nil {
				err = mail.SendArticle(&article, m.From, true)
				if err != nil {
					log.Printf("error sending mail to: %s: %v\n", m.From, err)
				} else {
					log.Printf("sent mail to %s: %s\n", m.From, article.Title)
				}
			} else {
				log.Printf("not readable: %s\n", err)
				err := mail.SendArticle(&article, m.From, false)
				if err != nil {
					log.Printf("error sending mail to: %s: %v\n", m.From, err)
				}
			}
		}
		w.WriteHeader(204)
	})

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