package main

import (
	"encoding/json"
	"image"
	"io/ioutil"
	"log"
	"net/http"
	"path/filepath"
	"text/template"

	"gocv.io/x/gocv"
)

// Server is the main application struct
type Server struct {
	Streams map[string]Stream
}

func (server Server) index(w http.ResponseWriter, r *http.Request) {
	if r.FormValue("URL") == "" {
		indexTemplate, err := template.ParseFiles(filepath.Join("templates", "index.html"))
		if err != nil {
			log.Fatal(err)
		}
		indexTemplate.Execute(w, nil)
		return
	}
	URL := r.FormValue("URL")
	stream, exists := server.Streams[URL]
	if !exists {
		stream = NewStream(URL)
		server.Streams[URL] = stream
		go stream.Update()
	}
	streamTemplate, err := template.ParseFiles(filepath.Join("templates", "stream.html"))

	if err != nil {
		log.Fatal(err)
	}

	streamTemplate.Execute(w, stream)
}

func (server Server) stream(w http.ResponseWriter, r *http.Request) {
	if r.FormValue("URL") == "" {
		return
	}
	w.Header().Set("Content-Type", "image/jpeg")
	URL := r.FormValue("URL")

	stream, exists := server.Streams[URL]
	if !exists {
		return
	}

	img := stream.GetStreamInstant(URL)
	mat, err := gocv.IMDecode(img, gocv.IMReadGrayScale)
	if err != nil {
		log.Fatal("Could not IMDecode img")
	}

	//gocv.Resize(mat, &mat, image.Point{X: 0, Y: 0}, 0, 0, gocv.InterpolationCubic)
	gocv.GaussianBlur(mat, &mat, image.Point{X: 21, Y: 21}, 0, 0, gocv.BorderReflect)

	go stream.SaveStreamInstant(URL, mat)

	if stream.PreviousInstantPathExists() {
		if err != nil {
			log.Fatal("Could not IMDecode img")
		}

		previous := stream.IMReadPrevious()

		gocv.GaussianBlur(previous, &previous, image.Point{X: 21, Y: 21}, 0, 0, gocv.BorderReflect)

		gocv.AbsDiff(previous, mat, &mat)

		gocv.Threshold(mat, &mat, 25, 255, gocv.ThresholdBinary)

		//img, err = gocv.IMEncode(".jpg", newMat)
	}

	w.Write(img)
}

func main() {
	staticFileServer := http.FileServer(http.Dir("./static"))
	http.Handle("/static/", http.StripPrefix("/static/", staticFileServer))

	server := Server{
		Streams: make(map[string]Stream),
	}
	streams, err := ioutil.ReadDir(GetStreamDirPath())
	if err != nil {
		log.Fatal("Could not read Streamdir")
	}
	for _, streamStoreDir := range streams {
		if !streamStoreDir.IsDir() {
			continue
		}

		streamJSONPath := filepath.Join(GetStreamDirPath(), streamStoreDir.Name(), "stream.json")
		streamJSONFile, _ := ioutil.ReadFile(streamJSONPath)
		stream := Stream{}
		json.Unmarshal([]byte(streamJSONFile), &stream)
		server.Streams[stream.URL] = stream
		go stream.Update()
	}

	http.HandleFunc("/", server.index)
	http.HandleFunc("/stream", server.stream)
	log.Fatal(http.ListenAndServe(":8080", nil))
}