Compare commits

...

4 Commits

6 changed files with 68 additions and 36 deletions

View File

@ -6,9 +6,11 @@ package cmd
import (
"encoding/gob"
"fmt"
"net/http"
"os"
"sync"
"time"
"github.com/julienschmidt/httprouter"
"github.com/klauspost/compress/zstd"
@ -79,6 +81,8 @@ func (cache *fileCache) isEmpty() bool {
}
func (cache *fileCache) Export(path string) error {
startTime := time.Now()
file, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0600)
if err != nil {
return err
@ -95,12 +99,23 @@ func (cache *fileCache) Export(path string) error {
cache.mutex.RLock()
enc.Encode(&cache.list)
length := len(cache.list)
cache.mutex.RUnlock()
if Verbose {
fmt.Printf("%s | CACHE: Exported %d entries in %s\n",
time.Now().Format(logDate),
length,
time.Since(startTime),
)
}
return nil
}
func (cache *fileCache) Import(path string) error {
startTime := time.Now()
file, err := os.OpenFile(path, os.O_RDONLY, 0600)
if err != nil {
return err
@ -116,15 +131,22 @@ func (cache *fileCache) Import(path string) error {
dec := gob.NewDecoder(z)
cache.mutex.Lock()
err = dec.Decode(&cache.list)
length := len(cache.list)
cache.mutex.Unlock()
if err != nil {
return err
}
if Verbose {
fmt.Printf("%s | CACHE: Imported %d entries in %s\n",
time.Now().Format(logDate),
length,
time.Since(startTime),
)
}
return nil
}
@ -146,6 +168,12 @@ func serveCacheClear(args []string, cache *fileCache, formats *types.Types, erro
}
func registerCacheHandlers(mux *httprouter.Router, args []string, cache *fileCache, formats *types.Types, errorChannel chan<- error) error {
register(mux, Prefix+"/clear_cache", serveCacheClear(args, cache, formats, errorChannel))
return nil
}
func importCache(args []string, cache *fileCache, formats *types.Types) error {
skipIndex := false
if CacheFile != "" {
@ -156,15 +184,11 @@ func registerCacheHandlers(mux *httprouter.Router, args []string, cache *fileCac
}
if !skipIndex {
list, err := fileList(args, &filters{}, "", &fileCache{}, formats)
_, err := fileList(args, &filters{}, "", cache, formats)
if err != nil {
return err
}
cache.set(list)
}
register(mux, Prefix+"/clear_cache", serveCacheClear(args, cache, formats, errorChannel))
return nil
}

View File

@ -27,14 +27,12 @@ const (
<meta name="theme-color" content="#ffffff">`
)
func serveFavicons(errorChannel chan<- error) httprouter.Handle {
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 {
errorChannel <- err
return
}

View File

@ -5,6 +5,7 @@ Copyright © 2023 Seednode <seednode@seedno.de>
package cmd
import (
"path/filepath"
"slices"
"strings"
)
@ -41,26 +42,30 @@ func (filters *filters) apply(fileList []string) []string {
if filters.hasExcludes() {
for _, exclude := range filters.excluded {
result = slices.DeleteFunc(fileList, func(s string) bool {
result = slices.DeleteFunc(result, func(s string) bool {
if CaseSensitive {
return strings.Contains(s, exclude)
return strings.Contains(s, filepath.Base(exclude))
} else {
return strings.Contains(strings.ToLower(s), strings.ToLower(exclude))
return strings.Contains(strings.ToLower(s), strings.ToLower(filepath.Base(exclude)))
}
})
}
}
if filters.hasIncludes() {
for _, include := range filters.included {
result = slices.DeleteFunc(fileList, func(s string) bool {
if CaseSensitive {
return !strings.Contains(s, include)
} else {
return !strings.Contains(strings.ToLower(s), strings.ToLower(include))
result = slices.DeleteFunc(result, func(s string) bool {
var delete bool = true
p := filepath.Base(s)
for _, include := range filters.included {
if (CaseSensitive && strings.Contains(p, include)) || (!CaseSensitive && strings.Contains(strings.ToLower(p), strings.ToLower(include))) {
delete = false
}
})
}
}
return delete
})
}
return result

View File

@ -12,7 +12,7 @@ import (
)
const (
ReleaseVersion string = "0.94.0"
ReleaseVersion string = "0.96.3"
)
var (

View File

@ -440,18 +440,6 @@ func ServePage(args []string) error {
return ErrNoMediaFound
}
cache := &fileCache{
mutex: sync.RWMutex{},
list: []string{},
}
regexes := &regexes{
filename: regexp.MustCompile(`(.+)([0-9]{3})(\..+)`),
alphanumeric: regexp.MustCompile(`^[A-z0-9]*$`),
}
mux := httprouter.New()
listenHost := net.JoinHostPort(Bind, strconv.Itoa(Port))
if Verbose {
@ -461,6 +449,23 @@ func ServePage(args []string) error {
)
}
cache := &fileCache{
mutex: sync.RWMutex{},
list: []string{},
}
err = importCache(paths, cache, formats)
if err != nil {
return err
}
regexes := &regexes{
filename: regexp.MustCompile(`(.+)([0-9]{3})(\..+)`),
alphanumeric: regexp.MustCompile(`^[A-z0-9]*$`),
}
mux := httprouter.New()
srv := &http.Server{
Addr: listenHost,
Handler: mux,
@ -485,9 +490,9 @@ func ServePage(args []string) error {
register(mux, "/", redirectRoot())
}
register(mux, Prefix+"/favicons/*favicon", serveFavicons(errorChannel))
register(mux, Prefix+"/favicons/*favicon", serveFavicons())
register(mux, Prefix+"/favicon.ico", serveFavicons(errorChannel))
register(mux, Prefix+"/favicon.ico", serveFavicons())
register(mux, Prefix+mediaPrefix+"/*media", serveMedia(paths, regexes, cache, formats, errorChannel))

Binary file not shown.