diff --git a/internal/rpc/msg/server.go b/internal/rpc/msg/server.go index 0aecb0943..c7426654e 100644 --- a/internal/rpc/msg/server.go +++ b/internal/rpc/msg/server.go @@ -134,17 +134,11 @@ func (m *msgServer) GetMaxSeq(ctx context.Context, req *sdkws.GetMaxSeqReq) (*sd } maxSeqs, err := m.MsgDatabase.GetMaxSeqs(ctx, conversationIDs) if err != nil { - log.ZWarn(ctx, "GetMaxSeqs error", err, "conversationIDs", conversationIDs) - return nil, err - } - minSeqs, err := m.MsgDatabase.GetMinSeqs(ctx, conversationIDs) - if err != nil { - log.ZWarn(ctx, "GetMinSeqs error", err, "conversationIDs", conversationIDs) + log.ZWarn(ctx, "GetMaxSeqs error", err, "conversationIDs", conversationIDs, "maxSeqs", maxSeqs) return nil, err } resp := new(sdkws.GetMaxSeqResp) resp.MaxSeqs = maxSeqs - resp.MinSeqs = minSeqs return resp, nil } diff --git a/pkg/common/db/cache/msg.go b/pkg/common/db/cache/msg.go index 4b12413ba..fb2850dff 100644 --- a/pkg/common/db/cache/msg.go +++ b/pkg/common/db/cache/msg.go @@ -147,7 +147,7 @@ func (c *msgCache) getSeqs(ctx context.Context, items []string, getkey func(s st pipe := c.rdb.Pipeline() for _, v := range items { if err := pipe.Get(ctx, getkey(v)).Err(); err != nil && err != redis.Nil { - return nil, err + return nil, errs.Wrap(err) } } result, err := pipe.Exec(ctx)