service

package
v0.0.0-...-702fcad Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 6, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MessageService 

type MessageService interface {
	SaveMessage(vang *dto.Message) error
	SaveManyMessages(messages []dto.Message) error
	FindOneMessage(filter interface{}) (*dto.Message, error)
	FindMessageList(filter interface{}, limit int64, skip int64, sort map[string]int) ([]dto.Message, error)
	FindById(objectId uuid.UUID) (*dto.Message, error)
	FindByOwnerUserId(ownerUserId uuid.UUID) ([]dto.Message, error)
	UpdateMessage(filter interface{}, data interface{}, opts ...*coreData.UpdateOptions) error
	UpdateMessageById(data *dto.Message) error
	DeleteMessage(filter interface{}) error
	DeleteMessageByOwner(ownerUserId uuid.UUID, vangId uuid.UUID) error
	DeleteManyMessage(filter interface{}) error
	CreateMessageIndex(indexes map[string]interface{}) error
	GetMessageByRoomId(roomId *uuid.UUID, sortBy string, page int64, lteDate int64, gteDate int64) ([]dto.Message, error)
	DeleteMessageByRoomId(ownerUserId uuid.UUID, roomId uuid.UUID) error
}

func NewMessageService 

func NewMessageService(db interface{}) (MessageService, error)

NewMessageService initializes MessageService's dependencies and create new MessageService struct

type MessageServiceImpl 

type MessageServiceImpl struct {
	MessageRepo repo.Repository
}

MessageService handlers with injected dependencies

func (MessageServiceImpl) CreateMessageIndex 

func (s MessageServiceImpl) CreateMessageIndex(indexes map[string]interface{}) error

CreateMessageIndex create index for message search.

func (MessageServiceImpl) DeleteManyMessage 

func (s MessageServiceImpl) DeleteManyMessage(filter interface{}) error

DeleteManyMessage delete many message by filter

func (MessageServiceImpl) DeleteMessage 

func (s MessageServiceImpl) DeleteMessage(filter interface{}) error

DeleteMessage delete message by filter

func (MessageServiceImpl) DeleteMessageByOwner 

func (s MessageServiceImpl) DeleteMessageByOwner(ownerUserId uuid.UUID, messageId uuid.UUID) error

DeleteMessage delete message by ownerUserId and messageId

func (MessageServiceImpl) DeleteMessageByRoomId 

func (s MessageServiceImpl) DeleteMessageByRoomId(ownerUserId uuid.UUID, roomId uuid.UUID) error

DeleteMessageByRoomId delete message by room id

func (MessageServiceImpl) FindById 

func (s MessageServiceImpl) FindById(objectId uuid.UUID) (*dto.Message, error)

FindById find by message id

func (MessageServiceImpl) FindByOwnerUserId 

func (s MessageServiceImpl) FindByOwnerUserId(ownerUserId uuid.UUID) ([]dto.Message, error)

FindByOwnerUserId find by owner user id

func (MessageServiceImpl) FindMessageList 

func (s MessageServiceImpl) FindMessageList(filter interface{}, limit int64, skip int64, sort map[string]int) ([]dto.Message, error)

FindMessageList get all messages by filter

func (MessageServiceImpl) FindOneMessage 

func (s MessageServiceImpl) FindOneMessage(filter interface{}) (*dto.Message, error)

FindOneMessage get one message

func (MessageServiceImpl) GetMessageByRoomId 

func (s MessageServiceImpl) GetMessageByRoomId(roomId *uuid.UUID, sortBy string, page int64, lteDate int64, gteDate int64) ([]dto.Message, error)

GetMessageByRoomId get all message by room ID

func (MessageServiceImpl) SaveManyMessages 

func (s MessageServiceImpl) SaveManyMessages(messages []dto.Message) error

SaveManyMessages save many messages

func (MessageServiceImpl) SaveMessage 

func (s MessageServiceImpl) SaveMessage(message *dto.Message) error

SaveMessage save the message

func (MessageServiceImpl) UpdateMessage 

func (s MessageServiceImpl) UpdateMessage(filter interface{}, data interface{}, opts ...*coreData.UpdateOptions) error

UpdateMessage update the message

func (MessageServiceImpl) UpdateMessageById 

func (s MessageServiceImpl) UpdateMessageById(data *dto.Message) error

UpdateMessage update the message

type RoomService 

type RoomService interface {
	SaveRoom(vang *dto.Room) error
	FindOneRoom(filter interface{}) (*dto.Room, error)
	FindRoomList(filter interface{}, limit int64, skip int64, sort map[string]int) ([]dto.Room, error)
	FindById(objectId uuid.UUID) (*dto.Room, error)
	FindByOwnerUserId(ownerUserId uuid.UUID) ([]dto.Room, error)
	UpdateRoom(filter interface{}, data interface{}, opts ...*coreData.UpdateOptions) error
	UpdateRoomById(data *dto.Room) error
	DeleteRoom(filter interface{}) error
	DeleteRoomByOwner(ownerUserId uuid.UUID, vangId uuid.UUID) error
	DeleteManyRoom(filter interface{}) error
	CreateRoomIndex(indexes map[string]interface{}) error
	GetPeerRoom(roomId uuid.UUID, members []string, DeactivePeerId uuid.UUID) (*dto.Room, error)
	DeleteRoomByRoomId(ownerUserId uuid.UUID, roomId uuid.UUID) error
	FindOneRoomByMembers(userIds []string, roomType int8) (*dto.Room, error)
	GetRoomsByUserId(userId string, roomType int8) ([]dto.Room, error)
	UpdateMessageMeta(roomId uuid.UUID, amount, createdDate int64, text, ownerId string) error
	UpdateMemberRead(roomId uuid.UUID, userId uuid.UUID, amount, messageCreatedDate int64) error
	DeactiveUserRoom(roomId uuid.UUID, userId uuid.UUID) error
	ActiveAllPeerRoom(roomId uuid.UUID, members []string, deactivePeerId uuid.UUID) error
	GetActiveRoom(roomId uuid.UUID, members []string) (*dto.Room, error)
}

func NewRoomService 

func NewRoomService(db interface{}) (RoomService, error)

NewRoomService initializes RoomService's dependencies and create new RoomService struct

type RoomServiceImpl 

type RoomServiceImpl struct {
	RoomRepo repo.Repository
}

RoomService handlers with injected dependencies

func (RoomServiceImpl) ActiveAllPeerRoom 

func (s RoomServiceImpl) ActiveAllPeerRoom(roomId uuid.UUID, members []string, deactivePeerId uuid.UUID) error

ActiveAllPeerRoom active all peer room members

func (RoomServiceImpl) CreateRoomIndex 

func (s RoomServiceImpl) CreateRoomIndex(indexes map[string]interface{}) error

CreateRoomIndex create index for room search.

func (RoomServiceImpl) DeactiveUserRoom 

func (s RoomServiceImpl) DeactiveUserRoom(roomId uuid.UUID, userId uuid.UUID) error

DeactiveUserRoom set user delete a room

func (RoomServiceImpl) DeleteManyRoom 

func (s RoomServiceImpl) DeleteManyRoom(filter interface{}) error

DeleteManyRoom delete many room by filter

func (RoomServiceImpl) DeleteRoom 

func (s RoomServiceImpl) DeleteRoom(filter interface{}) error

DeleteRoom delete room by filter

func (RoomServiceImpl) DeleteRoomByOwner 

func (s RoomServiceImpl) DeleteRoomByOwner(ownerUserId uuid.UUID, roomId uuid.UUID) error

DeleteRoom delete room by ownerUserId and roomId

func (RoomServiceImpl) DeleteRoomByRoomId 

func (s RoomServiceImpl) DeleteRoomByRoomId(ownerUserId uuid.UUID, roomId uuid.UUID) error

DeleteRoomByRoomId delete room by room id

func (RoomServiceImpl) FindById 

func (s RoomServiceImpl) FindById(objectId uuid.UUID) (*dto.Room, error)

FindById find by room id

func (RoomServiceImpl) FindByOwnerUserId 

func (s RoomServiceImpl) FindByOwnerUserId(ownerUserId uuid.UUID) ([]dto.Room, error)

FindByOwnerUserId find by owner user id

func (RoomServiceImpl) FindOneRoom 

func (s RoomServiceImpl) FindOneRoom(filter interface{}) (*dto.Room, error)

FindOneRoom get one room

func (RoomServiceImpl) FindOneRoomByMembers 

func (s RoomServiceImpl) FindOneRoomByMembers(userIds []string, roomType int8) (*dto.Room, error)

FindOneRoomByMembers find one room by members

func (RoomServiceImpl) FindRoomList 

func (s RoomServiceImpl) FindRoomList(filter interface{}, limit int64, skip int64, sort map[string]int) ([]dto.Room, error)

FindRoomList get all rooms by filter

func (RoomServiceImpl) GetActiveRoom 

func (s RoomServiceImpl) GetActiveRoom(roomId uuid.UUID, members []string) (*dto.Room, error)

GetActiveRoom active all peer room members

func (RoomServiceImpl) GetPeerRoom 

func (s RoomServiceImpl) GetPeerRoom(roomId uuid.UUID, members []string, deactivePeerId uuid.UUID) (*dto.Room, error)

GetPeerRoom get all room by room ID

func (RoomServiceImpl) GetRoomsByUserId 

func (s RoomServiceImpl) GetRoomsByUserId(userId string, roomType int8) ([]dto.Room, error)

GetRoomsByUserId Get rooms by user ID

func (RoomServiceImpl) IncreaseMemberCount 

func (s RoomServiceImpl) IncreaseMemberCount(roomId uuid.UUID, amount int64) error

IncreaseMemberCount Increase member count

func (RoomServiceImpl) SaveRoom 

func (s RoomServiceImpl) SaveRoom(room *dto.Room) error

SaveRoom save the room

func (RoomServiceImpl) UpdateMemberRead 

func (s RoomServiceImpl) UpdateMemberRead(roomId uuid.UUID, userId uuid.UUID, amount, messageCreatedDate int64) error

UpdateMemberRead Increase member read count and read member date to now

func (RoomServiceImpl) UpdateMessageMeta 

func (s RoomServiceImpl) UpdateMessageMeta(roomId uuid.UUID, amount, createdDate int64, text, ownerId string) error

UpdateMessageMeta Update message meta

func (RoomServiceImpl) UpdateRoom 

func (s RoomServiceImpl) UpdateRoom(filter interface{}, data interface{}, opts ...*coreData.UpdateOptions) error

UpdateRoom update the room

func (RoomServiceImpl) UpdateRoomById 

func (s RoomServiceImpl) UpdateRoomById(data *dto.Room) error

UpdateRoom update the room

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.