package routes

import (
	"fmt"
	"io/fs"
	"log"
	"net"
	"path/filepath"
	"strconv"
	"time"

	"github.com/fsnotify/fsnotify"
	"github.com/savsgio/atreugo/v11"

	"alin.ovh/elgit/config"
)

var ErrMethodNotAllowed = fmt.Errorf("that's not possible")
var ErrNotFound = fmt.Errorf("nothing like that here")

func Handlers(c *config.Config, staticFiles fs.FS) *atreugo.Atreugo {
	plist := filepath.Join(c.Repo.Root, "projects.list")
	projects, err := ReadProjectsList(plist)
	if err != nil {
		log.Fatal(err)
	}

	d := deps{
		c,
		projects,
	}

	addr := net.JoinHostPort(c.Server.Host, strconv.FormatInt(c.Server.Port, 10))
	srv := atreugo.New(atreugo.Config{
		Addr:                 addr,
		Name:                 c.Server.Name,
		Network:              "tcp6",
		Prefork:              false,
		Reuseport:            false,
		GracefulShutdown:     true,
		Compress:             true,
		Logger:               log.Default(),
		NotFoundView:         d.NotFound,
		MethodNotAllowedView: nil,
		ErrorView:            d.Error,
		// PanicView:                    d.Panic,
		ReadTimeout:                  5 * time.Second,
		DisablePreParseMultipartForm: true,
		KeepHijackedConns:            false,
		CloseOnShutdown:              true,
		StreamRequestBody:            true,
	})

	watcher, err := fsnotify.NewWatcher()
	if err != nil {
		log.Fatal(err)
	}

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

	go func() {
		for {
			select {
			case event, ok := <-watcher.Events:
				if !ok {
					continue
				}
				if event.Op.Has(fsnotify.Write) {
					d.projects, err = ReadProjectsList(plist)
					if err != nil {
						log.Println(err)
					}
				}
			case err, ok := <-watcher.Errors:
				if !ok {
					continue
				}
				log.Println("error:", err)
			}
		}
	}()

	d.mountRepoPaths(srv.NewGroupPath("/{name}"))
	d.mountRepoPaths(srv.NewGroupPath("/{category}/{name}"))

	srv.StaticFS("/static/", staticFiles)
	srv.GET("/", d.Index)

	return srv
}

func (d deps) mountRepoPaths(router *atreugo.Router) {
	router.GET("/tree/{ref}/{rest:*}", d.RepoTree)
	router.GET("/blob/{ref}/{rest:*}", d.FileContent)
	router.GET("/tree/{ref}/", d.RepoTree)
	router.GET("/log/{ref}/", d.Log)
	router.GET("/archive/{file}", d.Archive)
	router.GET("/commit/{ref}", d.Diff)
	router.GET("/commit/{ref}/{file:*}", d.FileDiff)
	router.GET("/refs/", d.Refs)
	router.GET("/info/refs", d.InfoRefs)
	router.POST("/git-upload-pack", d.UploadPack)
	router.GET("/", d.RepoIndex)
}