package fetcher

import (
	"context"
	"fmt"
	"io"
	"net/http"
	"strings"
	"time"

	"go.alanpearce.eu/searchix/internal/config"

	"github.com/andybalholm/brotli"
	"gitlab.com/tozd/go/errors"
	"go.alanpearce.eu/x/log"
)

type brotliReadCloser struct {
	src io.ReadCloser
	*brotli.Reader
}

func newBrotliReader(src io.ReadCloser) *brotliReadCloser {
	return &brotliReadCloser{
		src:    src,
		Reader: brotli.NewReader(src),
	}
}

func (r *brotliReadCloser) Close() error {
	return errors.Wrap(r.src.Close(), "failed to call close on underlying reader")
}

func fetchFileIfNeeded(
	ctx context.Context,
	log *log.Logger,
	mtime time.Time,
	url string,
) (io.ReadCloser, time.Time, errors.E) {
	var newMtime time.Time
	var ifModifiedSince string
	if !mtime.IsZero() {
		ifModifiedSince = strings.Replace(mtime.UTC().Format(time.RFC1123), "UTC", "GMT", 1)
	}

	req, baseErr := http.NewRequestWithContext(ctx, "GET", url, http.NoBody)
	if baseErr != nil {
		return nil, newMtime, errors.WithMessagef(
			baseErr,
			"could not create HTTP request for %s",
			url,
		)
	}

	req.Header.Set("User-Agent", fmt.Sprintf("Searchix %s", config.Version))

	if ifModifiedSince != "" {
		req.Header.Set("If-Modified-Since", ifModifiedSince)
	}
	res, baseErr := http.DefaultClient.Do(req)
	if baseErr != nil {
		return nil, newMtime, errors.WithMessagef(baseErr, "could not make HTTP request to %s", url)
	}

	var body io.ReadCloser
	var err errors.E
	switch res.StatusCode {
	case http.StatusNotModified:
		newMtime = mtime

		return nil, newMtime, nil
	case http.StatusOK:
		var baseErr error
		newMtime, baseErr = time.Parse(time.RFC1123, res.Header.Get("Last-Modified"))
		if baseErr != nil {
			log.Warn(
				"could not parse Last-Modified header from response",
				"value",
				res.Header.Get("Last-Modified"),
			)
			newMtime = time.Now()
		}

		switch ce := res.Header.Get("Content-Encoding"); ce {
		case "br":
			log.Debug("using brotli encoding")
			body = newBrotliReader(res.Body)
		case "", "identity", "gzip":
			body = res.Body
		default:
			err = errors.Errorf("cannot handle a body with content-encoding %s", ce)
		}
	default:
		err = errors.Errorf("got response code %d, don't know what to do", res.StatusCode)
	}

	return NewReadCloser(body), newMtime, err
}