feat: add retry in msg_sync. (#1044)

Author: mo3et

internal/interaction/msg_sync.go

@@ -412,13 +412,34 @@ func (m *MsgSyncer) doConnected(ctx context.Context) {
 		common.DispatchSyncFlag(ctx, constant.MsgSyncBegin, m.conversationEventQueue)
 	}
 	var resp sdkws.GetMaxSeqResp
-	if err := m.longConnMgr.SendReqWaitResp(ctx, &sdkws.GetMaxSeqReq{UserID: m.loginUserID}, constant.GetNewestSeq, &resp); err != nil {
+	maxRetries := 3                  // max number of retries
+	retryInterval := 2 * time.Second // wait time between retries
+
+	var err error
+	for retry := range maxRetries {
+		if retry > 0 {
+			log.ZWarn(ctx, "retrying to get max seq", nil, "attempt", retry+1, "max", maxRetries)
+
+			// Exponential Backoff Strategy
+			time.Sleep(retryInterval)
+			retryInterval *= 2
+		}
+
+		err = m.longConnMgr.SendReqWaitResp(ctx, &sdkws.GetMaxSeqReq{UserID: m.loginUserID}, constant.GetNewestSeq, &resp)
+		if err == nil {
+			log.ZDebug(ctx, "get max seq success", "resp", resp.MaxSeqs)
+			break
+		}
+
+		log.ZWarn(ctx, "get max seq attempt failed", err, "attempt", retry+1, "max", maxRetries)
+	}
+
+	if err != nil {
 		log.ZError(ctx, "get max seq error", err)
 		common.DispatchSyncFlag(ctx, constant.MsgSyncFailed, m.conversationEventQueue)
 		return
-	} else {
-		log.ZDebug(ctx, "get max seq success", "resp", resp.MaxSeqs)
 	}
+
 	m.compareSeqsAndBatchSync(ctx, resp.MaxSeqs, connectPullNums)
 	if reinstalled {
 		common.DispatchSyncFlag(ctx, constant.AppDataSyncFinish, m.conversationEventQueue)
@@ -665,7 +686,7 @@ func (m *MsgSyncer) syncMsgBySeqs(ctx context.Context, conversationID string, se
 		var pullMsgResp sdkws.PullMessageBySeqsResp
 		err := m.longConnMgr.SendReqWaitResp(ctx, &pullMsgReq, constant.PullMsgByRange, &pullMsgResp)
 		if err != nil {
-			log.ZError(ctx, "syncMsgFromServerSplit err", err, "pullMsgReq", pullMsgReq)
+			log.ZError(ctx, "syncMsgFromServerSplit err", err, "pullMsgReq", &pullMsgReq)
 			continue
 		}
 		i++

internal/third/file/file_test.go

@@ -2,22 +2,23 @@ package file
 
 import (
 	"context"
-	"github.com/openimsdk/openim-sdk-core/v3/pkg/ccontext"
-	"github.com/openimsdk/openim-sdk-core/v3/sdk_struct"
 	"path/filepath"
 	"testing"
+
+	"github.com/openimsdk/openim-sdk-core/v3/pkg/ccontext"
+	"github.com/openimsdk/openim-sdk-core/v3/sdk_struct"
 )
 
 func TestUpload(t *testing.T) {
 	conf := &ccontext.GlobalConfig{
 		UserID: `4931176757`,
 		Token:  `eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJVc2VySUQiOiI0OTMxMTc2NzU3IiwiUGxhdGZvcm1JRCI6MSwiZXhwIjoxNzA3MTE0MjIyLCJuYmYiOjE2OTkzMzc5MjIsImlhdCI6MTY5OTMzODIyMn0.AyNvrMGEdXD5rkvn7ZLHCNs-lNbDCb2otn97yLXia5Y`,
-		IMConfig: sdk_struct.IMConfig{
+		IMConfig: &sdk_struct.IMConfig{
 			ApiAddr: `http://203.56.175.233:10002`,
 		},
 	}
 	ctx := ccontext.WithInfo(context.WithValue(context.Background(), "operationID", "OP123456"), conf)
-	f := NewFile(nil, conf.UserID)
+	f := NewFile()
 
 	//fp := `C:\Users\openIM\Desktop\my_image (2).tar`
 	//fp := `C:\Users\openIM\Desktop\1234.zip`

pkg/common/trigger_channel.go

@@ -104,19 +104,19 @@ type DeleteConNode struct {
 type SyncReactionExtensionsNode struct {
 	OperationID string
 	Action      int
-	Args        interface{}
+	Args        any
 }
 
 type UpdateConNode struct {
 	ConID  string
 	Action int //1 Delete the conversation; 2 Update the latest news in the conversation or add a conversation; 3 Put a conversation on the top;
 	// 4 Cancel a conversation on the top, 5 Messages are not read and set to 0, 6 New conversations
-	Args interface{}
+	Args any
 }
 
 type UpdateMessageNode struct {
 	Action int
-	Args   interface{}
+	Args   any
 }
 
 type UpdateConInfo struct {