package frontend

import (
	"log"
	"os"
	"path/filepath"
	"time"

	"github.com/fsnotify/fsnotify"
)

// Dev starts the development server with file watching and HMR.
func (f *Frontend) Dev() error {
	if !f.DevMode {
		return nil
	}

	// Create watcher
	watcher, err := fsnotify.NewWatcher()
	if err != nil {
		return err
	}

	// Watch source directory recursively
	if err := f.watchDir(watcher, f.SourceDir); err != nil {
		// If source doesn't exist, just return without watching
		if os.IsNotExist(err) {
			log.Printf("[frontend] No source directory at %s, skipping watch", f.SourceDir)
			return nil
		}
		return err
	}

	log.Printf("[frontend] Watching %s for changes", f.SourceDir)

	// Store watcher for cleanup
	f.watcher = watcher

	// Start watching in background
	go f.watchLoop(watcher)

	return nil
}

// watchDir adds a directory and all subdirectories to the watcher.
func (f *Frontend) watchDir(watcher *fsnotify.Watcher, dir string) error {
	return filepath.Walk(dir, func(path string, info os.FileInfo, err error) error {
		if err != nil {
			return err
		}
		if info.IsDir() {
			return watcher.Add(path)
		}
		return nil
	})
}

// watchLoop handles file system events and triggers rebuilds.
func (f *Frontend) watchLoop(watcher *fsnotify.Watcher) {
	// Debounce timer to avoid rapid rebuilds
	var timer *time.Timer
	debounce := 100 * time.Millisecond

	rebuild := func() {
		log.Printf("[frontend] Rebuilding components...")
		start := time.Now()

		if err := f.Build(); err != nil {
			log.Printf("[frontend] Build error: %v", err)
			return
		}

		log.Printf("[frontend] Build completed in %v", time.Since(start))
		f.notifyClients()
	}

	for {
		select {
		case event, ok := <-watcher.Events:
			if !ok {
				return
			}

			// Only rebuild on write/create/remove events
			if event.Has(fsnotify.Write) || event.Has(fsnotify.Create) || event.Has(fsnotify.Remove) {
				// Check if it's a relevant file
				ext := filepath.Ext(event.Name)
				switch ext {
				case ".tsx", ".ts", ".jsx", ".js", ".css":
					// Debounce rebuild
					if timer != nil {
						timer.Stop()
					}
					timer = time.AfterFunc(debounce, rebuild)
				}
			}

			// Watch new directories
			if event.Has(fsnotify.Create) {
				if info, err := os.Stat(event.Name); err == nil && info.IsDir() {
					watcher.Add(event.Name)
				}
			}

		case err, ok := <-watcher.Errors:
			if !ok {
				return
			}
			log.Printf("[frontend] Watcher error: %v", err)
		}
	}
}

// Stop stops the development server and file watcher.
func (f *Frontend) Stop() {
	if f.watcher != nil {
		f.watcher.Close()
		f.watcher = nil
	}
	close(f.hmrDone) // shuts down hub goroutine, closes all client channels
}