highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-03-18 05:41:49 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: inject sw rate limiter in event strategies

Browse Source
This commit is contained in:
Ricardo Arturo Cabral Mejía 2022-11-15 08:44:31 -05:00
parent a9a00aab53
commit 760cb387bf
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/factories/message-handler-factory.ts
View File

@ -7,6 +7,7 @@ import { eventStrategyFactory } from './event-strategy-factory'
import { IEventRepository } from '../@types/repositories'
import { isDelegatedEvent } from '../utils/event'
import { IWebSocketAdapter } from '../@types/adapters'
import { slidingWindowRateLimiterFactory } from './rate-limiter-factory'
import { SubscribeMessageHandler } from '../handlers/subscribe-message-handler'
import { UnsubscribeMessageHandler } from '../handlers/unsubscribe-message-handler'
@ -20,11 +21,17 @@ export const messageHandlerFactory = (
return new DelegatedEventMessageHandler(
adapter,
delegatedEventStrategyFactory(eventRepository),
createSettings
createSettings,
slidingWindowRateLimiterFactory,
)
}
return new EventMessageHandler(adapter, eventStrategyFactory(eventRepository), createSettings)
return new EventMessageHandler(
adapter,
eventStrategyFactory(eventRepository),
createSettings,
slidingWindowRateLimiterFactory,
)
}
case MessageType.REQ:
return new SubscribeMessageHandler(adapter, eventRepository, createSettings)