fix some edge cases

Author: joecorall

internal/state/lock.go

@@ -48,7 +48,11 @@ func (fl *FileLock) Lock() error {
 			if info, statErr := os.Stat(fl.lockPath); statErr == nil {
 				if time.Since(info.ModTime()) > 10*time.Second {
 					// Lock file is stale, remove it and try again
-					os.Remove(fl.lockPath)
+					err = os.Remove(fl.lockPath)
+					if err != nil {
+						return fmt.Errorf("unable to remove lock: %v", err)
+					}
+					continue
 				}
 			}
 		}

internal/state/state.go

@@ -151,7 +151,7 @@ func ReconcileState(fileState State, rateCache, botCache, verifiedCache *lru.Cac
 
 	// Reconcile rate cache
 	for k, fileEntry := range fileState.Rate {
-		if fileEntry.Expiration > 0 && fileEntry.Expiration < now {
+		if fileEntry.Expiration > 0 && fileEntry.Expiration <= now {
 			continue // Skip expired entries
 		}
 

main.go

@@ -26,7 +26,7 @@ import (
 
 const (
 	// StateSaveInterval is how often the persistent state file is written to disk
-	StateSaveInterval = 5 * time.Second
+	StateSaveInterval = 10 * time.Second
 	// StateSaveJitter is the maximum random jitter added to save interval to prevent thundering herd
 	StateSaveJitter = 2 * time.Second
 )