summaryrefslogtreecommitdiffstats
path: root/app/status.go
diff options
context:
space:
mode:
authorJesús Espino <jespinog@gmail.com>2018-07-11 15:56:35 +0200
committerSaturnino Abril <saturnino.abril@gmail.com>2018-07-11 21:56:35 +0800
commit5b63e87ab7aae4d27b492ff25b6786924d4c6dcc (patch)
treea765a04661ead03d4de6aa9ba6d34a4a7e85c3ff /app/status.go
parent6c7dc2d29ccac5f9925402f6be1a4c2a3c46c005 (diff)
downloadchat-5b63e87ab7aae4d27b492ff25b6786924d4c6dcc.tar.gz
chat-5b63e87ab7aae4d27b492ff25b6786924d4c6dcc.tar.bz2
chat-5b63e87ab7aae4d27b492ff25b6786924d4c6dcc.zip
Deduplicating some code in app/status.go (#9095)
Diffstat (limited to 'app/status.go')
-rw-r--r--app/status.go20
1 files changed, 3 insertions, 17 deletions
diff --git a/app/status.go b/app/status.go
index 460cbbbd0..16c43160d 100644
--- a/app/status.go
+++ b/app/status.go
@@ -305,19 +305,14 @@ func (a *App) SetStatusDoNotDisturb(userId string) {
a.SaveAndBroadcastStatus(status)
}
-func (a *App) SaveAndBroadcastStatus(status *model.Status) *model.AppError {
+func (a *App) SaveAndBroadcastStatus(status *model.Status) {
a.AddStatusCache(status)
if result := <-a.Srv.Store.Status().SaveOrUpdate(status); result.Err != nil {
mlog.Error(fmt.Sprintf("Failed to save status for user_id=%v, err=%v", status.UserId, result.Err))
}
- event := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_STATUS_CHANGE, "", "", status.UserId, nil)
- event.Add("status", status.Status)
- event.Add("user_id", status.UserId)
- a.Publish(event)
-
- return nil
+ a.BroadcastStatus(status)
}
func (a *App) SetStatusOutOfOffice(userId string) {
@@ -334,16 +329,7 @@ func (a *App) SetStatusOutOfOffice(userId string) {
status.Status = model.STATUS_OUT_OF_OFFICE
status.Manual = true
- a.AddStatusCache(status)
-
- if result := <-a.Srv.Store.Status().SaveOrUpdate(status); result.Err != nil {
- mlog.Error(fmt.Sprintf("Failed to save status for user_id=%v, err=%v", userId, result.Err), mlog.String("user_id", userId))
- }
-
- event := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_STATUS_CHANGE, "", "", status.UserId, nil)
- event.Add("status", model.STATUS_OUT_OF_OFFICE)
- event.Add("user_id", status.UserId)
- a.Publish(event)
+ a.SaveAndBroadcastStatus(status)
}
func GetStatusFromCache(userId string) *model.Status {