package api

import (
	"encoding/json"
	"fmt"
	"net/http"
	"path/filepath"
	"strconv"
	"time"

	"github.com/gin-gonic/gin"
	"github.com/photoprism/photoprism/internal/config"
	"github.com/photoprism/photoprism/internal/entity"
	"github.com/photoprism/photoprism/internal/query"
	"github.com/photoprism/photoprism/internal/service"
)

type FoldersResponse struct {
	Root      string          `json:"root,omitempty"`
	Folders   []entity.Folder `json:"folders"`
	Files     []entity.File   `json:"files,omitempty"`
	Recursive bool            `json:"recursive,omitempty"`
	Cached    bool            `json:"cached,omitempty"`
}

// GetFolders is a reusable request handler for directory listings (GET /api/v1/folders/*).
func GetFolders(router *gin.RouterGroup, conf *config.Config, urlPath, rootName, rootPath string) {
	handler := func(c *gin.Context) {
		if Unauthorized(c, conf) {
			c.AbortWithStatusJSON(http.StatusUnauthorized, ErrUnauthorized)
			return
		}

		start := time.Now()
		cache := service.Cache()
		recursive := c.Query("recursive") != ""
		listFiles := c.Query("files") != ""
		uncached := listFiles || c.Query("uncached") != ""
		resp := FoldersResponse{Root: rootName, Recursive: recursive, Cached: !uncached}
		path := c.Param("path")

		cacheKey := fmt.Sprintf("folders:%s:%t:%t", filepath.Join(rootPath, path), recursive, listFiles)

		if !uncached {
			if cacheData, err := cache.Get(cacheKey); err == nil {
				var cached FoldersResponse

				if err := json.Unmarshal(cacheData, &cached); err != nil {
					log.Errorf("folders: %s", err)
				} else {
					log.Debugf("cache hit for %s [%s]", cacheKey, time.Since(start))
					c.JSON(http.StatusOK, cached)
					return
				}
			}
		}

		if folders, err := query.FoldersByPath(rootName, rootPath, path, recursive); err != nil {
			log.Errorf("folders: %s", err)
			c.JSON(http.StatusOK, resp)
			return
		} else {
			resp.Folders = folders
		}

		if listFiles {
			if files, err := query.FilesByPath(rootName, path); err != nil {
				log.Errorf("folders: %s", err)
			} else {
				resp.Files = files
			}
		}

		if !uncached {
			if c, err := json.Marshal(resp); err == nil {
				logError("folders", cache.Set(cacheKey, c))
				log.Debugf("cached %s [%s]", cacheKey, time.Since(start))
			}
		}

		c.Header("X-Count", strconv.Itoa(len(resp.Files)+len(resp.Folders)))
		c.Header("X-Offset", "0")

		c.JSON(http.StatusOK, resp)
	}

	router.GET("/folders/"+urlPath, handler)
	router.GET("/folders/"+urlPath+"/*path", handler)
}

// GET /api/v1/folders/originals
func GetFoldersOriginals(router *gin.RouterGroup, conf *config.Config) {
	GetFolders(router, conf, "originals", entity.RootDefault, conf.OriginalsPath())
}

// GET /api/v1/folders/import
func GetFoldersImport(router *gin.RouterGroup, conf *config.Config) {
	GetFolders(router, conf, "import", entity.RootImport, conf.ImportPath())
}