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

Update service/service.go

Browse Source
This commit is contained in:
Mikhail 2023-04-14 17:38:55 +00:00
parent e113f239a6
commit 3d121bad32
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
service/service.go
View File

@ -445,7 +445,7 @@ func (h *Heruvym) Subscribe(ctx context.Context) chan interface{} {
output <- errors.New("no tickets 4 user") 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 output <- message
//if err := h.dal.SetShown(ctx, message.ID, sess.User); err != nil { //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 { }); err != nil {
fmt.Println("1", err) fmt.Println("1", err)
output <- errors.New("cannot read messages " + err.Error()) output <- errors.New("cannot read messages " + err.Error())
} }*/
if err := h.dal.WatchMessages(ctx, ticketID, if err := h.dal.WatchMessages(ctx, ticketID,
func(message model.Message) error { func(message model.Message) error {