Add Ratelimit cleanup interval

CHANGELOG.md

@@ -1,5 +1,11 @@
 # Changelog
 
+## 9.1.7
+
+- Add Ratelimit cleanup interval
+- Fix typo in readme
+- fix some tabs
+
 ## 9.1.6
 
 - Do not include prefix in route files directly

README.MD

@@ -31,7 +31,7 @@ You will need a runtime to actually use the server. (adapt command to your packa
 
 ```sh
 npm install @rjweb/runtime-bun # for bun users
-npm install @rjweb/runtime-node # for nodejs users (who couldve guseed, may also work with deno though)
+npm install @rjweb/runtime-node # for nodejs users (who couldve guessed, may also work with deno though)
 ```
 
 ## Migrating

package.json

@@ -1,6 +1,6 @@
 {
   "name": "rjweb-server",
-  "version": "9.1.6",
+  "version": "9.1.7",
   "description": "Easy and Robust Way to create a Web Server with Many Easy-to-use Features in NodeJS",
   "main": "./lib/cjs/index.js",
   "module": "./lib/esm/index.js",

src/classes/Route.ts

@@ -55,19 +55,19 @@ export default class Route<Type extends RequestType> {
 
 		if (isRegExp(path)) {
 			this.urlData = {
-        type: 'regexp',
-        value: path,
+				type: 'regexp',
+				value: path,
 				prefix: '/',
-        segments: [{
+				segments: [{
 					raw: '',
-          paramsRegExp: new RegExp(''),
-          params: []
+					paramsRegExp: new RegExp(''),
+					params: []
 				}, {
 					raw: '',
-          paramsRegExp: new RegExp(''),
-          params: []
+					paramsRegExp: new RegExp(''),
+					params: []
 				}]
-      }
+			}
 		} else if (typeof path === 'string') {
 			const segments = parseURL(path).path.split('/')
 
@@ -80,8 +80,8 @@ export default class Route<Type extends RequestType> {
 			for (const segment of segments) {
 				this.urlData.segments.push({
 					raw: segment,
-          paramsRegExp: new RegExp(segment.replace(/{([^}]+)}/g, '(.*\\S)')),
-          params: (segment.match(/{([^}]+)}/g) ?? []).map((m) => m.slice(1, -1))
+					paramsRegExp: new RegExp(segment.replace(/{([^}]+)}/g, '(.*\\S)')),
+					params: (segment.match(/{([^}]+)}/g) ?? []).map((m) => m.slice(1, -1))
 				})
 			}
 		} else {

src/classes/Server.ts

@@ -1,7 +1,7 @@
 import { BaseImplementation, Implementation } from "@/types/implementation"
 import { Method, ReverseProxyIps, ServerStatus } from "@/types/global"
 import { FullServerOptions, ServerOptions } from "@/types/structures/ServerOptions"
-import { as, object, size } from "@rjweb/utils"
+import { as, object, size, time } from "@rjweb/utils"
 import GlobalContext from "@/types/internal/classes/GlobalContext"
 import ContentTypes from "@/classes/router/ContentTypes"
 import { DataContext, EndFn, ErrorCallbacks, RatelimitCallbacks, RealAny } from "@/types/internal"
@@ -67,6 +67,7 @@ export default class Server<const Options extends ServerOptions, Middlewares ext
 	private _status: ServerStatus = 'stopped'
 	private global: GlobalContext
 	private promises: Promise<any>[] = []
+	private interval: NodeJS.Timeout | null = null
 	private openAPISchemas: Record<string, oas31.SchemaObject | oas31.ReferenceObject> = {}
 
 	/**
@@ -286,6 +287,17 @@ export default class Server<const Options extends ServerOptions, Middlewares ext
 				await Promise.all(this.middlewares.map((middleware) => middleware.callbacks.load?.(middleware.config, this as any, this.global)))
 				this.global.logger.debug(`Running Middleware Promises ... Done ${(performance.now() - middlewareStartTime).toFixed(2)}ms`)
 
+				this.interval = setInterval(() => {
+					this.global.logger.debug('Running 1min Interval ...')
+					const intervalStartTime = performance.now()
+
+					for (const [ key, { end } ] of this.global.rateLimits) {
+						if (end < Date.now()) this.global.rateLimits.delete(key)
+					}
+
+					this.global.logger.debug(`Running 1min Interval ... Done ${(performance.now() - intervalStartTime).toFixed(2)}ms`)
+				}, time(1).m())
+
 				resolve(this.implementation.port())
 			} catch (err) {
 				this.implementation.stop()
@@ -318,6 +330,7 @@ export default class Server<const Options extends ServerOptions, Middlewares ext
 		if (this._status === 'stopped') throw new Error('Server is already stopped')
 
 		this.implementation.stop()
+		if (this.interval) clearInterval(this.interval)
 		this._status = 'stopped'
 
 		return this