Skip to content

Commit 2005c19

Browse files
authored
QFIX: Services rate limit (#9193)
Signed-off-by: Andrey Sobolev <[email protected]>
1 parent 7c032ab commit 2005c19

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/server/src/sessionManager.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1099,7 +1099,7 @@ export class TSessionManager implements SessionManager {
10991099
source: service.token.extra?.service ?? '🤦‍♂️user',
11001100
mode: '🧭 handleRequest'
11011101
})
1102-
const rateLimit = this.limitter.checkRateLimit(service.getUser())
1102+
const rateLimit = this.limitter.checkRateLimit(service.getUser() + (service.token.extra?.service ?? ''))
11031103
// If remaining is 0, rate limit is exceeded
11041104
if (rateLimit?.remaining === 0) {
11051105
void ws.send(
@@ -1213,7 +1213,7 @@ export class TSessionManager implements SessionManager {
12131213
ws: ConnectionSocket,
12141214
operation: (ctx: ClientSessionCtx, rateLimit: RateLimitInfo | undefined) => Promise<void>
12151215
): Promise<RateLimitInfo | undefined> {
1216-
const rateLimitStatus = this.limitter.checkRateLimit(service.getUser())
1216+
const rateLimitStatus = this.limitter.checkRateLimit(service.getUser() + (service.token.extra?.service ?? ''))
12171217
// If remaining is 0, rate limit is exceeded
12181218
if (rateLimitStatus?.remaining === 0) {
12191219
return await Promise.resolve(rateLimitStatus)

0 commit comments

Comments
 (0)