services

Documentation

Index

• type EventMultiService
  • func NewEventMultiService(ctx context.Context, logger zerolog.Logger, ...) *EventMultiService
  • func (s *EventMultiService) EventStreaming(stream proto.EventMultiService_EventStreamingServer) error
• type Services
  • func NewServices(databaseUri string, logger zerolog.Logger) Services

Types

type EventMultiService

type EventMultiService struct {
	proto.UnimplementedEventMultiServiceServer
	// contains filtered or unexported fields
}

EventMultiService обрабатывает соединения от клиентских приложений

func NewEventMultiService

func NewEventMultiService(
	ctx context.Context,
	logger zerolog.Logger,
	clients *collections.ConcurrentMap[string, *model.ClientEvents],
	notify chan<- model.Notification,
	userService users.UserService,
) *EventMultiService

NewEventMultiService создает сервис обслуживания клиентских приложений

func (*EventMultiService) EventStreaming

func (s *EventMultiService) EventStreaming(stream proto.EventMultiService_EventStreamingServer) error

EventStreaming получает двунаправленный поток отк клиента, достает из метаданных идентификаторы, идентифицирует клиента. В случае валидного клиента создает структуру ClientEvents, добавляет ее в общий словарь, чтобы обработчики команд от telegram могли обратиться к конкретному клиентскому приложению. Также запускается циклический опрос сообщений от клиентского приложения и перенаправление сообщений в каналы, привязанные к конкретному пользователю. Идентификация пользователя происходит в 2 этап: 1. При установке соединения проверяется валидность сертификата пользователя через tls handshake 2. Проверяется существование пользователя с указанным именем и идентификатором сертификата

type Services

type Services struct {
	UserService users.UserService
}

Services содержит настроенный сервисный слой приложения

func NewServices

func NewServices(databaseUri string, logger zerolog.Logger) Services

NewServices настраивает сервисный слой приложения