0

Добавлена поддержка поля threadid в json message protocol

This commit is contained in:
eleksir
2022-11-06 17:50:55 +03:00
parent c4fa8c07df
commit 6fe13e8605
2 changed files with 19 additions and 14 deletions

View File

@@ -42,6 +42,8 @@ func msgParser(ctx context.Context, msg string) {
return
}
// j.Threadid может быит пустымб значит либо нам его не дали, либо дали пустым. Это нормально.
if exist := j.Message; exist == "" {
log.Warnf("Incorrect msg from redis, no message field: %s", msg)
return
@@ -193,6 +195,7 @@ func msgParser(ctx context.Context, msg string) {
message.From = j.From
message.Userid = j.Userid
message.Chatid = j.Chatid
message.Threadid = j.Threadid
message.Message = j.Message
message.Plugin = j.Plugin
message.Mode = j.Mode