From c41fedd5af81f4776be6cfdcb0ad1f3b77fc5c6a Mon Sep 17 00:00:00 2001 From: skeris Date: Wed, 26 Mar 2025 22:25:23 +0300 Subject: [PATCH] fix ssh message encoding --- internal/controllers/tickets/tickets.go | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/internal/controllers/tickets/tickets.go b/internal/controllers/tickets/tickets.go index 78edfd5..57d35fb 100644 --- a/internal/controllers/tickets/tickets.go +++ b/internal/controllers/tickets/tickets.go @@ -13,6 +13,7 @@ import ( "github.com/gofiber/fiber/v2" "go.uber.org/zap" "gopkg.in/telebot.v3" + "encoding/json" ) type Deps struct { @@ -555,7 +556,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} { if err := t.dal.WatchMessages(ctx, ticketID, func(message model.Message) error { if !message.System { - output <- message + msg,_:=json.Marshal(message) + output <- msg } //if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil { @@ -577,7 +579,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} { go func() { if err := t.dal.YieldMessages(ctx, ticketID, func(message model.Message) error { - output <- message + msg,_:=json.Marshal(message) + output <- msg //if err := h.dal.SetShown(ctx, message.ID, sess.User); err != nil { // fmt.Println("2", err) @@ -593,7 +596,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} { if err := t.dal.WatchMessages(ctx, ticketID, func(message model.Message) error { - output <- message + msg,_:=json.Marshal(message) + output <- msg //if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil { // fmt.Println("3", err) @@ -637,7 +641,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} { if err := t.dal.WatchMessages(ctx, ticketID, func(message model.Message) error { if !message.System { - output <- message + msg,_:=json.Marshal(message) + output <- msg } //if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil {