mirror of
https://github.com/Luzifer/staticmap.git
synced 2024-10-18 07:34:23 +00:00
47 lines
1.1 KiB
Go
47 lines
1.1 KiB
Go
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"io"
|
|
"os"
|
|
"path"
|
|
"time"
|
|
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
const (
|
|
cacheDirMode = 0o700
|
|
cacheFileMode = 0o600
|
|
)
|
|
|
|
func filesystemCache(opts generateMapConfig) (io.ReadCloser, error) {
|
|
cacheKey := opts.getCacheKey()
|
|
cacheFileName := path.Join(cfg.CacheDir, cacheKey[0:2], cacheKey+".png")
|
|
|
|
if info, err := os.Stat(cacheFileName); err == nil && info.ModTime().Add(cfg.ForceCache).After(time.Now()) {
|
|
f, err := os.Open(cacheFileName) //#nosec:G304 // Intended to open a variable file
|
|
return f, errors.Wrap(err, "opening file")
|
|
}
|
|
|
|
// No cache hit, generate a new map
|
|
mapReader, err := generateMap(opts)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
buf := new(bytes.Buffer)
|
|
if _, err = io.Copy(buf, mapReader); err != nil {
|
|
return nil, errors.Wrap(err, "writing file")
|
|
}
|
|
|
|
if err = os.MkdirAll(path.Dir(cacheFileName), cacheDirMode); err != nil {
|
|
return nil, errors.Wrap(err, "creating cache dir")
|
|
}
|
|
|
|
if err = os.WriteFile(cacheFileName, buf.Bytes(), cacheFileMode); err != nil {
|
|
return nil, errors.Wrap(err, "writing cache file")
|
|
}
|
|
|
|
return io.NopCloser(buf), err
|
|
}
|