From 3d121bad32a4baf31cf38480e5f867eba12d7b09 Mon Sep 17 00:00:00 2001 From: Mikhail Date: Fri, 14 Apr 2023 17:38:55 +0000 Subject: [PATCH] Update service/service.go --- service/service.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/service/service.go b/service/service.go index 05f210a..b04407c 100644 --- a/service/service.go +++ b/service/service.go @@ -445,7 +445,7 @@ func (h *Heruvym) Subscribe(ctx context.Context) chan interface{} { output <- errors.New("no tickets 4 user") } - if err := h.dal.YieldMessages(ctx, ticketID, func(message model.Message) error { + /*if err := h.dal.YieldMessages(ctx, ticketID, func(message model.Message) error { output <- message //if err := h.dal.SetShown(ctx, message.ID, sess.User); err != nil { @@ -458,7 +458,7 @@ func (h *Heruvym) Subscribe(ctx context.Context) chan interface{} { }); err != nil { fmt.Println("1", err) output <- errors.New("cannot read messages " + err.Error()) - } + }*/ if err := h.dal.WatchMessages(ctx, ticketID, func(message model.Message) error {