keith/barkey
1
0
Fork 0
mirror of https://codeberg.org/yeentown/barkey synced 2024-11-22 11:25:13 +00:00
Code Issues Projects Releases Packages Wiki Activity

make the cap of activeRateLimitRequests match the rate limit

Browse source 
It's trivial to have more than 128 requests in flight: open a busy
timeline, scroll a bit down, wait for many notes to arrive, scroll to
the top. The frontend will send "subscribe to note" messages for each
new note that it accumulated, all at once. We don't want to shut down
the connection in those common cases!
This commit is contained in:
dakkar 2024-08-18 17:57:51 +01:00
parent d03c9f4b62
commit 77144b058c
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/backend/src/server/api/StreamingApiServerService.ts
View file

@ -151,7 +151,7 @@ export class StreamingApiServerService {
return this.rateLimitThis(user, requestIp, { return this.rateLimitThis(user, requestIp, {
key: 'wsmessage', key: 'wsmessage',
duration: ms('2sec'), duration: ms('2sec'),
max: 4090, max: 4096,
}); });
}; };

4
packages/backend/src/server/api/stream/Connection.ts
View file

@ -120,7 +120,9 @@ export default class Connection {
if (this.closingConnection) return; if (this.closingConnection) return;
if (this.rateLimiter) { if (this.rateLimiter) {
if (this.activeRateLimitRequests <= 128) { // this 4096 should match the `max` of the `rateLimiter`, see
// StreamingApiServerService
if (this.activeRateLimitRequests <= 4096) {
this.activeRateLimitRequests++; this.activeRateLimitRequests++;
const shouldRateLimit = await this.rateLimiter(); const shouldRateLimit = await this.rateLimiter();
this.activeRateLimitRequests--; this.activeRateLimitRequests--;