package main

import (
	"fmt"
	"io"
	"log"
	"net/http"
	"net/url"
	"strings"

	"github.com/PuerkitoBio/goquery"
	"github.com/tomnomnom/linkheader"
)

func (p *post) sendWebmentions() error {
	links := []string{}
	contentLinks, err := allLinksFromHTML(strings.NewReader(string(p.html())), p.fullURL())
	if err != nil {
		return err
	}
	links = append(links, contentLinks...)
	links = append(links, p.firstParameter(appConfig.Micropub.LikeParam), p.firstParameter(appConfig.Micropub.ReplyParam), p.firstParameter(appConfig.Micropub.BookmarkParam))
	for _, link := range links {
		if link == "" {
			continue
		}
		if strings.HasPrefix(link, appConfig.Server.PublicAddress) {
			// Save mention directly
			createWebmention(p.fullURL(), link)
			continue
		}
		endpoint := discoverEndpoint(link)
		if endpoint == "" {
			continue
		}
		_, err = sendWebmention(endpoint, p.fullURL(), link)
		if err != nil {
			log.Println("Sending webmention to " + link + " failed")
			continue
		}
		log.Println("Sent webmention to " + link)
	}
	return nil
}

func sendWebmention(endpoint, source, target string) (*http.Response, error) {
	req, err := http.NewRequest(http.MethodPost, endpoint, strings.NewReader(url.Values{
		"source": []string{source},
		"target": []string{target},
	}.Encode()))
	if err != nil {
		return nil, err
	}
	req.Header.Set(contentType, contentTypeWWWForm)
	req.Header.Set(userAgent, appUserAgent)
	res, err := http.DefaultClient.Do(req)
	if err != nil {
		return res, err
	}
	if code := res.StatusCode; code < 200 || 300 <= code {
		return res, fmt.Errorf("response error: %v", res.StatusCode)
	}
	return res, nil
}

func discoverEndpoint(urlStr string) string {
	doRequest := func(method, urlStr string) string {
		req, err := http.NewRequest(method, urlStr, nil)
		if err != nil {
			return ""
		}
		req.Header.Set(userAgent, appUserAgent)
		resp, err := http.DefaultClient.Do(req)
		if err != nil {
			return ""
		}
		if code := resp.StatusCode; code < 200 || 300 <= code {
			return ""
		}
		defer resp.Body.Close()
		endpoint, err := extractEndpoint(resp)
		if err != nil || endpoint == "" {
			return ""
		}
		if urls, err := resolveURLReferences(urlStr, endpoint); err == nil && len(urls) > 0 && urls[0] != "" {
			return urls[0]
		}
		return ""
	}
	headEndpoint := doRequest(http.MethodHead, urlStr)
	if headEndpoint != "" {
		return headEndpoint
	}
	getEndpoint := doRequest(http.MethodGet, urlStr)
	if getEndpoint != "" {
		return getEndpoint
	}
	return ""
}

func extractEndpoint(resp *http.Response) (string, error) {
	// first check http link headers
	if endpoint := wmEndpointHTTPLink(resp.Header); endpoint != "" {
		return endpoint, nil
	}
	// then look in the HTML body
	endpoint, err := wmEndpointHTMLLink(resp.Body)
	if err != nil {
		return "", err
	}
	return endpoint, nil
}

func wmEndpointHTTPLink(headers http.Header) string {
	links := linkheader.ParseMultiple(headers[http.CanonicalHeaderKey("Link")]).FilterByRel("webmention")
	for _, link := range links {
		if u := link.URL; u != "" {
			return u
		}
	}
	return ""
}

func wmEndpointHTMLLink(r io.Reader) (string, error) {
	doc, err := goquery.NewDocumentFromReader(r)
	if err != nil {
		return "", err
	}
	href, _ := doc.Find("a[href][rel=webmention],link[href][rel=webmention]").Attr("href")
	return href, nil
}