package main

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

	"git.icyphox.sh/forlater/navani/mail"
	"git.icyphox.sh/forlater/navani/reader"
	"git.icyphox.sh/forlater/navani/reader/twitter"
	_ "github.com/joho/godotenv"
)

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.From)
		if err != nil {
			log.Printf("using body as is: %v\n", err)
			body = mail.StripSignature(m.Body)
		}

		urls := mail.ExtractURLs(body)
		if len(urls) == 0 {
			log.Printf("no urls found")
		}
		for _, u := range distinct(urls) {
			log.Printf("url: %s\n", u)
			parsedURL, err := url.Parse(u)
			if err != nil {
				log.Printf("url parse: %v\n", err)
			}
			host := parsedURL.Host
			switch {
			case strings.Contains(host, "twitter.com"):
				creds := twitter.Creds{
					AccessToken:       os.Getenv("TWITTER_ACCESS_TOKEN"),
					AccessTokenSecret: os.Getenv("TWITTER_ACCESS_SECRET"),
					APIKey:            os.Getenv("TWITTER_API_KEY"),
					APISecret:         os.Getenv("TWITTER_API_SECRET"),
				}

				client := twitter.GetClient(&creds)
				tweet, err := twitter.GetTweet(client, u)
				if err != nil {
					log.Printf("error getting tweet: %v\n", err)
				}
				article := twitter.MakeTweetArticle(tweet, parsedURL)
				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)
				}
			default:
				resp, err := reader.Fetch(parsedURL.String())
				if err != nil {
					log.Printf("reader fetch: %v\n", err)
				}

				article, err := reader.Readable(resp.Body, parsedURL)
				if (err == nil) && (resp.MIMEType == "text/html") {
					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: %s\n", article.URL.String(), resp.MIMEType)
					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)
}