mgo

May 15, 2024

Changes in this version

type MsgMgo

+ func (m *MsgMgo) DeleteDoc(ctx context.Context, docID string) error

+ func (m *MsgMgo) DeleteMsgByIndex(ctx context.Context, docID string, index []int) error

+ func (m *MsgMgo) GetBeforeMsg(ctx context.Context, ts int64, limit int) ([]*relation.MsgDocModel, error)

Apr 20, 2024

Changes in this version

+ const MaximumSubscription

+ const SubscribedPrefix

+ const SubscriptionPrefix

+ func NewMsgMongo(db *mongo.Database) (relation.MsgDocModelInterface, error)

+ func NewUserMongoDriver(database *mongo.Database) relation.SubscribeUserModelInterface

type ConversationMgo

+ func (c *ConversationMgo) FindRecvMsgUserIDs(ctx context.Context, conversationID string, recvOpts []int) ([]string, error)

+ type MsgMgo struct

+ func (m *MsgMgo) ConvertMsgsDocLen(ctx context.Context, conversationIDs []string)

+ func (m *MsgMgo) Create(ctx context.Context, model *relation.MsgDocModel) error

+ func (m *MsgMgo) DeleteDocs(ctx context.Context, docIDs []string) error

+ func (m *MsgMgo) DeleteMsgsInOneDocByIndex(ctx context.Context, docID string, indexes []int) error

+ func (m *MsgMgo) FindOneByDocID(ctx context.Context, docID string) (*relation.MsgDocModel, error)

+ func (m *MsgMgo) GetMsgBySeqIndexIn1Doc(ctx context.Context, userID, docID string, seqs []int64) ([]*relation.MsgInfoModel, error)

+ func (m *MsgMgo) GetMsgDocModelByIndex(ctx context.Context, conversationID string, index, sort int64) (*relation.MsgDocModel, error)

+ func (m *MsgMgo) GetNewestMsg(ctx context.Context, conversationID string) (*relation.MsgInfoModel, error)

+ func (m *MsgMgo) GetOldestMsg(ctx context.Context, conversationID string) (*relation.MsgInfoModel, error)

+ func (m *MsgMgo) IsExistDocID(ctx context.Context, docID string) (bool, error)

+ func (m *MsgMgo) MarkSingleChatMsgsAsRead(ctx context.Context, userID string, docID string, indexes []int64) error

+ func (m *MsgMgo) PushMsgsToDoc(ctx context.Context, docID string, msgsToMongo []relation.MsgInfoModel) error

+ func (m *MsgMgo) PushUnique(ctx context.Context, docID string, index int64, key string, value any) (*mongo.UpdateResult, error)

+ func (m *MsgMgo) RangeGroupSendCount(ctx context.Context, start time.Time, end time.Time, ase bool, ...) (msgCount int64, userCount int64, groups []*relation.GroupCount, ...)

+ func (m *MsgMgo) RangeUserSendCount(ctx context.Context, start time.Time, end time.Time, group bool, ase bool, ...) (msgCount int64, userCount int64, users []*relation.UserCount, ...)

+ func (m *MsgMgo) SearchMessage(ctx context.Context, req *msg.SearchMessageReq) (int32, []*relation.MsgInfoModel, error)

+ func (m *MsgMgo) UpdateMsg(ctx context.Context, docID string, index int64, key string, value any) (*mongo.UpdateResult, error)

+ func (m *MsgMgo) UpdateMsgContent(ctx context.Context, docID string, index int64, msg []byte) error

+ type UserMongoDriver struct

+ func (u *UserMongoDriver) AddSubscriptionList(ctx context.Context, userID string, userIDList []string) error

+ func (u *UserMongoDriver) GetAllSubscribeList(ctx context.Context, userID string) (userIDList []string, err error)

+ func (u *UserMongoDriver) GetSubscribedList(ctx context.Context, userID string) (userIDList []string, err error)

+ func (u *UserMongoDriver) RemoveSubscribedListFromUser(ctx context.Context, userID string, userIDList []string) error

+ func (u *UserMongoDriver) UnsubscriptionList(ctx context.Context, userID string, userIDList []string) error

Mar 7, 2024

Changes in this version

type FriendMgo

+ func (f *FriendMgo) UpdateFriends(ctx context.Context, ownerUserID string, friendUserIDs []string, ...) error

type GroupMgo

+ func (g *GroupMgo) UpdateStatus(ctx context.Context, groupID string, status int32) (err error)

type UserMgo

+ func (u *UserMgo) GetAllUserCommand(ctx context.Context, userID string) ([]*user.AllCommandInfoResp, error)

+ func (u *UserMgo) PageFindUser(ctx context.Context, level1 int64, level2 int64, ...) (count int64, users []*relation.UserModel, err error)

+ func (u *UserMgo) PageFindUserWithKeyword(ctx context.Context, level1 int64, level2 int64, userID string, ...) (count int64, users []*relation.UserModel, err error)

+ func (u *UserMgo) TakeNotification(ctx context.Context, level int64) (user []*relation.UserModel, err error)

Dec 30, 2023

Changes in this version

type FriendMgo

+ func (f *FriendMgo) UpdateFriendEx(ctx context.Context, ownerUserID string, friendUserID string, ex string) (err error)

+ func (f *FriendMgo) UpdateFriendRemark(ctx context.Context, ownerUserID string, friendUserID string, remark string) (err error)

+ func (f *FriendMgo) UpdatePinStatus(ctx context.Context, ownerUserID string, friendUserID string, isPinned bool) (err error)

type UserMgo

+ func (u *UserMgo) AddUserCommand(ctx context.Context, userID string, Type int32, UUID string, value string) error

+ func (u *UserMgo) DeleteUserCommand(ctx context.Context, userID string, Type int32, UUID string) error

+ func (u *UserMgo) GetUserCommand(ctx context.Context, userID string, Type int32) ([]*user.CommandInfoResp, error)

+ func (u *UserMgo) TakeByNickname(ctx context.Context, nickname string) (user []*relation.UserModel, err error)

+ func (u *UserMgo) UpdateUserCommand(ctx context.Context, userID string, Type int32, UUID string, value string) error

Dec 14, 2023

Changes in this version

+ func NewBlackMongo(db *mongo.Database) (relation.BlackModelInterface, error)

+ func NewFriendMongo(db *mongo.Database) (relation.FriendModelInterface, error)

+ func NewFriendRequestMongo(db *mongo.Database) (relation.FriendRequestModelInterface, error)

+ func NewGroupMember(db *mongo.Database) (relation.GroupMemberModelInterface, error)

+ func NewGroupMongo(db *mongo.Database) (relation.GroupModelInterface, error)

+ func NewGroupRequestMgo(db *mongo.Database) (relation.GroupRequestModelInterface, error)

+ func NewLogMongo(db *mongo.Database) (relation.LogInterface, error)

+ func NewS3Mongo(db *mongo.Database) (relation.ObjectInfoModelInterface, error)

+ func NewUserMongo(db *mongo.Database) (relation.UserModelInterface, error)

+ type BlackMgo struct

+ func (b *BlackMgo) Create(ctx context.Context, blacks []*relation.BlackModel) (err error)

+ func (b *BlackMgo) Delete(ctx context.Context, blacks []*relation.BlackModel) (err error)

+ func (b *BlackMgo) Find(ctx context.Context, blacks []*relation.BlackModel) (blackList []*relation.BlackModel, err error)

+ func (b *BlackMgo) FindBlackUserIDs(ctx context.Context, ownerUserID string) (blackUserIDs []string, err error)

+ func (b *BlackMgo) FindOwnerBlackInfos(ctx context.Context, ownerUserID string, userIDs []string) (blacks []*relation.BlackModel, err error)

+ func (b *BlackMgo) FindOwnerBlacks(ctx context.Context, ownerUserID string, pagination pagination.Pagination) (total int64, blacks []*relation.BlackModel, err error)

+ func (b *BlackMgo) Take(ctx context.Context, ownerUserID, blockUserID string) (black *relation.BlackModel, err error)

+ func (b *BlackMgo) UpdateByMap(ctx context.Context, ownerUserID, blockUserID string, args map[string]any) (err error)

+ type ConversationMgo struct

+ func NewConversationMongo(db *mongo.Database) (*ConversationMgo, error)

+ func (c *ConversationMgo) Create(ctx context.Context, conversations []*relation.ConversationModel) (err error)

+ func (c *ConversationMgo) Delete(ctx context.Context, groupIDs []string) (err error)

+ func (c *ConversationMgo) Find(ctx context.Context, ownerUserID string, conversationIDs []string) (conversations []*relation.ConversationModel, err error)

+ func (c *ConversationMgo) FindConversationID(ctx context.Context, userID string, conversationIDs []string) (existConversationID []string, err error)

+ func (c *ConversationMgo) FindRecvMsgNotNotifyUserIDs(ctx context.Context, groupID string) ([]string, error)

+ func (c *ConversationMgo) FindUserID(ctx context.Context, userIDs []string, conversationIDs []string) ([]string, error)

+ func (c *ConversationMgo) FindUserIDAllConversationID(ctx context.Context, userID string) ([]string, error)

+ func (c *ConversationMgo) FindUserIDAllConversations(ctx context.Context, userID string) (conversations []*relation.ConversationModel, err error)

+ func (c *ConversationMgo) GetAllConversationIDs(ctx context.Context) ([]string, error)

+ func (c *ConversationMgo) GetAllConversationIDsNumber(ctx context.Context) (int64, error)

+ func (c *ConversationMgo) GetConversationIDsNeedDestruct(ctx context.Context) ([]*relation.ConversationModel, error)

+ func (c *ConversationMgo) GetConversationNotReceiveMessageUserIDs(ctx context.Context, conversationID string) ([]string, error)

+ func (c *ConversationMgo) GetConversationsByConversationID(ctx context.Context, conversationIDs []string) ([]*relation.ConversationModel, error)

+ func (c *ConversationMgo) GetUserRecvMsgOpt(ctx context.Context, ownerUserID, conversationID string) (opt int, err error)

+ func (c *ConversationMgo) PageConversationIDs(ctx context.Context, pagination pagination.Pagination) (conversationIDs []string, err error)

+ func (c *ConversationMgo) Take(ctx context.Context, userID, conversationID string) (conversation *relation.ConversationModel, err error)

+ func (c *ConversationMgo) Update(ctx context.Context, conversation *relation.ConversationModel) (err error)

+ func (c *ConversationMgo) UpdateByMap(ctx context.Context, userIDs []string, conversationID string, ...) (rows int64, err error)

+ type FriendMgo struct

+ func (f *FriendMgo) Create(ctx context.Context, friends []*relation.FriendModel) error

+ func (f *FriendMgo) Delete(ctx context.Context, ownerUserID string, friendUserIDs []string) error

+ func (f *FriendMgo) FindFriendUserIDs(ctx context.Context, ownerUserID string) ([]string, error)

+ func (f *FriendMgo) FindFriends(ctx context.Context, ownerUserID string, friendUserIDs []string) ([]*relation.FriendModel, error)

+ func (f *FriendMgo) FindInWhoseFriends(ctx context.Context, friendUserID string, pagination pagination.Pagination) (int64, []*relation.FriendModel, error)

+ func (f *FriendMgo) FindOwnerFriends(ctx context.Context, ownerUserID string, pagination pagination.Pagination) (int64, []*relation.FriendModel, error)

+ func (f *FriendMgo) FindReversalFriends(ctx context.Context, friendUserID string, ownerUserIDs []string) ([]*relation.FriendModel, error)

+ func (f *FriendMgo) FindUserState(ctx context.Context, userID1, userID2 string) ([]*relation.FriendModel, error)

+ func (f *FriendMgo) Take(ctx context.Context, ownerUserID, friendUserID string) (*relation.FriendModel, error)

+ func (f *FriendMgo) UpdateByMap(ctx context.Context, ownerUserID string, friendUserID string, ...) error

+ func (f *FriendMgo) UpdateRemark(ctx context.Context, ownerUserID, friendUserID, remark string) error

+ type FriendRequestMgo struct

+ func (f *FriendRequestMgo) Create(ctx context.Context, friendRequests []*relation.FriendRequestModel) error

+ func (f *FriendRequestMgo) Delete(ctx context.Context, fromUserID, toUserID string) (err error)

+ func (f *FriendRequestMgo) Find(ctx context.Context, fromUserID, toUserID string) (friendRequest *relation.FriendRequestModel, err error)

+ func (f *FriendRequestMgo) FindBothFriendRequests(ctx context.Context, fromUserID, toUserID string) (friends []*relation.FriendRequestModel, err error)

+ func (f *FriendRequestMgo) FindFromUserID(ctx context.Context, fromUserID string, pagination pagination.Pagination) (total int64, friendRequests []*relation.FriendRequestModel, err error)

+ func (f *FriendRequestMgo) FindToUserID(ctx context.Context, toUserID string, pagination pagination.Pagination) (total int64, friendRequests []*relation.FriendRequestModel, err error)

+ func (f *FriendRequestMgo) Take(ctx context.Context, fromUserID, toUserID string) (friendRequest *relation.FriendRequestModel, err error)

+ func (f *FriendRequestMgo) Update(ctx context.Context, friendRequest *relation.FriendRequestModel) (err error)

+ func (f *FriendRequestMgo) UpdateByMap(ctx context.Context, formUserID, toUserID string, args map[string]any) (err error)

+ type GroupMemberMgo struct

+ func (g *GroupMemberMgo) Create(ctx context.Context, groupMembers []*relation.GroupMemberModel) (err error)

+ func (g *GroupMemberMgo) Delete(ctx context.Context, groupID string, userIDs []string) (err error)

+ func (g *GroupMemberMgo) Find(ctx context.Context, groupIDs []string, userIDs []string, roleLevels []int32) (groupMembers []*relation.GroupMemberModel, err error)

+ func (g *GroupMemberMgo) FindMemberUserID(ctx context.Context, groupID string) (userIDs []string, err error)

+ func (g *GroupMemberMgo) FindRoleLevelUserIDs(ctx context.Context, groupID string, roleLevel int32) ([]string, error)

+ func (g *GroupMemberMgo) FindUserJoinedGroupID(ctx context.Context, userID string) (groupIDs []string, err error)

+ func (g *GroupMemberMgo) FindUserManagedGroupID(ctx context.Context, userID string) (groupIDs []string, err error)

+ func (g *GroupMemberMgo) IsUpdateRoleLevel(data map[string]any) bool

+ func (g *GroupMemberMgo) SearchMember(ctx context.Context, keyword string, groupID string, ...) (total int64, groupList []*relation.GroupMemberModel, err error)

+ func (g *GroupMemberMgo) Take(ctx context.Context, groupID string, userID string) (groupMember *relation.GroupMemberModel, err error)

+ func (g *GroupMemberMgo) TakeGroupMemberNum(ctx context.Context, groupID string) (count int64, err error)

+ func (g *GroupMemberMgo) TakeOwner(ctx context.Context, groupID string) (groupMember *relation.GroupMemberModel, err error)

+ func (g *GroupMemberMgo) Update(ctx context.Context, groupID string, userID string, data map[string]any) (err error)

+ func (g *GroupMemberMgo) UpdateRoleLevel(ctx context.Context, groupID string, userID string, roleLevel int32) error

+ type GroupMgo struct

+ func (g *GroupMgo) CountRangeEverydayTotal(ctx context.Context, start time.Time, end time.Time) (map[string]int64, error)

+ func (g *GroupMgo) CountTotal(ctx context.Context, before *time.Time) (count int64, err error)

+ func (g *GroupMgo) Create(ctx context.Context, groups []*relation.GroupModel) (err error)

+ func (g *GroupMgo) Find(ctx context.Context, groupIDs []string) (groups []*relation.GroupModel, err error)

+ func (g *GroupMgo) Search(ctx context.Context, keyword string, pagination pagination.Pagination) (total int64, groups []*relation.GroupModel, err error)

+ func (g *GroupMgo) Take(ctx context.Context, groupID string) (group *relation.GroupModel, err error)

+ func (g *GroupMgo) UpdateMap(ctx context.Context, groupID string, args map[string]any) (err error)

+ func (g *GroupMgo) UpdateState(ctx context.Context, groupID string, state int32) (err error)

+ type GroupRequestMgo struct

+ func (g *GroupRequestMgo) Create(ctx context.Context, groupRequests []*relation.GroupRequestModel) (err error)

+ func (g *GroupRequestMgo) Delete(ctx context.Context, groupID string, userID string) (err error)

+ func (g *GroupRequestMgo) FindGroupRequests(ctx context.Context, groupID string, userIDs []string) ([]*relation.GroupRequestModel, error)

+ func (g *GroupRequestMgo) Page(ctx context.Context, userID string, pagination pagination.Pagination) (total int64, groups []*relation.GroupRequestModel, err error)

+ func (g *GroupRequestMgo) PageGroup(ctx context.Context, groupIDs []string, pagination pagination.Pagination) (total int64, groups []*relation.GroupRequestModel, err error)

+ func (g *GroupRequestMgo) Take(ctx context.Context, groupID string, userID string) (groupRequest *relation.GroupRequestModel, err error)

+ func (g *GroupRequestMgo) UpdateHandler(ctx context.Context, groupID string, userID string, handledMsg string, ...) (err error)

+ type LogMgo struct

+ func (l *LogMgo) Create(ctx context.Context, log []*relation.LogModel) error

+ func (l *LogMgo) Delete(ctx context.Context, logID []string, userID string) error

+ func (l *LogMgo) Get(ctx context.Context, logIDs []string, userID string) ([]*relation.LogModel, error)

+ func (l *LogMgo) Search(ctx context.Context, keyword string, start time.Time, end time.Time, ...) (int64, []*relation.LogModel, error)

+ type S3Mongo struct

+ func (o *S3Mongo) Delete(ctx context.Context, engine string, name string) error

+ func (o *S3Mongo) SetObject(ctx context.Context, obj *relation.ObjectModel) error

+ func (o *S3Mongo) Take(ctx context.Context, engine string, name string) (*relation.ObjectModel, error)

+ type UserMgo struct

+ func (u *UserMgo) CountRangeEverydayTotal(ctx context.Context, start time.Time, end time.Time) (map[string]int64, error)

+ func (u *UserMgo) CountTotal(ctx context.Context, before *time.Time) (count int64, err error)

+ func (u *UserMgo) Create(ctx context.Context, users []*relation.UserModel) error

+ func (u *UserMgo) Exist(ctx context.Context, userID string) (exist bool, err error)

+ func (u *UserMgo) Find(ctx context.Context, userIDs []string) (users []*relation.UserModel, err error)

+ func (u *UserMgo) GetAllUserID(ctx context.Context, pagination pagination.Pagination) (int64, []string, error)

+ func (u *UserMgo) GetUserGlobalRecvMsgOpt(ctx context.Context, userID string) (opt int, err error)

+ func (u *UserMgo) Page(ctx context.Context, pagination pagination.Pagination) (count int64, users []*relation.UserModel, err error)

+ func (u *UserMgo) Take(ctx context.Context, userID string) (user *relation.UserModel, err error)

+ func (u *UserMgo) UpdateByMap(ctx context.Context, userID string, args map[string]any) (err error)