service

type Dialog struct {
	// contains filtered or unexported fields
}

type DialogParticipantEventProducer interface {
	Produce(ctx context.Context, event entity.ParticipantEvent) error
}

type DialogRepository interface {
	List(ctx context.Context) ([]entity.Dialog, error)
	Create(ctx context.Context, dialog *entity.Dialog) error
	GetByID(ctx context.Context, id int) (entity.Dialog, error)
	Update(ctx context.Context, dialog *entity.Dialog) error
}

type Group struct {
	// contains filtered or unexported fields
}

type GroupParticipant struct {
	// contains filtered or unexported fields
}

type GroupParticipantConfig struct {
	TxManager     TransactionManager
	Repository    GroupParticipantRepository
	EventProducer GroupParticipantEventProducer
}

type GroupParticipantEventProducer interface {
	Produce(ctx context.Context, event entity.ParticipantEvent) error
}

type GroupParticipantFunc func(p *entity.GroupParticipant) error

type GroupParticipantRepository interface {
	List(ctx context.Context, groupID int) ([]entity.GroupParticipant, error)
	Get(ctx context.Context, groupID, userID int, withLock bool) (entity.GroupParticipant, error)
	Create(ctx context.Context, p *entity.GroupParticipant) error
	Update(ctx context.Context, p *entity.GroupParticipant) error
}

type GroupRepository interface {
	List(ctx context.Context) ([]entity.Group, error)
	Create(ctx context.Context, group *entity.Group) error
	GetByID(ctx context.Context, id int) (entity.Group, error)
	Update(ctx context.Context, group *entity.Group) error
	Delete(ctx context.Context, id int) error
}

type InChatChecker interface {
	Check(ctx context.Context, chatID entity.ChatID, userID int) error
}

type Message struct {
	// contains filtered or unexported fields
}

type MessageConsumer interface {
	BeginConsume(ctx context.Context) (<-chan entity.Message, <-chan error)
	Subscribe(ctx context.Context, chatIDs ...entity.ChatID) error
	Unsubscribe(ctx context.Context, chatIDs ...entity.ChatID) error
	Close() error
}

type MessagePublisher interface {
	Publish(ctx context.Context, message entity.Message) error
}

type MessageRepository interface {
	List(ctx context.Context, obj dto.MessageList) ([]entity.Message, error)
	Create(ctx context.Context, message *entity.Message) error
}

type MessageServeManager struct {
	// contains filtered or unexported fields
}

type MessageServeManagerConfig struct {
	Service          *Message
	EventConsumer    ParticipantEventConsumer
	Subscriber       MessageSubscriber
	GroupRepository  GroupRepository
	DialogRepository DialogRepository
}

type MessageSubscriber interface {
	Subscribe(ctx context.Context, chatIDs ...entity.ChatID) MessageConsumer
}

type ParticipantEventConsumer interface {
	BeginConsume(ctx context.Context, userID int) (<-chan entity.ParticipantEvent, <-chan error)
}

type SessionRepository interface {
	DeleteAllByUserID(ctx context.Context, id string) error
}

type StatusMatrix interface {
	IsCorrectTransit(from, to entity.GroupParticipantStatus) bool
}

type TransactionManager interface {
	Do(ctx context.Context, fn func(ctx context.Context) error) error
}

type User struct {
	// contains filtered or unexported fields
}

type UserConfig struct {
	UserRepository    UserRepository
	SessionRepository SessionRepository
}

type UserRepository interface {
	List(ctx context.Context) ([]entity.User, error)
	Create(ctx context.Context, user *entity.User) error
	GetByID(ctx context.Context, id int) (entity.User, error)
	GetByUsername(ctx context.Context, username string) (entity.User, error)
	Update(ctx context.Context, user *entity.User) error
	UpdatePassword(ctx context.Context, userID int, pwdHash string) error
	Delete(ctx context.Context, id int) error
}