roulette/cmd/web.go

1111 lines
23 KiB
Go
Raw Normal View History

2022-09-08 15:12:06 +00:00
/*
2023-01-18 17:19:29 +00:00
Copyright © 2023 Seednode <seednode@seedno.de>
2022-09-08 15:12:06 +00:00
*/
package cmd
import (
"bytes"
"embed"
"encoding/gob"
"encoding/json"
"errors"
"fmt"
2022-09-08 15:12:06 +00:00
"io"
2023-02-08 13:50:40 +00:00
"log"
"math/rand"
"net"
2022-09-08 15:12:06 +00:00
"net/http"
2022-09-08 20:30:51 +00:00
"net/url"
2022-09-08 15:57:59 +00:00
"os"
2023-02-08 13:50:40 +00:00
"os/signal"
"path/filepath"
"regexp"
2022-10-23 21:29:58 +00:00
"runtime"
"sort"
2022-09-08 15:12:06 +00:00
"strconv"
"strings"
"sync"
2023-02-08 13:50:40 +00:00
"syscall"
"time"
"github.com/julienschmidt/httprouter"
2023-02-05 20:34:22 +00:00
"github.com/klauspost/compress/zstd"
"github.com/yosssi/gohtml"
2022-09-08 15:12:06 +00:00
)
//go:embed favicons/*
var favicons embed.FS
const (
LogDate string = `2006-01-02T15:04:05.000-07:00`
SourcePrefix string = `/source`
ImagePrefix string = `/view`
RedirectStatusCode int = http.StatusSeeOther
Timeout time.Duration = 10 * time.Second
)
type Stat int
type Regexes struct {
alphanumeric *regexp.Regexp
filename *regexp.Regexp
units *regexp.Regexp
}
type Filters struct {
includes []string
excludes []string
}
func (f *Filters) IsEmpty() bool {
return !(f.HasIncludes() || f.HasExcludes())
}
func (f *Filters) HasIncludes() bool {
return len(f.includes) != 0
}
func (f *Filters) Includes() string {
return strings.Join(f.includes, ",")
}
func (f *Filters) HasExcludes() bool {
return len(f.excludes) != 0
}
func (f *Filters) Excludes() string {
return strings.Join(f.excludes, ",")
}
type Index struct {
mutex sync.RWMutex
list []string
}
func (i *Index) Index() []string {
i.mutex.RLock()
val := i.list
i.mutex.RUnlock()
return val
}
func (i *Index) setIndex(val []string) {
i.mutex.Lock()
i.list = val
i.mutex.Unlock()
}
func (i *Index) generateCache(args []string) {
i.mutex.Lock()
i.list = []string{}
i.mutex.Unlock()
fileList(args, &Filters{}, "", i)
2023-02-05 20:34:22 +00:00
if cache && cacheFile != "" {
i.Export(cacheFile)
}
}
func (i *Index) IsEmpty() bool {
i.mutex.RLock()
length := len(i.list)
i.mutex.RUnlock()
return length == 0
}
func (i *Index) Export(path string) error {
file, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0600)
if err != nil {
return err
}
defer file.Close()
2023-02-05 20:34:22 +00:00
z, err := zstd.NewWriter(file)
if err != nil {
return err
}
defer z.Close()
enc := gob.NewEncoder(z)
2023-02-08 13:50:40 +00:00
i.mutex.RLock()
enc.Encode(&i.list)
2023-02-08 13:50:40 +00:00
i.mutex.RUnlock()
return nil
}
func (i *Index) Import(path string) error {
file, err := os.OpenFile(path, os.O_RDONLY, 0600)
2023-02-08 13:50:40 +00:00
if err != nil {
return err
}
defer file.Close()
2023-02-05 20:34:22 +00:00
z, err := zstd.NewReader(file)
if err != nil {
return err
}
defer z.Close()
dec := gob.NewDecoder(z)
2023-02-08 13:50:40 +00:00
i.mutex.Lock()
err = dec.Decode(&i.list)
2023-02-08 13:50:40 +00:00
i.mutex.Unlock()
if err != nil {
return err
}
return nil
}
type ServeStats struct {
mutex sync.RWMutex
list []string
count map[string]uint64
size map[string]string
times map[string][]string
}
2023-02-08 13:50:40 +00:00
type exportedServeStats struct {
List []string
Count map[string]uint64
Size map[string]string
Times map[string][]string
}
func (s *ServeStats) incrementCounter(image string, timestamp time.Time, filesize string) {
s.mutex.Lock()
s.count[image]++
s.times[image] = append(s.times[image], timestamp.Format(LogDate))
_, exists := s.size[image]
if !exists {
s.size[image] = filesize
}
if !contains(s.list, image) {
s.list = append(s.list, image)
}
s.mutex.Unlock()
}
2023-02-08 13:50:40 +00:00
func (s *ServeStats) toExported() *exportedServeStats {
stats := &exportedServeStats{
List: make([]string, len(s.list)),
2023-02-08 13:50:40 +00:00
Count: make(map[string]uint64),
Size: make(map[string]string),
Times: make(map[string][]string),
}
s.mutex.RLock()
copy(stats.List, s.list)
2023-02-08 13:50:40 +00:00
for k, v := range s.count {
stats.Count[k] = v
}
for k, v := range s.size {
stats.Size[k] = v
}
for k, v := range s.times {
stats.Times[k] = v
}
s.mutex.RUnlock()
2023-02-08 13:50:40 +00:00
return stats
}
func (s *ServeStats) toImported(stats *exportedServeStats) {
s.mutex.Lock()
s.list = make([]string, len(stats.List))
copy(s.list, stats.List)
2023-02-08 13:50:40 +00:00
for k, v := range stats.Count {
s.count[k] = v
}
for k, v := range stats.Size {
s.size[k] = v
}
for k, v := range stats.Times {
s.times[k] = v
}
s.mutex.Unlock()
}
func (s *ServeStats) ListImages() ([]byte, error) {
stats := s.toExported()
sort.SliceStable(stats.List, func(p, q int) bool {
return strings.ToLower(stats.List[p]) < strings.ToLower(stats.List[q])
})
a := make([]timesServed, len(stats.List))
for k, v := range stats.List {
a[k] = timesServed{v, stats.Count[v], stats.Size[v], stats.Times[v]}
}
r, err := json.MarshalIndent(a, "", " ")
if err != nil {
return []byte{}, err
}
return r, nil
}
func (s *ServeStats) GetHistory() (string, string, error) {
stats := s.toExported()
type History struct {
name string
time time.Time
}
firstServed := History{}
lastServed := History{}
for _, name := range stats.List {
for _, accessTime := range stats.Times[name] {
t, err := time.Parse(LogDate, accessTime)
if err != nil {
return "", "", err
}
if (firstServed.time == time.Time{}) {
firstServed.name = name
firstServed.time = t
}
if (lastServed.time == time.Time{}) {
lastServed.name = name
lastServed.time = t
}
switch {
case t.Before(firstServed.time):
firstServed.name = name
firstServed.time = t
case t.After(lastServed.time):
lastServed.name = name
lastServed.time = t
}
}
}
return firstServed.name, lastServed.name, nil
}
func (s *ServeStats) GetMostServed() string {
stats := s.toExported()
retVal := ""
for _, v := range stats.List {
if retVal == "" {
retVal = v
2023-06-03 23:45:32 +00:00
continue
}
if stats.Count[v] > stats.Count[retVal] {
retVal = v
}
}
return retVal
}
2023-02-08 13:50:40 +00:00
func (s *ServeStats) Export(path string) error {
file, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0600)
2023-02-08 13:50:40 +00:00
if err != nil {
return err
}
defer file.Close()
z, err := zstd.NewWriter(file)
if err != nil {
return err
}
defer z.Close()
enc := gob.NewEncoder(z)
stats := s.toExported()
err = enc.Encode(&stats)
if err != nil {
log.Fatal(err)
}
return nil
}
func (s *ServeStats) Import(path string) error {
file, err := os.OpenFile(path, os.O_RDONLY, 0600)
if err != nil {
return err
}
defer file.Close()
z, err := zstd.NewReader(file)
if err != nil {
return err
}
defer z.Close()
dec := gob.NewDecoder(z)
stats := &exportedServeStats{
List: []string{},
Count: make(map[string]uint64),
Size: make(map[string]string),
Times: make(map[string][]string),
}
err = dec.Decode(stats)
if err != nil {
return err
}
s.toImported(stats)
return nil
}
type timesServed struct {
File string
Served uint64
Size string
Times []string
}
func notFound(w http.ResponseWriter, r *http.Request, filePath string) error {
startTime := time.Now()
if verbose {
fmt.Printf("%s | Unavailable file %s requested by %s\n",
startTime.Format(LogDate),
filePath,
r.RemoteAddr,
)
}
2023-06-03 20:51:08 +00:00
w.WriteHeader(http.StatusNotFound)
w.Header().Add("Content-Type", "text/html")
var htmlBody strings.Builder
htmlBody.WriteString(`<!DOCTYPE html><html lang="en"><head>`)
htmlBody.WriteString(`<style>a{display:block;height:100%;width:100%;text-decoration:none;color:inherit;cursor:auto;}</style>`)
htmlBody.WriteString(`<title>Not Found</title></head>`)
htmlBody.WriteString(`<body><a href="/">404 page not found</a></body></html>`)
_, err := io.WriteString(w, gohtml.Format(htmlBody.String()))
if err != nil {
return err
}
return nil
}
func serverError() func(http.ResponseWriter, *http.Request, interface{}) {
return func(w http.ResponseWriter, r *http.Request, i interface{}) {
startTime := time.Now()
if verbose {
fmt.Printf("%s | Invalid request for %s from %s\n",
startTime.Format(LogDate),
r.URL.Path,
r.RemoteAddr,
)
}
2023-06-03 20:51:08 +00:00
w.WriteHeader(http.StatusInternalServerError)
w.Header().Add("Content-Type", "text/html")
var htmlBody strings.Builder
htmlBody.WriteString(`<!DOCTYPE html><html lang="en"><head>`)
htmlBody.WriteString(`<style>a{display:block;height:100%;width:100%;text-decoration:none;color:inherit;cursor:auto;}</style>`)
htmlBody.WriteString(`<title>Server Error</title></head>`)
htmlBody.WriteString(`<body><a href="/">500 Internal Server Error</a></body></html>`)
io.WriteString(w, gohtml.Format(htmlBody.String()))
}
}
2023-05-08 18:12:51 +00:00
func RefreshInterval(r *http.Request, Regexes *Regexes) (int64, string) {
refreshInterval := r.URL.Query().Get("refresh")
if !Regexes.units.MatchString(refreshInterval) {
return 0, "0ms"
}
duration, err := time.ParseDuration(refreshInterval)
if err != nil {
return 0, "0ms"
}
return duration.Milliseconds(), refreshInterval
}
2023-05-08 18:12:51 +00:00
func SortOrder(r *http.Request) string {
sortOrder := r.URL.Query().Get("sort")
if sortOrder == "asc" || sortOrder == "desc" {
return sortOrder
}
return ""
}
func splitQueryParams(query string, Regexes *Regexes) []string {
results := []string{}
if query == "" {
return results
}
params := strings.Split(query, ",")
for i := 0; i < len(params); i++ {
if Regexes.alphanumeric.MatchString(params[i]) {
results = append(results, strings.ToLower(params[i]))
}
}
return results
}
func generateQueryParams(filters *Filters, sortOrder, refreshInterval string) string {
var hasParams bool
var queryParams strings.Builder
queryParams.WriteString("?")
if filtering {
queryParams.WriteString("include=")
if filters.HasIncludes() {
queryParams.WriteString(filters.Includes())
}
queryParams.WriteString("&exclude=")
if filters.HasExcludes() {
queryParams.WriteString(filters.Excludes())
}
hasParams = true
}
if sorting {
if hasParams {
queryParams.WriteString("&")
}
queryParams.WriteString(fmt.Sprintf("sort=%s", sortOrder))
hasParams = true
}
if hasParams {
queryParams.WriteString("&")
}
queryParams.WriteString(fmt.Sprintf("refresh=%s", refreshInterval))
return queryParams.String()
}
func stripQueryParams(u string) (string, error) {
uri, err := url.Parse(u)
if err != nil {
return "", err
}
uri.RawQuery = ""
escapedUri, err := url.QueryUnescape(uri.String())
if err != nil {
return "", err
}
if runtime.GOOS == "windows" {
return strings.TrimPrefix(escapedUri, "/"), nil
}
return escapedUri, nil
}
func generateFilePath(filePath string) string {
var htmlBody strings.Builder
htmlBody.WriteString(SourcePrefix)
if runtime.GOOS == "windows" {
htmlBody.WriteString(`/`)
}
htmlBody.WriteString(filePath)
return htmlBody.String()
}
func refererToUri(referer string) string {
parts := strings.SplitAfterN(referer, "/", 4)
if len(parts) < 4 {
return ""
}
return "/" + parts[3]
}
func realIP(r *http.Request) string {
remoteAddr := strings.SplitAfter(r.RemoteAddr, ":")
if len(remoteAddr) < 1 {
return r.RemoteAddr
}
remotePort := remoteAddr[len(remoteAddr)-1]
cfIP := r.Header.Get("Cf-Connecting-Ip")
xRealIp := r.Header.Get("X-Real-Ip")
switch {
case cfIP != "":
return cfIP + ":" + remotePort
case xRealIp != "":
return xRealIp + ":" + remotePort
default:
return r.RemoteAddr
}
}
func serveCacheClear(args []string, index *Index) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
index.generateCache(args)
w.WriteHeader(http.StatusOK)
2023-06-03 23:45:32 +00:00
w.Header().Set("Content-Type", "text/plain")
2023-06-03 23:45:32 +00:00
w.Write([]byte("Ok"))
}
}
func serveStats(args []string, stats *ServeStats) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
w.WriteHeader(http.StatusOK)
2023-01-19 18:07:15 +00:00
w.Header().Set("Content-Type", "application/json")
startTime := time.Now()
first, last, err := stats.GetHistory()
if err != nil {
log.Fatal(err)
}
most := stats.GetMostServed()
fmt.Printf("First served: %s\n", first)
fmt.Printf("Last served: %s\n", last)
fmt.Printf("Most served: %s\n", most)
2023-01-19 18:07:15 +00:00
response, err := stats.ListImages()
if err != nil {
fmt.Println(err)
2023-06-03 23:45:32 +00:00
return
2023-01-19 18:07:15 +00:00
}
w.Write(response)
if verbose {
fmt.Printf("%s | Served statistics page (%s) to %s in %s\n",
startTime.Format(LogDate),
humanReadableSize(len(response)),
realIP(r),
time.Since(startTime).Round(time.Microsecond),
)
}
2023-02-08 13:50:40 +00:00
if statisticsFile != "" {
stats.Export(statisticsFile)
}
2023-01-19 18:07:15 +00:00
}
}
func serveDebugHtml(args []string, index *Index) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
w.WriteHeader(http.StatusOK)
w.Header().Set("Content-Type", "text/html")
startTime := time.Now()
indexDump := index.Index()
fileCount := strconv.Itoa(len(indexDump))
sort.SliceStable(indexDump, func(p, q int) bool {
return strings.ToLower(indexDump[p]) < strings.ToLower(indexDump[q])
})
var htmlBody strings.Builder
htmlBody.WriteString(`<!DOCTYPE html><html lang="en"><head>`)
2023-06-09 20:56:03 +00:00
htmlBody.WriteString(`<link rel="apple-touch-icon" sizes="180x180" href="/favicons/apple-touch-icon.png">`)
htmlBody.WriteString(`<link rel="icon" type="image/png" sizes="32x32" href="/favicons/favicon-32x32.png">`)
htmlBody.WriteString(`<link rel="icon" type="image/png" sizes="16x16" href="/favicons/favicon-16x16.png">`)
htmlBody.WriteString(`<link rel="manifest" href="/favicons/site.webmanifest">`)
htmlBody.WriteString(`<link rel="mask-icon" href="/favicons/safari-pinned-tab.svg" color="#5bbad5">`)
htmlBody.WriteString(`<meta name="msapplication-TileColor" content="#da532c">`)
htmlBody.WriteString(`<meta name="theme-color" content="#ffffff">`)
htmlBody.WriteString(`<style>a{text-decoration:none;height:100%;width:100%;color:inherit;cursor:pointer}table,td,tr{border:1px solid black;border-collapse:collapse}td{white-space:nowrap;padding:.5em}</style>`)
2023-06-03 02:04:06 +00:00
htmlBody.WriteString(`<title>Index contains `)
htmlBody.WriteString(fileCount)
htmlBody.WriteString(` files</title></head><body><table>`)
for _, v := range indexDump {
var shouldSort = ""
if sorting {
shouldSort = "?sort=asc"
}
htmlBody.WriteString(fmt.Sprintf("<tr><td><a href=\"%s%s%s\">%s</a></td></tr>\n", ImagePrefix, v, shouldSort, v))
}
htmlBody.WriteString(`</table></body></html>`)
b, err := io.WriteString(w, gohtml.Format(htmlBody.String()))
if err != nil {
return
}
if verbose {
fmt.Printf("%s | Served HTML debug page (%s) to %s in %s\n",
startTime.Format(LogDate),
humanReadableSize(b),
realIP(r),
time.Since(startTime).Round(time.Microsecond),
)
}
}
}
func serveDebugJson(args []string, index *Index) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
w.WriteHeader(http.StatusOK)
w.Header().Set("Content-Type", "application/json")
startTime := time.Now()
2023-04-28 18:26:47 +00:00
indexDump := index.Index()
sort.SliceStable(indexDump, func(p, q int) bool {
return strings.ToLower(indexDump[p]) < strings.ToLower(indexDump[q])
2023-04-28 18:26:47 +00:00
})
response, err := json.MarshalIndent(indexDump, "", " ")
if err != nil {
return
}
w.Write(response)
if verbose {
fmt.Printf("%s | Served JSON debug page (%s) to %s in %s\n",
startTime.Format(LogDate),
humanReadableSize(len(response)),
realIP(r),
time.Since(startTime).Round(time.Microsecond),
)
}
}
}
func serveStaticFile(paths []string, stats *ServeStats) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
path := strings.TrimPrefix(r.URL.Path, SourcePrefix)
prefixedFilePath, err := stripQueryParams(path)
2023-05-08 18:12:51 +00:00
if err != nil {
fmt.Println(err)
2023-06-03 23:45:32 +00:00
2023-05-08 18:12:51 +00:00
return
}
filePath, err := filepath.EvalSymlinks(strings.TrimPrefix(prefixedFilePath, SourcePrefix))
2023-05-08 18:12:51 +00:00
if err != nil {
fmt.Println(err)
2023-06-03 23:45:32 +00:00
2023-05-08 18:12:51 +00:00
return
}
if !pathIsValid(filePath, paths) {
notFound(w, r, filePath)
return
}
exists, err := fileExists(filePath)
if err != nil {
fmt.Println(err)
2023-06-03 23:45:32 +00:00
2023-05-08 18:12:51 +00:00
return
}
if !exists {
notFound(w, r, filePath)
return
}
startTime := time.Now()
buf, err := os.ReadFile(filePath)
if err != nil {
fmt.Println(err)
2023-06-03 23:45:32 +00:00
2023-05-08 18:12:51 +00:00
return
}
w.Write(buf)
fileSize := humanReadableSize(len(buf))
if verbose {
fmt.Printf("%s | Served %s (%s) to %s in %s\n",
startTime.Format(LogDate),
filePath,
fileSize,
realIP(r),
time.Since(startTime).Round(time.Microsecond),
)
}
if statistics {
stats.incrementCounter(filePath, startTime, fileSize)
}
}
}
func serveRoot(paths []string, Regexes *Regexes, index *Index) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
refererUri, err := stripQueryParams(refererToUri(r.Referer()))
if err != nil {
fmt.Println(err)
return
}
strippedRefererUri := strings.TrimPrefix(refererUri, ImagePrefix)
filters := &Filters{
includes: splitQueryParams(r.URL.Query().Get("include"), Regexes),
excludes: splitQueryParams(r.URL.Query().Get("exclude"), Regexes),
}
2023-05-08 18:12:51 +00:00
sortOrder := SortOrder(r)
2023-05-08 18:12:51 +00:00
_, refreshInterval := RefreshInterval(r, Regexes)
var filePath string
if refererUri != "" {
filePath, err = nextFile(strippedRefererUri, sortOrder, Regexes)
if err != nil {
fmt.Println(err)
return
}
}
loop:
for timeout := time.After(Timeout); ; {
select {
case <-timeout:
break loop
default:
}
if filePath != "" {
break loop
}
filePath, err = newFile(paths, filters, sortOrder, Regexes, index)
switch {
case err != nil && err == ErrNoImagesFound:
notFound(w, r, filePath)
return
case err != nil:
fmt.Println(err)
return
}
}
2023-05-09 01:05:10 +00:00
queryParams := generateQueryParams(filters, sortOrder, refreshInterval)
newUrl := fmt.Sprintf("http://%s%s%s",
r.Host,
preparePath(filePath),
queryParams,
)
http.Redirect(w, r, newUrl, RedirectStatusCode)
}
}
func serveImage(paths []string, Regexes *Regexes, index *Index) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
filters := &Filters{
includes: splitQueryParams(r.URL.Query().Get("include"), Regexes),
excludes: splitQueryParams(r.URL.Query().Get("exclude"), Regexes),
}
2023-05-09 01:05:10 +00:00
sortOrder := SortOrder(r)
filePath := strings.TrimPrefix(r.URL.Path, ImagePrefix)
2023-05-08 18:12:51 +00:00
if runtime.GOOS == "windows" {
filePath = strings.TrimPrefix(filePath, "/")
}
2023-05-08 18:12:51 +00:00
exists, err := fileExists(filePath)
if err != nil {
fmt.Println(err)
return
}
if !exists {
notFound(w, r, filePath)
return
}
2023-05-08 18:12:51 +00:00
image, err := isSupportedFileType(filePath)
if err != nil {
fmt.Println(err)
return
}
2023-05-08 18:12:51 +00:00
if !image {
notFound(w, r, filePath)
2023-05-08 18:12:51 +00:00
return
}
var dimensions *Dimensions
2023-05-08 18:12:51 +00:00
if image {
dimensions, err = imageDimensions(filePath)
if err != nil {
fmt.Println(err)
return
}
}
fileName := filepath.Base(filePath)
w.Header().Add("Content-Type", "text/html")
refreshTimer, refreshInterval := RefreshInterval(r, Regexes)
queryParams := generateQueryParams(filters, sortOrder, refreshInterval)
var htmlBody strings.Builder
htmlBody.WriteString(`<!DOCTYPE html><html lang="en"><head>`)
htmlBody.WriteString(`<link rel="apple-touch-icon" sizes="180x180" href="/favicons/apple-touch-icon.png">`)
htmlBody.WriteString(`<link rel="icon" type="image/png" sizes="32x32" href="/favicons/favicon-32x32.png">`)
htmlBody.WriteString(`<link rel="icon" type="image/png" sizes="16x16" href="/favicons/favicon-16x16.png">`)
htmlBody.WriteString(`<link rel="manifest" href="/favicons/site.webmanifest">`)
htmlBody.WriteString(`<link rel="mask-icon" href="/favicons/safari-pinned-tab.svg" color="#5bbad5">`)
htmlBody.WriteString(`<meta name="msapplication-TileColor" content="#da532c">`)
htmlBody.WriteString(`<meta name="theme-color" content="#ffffff">`)
htmlBody.WriteString(`<style>html,body{margin:0;padding:0;height:100%;}`)
htmlBody.WriteString(`a{display:block;height:100%;width:100%;text-decoration:none;}`)
htmlBody.WriteString(`img{margin:auto;display:block;max-width:97%;max-height:97%;object-fit:scale-down;`)
htmlBody.WriteString(`position:absolute;top:50%;left:50%;transform:translate(-50%,-50%);}</style>`)
htmlBody.WriteString(fmt.Sprintf(`<title>%s (%dx%d)</title>`,
fileName,
dimensions.width,
dimensions.height))
htmlBody.WriteString(`</head><body>`)
if refreshInterval != "0ms" {
htmlBody.WriteString(fmt.Sprintf("<script>window.onload = function(){setInterval(function(){window.location.href = '/%s';}, %d);};</script>",
queryParams,
refreshTimer))
}
htmlBody.WriteString(fmt.Sprintf(`<a href="/%s"><img src="%s" width="%d" height="%d" alt="Roulette selected: %s"></a>`,
queryParams,
generateFilePath(filePath),
dimensions.width,
dimensions.height,
fileName))
htmlBody.WriteString(`</body></html>`)
_, err = io.WriteString(w, gohtml.Format(htmlBody.String()))
if err != nil {
fmt.Println(err)
return
}
}
}
func serveFavicons() httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
fname := strings.TrimPrefix(r.URL.Path, "/")
data, err := favicons.ReadFile(fname)
if err != nil {
return
}
w.Header().Write(bytes.NewBufferString("Content-Length: " + strconv.Itoa(len(data))))
w.Write(data)
}
}
2023-06-03 20:51:08 +00:00
func serveVersion() httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, p httprouter.Params) {
data := []byte(fmt.Sprintf("roulette v%s\n", Version))
w.Header().Write(bytes.NewBufferString("Content-Length: " + strconv.Itoa(len(data))))
2023-06-03 20:51:08 +00:00
w.Write(data)
}
}
func ServePage(args []string) error {
bindHost, err := net.LookupHost(bind)
if err != nil {
return err
}
bindAddr := net.ParseIP(bindHost[0])
if bindAddr == nil {
return errors.New("invalid bind address provided")
}
paths, err := normalizePaths(args)
if err != nil {
return err
}
2023-04-11 09:44:18 +00:00
if len(paths) == 0 {
return errors.New("no supported files found in provided paths")
2023-04-11 09:44:18 +00:00
}
Regexes := &Regexes{
filename: regexp.MustCompile(`(.+)([0-9]{3})(\..+)`),
alphanumeric: regexp.MustCompile(`^[a-zA-Z0-9]*$`),
units: regexp.MustCompile(`^[0-9]+(ns|us|µs|ms|s|m|h)$`),
2022-09-16 19:45:54 +00:00
}
rand.New(rand.NewSource(time.Now().UnixNano()))
index := &Index{
mutex: sync.RWMutex{},
list: []string{},
}
mux := httprouter.New()
mux.PanicHandler = serverError()
if cache {
skipIndex := false
2023-02-05 20:34:22 +00:00
if cacheFile != "" {
2023-02-08 13:50:40 +00:00
err := index.Import(cacheFile)
if err == nil {
skipIndex = true
}
}
if !skipIndex {
index.generateCache(args)
}
mux.GET("/clear_cache", serveCacheClear(args, index))
}
stats := &ServeStats{
mutex: sync.RWMutex{},
list: []string{},
count: make(map[string]uint64),
size: make(map[string]string),
times: make(map[string][]string),
}
2023-02-08 13:50:40 +00:00
if statistics && statisticsFile != "" {
stats.Import(statisticsFile)
gracefulShutdown := make(chan os.Signal, 1)
signal.Notify(gracefulShutdown, syscall.SIGINT, syscall.SIGTERM)
go func() {
<-gracefulShutdown
2023-02-08 13:50:40 +00:00
stats.Export(statisticsFile)
2023-02-08 13:50:40 +00:00
os.Exit(0)
}()
}
2023-02-05 20:34:22 +00:00
if statistics {
mux.GET("/stats", serveStats(args, stats))
}
if debug {
mux.GET("/html", serveDebugHtml(args, index))
mux.GET("/json", serveDebugJson(args, index))
}
2023-06-03 20:51:08 +00:00
mux.GET("/", serveRoot(paths, Regexes, index))
mux.GET("/favicons/*favicon", serveFavicons())
2023-06-03 20:51:08 +00:00
mux.GET(ImagePrefix+"/*image", serveImage(paths, Regexes, index))
2023-06-03 20:51:08 +00:00
mux.GET(SourcePrefix+"/*static", serveStaticFile(paths, stats))
2023-06-03 20:51:08 +00:00
mux.GET("/version", serveVersion())
srv := &http.Server{
Addr: net.JoinHostPort(bind, strconv.FormatInt(int64(port), 10)),
Handler: mux,
IdleTimeout: 10 * time.Minute,
ReadTimeout: 5 * time.Second,
WriteTimeout: 5 * time.Minute,
}
err = srv.ListenAndServe()
if !errors.Is(err, http.ErrServerClosed) {
return err
}
return nil
2022-09-08 15:12:06 +00:00
}