Skip to content

Commit 7ef1a0e

Browse files
committed
change(cache): clear cache of banned sa's that have expired on close
1 parent 95f828d commit 7ef1a0e

File tree

2 files changed

+14
-0
lines changed

2 files changed

+14
-0
lines changed

cache/cache.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,10 @@ func Init(cachePath string, logLevel int) error {
4141
}
4242

4343
func Close() {
44+
// clear banned sa's
45+
ClearExpiredBans()
46+
47+
// close
4448
if err := db.Close(); err != nil {
4549
log.WithError(err).Error("Failed closing cache gracefully...")
4650
}

cache/sa.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,16 @@ type Banned struct {
1010
Expires time.Time
1111
}
1212

13+
func ClearExpiredBans() {
14+
iter := db.Bucket("banned").Iter()
15+
defer iter.Close()
16+
17+
var page Banned
18+
for iter.Next(&page) {
19+
_, _ = IsBanned(page.Path)
20+
}
21+
}
22+
1323
func IsBanned(key string) (bool, time.Time) {
1424
// check if key was found in banned bucket
1525
var item Banned

0 commit comments

Comments
 (0)