package client_api

import (
	"encoding/json"
	"net/http"

	"git.ohea.xyz/mediasrv/server/database"
	"github.com/op/go-logging"
)

var log = logging.MustGetLogger("mediasrv-server")

type Episodes struct {
	Episodes []database.Episode `json:"episodes"`
}

func episodesHandler(data_dir string, w http.ResponseWriter, r *http.Request) {
	log.Debugf("/episodes called\n")
	db, _, err := database.OpenDatabase(data_dir)
	if err != nil {
		log.Errorf("Could not open database: %v\n", err)
		return
	}

	rows, err := db.Query("SELECT title, show_title, number, season, original_filename FROM episodes")
	if err != nil {
		log.Errorf("Could not check if database was new: %v", err)
	}
	defer rows.Close()

	var return_json Episodes

	for {
		if !rows.Next() {
			err = rows.Err()
			if err != nil {
				log.Fatalf("Could not get row from database: %v\n", err)
				return
			} else {
				log.Debugf("%v rows processed\n", len(return_json.Episodes))
				break
			}
		}
		var episode database.Episode
		rows.Scan(&episode.Title, &episode.ShowTitle, &episode.Episode, &episode.Season, &episode.OriginalFilename)

		return_json.Episodes = append(return_json.Episodes, episode)
	}
	data, err := json.Marshal(return_json)
	if err != nil {
		log.Errorf("Could not marshal episode data: %v\n", err)
		return
	}
	w.Write(data)
}