diff options
author | George Goldberg <george@gberg.me> | 2017-09-20 14:34:50 +0100 |
---|---|---|
committer | Joram Wilander <jwawilander@gmail.com> | 2017-09-20 09:34:50 -0400 |
commit | c3916bb5305b11068ff8a9a754e39f12e33ebcc0 (patch) | |
tree | 0f405e45798ca752b1700ca16d645c5e5da25a5b /store/sql_status_store.go | |
parent | 2d322a41749849e62eeeb2d0de61b1e94b83b46d (diff) | |
download | chat-c3916bb5305b11068ff8a9a754e39f12e33ebcc0.tar.gz chat-c3916bb5305b11068ff8a9a754e39f12e33ebcc0.tar.bz2 chat-c3916bb5305b11068ff8a9a754e39f12e33ebcc0.zip |
Add error codes to the remaining stores (Part 1). (#7461)
Diffstat (limited to 'store/sql_status_store.go')
-rw-r--r-- | store/sql_status_store.go | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/store/sql_status_store.go b/store/sql_status_store.go index 44c9c76ea..741557a7b 100644 --- a/store/sql_status_store.go +++ b/store/sql_status_store.go @@ -5,6 +5,7 @@ package store import ( "database/sql" + "net/http" "strconv" "strings" @@ -45,12 +46,12 @@ func (s SqlStatusStore) SaveOrUpdate(status *model.Status) StoreChannel { if err := s.GetReplica().SelectOne(&model.Status{}, "SELECT * FROM Status WHERE UserId = :UserId", map[string]interface{}{"UserId": status.UserId}); err == nil { if _, err := s.GetMaster().Update(status); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.SaveOrUpdate", "store.sql_status.update.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.SaveOrUpdate", "store.sql_status.update.app_error", nil, err.Error(), http.StatusInternalServerError) } } else { if err := s.GetMaster().Insert(status); err != nil { if !(strings.Contains(err.Error(), "for key 'PRIMARY'") && strings.Contains(err.Error(), "Duplicate entry")) { - result.Err = model.NewLocAppError("SqlStatusStore.SaveOrUpdate", "store.sql_status.save.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.SaveOrUpdate", "store.sql_status.save.app_error", nil, err.Error(), http.StatusInternalServerError) } } } @@ -78,9 +79,9 @@ func (s SqlStatusStore) Get(userId string) StoreChannel { WHERE UserId = :UserId`, map[string]interface{}{"UserId": userId}); err != nil { if err == sql.ErrNoRows { - result.Err = model.NewLocAppError("SqlStatusStore.Get", MISSING_STATUS_ERROR, nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.Get", MISSING_STATUS_ERROR, nil, err.Error(), http.StatusNotFound) } else { - result.Err = model.NewLocAppError("SqlStatusStore.Get", "store.sql_status.get.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.Get", "store.sql_status.get.app_error", nil, err.Error(), http.StatusInternalServerError) } } else { result.Data = &status @@ -113,7 +114,7 @@ func (s SqlStatusStore) GetByIds(userIds []string) StoreChannel { var statuses []*model.Status if _, err := s.GetReplica().Select(&statuses, "SELECT * FROM Status WHERE UserId IN ("+idQuery+")", props); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.GetByIds", "store.sql_status.get.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.GetByIds", "store.sql_status.get.app_error", nil, err.Error(), http.StatusInternalServerError) } else { result.Data = statuses } @@ -133,7 +134,7 @@ func (s SqlStatusStore) GetOnlineAway() StoreChannel { var statuses []*model.Status if _, err := s.GetReplica().Select(&statuses, "SELECT * FROM Status WHERE Status = :Online OR Status = :Away LIMIT 300", map[string]interface{}{"Online": model.STATUS_ONLINE, "Away": model.STATUS_AWAY}); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.GetOnlineAway", "store.sql_status.get_online_away.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.GetOnlineAway", "store.sql_status.get_online_away.app_error", nil, err.Error(), http.StatusInternalServerError) } else { result.Data = statuses } @@ -153,7 +154,7 @@ func (s SqlStatusStore) GetOnline() StoreChannel { var statuses []*model.Status if _, err := s.GetReplica().Select(&statuses, "SELECT * FROM Status WHERE Status = :Online", map[string]interface{}{"Online": model.STATUS_ONLINE}); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.GetOnline", "store.sql_status.get_online.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.GetOnline", "store.sql_status.get_online.app_error", nil, err.Error(), http.StatusInternalServerError) } else { result.Data = statuses } @@ -175,7 +176,7 @@ func (s SqlStatusStore) GetAllFromTeam(teamId string) StoreChannel { if _, err := s.GetReplica().Select(&statuses, `SELECT s.* FROM Status AS s INNER JOIN TeamMembers AS tm ON tm.TeamId=:TeamId AND s.UserId=tm.UserId`, map[string]interface{}{"TeamId": teamId}); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.GetAllFromTeam", "store.sql_status.get_team_statuses.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.GetAllFromTeam", "store.sql_status.get_team_statuses.app_error", nil, err.Error(), http.StatusInternalServerError) } else { result.Data = statuses } @@ -194,7 +195,7 @@ func (s SqlStatusStore) ResetAll() StoreChannel { result := StoreResult{} if _, err := s.GetMaster().Exec("UPDATE Status SET Status = :Status WHERE Manual = false", map[string]interface{}{"Status": model.STATUS_OFFLINE}); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.ResetAll", "store.sql_status.reset_all.app_error", nil, "") + result.Err = model.NewAppError("SqlStatusStore.ResetAll", "store.sql_status.reset_all.app_error", nil, "", http.StatusInternalServerError) } storeChannel <- result @@ -213,7 +214,7 @@ func (s SqlStatusStore) GetTotalActiveUsersCount() StoreChannel { time := model.GetMillis() - (1000 * 60 * 60 * 24) if count, err := s.GetReplica().SelectInt("SELECT COUNT(UserId) FROM Status WHERE LastActivityAt > :Time", map[string]interface{}{"Time": time}); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.GetTotalActiveUsersCount", "store.sql_status.get_total_active_users_count.app_error", nil, err.Error()) + result.Err = model.NewAppError("SqlStatusStore.GetTotalActiveUsersCount", "store.sql_status.get_total_active_users_count.app_error", nil, err.Error(), http.StatusInternalServerError) } else { result.Data = count } @@ -232,7 +233,7 @@ func (s SqlStatusStore) UpdateLastActivityAt(userId string, lastActivityAt int64 result := StoreResult{} if _, err := s.GetMaster().Exec("UPDATE Status SET LastActivityAt = :Time WHERE UserId = :UserId", map[string]interface{}{"UserId": userId, "Time": lastActivityAt}); err != nil { - result.Err = model.NewLocAppError("SqlStatusStore.UpdateLastActivityAt", "store.sql_status.update_last_activity_at.app_error", nil, "") + result.Err = model.NewAppError("SqlStatusStore.UpdateLastActivityAt", "store.sql_status.update_last_activity_at.app_error", nil, "", http.StatusInternalServerError) } storeChannel <- result |