highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-08-04 11:42:24 +02: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
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 { IEventRepository } from '../@types/repositories'
import { isDelegatedEvent } from '../utils/event' import { isDelegatedEvent } from '../utils/event'
import { IWebSocketAdapter } from '../@types/adapters' import { IWebSocketAdapter } from '../@types/adapters'
import { slidingWindowRateLimiterFactory } from './rate-limiter-factory'
import { SubscribeMessageHandler } from '../handlers/subscribe-message-handler' import { SubscribeMessageHandler } from '../handlers/subscribe-message-handler'
import { UnsubscribeMessageHandler } from '../handlers/unsubscribe-message-handler' import { UnsubscribeMessageHandler } from '../handlers/unsubscribe-message-handler'
@@ -20,11 +21,17 @@ export const messageHandlerFactory = (
return new DelegatedEventMessageHandler( return new DelegatedEventMessageHandler(
adapter, adapter,
delegatedEventStrategyFactory(eventRepository), delegatedEventStrategyFactory(eventRepository),
createSettings createSettings,
slidingWindowRateLimiterFactory,
) )
} }
return new EventMessageHandler(adapter, eventStrategyFactory(eventRepository), createSettings) return new EventMessageHandler(
adapter,
eventStrategyFactory(eventRepository),
createSettings,
slidingWindowRateLimiterFactory,
)
} }
case MessageType.REQ: case MessageType.REQ:
return new SubscribeMessageHandler(adapter, eventRepository, createSettings) return new SubscribeMessageHandler(adapter, eventRepository, createSettings)