conversation_msg

Nov 22, 2024

Changes in this version

+ func LocalChatLogToMsgStruct(localMessage *model_struct.LocalChatLog) *sdk_struct.MsgStruct

+ func MsgDataToLocalChatLog(serverMessage *sdkws.MsgData) *model_struct.LocalChatLog

+ func MsgStructToLocalChatLog(message *sdk_struct.MsgStruct) *model_struct.LocalChatLog

type Conversation

+ func (c *Conversation) FetchSurroundingMessages(ctx context.Context, conversationID string, seq int64, before int64, ...) ([]*sdk_struct.MsgStruct, error)

+ func (c *Conversation) LocalChatLog2MsgStruct(ctx context.Context, list []*model_struct.LocalChatLog) (int64, []*sdk_struct.MsgStruct)

+ func (c *Conversation) MarkAllConversationMessageAsRead(ctx context.Context) error

Sep 29, 2024

Changes in this version

type Conversation

+ func (c *Conversation) DeleteAllMsgFromLocalAndServer(ctx context.Context) error

+ func (c *Conversation) SetBusinessListener(businessListener func() open_im_sdk_callback.OnCustomBusinessListener)

+ func (c *Conversation) SetConversation(ctx context.Context, conversationID string, ...) error

Aug 1, 2024

Changes in this version

+ const InitSyncProgress

type Conversation

+ func (c *Conversation) DoNotification(ctx context.Context, msg *sdkws.MsgData)

+ func (c *Conversation) IncrSyncConversations(ctx context.Context) error

Mar 4, 2024

Changes in this version

type Conversation

+ func (c *Conversation) ChangeInputStates(ctx context.Context, conversationID string, focus bool) error

+ func (c *Conversation) GetInputStates(ctx context.Context, conversationID string, userID string) ([]int32, error)

+ type InputStatesChangedData struct

+ ConversationID string

+ PlatformIDs []int32

+ UserID string

Dec 29, 2023

Changes in this version

type Conversation

+ func (c *Conversation) SearchConversation(ctx context.Context, searchParam string) ([]*server_api_params.Conversation, error)

+ func (c *Conversation) SetOneConversationEx(ctx context.Context, conversationID string, ex string) error

Nov 10, 2023

Changes in this version

type Conversation

+ func (c *Conversation) DeleteAllMsgFromLocalAndSvr(ctx context.Context) error

+ func (c *Conversation) HideAllConversations(ctx context.Context) error

Sep 7, 2023

Changes in this version

+ var SearchContentType = []int

+ func DeleteUserReactionElem(a []*sdk_struct.UserReactionElem, userID string) []*sdk_struct.UserReactionElem

+ func LocalConversationToServer(conversation *model_struct.LocalConversation) *pbConversation.Conversation

+ func NewUploadFileCallback(ctx context.Context, progress func(progress int), msg *sdk_struct.MsgStruct, ...) file.UploadFileCallback

+ func ServerConversationToLocal(conversation *pbConversation.Conversation) *model_struct.LocalConversation

+ type Conversation struct

+ ConversationListener open_im_sdk_callback.OnConversationListener

+ DataDir string

+ IsExternalExtensions bool

+ func NewConversation(ctx context.Context, longConnMgr *interaction.LongConnMgr, ...) *Conversation

+ func (c *Conversation) AddMessageReactionExtensions(ctx context.Context, s *sdk_struct.MsgStruct, ...) ([]*server_api_params.ExtensionResult, error)

+ func (c *Conversation) ClearConversationAndDeleteAllMsg(ctx context.Context, conversationID string) error

+ func (c *Conversation) CreateAdvancedQuoteMessage(ctx context.Context, text string, qs *sdk_struct.MsgStruct, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateAdvancedTextMessage(ctx context.Context, text string, messageEntities []*sdk_struct.MessageEntity) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateCardMessage(ctx context.Context, card *sdk_struct.CardElem) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateCustomMessage(ctx context.Context, data, extension string, description string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFaceMessage(ctx context.Context, index int, data string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFileMessage(ctx context.Context, filePath string, fileName string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFileMessageByURL(ctx context.Context, fileElem sdk_struct.FileBaseInfo) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateFileMessageFromFullPath(ctx context.Context, fileFullPath string, fileName string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateForwardMessage(ctx context.Context, s *sdk_struct.MsgStruct) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateImageMessage(ctx context.Context, imagePath string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateImageMessageByURL(ctx context.Context, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateImageMessageFromFullPath(ctx context.Context, imageFullPath string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateLocationMessage(ctx context.Context, description string, longitude, latitude float64) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateMergerMessage(ctx context.Context, messages []*sdk_struct.MsgStruct, title string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateQuoteMessage(ctx context.Context, text string, qs *sdk_struct.MsgStruct) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateSoundMessage(ctx context.Context, soundPath string, duration int64) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateSoundMessageByURL(ctx context.Context, soundElem *sdk_struct.SoundBaseInfo) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateSoundMessageFromFullPath(ctx context.Context, soundPath string, duration int64) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateTextAtMessage(ctx context.Context, text string, userIDList []string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateTextMessage(ctx context.Context, text string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateVideoMessage(ctx context.Context, videoPath string, videoType string, duration int64, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateVideoMessageByURL(ctx context.Context, videoElem sdk_struct.VideoBaseInfo) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) CreateVideoMessageFromFullPath(ctx context.Context, videoFullPath string, videoType string, duration int64, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) DeleteAllConversationFromLocal(ctx context.Context) error

+ func (c *Conversation) DeleteAllMessage(ctx context.Context) error

+ func (c *Conversation) DeleteAllMessageFromLocalStorage(ctx context.Context) error

+ func (c *Conversation) DeleteConversationAndDeleteAllMsg(ctx context.Context, conversationID string) error

+ func (c *Conversation) DeleteMessage(ctx context.Context, conversationID string, clientMsgID string) error

+ func (c *Conversation) DeleteMessageFromLocalStorage(ctx context.Context, conversationID string, clientMsgID string) error

+ func (c *Conversation) DeleteMessageReactionExtensions(ctx context.Context, s *sdk_struct.MsgStruct, ...) ([]*server_api_params.ExtensionResult, error)

+ func (c *Conversation) DoConversationChangedNotification(ctx context.Context, msg *sdkws.MsgData)

+ func (c *Conversation) DoConversationIsPrivateChangedNotification(ctx context.Context, msg *sdkws.MsgData)

+ func (c *Conversation) DoMsgReaction(msgReactionList []*sdk_struct.MsgStruct)

+ func (c *Conversation) FindMessageList(ctx context.Context, req []*sdk_params_callback.ConversationArgs) (*sdk_params_callback.FindMessageListCallback, error)

+ func (c *Conversation) GetAdvancedHistoryMessageList(ctx context.Context, ...) (*sdk_params_callback.GetAdvancedHistoryMessageListCallback, error)

+ func (c *Conversation) GetAdvancedHistoryMessageListReverse(ctx context.Context, ...) (*sdk_params_callback.GetAdvancedHistoryMessageListCallback, error)

+ func (c *Conversation) GetAllConversationList(ctx context.Context) ([]*model_struct.LocalConversation, error)

+ func (c *Conversation) GetAtAllTag(_ context.Context) string

+ func (c *Conversation) GetCh() chan common.Cmd2Value

+ func (c *Conversation) GetConversationIDBySessionType(_ context.Context, sourceID string, sessionType int) string

+ func (c *Conversation) GetConversationListSplit(ctx context.Context, offset, count int) ([]*model_struct.LocalConversation, error)

+ func (c *Conversation) GetConversationRecvMessageOpt(ctx context.Context, conversationIDs []string) (resp []*server_api_params.GetConversationRecvMessageOptResp, err error)

+ func (c *Conversation) GetHistoryMessageList(ctx context.Context, req sdk_params_callback.GetHistoryMessageListParams) ([]*sdk_struct.MsgStruct, error)

+ func (c *Conversation) GetHistoryMessageListReverse(ctx context.Context, req sdk_params_callback.GetHistoryMessageListParams) ([]*sdk_struct.MsgStruct, error)

+ func (c *Conversation) GetMessageListReactionExtensions(ctx context.Context, conversationID string, ...) ([]*server_api_params.SingleMessageExtensionResult, error)

+ func (c *Conversation) GetMultipleConversation(ctx context.Context, conversationIDList []string) ([]*model_struct.LocalConversation, error)

+ func (c *Conversation) GetOneConversation(ctx context.Context, sessionType int32, sourceID string) (*model_struct.LocalConversation, error)

+ func (c *Conversation) GetTotalUnreadMsgCount(ctx context.Context) (totalUnreadCount int32, err error)

+ func (c *Conversation) HideConversation(ctx context.Context, conversationID string) error

+ func (c *Conversation) InsertGroupMessageToLocalStorage(ctx context.Context, s *sdk_struct.MsgStruct, groupID, sendID string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) InsertSingleMessageToLocalStorage(ctx context.Context, s *sdk_struct.MsgStruct, recvID, sendID string) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) LoginTime() int64

+ func (c *Conversation) MarkConversationMessageAsRead(ctx context.Context, conversationID string) error

+ func (c *Conversation) MarkMessagesAsReadByMsgID(ctx context.Context, conversationID string, clientMsgIDs []string) error

+ func (c *Conversation) MsgListener() open_im_sdk_callback.OnAdvancedMsgListener

+ func (c *Conversation) PinConversation(ctx context.Context, conversationID string, isPinned bool) error

+ func (c *Conversation) PullMessageBySeqs(ctx context.Context, seqs []*sdkws.SeqRange) (*sdkws.PullMessageBySeqsResp, error)

+ func (c *Conversation) ResetConversationGroupAtType(ctx context.Context, conversationID string) error

+ func (c *Conversation) RevokeMessage(ctx context.Context, conversationID, clientMsgID string) error

+ func (c *Conversation) SearchLocalMessages(ctx context.Context, ...) (*sdk_params_callback.SearchLocalMessagesCallback, error)

+ func (c *Conversation) SendMessage(ctx context.Context, s *sdk_struct.MsgStruct, recvID, groupID string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) SendMessageByBuffer(ctx context.Context, s *sdk_struct.MsgStruct, recvID, groupID string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) SendMessageNotOss(ctx context.Context, s *sdk_struct.MsgStruct, recvID, groupID string, ...) (*sdk_struct.MsgStruct, error)

+ func (c *Conversation) SetBatchMsgListener(batchMsgListener open_im_sdk_callback.OnBatchMsgListener)

+ func (c *Conversation) SetConversationDraft(ctx context.Context, conversationID, draftText string) error

+ func (c *Conversation) SetConversationIsMsgDestruct(ctx context.Context, conversationID string, isMsgDestruct bool) error

+ func (c *Conversation) SetConversationListener(listener open_im_sdk_callback.OnConversationListener)

+ func (c *Conversation) SetConversationMsgDestructTime(ctx context.Context, conversationID string, msgDestructTime int64) error

+ func (c *Conversation) SetGlobalRecvMessageOpt(ctx context.Context, opt int) error

+ func (c *Conversation) SetListenerForService(listener open_im_sdk_callback.OnListenerForService)

+ func (c *Conversation) SetLoginTime()

+ func (c *Conversation) SetMessageLocalEx(ctx context.Context, conversationID string, clientMsgID string, localEx string) error

+ func (c *Conversation) SetMessageReactionExtensions(ctx context.Context, s *sdk_struct.MsgStruct, ...) ([]*server_api_params.ExtensionResult, error)

+ func (c *Conversation) SetMsgKvListener(msgKvListener open_im_sdk_callback.OnMessageKvInfoListener)

+ func (c *Conversation) SetMsgListener(msgListener open_im_sdk_callback.OnAdvancedMsgListener)

+ func (c *Conversation) SetOneConversationBurnDuration(ctx context.Context, conversationID string, burnDuration int32) error

+ func (c *Conversation) SetOneConversationPrivateChat(ctx context.Context, conversationID string, isPrivate bool) error

+ func (c *Conversation) SetOneConversationRecvMessageOpt(ctx context.Context, conversationID string, opt int) error

+ func (c *Conversation) SyncAllConversationHashReadSeqs(ctx context.Context) error

+ func (c *Conversation) SyncAllConversations(ctx context.Context) error

+ func (c *Conversation) SyncConversationUnreadCount(ctx context.Context) error

+ func (c *Conversation) SyncConversations(ctx context.Context, conversationIDs []string) error

+ func (c *Conversation) SyncConversationsAndTriggerCallback(ctx context.Context, conversationsOnServer []*model_struct.LocalConversation) error

+ func (c *Conversation) TypingStatusUpdate(ctx context.Context, recvID, msgTip string) error

+ func (c *Conversation) Work(c2v common.Cmd2Value)

+ type MaxSeqRecorder struct

+ func NewMaxSeqRecorder() MaxSeqRecorder

+ func (m *MaxSeqRecorder) Get(conversationID string) int64

+ func (m *MaxSeqRecorder) Incr(conversationID string, num int64)

+ func (m *MaxSeqRecorder) IsNewMsg(conversationID string, seq int64) bool

+ func (m *MaxSeqRecorder) Set(conversationID string, seq int64)

+ type MessageController struct

+ func NewMessageController(db db_interface.DataBase) *MessageController

+ func (m *MessageController) BatchInsertMessageList(ctx context.Context, insertMsg map[string][]*model_struct.LocalChatLog) error

+ func (m *MessageController) BatchUpdateMessageList(ctx context.Context, updateMsg map[string][]*model_struct.LocalChatLog) error

+ func (m *MessageController) SearchMessageByContentTypeAndKeyword(ctx context.Context, contentType []int, keywordList []string, ...) (result []*model_struct.LocalChatLog, err error)