From eb7561e05bb797a0f925ac69079040016926eef5 Mon Sep 17 00:00:00 2001 From: Corey Hulen Date: Thu, 29 Jun 2017 07:51:15 -0700 Subject: PLT-6610 sending websocket event for last channel viewed (#6787) --- app/channel.go | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) (limited to 'app/channel.go') diff --git a/app/channel.go b/app/channel.go index c9f89eb1a..5dafa1f76 100644 --- a/app/channel.go +++ b/app/channel.go @@ -266,7 +266,7 @@ func createGroupChannel(userIds []string, creatorId string) (*model.Channel, *mo } if len(users) != len(userIds) { - return nil, model.NewAppError("CreateGroupChannel", "api.channel.create_group.bad_user.app_error", nil, "user_ids=" + model.ArrayToJson(userIds), http.StatusBadRequest) + return nil, model.NewAppError("CreateGroupChannel", "api.channel.create_group.bad_user.app_error", nil, "user_ids="+model.ArrayToJson(userIds), http.StatusBadRequest) } group := &model.Channel{ @@ -1091,6 +1091,14 @@ func UpdateChannelLastViewedAt(channelIds []string, userId string) *model.AppErr return result.Err } + if *utils.Cfg.ServiceSettings.EnablChannelViewedMessages { + for _, channelId := range channelIds { + message := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_CHANNEL_VIEWED, "", "", userId, nil) + message.Add("channel_id", channelId) + go Publish(message) + } + } + return nil } @@ -1150,6 +1158,12 @@ func ViewChannel(view *model.ChannelView, userId string, clearPushNotifications return result.Err } + if *utils.Cfg.ServiceSettings.EnablChannelViewedMessages { + message := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_CHANNEL_VIEWED, "", "", userId, nil) + message.Add("channel_id", view.ChannelId) + go Publish(message) + } + return nil } -- cgit v1.2.3-1-g7c22