Function messageHandlerFactory

src/factories/message-handler-factory.ts:24–54

(
    eventRepository: IEventRepository,
    userRepository: IUserRepository,
    nip05VerificationRepository: INip05VerificationRepository,
  )

export const messageHandlerFactory =
  (
    eventRepository: IEventRepository,
    userRepository: IUserRepository,
    nip05VerificationRepository: INip05VerificationRepository,
  ) =>
  ([message, adapter]: [IncomingMessage, IWebSocketAdapter]) => {
    switch (message[0]) {
      case MessageType.EVENT: {
        return new EventMessageHandler(
          adapter,
          eventStrategyFactory(eventRepository, userRepository),
          eventRepository,
          userRepository,
          createSettings,
          nip05VerificationRepository,
          getCache(),
          rateLimiterFactory,
        )
      }
      case MessageType.REQ:
        return new SubscribeMessageHandler(adapter, eventRepository, createSettings)
      case MessageType.CLOSE:
        return new UnsubscribeMessageHandler(adapter)
      case MessageType.COUNT:
        return new CountMessageHandler(adapter, eventRepository, createSettings)
      case MessageType.AUTH:
        return new AuthMessageHandler(adapter, createSettings)
      default:
        throw new Error(`Unknown message type: ${String(message[0]).substring(0, 64)}`)
    }
  }