indexdb

package
v3.5.1 Latest Latest
Warning

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

Go to latest
Published: Mar 4, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Rendered for js/wasm

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Black

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

func NewBlack

func NewBlack(loginUserID string) *Black

func (Black) DeleteBlack

func (i Black) DeleteBlack(ctx context.Context, blockUserID string) error

DeleteBlack removes a blocked user from the database

func (Black) GetBlackInfoByBlockUserID

func (i Black) GetBlackInfoByBlockUserID(ctx context.Context, blockUserID string) (result *model_struct.LocalBlack, err error)

GetBlackInfoByBlockUserID gets the information of a blocked user by their user ID

func (Black) GetBlackInfoList

func (i Black) GetBlackInfoList(ctx context.Context, blockUserIDList []string) (result []*model_struct.LocalBlack, err error)

GetBlackInfoList gets the information of multiple blocked users by their user IDs

func (Black) GetBlackListDB

func (i Black) GetBlackListDB(ctx context.Context) (result []*model_struct.LocalBlack, err error)

GetBlackListDB gets the blacklist list from the database

func (Black) GetBlackListUserID

func (i Black) GetBlackListUserID(ctx context.Context) (result []string, err error)

GetBlackListUserID gets the list of blocked user IDs

func (Black) InsertBlack

func (i Black) InsertBlack(ctx context.Context, black *model_struct.LocalBlack) error

InsertBlack inserts a new blocked user into the database

func (Black) UpdateBlack

func (i Black) UpdateBlack(ctx context.Context, black *model_struct.LocalBlack) error

UpdateBlack updates the information of a blocked user in the database

type Friend

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

func NewFriend

func NewFriend(loginUserID string) *Friend

func (*Friend) DeleteFriendDB

func (i *Friend) DeleteFriendDB(ctx context.Context, friendUserID string) error

func (*Friend) GetAllFriendList

func (i *Friend) GetAllFriendList(ctx context.Context) (result []*model_struct.LocalFriend, err error)

func (*Friend) GetFriendInfoByFriendUserID

func (i *Friend) GetFriendInfoByFriendUserID(ctx context.Context, FriendUserID string) (*model_struct.LocalFriend, error)

func (*Friend) GetFriendInfoList

func (i *Friend) GetFriendInfoList(ctx context.Context, friendUserIDList []string) (result []*model_struct.LocalFriend, err error)

func (*Friend) GetPageFriendList

func (i *Friend) GetPageFriendList(ctx context.Context, offset, count int) (result []*model_struct.LocalFriend, err error)

func (*Friend) InsertFriend

func (i *Friend) InsertFriend(ctx context.Context, friend *model_struct.LocalFriend) error

func (*Friend) SearchFriendList

func (i *Friend) SearchFriendList(ctx context.Context, keyword string, isSearchUserID, isSearchNickname, isSearchRemark bool) (result []*model_struct.LocalFriend, err error)

func (*Friend) UpdateColumnsFriend added in v3.5.0

func (i *Friend) UpdateColumnsFriend(ctx context.Context, friendIDs []string, args map[string]interface{}) error

func (*Friend) UpdateFriend

func (i *Friend) UpdateFriend(ctx context.Context, friend *model_struct.LocalFriend) error

type FriendRequest

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

func NewFriendRequest

func NewFriendRequest(loginUserID string) *FriendRequest

func (FriendRequest) DeleteFriendRequestBothUserID

func (i FriendRequest) DeleteFriendRequestBothUserID(ctx context.Context, fromUserID, toUserID string) error

func (FriendRequest) GetBothFriendReq

func (i FriendRequest) GetBothFriendReq(ctx context.Context, fromUserID, toUserID string) (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) GetFriendApplicationByBothID

func (i FriendRequest) GetFriendApplicationByBothID(ctx context.Context, fromUserID, toUserID string) (*model_struct.LocalFriendRequest, error)

func (FriendRequest) GetRecvFriendApplication

func (i FriendRequest) GetRecvFriendApplication(ctx context.Context) (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) GetSendFriendApplication

func (i FriendRequest) GetSendFriendApplication(ctx context.Context) (result []*model_struct.LocalFriendRequest, err error)

func (FriendRequest) InsertFriendRequest

func (i FriendRequest) InsertFriendRequest(ctx context.Context, friendRequest *model_struct.LocalFriendRequest) error

func (FriendRequest) UpdateFriendRequest

func (i FriendRequest) UpdateFriendRequest(ctx context.Context, friendRequest *model_struct.LocalFriendRequest) error

type IndexDB

func (IndexDB) Close

func (i IndexDB) Close(ctx context.Context) error

func (IndexDB) InitDB

func (i IndexDB) InitDB(ctx context.Context, userID string, dataDir string) error

func (IndexDB) SetChatLogFailedStatus

func (i IndexDB) SetChatLogFailedStatus(ctx context.Context)

type LocalCacheMessage

type LocalCacheMessage struct {
}

func NewLocalCacheMessage

func NewLocalCacheMessage() *LocalCacheMessage

func (*LocalCacheMessage) BatchInsertTempCacheMessageList

func (i *LocalCacheMessage) BatchInsertTempCacheMessageList(ctx context.Context, MessageList []*model_struct.TempCacheLocalChatLog) error

func (*LocalCacheMessage) InsertTempCacheMessage

func (i *LocalCacheMessage) InsertTempCacheMessage(ctx context.Context, Message *model_struct.TempCacheLocalChatLog) error

type LocalChatLogReactionExtensions

type LocalChatLogReactionExtensions struct {
	ExtKey  string `json:"ext_key"`
	ExtVal  string `json:"ext_val"`
	ExtKey2 string `json:"ext_key2"`
	ExtVal2 string `json:"ext_val2"`
}

func NewLocalChatLogReactionExtensions

func NewLocalChatLogReactionExtensions() *LocalChatLogReactionExtensions

func (*LocalChatLogReactionExtensions) DeleteMessageReactionExtension

func (i *LocalChatLogReactionExtensions) DeleteMessageReactionExtension(ctx context.Context, msgID string) error

func (*LocalChatLogReactionExtensions) GetMessageReactionExtension

func (i *LocalChatLogReactionExtensions) GetMessageReactionExtension(ctx context.Context, clientMsgID string) (result *model_struct.LocalChatLogReactionExtensions, err error)

func (*LocalChatLogReactionExtensions) GetMultipleMessageReactionExtension

func (i *LocalChatLogReactionExtensions) GetMultipleMessageReactionExtension(ctx context.Context, msgIDList []string) (result []*model_struct.LocalChatLogReactionExtensions, err error)
func (i *LocalChatLogReactionExtensions) GetAndUpdateMessageReactionExtension(ctx context.Context, clientMsgID string, m map[string]*sdkws.KeyValue) error {
	_, err := exec.Exec(clientMsgID, utils.StructToJsonString(m))
	return err
}
func (i *LocalChatLogReactionExtensions) DeleteAndUpdateMessageReactionExtension(ctx context.Context, clientMsgID string, m map[string]*sdkws.KeyValue) error {
	_, err := exec.Exec(clientMsgID, utils.StructToJsonString(m))
	return err
}

func (*LocalChatLogReactionExtensions) InsertMessageReactionExtension

func (i *LocalChatLogReactionExtensions) InsertMessageReactionExtension(ctx context.Context, messageReactionExtension *model_struct.LocalChatLogReactionExtensions) error

func (*LocalChatLogReactionExtensions) UpdateMessageReactionExtension

type LocalChatLogs

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

func NewLocalChatLogs

func NewLocalChatLogs(loginUserID string) *LocalChatLogs

NewLocalChatLogs creates a new LocalChatLogs

func (*LocalChatLogs) BatchInsertExceptionMsg

func (i *LocalChatLogs) BatchInsertExceptionMsg(ctx context.Context, MessageList []*model_struct.LocalErrChatLog) error

Batch insert exception messages into the chat logs

func (*LocalChatLogs) BatchInsertMessageList

func (i *LocalChatLogs) BatchInsertMessageList(ctx context.Context, conversationID string, messageList []*model_struct.LocalChatLog) error

UpdateMessageStatus updates the message status in the database

func (*LocalChatLogs) DeleteAllMessage

func (i *LocalChatLogs) DeleteAllMessage(ctx context.Context) error

DeleteAllMessage deletes all messages from the local chat log.

func (*LocalChatLogs) DeleteConversationAllMessages

func (i *LocalChatLogs) DeleteConversationAllMessages(ctx context.Context, conversationID string) error

DeleteConversationAllMessages deletes all messages of the session

func (*LocalChatLogs) DeleteConversationMsgs

func (i *LocalChatLogs) DeleteConversationMsgs(ctx context.Context, conversationID string, msgIDs []string) error

DeleteConversationMsgs deletes messages of the session

func (*LocalChatLogs) DeleteConversationMsgsBySeqs

func (i *LocalChatLogs) DeleteConversationMsgsBySeqs(ctx context.Context, conversationID string, seqs []int64) error

DeleteConversationMsgsBySeqs deletes messages of the session

func (*LocalChatLogs) GetAbnormalMsgSeq

func (i *LocalChatLogs) GetAbnormalMsgSeq(ctx context.Context) (int64, error)

Get the abnormal message sequence number

func (*LocalChatLogs) GetAbnormalMsgSeqList

func (i *LocalChatLogs) GetAbnormalMsgSeqList(ctx context.Context) (result []int64, err error)

Get the list of abnormal message sequence numbers

func (*LocalChatLogs) GetAlreadyExistSeqList

func (i *LocalChatLogs) GetAlreadyExistSeqList(ctx context.Context, conversationID string, lostSeqList []int64) (result []int64, err error)

GetAlreadyExistSeqList get already exist seq list

func (*LocalChatLogs) GetConversationAbnormalMsgSeq

func (i *LocalChatLogs) GetConversationAbnormalMsgSeq(ctx context.Context, groupID string) (int64, error)

GetConversationAbnormalMsgSeq gets the maximum abnormal seq of the session

func (*LocalChatLogs) GetConversationNormalMsgSeq

func (i *LocalChatLogs) GetConversationNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

GetConversationNormalMsgSeq gets the maximum seq of the session

func (*LocalChatLogs) GetConversationPeerNormalMsgSeq

func (i *LocalChatLogs) GetConversationPeerNormalMsgSeq(ctx context.Context, conversationID string) (int64, error)

GetConversationPeerNormalMsgSeq gets the maximum seq of the peer in the session

func (*LocalChatLogs) GetLostMsgSeqList

func (i *LocalChatLogs) GetLostMsgSeqList(ctx context.Context, minSeqInSvr uint32) (result []uint32, err error)

GetLostMsgSeqList gets lost message seq list.

func (*LocalChatLogs) GetMessage

func (i *LocalChatLogs) GetMessage(ctx context.Context, conversationID, clientMsgID string) (*model_struct.LocalChatLog, error)

GetMessage gets the message from the database

func (*LocalChatLogs) GetMessageBySeq

func (i *LocalChatLogs) GetMessageBySeq(ctx context.Context, conversationID string, seq int64) (*model_struct.LocalChatLog, error)

GetMessagesBySeq get message by seq

func (*LocalChatLogs) GetMessageList

func (i *LocalChatLogs) GetMessageList(ctx context.Context, conversationID string, count int, startTime int64, isReverse bool) (result []*model_struct.LocalChatLog, err error)

GetMessageList retrieves a list of messages from the local chat log.

func (*LocalChatLogs) GetMessageListNoTime

func (i *LocalChatLogs) GetMessageListNoTime(ctx context.Context, conversationID string, count int, isReverse bool) (result []*model_struct.LocalChatLog, err error)

GetMessageListNoTime retrieves a list of messages from the local chat log without specifying a start time.

func (*LocalChatLogs) GetMessagesByClientMsgIDs

func (i *LocalChatLogs) GetMessagesByClientMsgIDs(ctx context.Context, conversationID string, msgIDs []string) (result []*model_struct.LocalChatLog, err error)

func (*LocalChatLogs) GetMessagesBySeqs

func (i *LocalChatLogs) GetMessagesBySeqs(ctx context.Context, conversationID string, seqs []int64) (result []*model_struct.LocalChatLog, err error)

GetMessagesBySeqs gets messages by seqs

func (*LocalChatLogs) GetMsgSeqByClientMsgID

func (i *LocalChatLogs) GetMsgSeqByClientMsgID(ctx context.Context, clientMsgID string) (uint32, error)

Get the message sequence number by client message ID

func (*LocalChatLogs) GetMsgSeqListByGroupID

func (i *LocalChatLogs) GetMsgSeqListByGroupID(ctx context.Context, groupID string) (result []uint32, err error)

Get the message sequence number list by group ID

func (*LocalChatLogs) GetMsgSeqListByPeerUserID

func (i *LocalChatLogs) GetMsgSeqListByPeerUserID(ctx context.Context, userID string) (result []uint32, err error)

Get the message sequence number list by peer user ID

func (*LocalChatLogs) GetMsgSeqListBySelfUserID

func (i *LocalChatLogs) GetMsgSeqListBySelfUserID(ctx context.Context, userID string) (result []uint32, err error)

Get the message sequence number list by self user ID

func (*LocalChatLogs) GetMultipleMessage

func (i *LocalChatLogs) GetMultipleMessage(ctx context.Context, msgIDList []string) (result []*model_struct.LocalChatLog, err error)

GetMultipleMessage gets multiple messages from the local chat log.

func (*LocalChatLogs) GetSuperGroupAbnormalMsgSeq

func (i *LocalChatLogs) GetSuperGroupAbnormalMsgSeq(ctx context.Context, groupID string) (uint32, error)

GetSuperGroupAbnormalMsgSeq get super group abnormal msg seq

func (*LocalChatLogs) GetTestMessage

func (i *LocalChatLogs) GetTestMessage(ctx context.Context, seq uint32) (*model_struct.LocalChatLog, error)

GetTestMessage gets test message.

func (*LocalChatLogs) GetUnreadMessage

func (i *LocalChatLogs) GetUnreadMessage(ctx context.Context, conversationID string) (result []*model_struct.LocalChatLog, err error)

func (*LocalChatLogs) InsertMessage

func (i *LocalChatLogs) InsertMessage(ctx context.Context, conversationID string, message *model_struct.LocalChatLog) error

InsertMessage inserts a message into the local chat log.

func (*LocalChatLogs) IsExistsInErrChatLogBySeq

func (i *LocalChatLogs) IsExistsInErrChatLogBySeq(ctx context.Context, seq int64) bool

IsExistsInErrChatLogBySeq check if message exists in error chat log by seq

func (*LocalChatLogs) MarkConversationAllMessageAsRead

func (i *LocalChatLogs) MarkConversationAllMessageAsRead(ctx context.Context, conversationID string) (rowsAffected int64, err error)

func (*LocalChatLogs) MarkConversationMessageAsReadBySeqs

func (i *LocalChatLogs) MarkConversationMessageAsReadBySeqs(ctx context.Context, conversationID string, seqs []int64) (rowsAffected int64, err error)

func (*LocalChatLogs) MarkConversationMessageAsReadDB

func (i *LocalChatLogs) MarkConversationMessageAsReadDB(ctx context.Context, conversationID string, msgIDs []string) (rowsAffected int64, err error)

func (*LocalChatLogs) MarkDeleteConversationAllMessages

func (i *LocalChatLogs) MarkDeleteConversationAllMessages(ctx context.Context, conversationID string) error

MarkDeleteConversationAllMessages marks all messages of the session as deleted

func (*LocalChatLogs) MessageIfExists

func (i *LocalChatLogs) MessageIfExists(ctx context.Context, clientMsgID string) (bool, error)

MessageIfExists check if message exists

func (*LocalChatLogs) MessageIfExistsBySeq

func (i *LocalChatLogs) MessageIfExistsBySeq(ctx context.Context, seq int64) (bool, error)

MessageIfExistsBySeq check if message exists by seq

func (*LocalChatLogs) SearchAllMessageByContentType

func (i *LocalChatLogs) SearchAllMessageByContentType(ctx context.Context, conversationID string, contentType int) (result []*model_struct.LocalChatLog, err error)

Search all messages by content type

func (*LocalChatLogs) SearchMessageByContentType

func (i *LocalChatLogs) SearchMessageByContentType(ctx context.Context, contentType []int, conversationID string, startTime, endTime int64, offset, count int) (messages []*model_struct.LocalChatLog, err error)

SearchMessageByContentType searches for messages in the local chat log by content type.

func (*LocalChatLogs) SearchMessageByContentTypeAndKeyword

func (i *LocalChatLogs) SearchMessageByContentTypeAndKeyword(ctx context.Context, contentType []int, conversationID string, keywordList []string, keywordListMatchType int, startTime, endTime int64) (result []*model_struct.LocalChatLog, err error)

SearchMessageByKeyword searches for messages in the local chat log by keyword.

func (*LocalChatLogs) SearchMessageByKeyword

func (i *LocalChatLogs) SearchMessageByKeyword(ctx context.Context, contentType []int, keywordList []string, keywordListMatchType int, conversationID string, startTime, endTime int64, offset, count int) (result []*model_struct.LocalChatLog, err error)

Get the message by message ID

func (*LocalChatLogs) UpdateColumnsMessage

func (i *LocalChatLogs) UpdateColumnsMessage(ctx context.Context, conversationID, clientMsgID string, args map[string]interface{}) error

UpdateColumnsMessage updates a column of a message in the local chat log.

func (*LocalChatLogs) UpdateColumnsMessageList

func (i *LocalChatLogs) UpdateColumnsMessageList(ctx context.Context, clientMsgIDList []string, args map[string]interface{}) error

UpdateColumnsMessageList updates multiple columns of a message in the local chat log.

func (*LocalChatLogs) UpdateGroupMessageHasRead

func (i *LocalChatLogs) UpdateGroupMessageHasRead(ctx context.Context, msgIDList []string, sessionType int32) error

Update the message status to read in the chat logs

func (*LocalChatLogs) UpdateMessage

func (i *LocalChatLogs) UpdateMessage(ctx context.Context, conversationID string, c *model_struct.LocalChatLog) error

UpdateMessage updates the message in the database

func (*LocalChatLogs) UpdateMessageBySeq

func (i *LocalChatLogs) UpdateMessageBySeq(ctx context.Context, conversationID string, c *model_struct.LocalChatLog) error

UpdateMessageBySeq update message

func (*LocalChatLogs) UpdateMessageStatusBySourceID

func (i *LocalChatLogs) UpdateMessageStatusBySourceID(ctx context.Context, sourceID string, status, sessionType int32) error

UpdateMessageStatusBySourceID updates the status of a message in the local chat log by its source ID.

func (*LocalChatLogs) UpdateMessageTimeAndStatus

func (i *LocalChatLogs) UpdateMessageTimeAndStatus(ctx context.Context, conversationID, clientMsgID string, serverMsgID string, sendTime int64, status int32) error

UpdateMessageTimeAndStatus updates the time and status of a message in the local chat log.

func (*LocalChatLogs) UpdateMsgSenderFaceURL

func (i *LocalChatLogs) UpdateMsgSenderFaceURL(ctx context.Context, sendID, faceURL string, sType int) error

Update the sender's face URL in the chat logs

func (*LocalChatLogs) UpdateMsgSenderFaceURLAndSenderNickname

func (i *LocalChatLogs) UpdateMsgSenderFaceURLAndSenderNickname(ctx context.Context, conversationID, sendID, faceURL, nickname string) error

Update the sender's face URL and nickname in the chat logs

func (*LocalChatLogs) UpdateMsgSenderNickname

func (i *LocalChatLogs) UpdateMsgSenderNickname(ctx context.Context, sendID, nickname string, sType int) error

Update the sender's nickname in the chat logs

func (*LocalChatLogs) UpdateSingleMessageHasRead

func (i *LocalChatLogs) UpdateSingleMessageHasRead(ctx context.Context, sendID string, msgIDList []string) error

UpdateSingleMessageHasRead updates the hasRead field of a single message in the local chat log.

type LocalConversationUnreadMessages

type LocalConversationUnreadMessages struct {
}

func NewLocalConversationUnreadMessages

func NewLocalConversationUnreadMessages() *LocalConversationUnreadMessages

func (*LocalConversationUnreadMessages) BatchInsertConversationUnreadMessageList

func (i *LocalConversationUnreadMessages) BatchInsertConversationUnreadMessageList(ctx context.Context, messageList []*model_struct.LocalConversationUnreadMessage) error

func (*LocalConversationUnreadMessages) DeleteConversationUnreadMessageList

func (i *LocalConversationUnreadMessages) DeleteConversationUnreadMessageList(ctx context.Context, conversationID string, sendTime int64) int64

type LocalConversations

type LocalConversations struct {
}

func NewLocalConversations

func NewLocalConversations() *LocalConversations

func (*LocalConversations) BatchInsertConversationList

func (i *LocalConversations) BatchInsertConversationList(ctx context.Context, conversationList []*model_struct.LocalConversation) error

func (*LocalConversations) BatchUpdateConversationList

func (i *LocalConversations) BatchUpdateConversationList(ctx context.Context, conversationList []*model_struct.LocalConversation) error

func (*LocalConversations) ClearAllConversation

func (i *LocalConversations) ClearAllConversation(ctx context.Context) error

func (*LocalConversations) ClearConversation

func (i *LocalConversations) ClearConversation(ctx context.Context, conversationID string) error

func (*LocalConversations) ConversationIfExists

func (i *LocalConversations) ConversationIfExists(ctx context.Context, conversationID string) (bool, error)

func (*LocalConversations) DecrConversationUnreadCount

func (i *LocalConversations) DecrConversationUnreadCount(ctx context.Context, conversationID string, count int64) error

func (*LocalConversations) DeleteConversation

func (i *LocalConversations) DeleteConversation(ctx context.Context, conversationID string) error

func (*LocalConversations) GetAllConversationIDList

func (i *LocalConversations) GetAllConversationIDList(ctx context.Context) ([]string, error)

func (*LocalConversations) GetAllConversationListDB

func (i *LocalConversations) GetAllConversationListDB(ctx context.Context) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetAllConversations

func (i *LocalConversations) GetAllConversations(ctx context.Context) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetAllSingleConversationIDList

func (i *LocalConversations) GetAllSingleConversationIDList(ctx context.Context) (result []string, err error)

func (*LocalConversations) GetConversation

func (i *LocalConversations) GetConversation(ctx context.Context, conversationID string) (*model_struct.LocalConversation, error)

func (*LocalConversations) GetConversationByUserID

func (i *LocalConversations) GetConversationByUserID(ctx context.Context, userID string) (*model_struct.LocalConversation, error)

func (*LocalConversations) GetConversationListSplitDB

func (i *LocalConversations) GetConversationListSplitDB(ctx context.Context, offset, count int) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetHiddenConversationList

func (i *LocalConversations) GetHiddenConversationList(ctx context.Context) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetMultipleConversationDB

func (i *LocalConversations) GetMultipleConversationDB(ctx context.Context, conversationIDList []string) (result []*model_struct.LocalConversation, err error)

func (*LocalConversations) GetTotalUnreadMsgCountDB

func (i *LocalConversations) GetTotalUnreadMsgCountDB(ctx context.Context) (totalUnreadCount int32, err error)

func (*LocalConversations) IncrConversationUnreadCount

func (i *LocalConversations) IncrConversationUnreadCount(ctx context.Context, conversationID string) error

func (*LocalConversations) InsertConversation

func (i *LocalConversations) InsertConversation(ctx context.Context, conversationList *model_struct.LocalConversation) error

func (*LocalConversations) RemoveConversationDraft

func (i *LocalConversations) RemoveConversationDraft(ctx context.Context, conversationID, draftText string) error

func (*LocalConversations) ResetAllConversation

func (i *LocalConversations) ResetAllConversation(ctx context.Context) error

func (*LocalConversations) ResetConversation

func (i *LocalConversations) ResetConversation(ctx context.Context, conversationID string) error

func (*LocalConversations) SearchConversations added in v3.5.0

func (i *LocalConversations) SearchConversations(ctx context.Context, searchParam string) ([]*model_struct.LocalConversation, error)

func (*LocalConversations) SetConversationDraftDB

func (i *LocalConversations) SetConversationDraftDB(ctx context.Context, conversationID, draftText string) error

func (*LocalConversations) SetMultipleConversationRecvMsgOpt

func (i *LocalConversations) SetMultipleConversationRecvMsgOpt(ctx context.Context, conversationIDList []string, opt int) (err error)

func (*LocalConversations) UnPinConversation

func (i *LocalConversations) UnPinConversation(ctx context.Context, conversationID string, isPinned int) error

func (*LocalConversations) UpdateAllConversation

func (i *LocalConversations) UpdateAllConversation(ctx context.Context, conversation *model_struct.LocalConversation) error

func (*LocalConversations) UpdateColumnsConversation

func (i *LocalConversations) UpdateColumnsConversation(ctx context.Context, conversationID string, args map[string]interface{}) error

func (*LocalConversations) UpdateConversation

func (i *LocalConversations) UpdateConversation(ctx context.Context, c *model_struct.LocalConversation) error

func (*LocalConversations) UpdateConversationForSync

func (i *LocalConversations) UpdateConversationForSync(ctx context.Context, c *model_struct.LocalConversation) error

func (*LocalConversations) UpdateOrCreateConversations

func (i *LocalConversations) UpdateOrCreateConversations(ctx context.Context, conversationList []*model_struct.LocalConversation) error

type LocalGroupMember

type LocalGroupMember struct {
}

func NewLocalGroupMember

func NewLocalGroupMember() *LocalGroupMember

func (*LocalGroupMember) BatchInsertGroupMember

func (i *LocalGroupMember) BatchInsertGroupMember(ctx context.Context, groupMemberList []*model_struct.LocalGroupMember) error

func (*LocalGroupMember) DeleteGroupAllMembers

func (i *LocalGroupMember) DeleteGroupAllMembers(ctx context.Context, groupID string) error

func (*LocalGroupMember) DeleteGroupMember

func (i *LocalGroupMember) DeleteGroupMember(ctx context.Context, groupID, userID string) error

func (*LocalGroupMember) GetAllGroupMemberList

func (i *LocalGroupMember) GetAllGroupMemberList(ctx context.Context) ([]model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetAllGroupMemberUserIDList

func (i *LocalGroupMember) GetAllGroupMemberUserIDList(ctx context.Context) ([]model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupAdminID

func (i *LocalGroupMember) GetGroupAdminID(ctx context.Context, groupID string) ([]string, error)

func (*LocalGroupMember) GetGroupMemberCount

func (i *LocalGroupMember) GetGroupMemberCount(ctx context.Context, groupID string) (int32, error)

func (*LocalGroupMember) GetGroupMemberInfoByGroupIDUserID

func (i *LocalGroupMember) GetGroupMemberInfoByGroupIDUserID(ctx context.Context, groupID, userID string) (*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberInfoIfOwnerOrAdmin

func (i *LocalGroupMember) GetGroupMemberInfoIfOwnerOrAdmin(ctx context.Context) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberListByGroupID

func (i *LocalGroupMember) GetGroupMemberListByGroupID(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberListSplit

func (i *LocalGroupMember) GetGroupMemberListSplit(ctx context.Context, groupID string, filter int32, offset, count int) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberListSplitByJoinTimeFilter

func (i *LocalGroupMember) GetGroupMemberListSplitByJoinTimeFilter(ctx context.Context, groupID string, offset, count int, joinTimeBegin, joinTimeEnd int64, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberOwner

func (i *LocalGroupMember) GetGroupMemberOwner(ctx context.Context, groupID string) (*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberOwnerAndAdminDB

func (i *LocalGroupMember) GetGroupMemberOwnerAndAdminDB(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupMemberUIDListByGroupID

func (i *LocalGroupMember) GetGroupMemberUIDListByGroupID(ctx context.Context, groupID string) (result []string, err error)

func (*LocalGroupMember) GetGroupOwnerAndAdminByGroupID

func (i *LocalGroupMember) GetGroupOwnerAndAdminByGroupID(ctx context.Context, groupID string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetGroupSomeMemberInfo

func (i *LocalGroupMember) GetGroupSomeMemberInfo(ctx context.Context, groupID string, userIDList []string) ([]*model_struct.LocalGroupMember, error)

func (*LocalGroupMember) GetUserJoinedGroupIDs

func (i *LocalGroupMember) GetUserJoinedGroupIDs(ctx context.Context, userID string) (result []string, err error)

func (*LocalGroupMember) InsertGroupMember

func (i *LocalGroupMember) InsertGroupMember(ctx context.Context, groupMember *model_struct.LocalGroupMember) error

func (*LocalGroupMember) SearchGroupMembersDB

func (i *LocalGroupMember) SearchGroupMembersDB(ctx context.Context, keyword string, groupID string, isSearchMemberNickname, isSearchUserID bool, offset, count int) (result []*model_struct.LocalGroupMember, err error)

func (*LocalGroupMember) UpdateGroupMember

func (i *LocalGroupMember) UpdateGroupMember(ctx context.Context, groupMember *model_struct.LocalGroupMember) error

func (*LocalGroupMember) UpdateGroupMemberField

func (i *LocalGroupMember) UpdateGroupMemberField(ctx context.Context, groupID, userID string, args map[string]interface{}) error

type LocalGroupRequest

type LocalGroupRequest struct {
}

func NewLocalGroupRequest

func NewLocalGroupRequest() *LocalGroupRequest

func (*LocalGroupRequest) DeleteAdminGroupRequest

func (i *LocalGroupRequest) DeleteAdminGroupRequest(ctx context.Context, groupID, userID string) error

func (*LocalGroupRequest) DeleteGroupRequest

func (i *LocalGroupRequest) DeleteGroupRequest(ctx context.Context, groupID, userID string) error

func (*LocalGroupRequest) GetAdminGroupApplication

func (i *LocalGroupRequest) GetAdminGroupApplication(ctx context.Context) ([]*model_struct.LocalAdminGroupRequest, error)

func (*LocalGroupRequest) GetSendGroupApplication

func (i *LocalGroupRequest) GetSendGroupApplication(ctx context.Context) ([]*model_struct.LocalGroupRequest, error)

func (*LocalGroupRequest) InsertAdminGroupRequest

func (i *LocalGroupRequest) InsertAdminGroupRequest(ctx context.Context, groupRequest *model_struct.LocalAdminGroupRequest) error

func (*LocalGroupRequest) InsertGroupRequest

func (i *LocalGroupRequest) InsertGroupRequest(ctx context.Context, groupRequest *model_struct.LocalGroupRequest) error

func (*LocalGroupRequest) UpdateAdminGroupRequest

func (i *LocalGroupRequest) UpdateAdminGroupRequest(ctx context.Context, groupRequest *model_struct.LocalAdminGroupRequest) error

func (*LocalGroupRequest) UpdateGroupRequest

func (i *LocalGroupRequest) UpdateGroupRequest(ctx context.Context, groupRequest *model_struct.LocalGroupRequest) error

type LocalGroups

type LocalGroups struct{}

func NewLocalGroups

func NewLocalGroups() *LocalGroups

func (*LocalGroups) AddMemberCount

func (i *LocalGroups) AddMemberCount(ctx context.Context, groupID string) error

func (*LocalGroups) DeleteGroup

func (i *LocalGroups) DeleteGroup(ctx context.Context, groupID string) error

func (*LocalGroups) GetAllGroupInfoByGroupIDOrGroupName

func (i *LocalGroups) GetAllGroupInfoByGroupIDOrGroupName(ctx context.Context, keyword string, isSearchGroupID bool, isSearchGroupName bool) (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) GetGroupInfoByGroupID

func (i *LocalGroups) GetGroupInfoByGroupID(ctx context.Context, groupID string) (*model_struct.LocalGroup, error)

func (*LocalGroups) GetGroupMemberAllGroupIDs

func (i *LocalGroups) GetGroupMemberAllGroupIDs(ctx context.Context) (result []string, err error)

func (*LocalGroups) GetGroups

func (i *LocalGroups) GetGroups(ctx context.Context, groupIDs []string) (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) GetJoinedGroupListDB

func (i *LocalGroups) GetJoinedGroupListDB(ctx context.Context) (result []*model_struct.LocalGroup, err error)

func (*LocalGroups) InsertGroup

func (i *LocalGroups) InsertGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

func (*LocalGroups) SubtractMemberCount

func (i *LocalGroups) SubtractMemberCount(ctx context.Context, groupID string) error

func (*LocalGroups) UpdateGroup

func (i *LocalGroups) UpdateGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

该函数需要全更新

type LocalSendingMessages added in v3.4.0

type LocalSendingMessages struct {
}

func NewLocalSendingMessages added in v3.4.0

func NewLocalSendingMessages() *LocalSendingMessages

func (*LocalSendingMessages) DeleteSendingMessage added in v3.4.0

func (i *LocalSendingMessages) DeleteSendingMessage(ctx context.Context, conversationID, clientMsgID string) error

func (*LocalSendingMessages) GetAllSendingMessages added in v3.4.0

func (i *LocalSendingMessages) GetAllSendingMessages(ctx context.Context) (result []*model_struct.LocalSendingMessages, err error)

func (*LocalSendingMessages) InsertSendingMessage added in v3.4.0

func (i *LocalSendingMessages) InsertSendingMessage(ctx context.Context, message *model_struct.LocalSendingMessages) error

type LocalStrangers

type LocalStrangers struct {
}

func NewLocalStrangers

func NewLocalStrangers() *LocalStrangers

func (*LocalStrangers) GetStrangerInfo

func (l *LocalStrangers) GetStrangerInfo(ctx context.Context, userIDs []string) (result []*model_struct.LocalStranger, err error)

func (*LocalStrangers) SetStrangerInfo

func (l *LocalStrangers) SetStrangerInfo(ctx context.Context, strangerList []*model_struct.LocalStranger) error

type LocalSuperGroup

type LocalSuperGroup struct{}

func NewLocalSuperGroup

func NewLocalSuperGroup() *LocalSuperGroup

func (*LocalSuperGroup) DeleteAllSuperGroup

func (i *LocalSuperGroup) DeleteAllSuperGroup(ctx context.Context) error

func (*LocalSuperGroup) DeleteSuperGroup

func (i *LocalSuperGroup) DeleteSuperGroup(ctx context.Context, groupID string) error

func (*LocalSuperGroup) GetJoinedSuperGroupList

func (i *LocalSuperGroup) GetJoinedSuperGroupList(ctx context.Context) (result []*model_struct.LocalGroup, err error)

func (*LocalSuperGroup) GetJoinedWorkingGroupIDList

func (i *LocalSuperGroup) GetJoinedWorkingGroupIDList(ctx context.Context) ([]string, error)

func (*LocalSuperGroup) GetJoinedWorkingGroupList

func (i *LocalSuperGroup) GetJoinedWorkingGroupList(ctx context.Context) (result []*model_struct.LocalGroup, err error)

func (*LocalSuperGroup) GetSuperGroupInfoByGroupID

func (i *LocalSuperGroup) GetSuperGroupInfoByGroupID(ctx context.Context, groupID string) (*model_struct.LocalGroup, error)

func (*LocalSuperGroup) InsertSuperGroup

func (i *LocalSuperGroup) InsertSuperGroup(ctx context.Context, groupInfo *model_struct.LocalGroup) error

func (*LocalSuperGroup) UpdateSuperGroup

func (i *LocalSuperGroup) UpdateSuperGroup(ctx context.Context, g *model_struct.LocalGroup) error

type LocalSuperGroupChatLogs

type LocalSuperGroupChatLogs struct{}

func NewLocalSuperGroupChatLogs

func NewLocalSuperGroupChatLogs() *LocalSuperGroupChatLogs

func (*LocalSuperGroupChatLogs) InitSuperLocalChatLog

func (i *LocalSuperGroupChatLogs) InitSuperLocalChatLog(ctx context.Context, groupID string)

func (*LocalSuperGroupChatLogs) InitSuperLocalErrChatLog

func (i *LocalSuperGroupChatLogs) InitSuperLocalErrChatLog(ctx context.Context, groupID string)

func (*LocalSuperGroupChatLogs) SuperBatchInsertExceptionMsg

func (i *LocalSuperGroupChatLogs) SuperBatchInsertExceptionMsg(ctx context.Context, MessageList []*model_struct.LocalErrChatLog, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupBatchInsertMessageList

func (i *LocalSuperGroupChatLogs) SuperGroupBatchInsertMessageList(ctx context.Context, messageList []*model_struct.LocalChatLog, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupBatchUpdateMessageList

func (i *LocalSuperGroupChatLogs) SuperGroupBatchUpdateMessageList(ctx context.Context, MessageList []*model_struct.LocalChatLog) error

func (*LocalSuperGroupChatLogs) SuperGroupDeleteAllMessage

func (i *LocalSuperGroupChatLogs) SuperGroupDeleteAllMessage(ctx context.Context, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupGetAllUnDeleteMessageSeqList

func (i *LocalSuperGroupChatLogs) SuperGroupGetAllUnDeleteMessageSeqList(ctx context.Context) ([]uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMessage

func (i *LocalSuperGroupChatLogs) SuperGroupGetMessage(ctx context.Context, message *sdk_struct.MsgStruct) (*model_struct.LocalChatLog, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMessageList

func (i *LocalSuperGroupChatLogs) SuperGroupGetMessageList(ctx context.Context, sourceID string, sessionType, count int, startTime int64, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMessageListNoTime

func (i *LocalSuperGroupChatLogs) SuperGroupGetMessageListNoTime(ctx context.Context, sourceID string, sessionType, count int, isReverse bool) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMsgSeqByClientMsgID

func (i *LocalSuperGroupChatLogs) SuperGroupGetMsgSeqByClientMsgID(ctx context.Context, clientMsgID string, groupID string) (uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMsgSeqListByGroupID

func (i *LocalSuperGroupChatLogs) SuperGroupGetMsgSeqListByGroupID(ctx context.Context, groupID string) ([]uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMsgSeqListByPeerUserID

func (i *LocalSuperGroupChatLogs) SuperGroupGetMsgSeqListByPeerUserID(ctx context.Context, userID string) ([]uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMsgSeqListBySelfUserID

func (i *LocalSuperGroupChatLogs) SuperGroupGetMsgSeqListBySelfUserID(ctx context.Context, userID string) ([]uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetMultipleMessage

func (i *LocalSuperGroupChatLogs) SuperGroupGetMultipleMessage(ctx context.Context, msgIDList []string, groupID string) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupGetNormalMinSeq

func (i *LocalSuperGroupChatLogs) SuperGroupGetNormalMinSeq(ctx context.Context, groupID string) (uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetNormalMsgSeq

func (i *LocalSuperGroupChatLogs) SuperGroupGetNormalMsgSeq(ctx context.Context) (uint32, error)

func (*LocalSuperGroupChatLogs) SuperGroupGetSendingMessageList

func (i *LocalSuperGroupChatLogs) SuperGroupGetSendingMessageList(ctx context.Context, groupID string) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupGetTestMessage

func (i *LocalSuperGroupChatLogs) SuperGroupGetTestMessage(ctx context.Context, seq uint32) (*model_struct.LocalChatLog, error)

func (*LocalSuperGroupChatLogs) SuperGroupInsertMessage

func (i *LocalSuperGroupChatLogs) SuperGroupInsertMessage(ctx context.Context, message *model_struct.LocalChatLog, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupIsExistsInErrChatLogBySeq

func (i *LocalSuperGroupChatLogs) SuperGroupIsExistsInErrChatLogBySeq(ctx context.Context, seq int64) bool

func (*LocalSuperGroupChatLogs) SuperGroupMessageIfExists

func (i *LocalSuperGroupChatLogs) SuperGroupMessageIfExists(ctx context.Context, ClientMsgID string) (bool, error)

func (*LocalSuperGroupChatLogs) SuperGroupMessageIfExistsBySeq

func (i *LocalSuperGroupChatLogs) SuperGroupMessageIfExistsBySeq(ctx context.Context, seq int64) (bool, error)

func (*LocalSuperGroupChatLogs) SuperGroupSearchAllMessageByContentType

func (i *LocalSuperGroupChatLogs) SuperGroupSearchAllMessageByContentType(ctx context.Context, superGroupID string, contentType int32) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupSearchMessageByContentTypeAndKeyword

func (i *LocalSuperGroupChatLogs) SuperGroupSearchMessageByContentTypeAndKeyword(ctx context.Context, contentType []int, keywordList []string, keywordListMatchType int, startTime, endTime int64, groupID string) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupSearchMessageByKeyword

func (i *LocalSuperGroupChatLogs) SuperGroupSearchMessageByKeyword(ctx context.Context, contentType []int, keywordList []string, keywordListMatchType int, sourceID string, startTime, endTime int64, sessionType, offset, count int) (result []*model_struct.LocalChatLog, err error)

func (*LocalSuperGroupChatLogs) SuperGroupUpdateColumnsMessage

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateColumnsMessage(ctx context.Context, clientMsgID, groupID string, args map[string]interface{}) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateGroupMessageHasRead

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateGroupMessageHasRead(ctx context.Context, msgIDList []string, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMessage

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMessage(ctx context.Context, c *model_struct.LocalChatLog) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMessageStatusBySourceID

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMessageStatusBySourceID(ctx context.Context, sourceID string, status, sessionType int32) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMessageTimeAndStatus

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMessageTimeAndStatus(ctx context.Context, msg *sdk_struct.MsgStruct) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMsgSenderFaceURL

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMsgSenderFaceURL(ctx context.Context, sendID, faceURL string, sType int) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMsgSenderFaceURLAndSenderNickname

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMsgSenderFaceURLAndSenderNickname(ctx context.Context, sendID, faceURL, nickname string, sessionType int, groupID string) error

func (*LocalSuperGroupChatLogs) SuperGroupUpdateMsgSenderNickname

func (i *LocalSuperGroupChatLogs) SuperGroupUpdateMsgSenderNickname(ctx context.Context, sendID, nickname string, sType int) error

type LocalUpload

type LocalUpload struct{}

func NewLocalUpload

func NewLocalUpload() *LocalUpload

func (*LocalUpload) DeleteExpireUpload

func (i *LocalUpload) DeleteExpireUpload(ctx context.Context) error

func (*LocalUpload) DeleteUpload

func (i *LocalUpload) DeleteUpload(ctx context.Context, partHash string) error

func (*LocalUpload) GetUpload

func (i *LocalUpload) GetUpload(ctx context.Context, partHash string) (*model_struct.LocalUpload, error)

func (*LocalUpload) InsertUpload

func (i *LocalUpload) InsertUpload(ctx context.Context, upload *model_struct.LocalUpload) error

func (*LocalUpload) UpdateUpload

func (i *LocalUpload) UpdateUpload(ctx context.Context, upload *model_struct.LocalUpload) error

type LocalUsers

type LocalUsers struct {
}

func NewLocalUsers

func NewLocalUsers() *LocalUsers

func (*LocalUsers) GetLoginUser

func (l *LocalUsers) GetLoginUser(ctx context.Context, userID string) (*model_struct.LocalUser, error)

func (*LocalUsers) InsertLoginUser

func (l *LocalUsers) InsertLoginUser(ctx context.Context, user *model_struct.LocalUser) error

func (*LocalUsers) UpdateLoginUser

func (l *LocalUsers) UpdateLoginUser(ctx context.Context, user *model_struct.LocalUser) error

func (*LocalUsers) UpdateLoginUserByMap

func (l *LocalUsers) UpdateLoginUserByMap(ctx context.Context, user *model_struct.LocalUser, args map[string]interface{}) error

type NotificationSeqs

type NotificationSeqs struct {
}

func NewNotificationSeqs

func NewNotificationSeqs() *NotificationSeqs

func (*NotificationSeqs) GetNotificationAllSeqs

func (i *NotificationSeqs) GetNotificationAllSeqs(ctx context.Context) (result []*model_struct.NotificationSeqs, err error)

func (*NotificationSeqs) SetNotificationSeq

func (i *NotificationSeqs) SetNotificationSeq(ctx context.Context, conversationID string, seq int64) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL