449 lines
8.6 KiB
Go
449 lines
8.6 KiB
Go
/*
|
|
Copyright © 2022 Seednode <seednode@seedno.de>
|
|
*/
|
|
|
|
package cmd
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"net/url"
|
|
"os"
|
|
"path/filepath"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
const LOGDATE string = "2006-01-02T15:04:05.000-07:00"
|
|
const PREFIX string = "/src"
|
|
|
|
type Filters struct {
|
|
Includes []string
|
|
Excludes []string
|
|
}
|
|
|
|
func (f *Filters) IsEmpty() bool {
|
|
if !(f.HasIncludes() && f.HasExcludes()) {
|
|
return true
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func (f *Filters) HasIncludes() bool {
|
|
if len(f.Includes) == 0 {
|
|
return false
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
func (f *Filters) GetIncludes() string {
|
|
return strings.Join(f.Includes, ",")
|
|
}
|
|
|
|
func (f *Filters) HasExcludes() bool {
|
|
if len(f.Excludes) == 0 {
|
|
return false
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
func (f *Filters) GetExcludes() string {
|
|
return strings.Join(f.Excludes, ",")
|
|
}
|
|
|
|
type appHandler func(http.ResponseWriter, *http.Request) error
|
|
|
|
func (fn appHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
if err := fn(w, r); err != nil {
|
|
http.Error(w, err.Error(), 500)
|
|
}
|
|
}
|
|
|
|
func splitQueryParams(query string) []string {
|
|
if query == "" {
|
|
return []string{}
|
|
}
|
|
|
|
params := strings.Split(query, ",")
|
|
|
|
for i := 0; i < len(params); i++ {
|
|
params[i] = strings.ToLower(params[i])
|
|
}
|
|
|
|
return params
|
|
}
|
|
|
|
func generateQueryParams(filters *Filters, sort string) string {
|
|
switch {
|
|
case Filter && !Sort:
|
|
return fmt.Sprintf("?include=%v&exclude=%v",
|
|
filters.GetIncludes(),
|
|
filters.GetExcludes(),
|
|
)
|
|
case !Filter && Sort:
|
|
return fmt.Sprintf("?sort=%v", sort)
|
|
case Filter && Sort:
|
|
return fmt.Sprintf("?include=%v&exclude=%v&sort=%v",
|
|
filters.GetIncludes(),
|
|
filters.GetExcludes(),
|
|
sort,
|
|
)
|
|
}
|
|
|
|
return ""
|
|
}
|
|
|
|
func stripQueryParams(inUrl string) (string, error) {
|
|
url, err := url.Parse(inUrl)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
url.RawQuery = ""
|
|
|
|
return url.String(), nil
|
|
}
|
|
|
|
func refererToUri(referer string) string {
|
|
parts := strings.SplitAfterN(referer, "/", 4)
|
|
|
|
if len(parts) < 4 {
|
|
return ""
|
|
}
|
|
|
|
return "/" + parts[3]
|
|
}
|
|
|
|
func serveHtml(w http.ResponseWriter, r *http.Request, filePath string) error {
|
|
fileName := filepath.Base(filePath)
|
|
|
|
w.Header().Add("Content-Type", "text/html")
|
|
|
|
htmlBody := `<html lang="en">
|
|
<head>
|
|
<style>img{max-width:100%;max-height:97vh;height:auto;}</style>
|
|
<title>`
|
|
htmlBody += fileName
|
|
htmlBody += `</title>
|
|
</head>
|
|
<body>`
|
|
switch {
|
|
case Filter && Sort:
|
|
htmlBody += fmt.Sprintf(`<a href="/?include=%v&exclude=%v&sort=%v"><img src="`,
|
|
r.URL.Query().Get("include"),
|
|
r.URL.Query().Get("exclude"),
|
|
r.URL.Query().Get("sort"),
|
|
)
|
|
case Filter && !Sort:
|
|
htmlBody += fmt.Sprintf(`<a href="/?include=%v&exclude=%v"><img src="`,
|
|
r.URL.Query().Get("include"),
|
|
r.URL.Query().Get("exclude"),
|
|
)
|
|
case !Filter && Sort:
|
|
htmlBody += fmt.Sprintf(`<a href="/?sort=%v"><img src="`,
|
|
r.URL.Query().Get("sort"),
|
|
)
|
|
default:
|
|
htmlBody += `<a href="/"><img src="`
|
|
}
|
|
htmlBody += PREFIX + filePath
|
|
htmlBody += `"></img></a>
|
|
</body>
|
|
</html>`
|
|
|
|
_, err := io.WriteString(w, htmlBody)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func serveStaticFile(w http.ResponseWriter, r *http.Request, paths []string) error {
|
|
strippedUrl, err := stripQueryParams(r.URL.Path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
prefixedFilePath, err := url.QueryUnescape(strippedUrl)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filePath := filepath.Clean(strings.TrimPrefix(prefixedFilePath, PREFIX))
|
|
|
|
if !pathIsValid(filePath, paths) {
|
|
http.NotFound(w, r)
|
|
}
|
|
|
|
exists, err := fileExists(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if !exists {
|
|
http.NotFound(w, r)
|
|
|
|
return nil
|
|
}
|
|
|
|
var startTime time.Time
|
|
if Verbose {
|
|
startTime = time.Now()
|
|
fmt.Printf("%v Serving file: %v", startTime.Format(LOGDATE), filePath)
|
|
}
|
|
|
|
buf, err := os.ReadFile(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
w.Write(buf)
|
|
|
|
if Verbose {
|
|
fmt.Printf(" (Finished in %v)\n", time.Since(startTime).Round(time.Microsecond))
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func serveStaticFileHandler(paths []string) appHandler {
|
|
return func(w http.ResponseWriter, r *http.Request) error {
|
|
err := serveStaticFile(w, r, paths)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func serveHtmlHandler(paths []string) appHandler {
|
|
return func(w http.ResponseWriter, r *http.Request) error {
|
|
refererUri, err := stripQueryParams(refererToUri(r.Referer()))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filters := Filters{}
|
|
if Filter {
|
|
filters.Includes = splitQueryParams(r.URL.Query().Get("include"))
|
|
filters.Excludes = splitQueryParams(r.URL.Query().Get("exclude"))
|
|
} else {
|
|
fmt.Println("Filters disabled")
|
|
}
|
|
|
|
sortOrder := ""
|
|
if Sort {
|
|
sortOrder = r.URL.Query().Get("sort")
|
|
}
|
|
|
|
switch {
|
|
case r.URL.Path == "/" && sortOrder == "asc" && refererUri != "":
|
|
query, err := url.QueryUnescape(refererUri)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
path, err := splitPath(query)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filePath, err := getNextFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if filePath == "" {
|
|
filePath, err = pickFile(paths, &filters, sortOrder)
|
|
switch {
|
|
case err != nil && err == ErrNoImagesFound:
|
|
http.NotFound(w, r)
|
|
|
|
return nil
|
|
case err != nil:
|
|
return err
|
|
}
|
|
|
|
path, err := splitPath(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filePath, err = getFirstFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
newUrl := fmt.Sprintf("%v%v%v",
|
|
r.URL.Host,
|
|
filePath,
|
|
generateQueryParams(&filters, sortOrder),
|
|
)
|
|
http.Redirect(w, r, newUrl, http.StatusTemporaryRedirect)
|
|
case r.URL.Path == "/" && sortOrder == "asc" && refererUri == "":
|
|
filePath, err := pickFile(paths, &filters, sortOrder)
|
|
if err != nil && err == ErrNoImagesFound {
|
|
http.NotFound(w, r)
|
|
|
|
return nil
|
|
} else if err != nil {
|
|
return err
|
|
}
|
|
|
|
path, err := splitPath(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filePath, err = getFirstFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
newUrl := fmt.Sprintf("%v%v%v",
|
|
r.URL.Host,
|
|
filePath,
|
|
generateQueryParams(&filters, sortOrder),
|
|
)
|
|
http.Redirect(w, r, newUrl, http.StatusTemporaryRedirect)
|
|
case r.URL.Path == "/" && sortOrder == "desc" && refererUri != "":
|
|
query, err := url.QueryUnescape(refererUri)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
path, err := splitPath(query)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filePath, err := getPreviousFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if filePath == "" {
|
|
filePath, err = pickFile(paths, &filters, sortOrder)
|
|
switch {
|
|
case err != nil && err == ErrNoImagesFound:
|
|
http.NotFound(w, r)
|
|
|
|
return nil
|
|
case err != nil:
|
|
return err
|
|
}
|
|
|
|
path, err := splitPath(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filePath, err = getLastFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
newUrl := fmt.Sprintf("%v%v%v",
|
|
r.URL.Host,
|
|
filePath,
|
|
generateQueryParams(&filters, sortOrder),
|
|
)
|
|
http.Redirect(w, r, newUrl, http.StatusTemporaryRedirect)
|
|
case r.URL.Path == "/" && sortOrder == "desc" && refererUri == "":
|
|
filePath, err := pickFile(paths, &filters, sortOrder)
|
|
if err != nil && err == ErrNoImagesFound {
|
|
http.NotFound(w, r)
|
|
|
|
return nil
|
|
} else if err != nil {
|
|
return err
|
|
}
|
|
|
|
path, err := splitPath(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
filePath, err = getLastFile(path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
newUrl := fmt.Sprintf("%v%v%v",
|
|
r.URL.Host,
|
|
filePath,
|
|
generateQueryParams(&filters, sortOrder),
|
|
)
|
|
http.Redirect(w, r, newUrl, http.StatusTemporaryRedirect)
|
|
case r.URL.Path == "/":
|
|
filePath, err := pickFile(paths, &filters, sortOrder)
|
|
if err != nil && err == ErrNoImagesFound {
|
|
http.NotFound(w, r)
|
|
|
|
return nil
|
|
} else if err != nil {
|
|
return err
|
|
}
|
|
|
|
newUrl := fmt.Sprintf("%v%v%v",
|
|
r.URL.Host,
|
|
filePath,
|
|
generateQueryParams(&filters, sortOrder),
|
|
)
|
|
http.Redirect(w, r, newUrl, http.StatusTemporaryRedirect)
|
|
default:
|
|
filePath := r.URL.Path
|
|
|
|
image, err := isImage(filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if !image {
|
|
http.NotFound(w, r)
|
|
|
|
return nil
|
|
}
|
|
|
|
err = serveHtml(w, r, filePath)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
}
|
|
|
|
func doNothing(http.ResponseWriter, *http.Request) {}
|
|
|
|
func ServePage(args []string) error {
|
|
paths, err := normalizePaths(args)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
for _, i := range paths {
|
|
fmt.Println("Paths: " + i)
|
|
}
|
|
|
|
http.Handle("/", serveHtmlHandler(paths))
|
|
http.Handle(PREFIX+"/", http.StripPrefix(PREFIX, serveStaticFileHandler(paths)))
|
|
http.HandleFunc("/favicon.ico", doNothing)
|
|
|
|
err = http.ListenAndServe(":"+strconv.FormatInt(int64(Port), 10), nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|