repository

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

type MessageRepository interface {
	// GetMessageTime returns time when massage was sent by its id
	GetMessageTime(messageID uuid.UUID) (time.Time, error)

	// GetMessages returns limited amount of messages from specified room and after specified time
	GetMessages(roomID uuid.UUID, afterTime time.Time, limit uint) ([]message.Message, error)

	// SaveMessage saves given massage
	SaveMessage(message *message.Message) error
}

type Repository interface {
	MessageRepository
	UserRepository
	RoomRepository
}

type RoomRepository interface {
	// IsRoomExist checks if room exist
	IsRoomExist(roomID uuid.UUID) (bool, error)
}

type UserRepository interface {
	// GetUsersFromIDs returns slice of users by their ids
	GetUsersFromIDs([]uuid.UUID) ([]user.User, error)
}