package main

import (
	"encoding/json"
	"fmt"
	"io"
	"math/rand/v2"
	"net/http"
	"net/url"
	"strings"
	"time"

	"github.com/dlclark/regexp2"
	_ "github.com/joho/godotenv/autoload"
	"github.com/rs/zerolog/log"

	"github.com/gorilla/mux"
)

// @title           RFD FYI API
// @version         1.0
// @description     An API for issue tracking
// @termsOfService  http://swagger.io/terms/

// @contact.name   API Support
// @contact.url    https://linktr.ee/davegallant
// @contact.email  davegallant@gmail.com

// @license.name  Apache 2.0
// @license.url   http://www.apache.org/licenses/LICENSE-2.0.html

// @host      localhost:8080
// @BasePath  /api/v1

type App struct {
	Router        *mux.Router
	BasePath      string
	CurrentTopics []Topic
	LastRefresh   time.Time
	Redirects     []Redirect
}

type Redirect struct {
	Name    string `json:"name"`
	Pattern string `json:"pattern"`
}

func (a *App) Initialize() {
	a.BasePath = "/api/v1"

	a.Router = mux.NewRouter().PathPrefix(a.BasePath).Subrouter()
	http.Handle("/", a.Router)

	a.initializeRoutes()
}

func (a *App) Run(httpPort string) {
	log.Info().Msgf("Serving requests on port " + httpPort)
	if err := http.ListenAndServe(fmt.Sprintf(":"+httpPort), nil); err != nil {
		panic(err)
	}
}

func (a *App) initializeRoutes() {
	a.Router.HandleFunc("/topics", a.listTopics).Methods("GET")
	a.Router.HandleFunc("/topics/{id}", a.getTopicDetails).Methods("GET")
}

// func respondWithError(w http.ResponseWriter, code int, message string) {
// 	respondWithJSON(w, code, map[string]string{"error": message})
// }

func respondWithJSON(w http.ResponseWriter, code int, payload interface{}) {
	response, _ := json.Marshal(payload)

	w.Header().Set("Content-Type", "application/json")
	w.WriteHeader(code)
	w.Write(response)
}

// listtopics godoc
// @Summary      Lists all topics stored in the database
// @Description  All topics will be listed. There is currently no pagination implemented.
// @ID           list-topics
// @Router       /topics [get]
// @Success 200 {array} Topic
func (a *App) listTopics(w http.ResponseWriter, r *http.Request) {
	respondWithJSON(w, http.StatusOK, a.CurrentTopics)
}

// getTopicDetails godoc
// @Summary      Get detailed information about a specific topic
// @Description  Fetches full details including recent comments for a topic by ID
// @ID           get-topic-details
// @Param        id path int true "Topic ID"
// @Router       /topics/{id} [get]
// @Success 200 {object} TopicDetails
func (a *App) getTopicDetails(w http.ResponseWriter, r *http.Request) {
	vars := mux.Vars(r)
	topicID := vars["id"]

	// Find topic in current topics
	var topic *Topic
	for i := range a.CurrentTopics {
		if fmt.Sprintf("%d", a.CurrentTopics[i].TopicID) == topicID {
			topic = &a.CurrentTopics[i]
			break
		}
	}

	if topic == nil {
		respondWithJSON(w, http.StatusNotFound, map[string]string{"error": "Topic not found"})
		return
	}

	// Fetch detailed info from RFD API
	requestURL := fmt.Sprintf("https://forums.redflagdeals.com/api/topics/%s", topicID)
	res, err := http.Get(requestURL)
	if err != nil {
		log.Warn().Msgf("error fetching topic details: %s\n", err)
		respondWithJSON(w, http.StatusInternalServerError, map[string]string{"error": "Failed to fetch details"})
		return
	}
	defer res.Body.Close()

	body, err := io.ReadAll(res.Body)
	if err != nil {
		log.Warn().Msgf("could not read response body: %s\n", err)
		respondWithJSON(w, http.StatusInternalServerError, map[string]string{"error": "Failed to read response"})
		return
	}

	var rfdResponse map[string]interface{}
	err = json.Unmarshal([]byte(body), &rfdResponse)
	if err != nil {
		log.Warn().Msgf("could not unmarshal response body: %s", err)
		respondWithJSON(w, http.StatusInternalServerError, map[string]string{"error": "Failed to parse response"})
		return
	}

	// Extract relevant fields for tooltip
	details := TopicDetails{
		Topic:       *topic,
		Description: extractDescription(rfdResponse),
		FirstPost:   extractFirstPost(rfdResponse),
	}

	respondWithJSON(w, http.StatusOK, details)
}

func extractDescription(data map[string]interface{}) string {
	if topic, ok := data["topic"].(map[string]interface{}); ok {
		if description, ok := topic["description"].(string); ok {
			return description
		}
	}
	return ""
}

func extractFirstPost(data map[string]interface{}) string {
	if posts, ok := data["posts"].([]interface{}); ok && len(posts) > 0 {
		if firstPost, ok := posts[0].(map[string]interface{}); ok {
			if body, ok := firstPost["body"].(string); ok {
				// Truncate to first 200 characters
				if len(body) > 200 {
					return body[:200] + "..."
				}
				return body
			}
		}
	}
	return ""
}

func (a *App) refreshTopics() {
	for {
		log.Info().Msg("Refreshing topics")
		latestTopics := a.getDeals(9, 1, 6)

		if len(latestTopics) > 0 {
			latestTopics = a.deduplicateTopics(latestTopics)
			latestTopics = a.updateScores(latestTopics)

			log.Info().Msg("Refreshing redirects")
			latestRedirects := a.getRedirects()
			a.Redirects = latestRedirects
			a.CurrentTopics = a.stripRedirects(latestTopics)
		}

		a.LastRefresh = time.Now()
		time.Sleep(time.Duration(rand.IntN(90-60+1)+60) * time.Second)
	}
}

func (a *App) updateScores(t []Topic) []Topic {
	for i := range t {
		t[i].Score = t[i].Votes.Up - t[i].Votes.Down
	}
	return t
}

func (a *App) stripRedirects(t []Topic) []Topic {
	for i := range t {
		if t[i].Offer.Url == "" {
			continue
		}

		var offerUrl = t[i].Offer.Url
		log.Debug().Msgf("Offer url is : %s", offerUrl)
		for _, r := range a.Redirects {
			re := regexp2.MustCompile(r.Pattern, 0)
			if m, _ := re.FindStringMatch(offerUrl); m != nil {
				g := m.GroupByName("baseUrl")

				if g.Name != "baseUrl" {
					continue
				}
				decodedValue, err := url.QueryUnescape(g.String())
				if err != nil {
					log.Error().Msgf("%s", err)
					break
				}
				t[i].Offer.Url = decodedValue
				log.Debug().Msgf("Setting offer url to: %s", t[i].Offer.Url)

				break
			}
		}

	}
	return t
}

func (a *App) deduplicateTopics(topics []Topic) []Topic {
	seen := make(map[uint]bool)
	var deduplicated []Topic

	for _, topic := range topics {
		if !seen[topic.TopicID] {
			seen[topic.TopicID] = true
			deduplicated = append(deduplicated, topic)
		} else {
			log.Debug().Msgf("Removing duplicate topic: %d", topic.TopicID)
		}
	}

	return deduplicated
}

func (a *App) isSponsor(t Topic) bool {
	return strings.HasPrefix(t.Title, "[Sponsored]")
}

func (a *App) getDeals(id int, firstPage int, lastPage int) []Topic {

	var t []Topic

	for i := firstPage; i < lastPage; i++ {
		requestURL := fmt.Sprintf("https://forums.redflagdeals.com/api/topics?forum_id=%d&per_page=40&page=%d", id, i)
		res, err := http.Get(requestURL)
		if err != nil {
			log.Warn().Msgf("error fetching deals: %s\n", err)
		}
		body, err := io.ReadAll(res.Body)
		if err != nil {
			log.Warn().Msgf("could not read response body: %s\n", err)
		}

		var response TopicsResponse

		err = json.Unmarshal([]byte(body), &response)

		if err != nil {
			log.Warn().Msgf("could not unmarshal response body: %s", err)
		}

		for _, topic := range response.Topics {
			if a.isSponsor(topic) {
				continue
			}
			t = append(t, topic)
		}
	}
	return t
}

func (a *App) getRedirects() []Redirect {

	requestURL := fmt.Sprintf("https://raw.githubusercontent.com/davegallant/rfd-redirect-stripper/main/redirects.json")
	res, err := http.Get(requestURL)
	if err != nil {
		log.Warn().Msgf("error fetching redirects: %s\n", err)
	}
	body, err := io.ReadAll(res.Body)
	if err != nil {
		log.Warn().Msgf("could not read response body: %s\n", err)
	}

	var r []Redirect

	err = json.Unmarshal([]byte(body), &r)

	if err != nil {
		log.Warn().Msgf("could not unmarshal response body: %s", err)
	}

	return r
}