Remove expired rate_conn hash keys (#66)

closes #65
haraka · Jul 17, 2024 · 89b4769 · 89b4769
1 parent 58a35ca
commit 89b4769
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/index.js b/index.js
@@ -511,7 +511,10 @@ exports.rate_conn_enforce = async function (next, connection) {
 
     let connections_in_ttl_period = 0
     for (const ts of Object.keys(tstamps)) {
-      if (parseInt(ts, 10) < periodStartTs) continue // older than ttl
+      if (parseInt(ts, 10) < periodStartTs) { // older than ttl
+        this.db.hDel(`rate_conn:${key}`, ts);
+        continue
+      }
       connections_in_ttl_period =
         connections_in_ttl_period + parseInt(tstamps[ts], 10)
     }