skunky/SkunkyArt
1
0
Fork 0
mirror of https://git.macaw.me/skunky/SkunkyArt.git synced 2025-04-28 12:05:06 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Переключатель кеша в озу, небольшие улучшения ксс, фикс нсфв, фикс максимального размера кеша

Browse source
This commit is contained in:
lost+skunk 2025-02-22 15:30:29 +03:00
parent 32c61ec8ea
commit 048bb470ab
7 changed files with 88 additions and 47 deletions
Download patch file Download diff file Expand all files Collapse all files

72
app/cache.go
View file

@ -38,17 +38,7 @@ func (s skunkyart) DownloadAndSendMedia(subdomain, path string) {
fileName := sha1.Sum([]byte(subdomain + path))
filePath := CFG.Cache.Path + "/" + hex.EncodeToString(fileName[:])
mx.Lock()
if tempFS[fileName] == nil {
tempFS[fileName] = &file{}
}
mx.Unlock()
if tempFS[fileName].Content != nil {
response = tempFS[fileName].Content
tempFS[fileName].Score += 2
break
} else {
c := func() {
file, err := os.Open(filePath)
if err != nil {
if dwnld := Download(url.String()); dwnld.Status == 200 && dwnld.Headers["Content-Type"][0][:5] == "image" {
@ -63,27 +53,44 @@ func (s skunkyart) DownloadAndSendMedia(subdomain, path string) {
try(e)
response = file
}
}
go func() {
defer restore()
if CFG.Cache.MemCache {
mx.Lock()
if tempFS[fileName] == nil {
tempFS[fileName] = &file{}
}
mx.Unlock()
mx.RLock()
tempFS[fileName].Content = response
mx.RUnlock()
if tempFS[fileName].Content != nil {
response = tempFS[fileName].Content
tempFS[fileName].Score += 2
break
} else {
c()
go func() {
defer restore()
for {
time.Sleep(1 * time.Minute)
mx.RLock()
tempFS[fileName].Content = response
mx.RUnlock()
mx.Lock()
if tempFS[fileName].Score <= 0 {
delete(tempFS, fileName)
for {
time.Sleep(1 * time.Minute)
mx.Lock()
if tempFS[fileName].Score <= 0 {
delete(tempFS, fileName)
mx.Unlock()
return
}
tempFS[fileName].Score--
mx.Unlock()
return
}
tempFS[fileName].Score--
mx.Unlock()
}
}()
}()
}
} else {
c()
}
case CFG.Proxy:
dwnld := Download(url.String())
@ -112,6 +119,7 @@ func InitCacheSystem() {
println(err.Error())
}
var total int64
for _, file := range dir {
fileName := c.Path + "/" + file.Name()
fileInfo, err := file.Info()
@ -128,9 +136,15 @@ func InitCacheSystem() {
}
}
if c.MaxSize != 0 && fileInfo.Size() > c.MaxSize {
try(os.RemoveAll(fileName))
}
total += fileInfo.Size()
// if c.MaxSize != 0 && fileInfo.Size() > c.MaxSize {
// try(os.RemoveAll(fileName))
// }
}
if c.MaxSize != 0 && total > c.MaxSize {
try(os.RemoveAll(c.Path))
os.Mkdir(c.Path, 0700)
}
time.Sleep(time.Second * time.Duration(c.UpdateInterval))