feat(mysql): delete expired key on get

mdelapenya · mdelapenya · commit bbe68b9fa88f · 2025-11-24T16:46:05.000+01:00
diff --git a/mysql/mysql.go b/mysql/mysql.go
@@ -129,6 +129,10 @@ func (s *Storage) GetWithContext(ctx context.Context, key string) ([]byte, error
 
 	// If the expiration time has already passed, then return nil
 	if exp != 0 && exp <= time.Now().Unix() {
+		_, err := s.db.ExecContext(ctx, s.sqlDelete, key)
+		if err != nil {
+			return nil, fmt.Errorf("delete expired key: %w", err)
+		}
 		return nil, nil
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -129,6 +129,10 @@ func (s *Storage) GetWithContext(ctx context.Context, key string) ([]byte, error`
`129`	`129`
`130`	`130`	`// If the expiration time has already passed, then return nil`
`131`	`131`	`if exp != 0 && exp <= time.Now().Unix() {`
	`132`	`+ _, err := s.db.ExecContext(ctx, s.sqlDelete, key)`
	`133`	`+ if err != nil {`
	`134`	`+ return nil, fmt.Errorf("delete expired key: %w", err)`
	`135`	`+ }`
`132`	`136`	`return nil, nil`
`133`	`137`	`}`
`134`	`138`