diff --git a/internal/common/check/conversation.go b/internal/common/check/conversation.go index ca3bf21e9..c391d2626 100644 --- a/internal/common/check/conversation.go +++ b/internal/common/check/conversation.go @@ -31,5 +31,16 @@ func (c *ConversationChecker) getConn() (*grpc.ClientConn, error) { } func (c *ConversationChecker) GetSingleConversationRecvMsgOpt(ctx context.Context, userID, conversationID string) (int32, error) { - panic("implement me") + cc, err := c.getConn() + if err != nil { + return 0, err + } + var req conversation.GetConversationReq + req.OwnerUserID = userID + req.ConversationID = conversationID + sConversation, err := conversation.NewConversationClient(cc).GetConversation(ctx, &req) + if err != nil { + return 0, err + } + return sConversation.GetConversation().RecvMsgOpt, err } diff --git a/pkg/common/log/zap.go b/pkg/common/log/zap.go index dc8a0ed95..4a5c2efa2 100644 --- a/pkg/common/log/zap.go +++ b/pkg/common/log/zap.go @@ -77,6 +77,7 @@ func (l *ZapLogger) cores() (zap.Option, error) { c := zap.NewProductionEncoderConfig() c.EncodeTime = zapcore.ISO8601TimeEncoder c.EncodeDuration = zapcore.SecondsDurationEncoder + c.EncodeLevel = zapcore.CapitalLevelEncoder c.MessageKey = "msg" c.LevelKey = "level" c.TimeKey = "time"