PenaSide/heruvym
3
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

fix ssh message encoding
All checks were successful
Deploy / CreateImage (push) Successful in 1m26s
Details
Deploy / DeployService (push) Successful in 37s
Details

Browse Source
This commit is contained in:
skeris 2025-03-26 22:25:23 +03:00
parent 464c571cfa
commit c41fedd5af
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
internal/controllers/tickets/tickets.go
View File

@ -13,6 +13,7 @@ import (
"github.com/gofiber/fiber/v2" "github.com/gofiber/fiber/v2"
"go.uber.org/zap" "go.uber.org/zap"
"gopkg.in/telebot.v3" "gopkg.in/telebot.v3"
"encoding/json"
) )
type Deps struct { type Deps struct {
@ -555,7 +556,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} {
if err := t.dal.WatchMessages(ctx, ticketID, if err := t.dal.WatchMessages(ctx, ticketID,
func(message model.Message) error { func(message model.Message) error {
if !message.System { if !message.System {
output <- message msg,_:=json.Marshal(message)
output <- msg
} }
//if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil { //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() { go func() {
if err := t.dal.YieldMessages(ctx, ticketID, func(message model.Message) error { 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 { //if err := h.dal.SetShown(ctx, message.ID, sess.User); err != nil {
// fmt.Println("2", err) // fmt.Println("2", err)
@ -593,7 +596,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} {
if err := t.dal.WatchMessages(ctx, ticketID, if err := t.dal.WatchMessages(ctx, ticketID,
func(message model.Message) error { 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 { //if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil {
// fmt.Println("3", err) // fmt.Println("3", err)
@ -637,7 +641,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} {
if err := t.dal.WatchMessages(ctx, ticketID, if err := t.dal.WatchMessages(ctx, ticketID,
func(message model.Message) error { func(message model.Message) error {
if !message.System { if !message.System {
output <- message msg,_:=json.Marshal(message)
output <- msg
} }
//if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil { //if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil {