36 lines
845 B
Go
36 lines
845 B
Go
package storage
|
|
|
|
import (
|
|
"io/ioutil"
|
|
"log"
|
|
"os"
|
|
"strconv"
|
|
"time"
|
|
|
|
"openreplay/backend/pkg/flakeid"
|
|
)
|
|
|
|
func (s *Storage) CleanDir(dirname string) {
|
|
files, err := ioutil.ReadDir(dirname)
|
|
if err != nil {
|
|
log.Printf("Cannot read file directory. %v", err)
|
|
return
|
|
}
|
|
removedFiles := 0
|
|
for _, f := range files {
|
|
name := f.Name()
|
|
id, err := strconv.ParseUint(name, 10, 64)
|
|
if err != nil {
|
|
log.Printf("Cannot parse session filename. %v", err)
|
|
continue
|
|
}
|
|
ts := int64(flakeid.ExtractTimestamp(id))
|
|
if time.UnixMilli(ts).Add(s.cfg.DeleteTimeout).Before(time.Now()) {
|
|
// returns an error. Don't log it since it can be race condition between worker instances
|
|
if err := os.Remove(dirname + "/" + name); err == nil {
|
|
removedFiles++
|
|
}
|
|
}
|
|
}
|
|
log.Printf("Removed %d of %d session files", removedFiles, len(files))
|
|
}
|