provide customResponseSchema feature

lib/default-options.spec.ts

@@ -29,5 +29,6 @@ describe('defaultRateLimiterOptions', () => {
 		expect(Object.keys(defaultRateLimiterOptions.indexKeyPrefix).length).toBe(0)
 		expect(defaultRateLimiterOptions.maxQueueSize).toBe(100)
 		expect(defaultRateLimiterOptions.errorMessage).toBe('Rate limit exceeded')
+		expect(defaultRateLimiterOptions.customResponseSchema).toBeUndefined()
 	})
 })

lib/default-options.ts

@@ -24,5 +24,6 @@ export const defaultRateLimiterOptions: RateLimiterOptions = {
 	execEvenlyMinDelayMs: undefined,
 	indexKeyPrefix: {},
 	maxQueueSize: 100,
-	errorMessage: 'Rate limit exceeded'
+	errorMessage: 'Rate limit exceeded',
+	customResponseSchema: undefined
 }

lib/rate-limiter.interceptor.ts

@@ -191,8 +191,9 @@ export class RateLimiterInterceptor implements NestInterceptor {
 			}
 		} catch (rateLimiterResponse) {
 			response.header('Retry-After', Math.ceil(rateLimiterResponse.msBeforeNext / 1000))
-			if (typeof this.options.createErrorBody === 'function') {
-				throw new HttpException(this.options.createErrorBody(rateLimiterResponse), HttpStatus.TOO_MANY_REQUESTS)
+			if (typeof this.spesificOptions?.customResponseSchema === 'function' || typeof this.options.customResponseSchema === 'function') {
+				var errorBody = this.spesificOptions?.customResponseSchema || this.options.customResponseSchema;
+				throw new HttpException(errorBody(rateLimiterResponse), HttpStatus.TOO_MANY_REQUESTS)
 			} else {
 				throw new HttpException(this.spesificOptions?.errorMessage || this.options.errorMessage, HttpStatus.TOO_MANY_REQUESTS)
 			}

lib/rate-limiter.interface.ts

@@ -27,7 +27,7 @@ export interface RateLimiterOptions {
 	indexKeyPrefix?: {}
 	maxQueueSize?: number
 	errorMessage?: string
-	createErrorBody?: (rateLimiterResponse: RateLimiterRes) => {}
+	customResponseSchema?: (rateLimiterResponse: RateLimiterRes) => {}
 }
 
 export interface RateLimiterOptionsFactory {