Skip to content

Commit b1e6f66

Browse files
committed
fix(group): set max_seq to 0 when join group
1 parent 1a1391c commit b1e6f66

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

go.mod

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ require (
1212
github.com/gorilla/websocket v1.5.1
1313
github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0
1414
github.com/mitchellh/mapstructure v1.5.0
15-
github.com/openimsdk/protocol v0.0.73-alpha.12
15+
github.com/openimsdk/protocol v0.0.73-alpha.18
1616
github.com/openimsdk/tools v0.0.50-alpha.106
1717
github.com/pkg/errors v0.9.1 // indirect
1818
github.com/prometheus/client_golang v1.18.0

go.sum

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -349,6 +349,8 @@ github.com/openimsdk/gomake v0.0.15-alpha.5 h1:eEZCEHm+NsmcO3onXZPIUbGFCYPYbsX5b
349349
github.com/openimsdk/gomake v0.0.15-alpha.5/go.mod h1:PndCozNc2IsQIciyn9mvEblYWZwJmAI+06z94EY+csI=
350350
github.com/openimsdk/protocol v0.0.73-alpha.12 h1:2NYawXeHChYUeSme6QJ9pOLh+Empce2WmwEtbP4JvKk=
351351
github.com/openimsdk/protocol v0.0.73-alpha.12/go.mod h1:WF7EuE55vQvpyUAzDXcqg+B+446xQyEba0X35lTINmw=
352+
github.com/openimsdk/protocol v0.0.73-alpha.18 h1:LXmDFx3KnMd2mN0/S3Q2U33Ft/DHvplSsINO0/bto/c=
353+
github.com/openimsdk/protocol v0.0.73-alpha.18/go.mod h1:WF7EuE55vQvpyUAzDXcqg+B+446xQyEba0X35lTINmw=
352354
github.com/openimsdk/tools v0.0.50-alpha.106 h1:gaqU08IbRxOdL16ZEQNyYLhCTf7K1HNkrik8KZLA+BM=
353355
github.com/openimsdk/tools v0.0.50-alpha.106/go.mod h1:x9i/e+WJFW4tocy6RNJQ9NofQiP3KJ1Y576/06TqOG4=
354356
github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=

internal/rpc/group/group.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ package group
1717
import (
1818
"context"
1919
"fmt"
20-
"math"
2120
"math/big"
2221
"math/rand"
2322
"strconv"
@@ -1025,7 +1024,7 @@ func (s *groupServer) deleteMemberAndSetConversationSeq(ctx context.Context, gro
10251024

10261025
func (s *groupServer) setMemberJoinSeq(ctx context.Context, groupID string, userIDs []string) error {
10271026
conversationID := msgprocessor.GetConversationIDBySessionType(constant.ReadGroupChatType, groupID)
1028-
return s.conversationClient.SetConversationMaxSeq(ctx, conversationID, userIDs, math.MaxInt64)
1027+
return s.conversationClient.SetConversationMaxSeq(ctx, conversationID, userIDs, 0)
10291028
}
10301029

10311030
func (s *groupServer) SetGroupInfo(ctx context.Context, req *pbgroup.SetGroupInfoReq) (*pbgroup.SetGroupInfoResp, error) {

0 commit comments

Comments
 (0)