[MM-16165] Migrate Team.GetAllPage to Sync by default (#11201)

* [MM-16165] Migrate Team.GetAllPage to Sync by default

* [MM-16165] Pull Request suggested changes: remove else
Этот коммит содержится в:
Micah Thompson
2019-06-17 13:45:52 -04:00
коммит произвёл Christopher Poile
родитель e15a75a2ec
Коммит 6bb147c380
4 изменённых файлов: 39 добавлений и 25 удалений

Просмотреть файл

@@ -611,11 +611,7 @@ func (a *App) GetAllTeams() ([]*model.Team, *model.AppError) {
} }
func (a *App) GetAllTeamsPage(offset int, limit int) ([]*model.Team, *model.AppError) { func (a *App) GetAllTeamsPage(offset int, limit int) ([]*model.Team, *model.AppError) {
result := <-a.Srv.Store.Team().GetAllPage(offset, limit) return a.Srv.Store.Team().GetAllPage(offset, limit)
if result.Err != nil {
return nil, result.Err
}
return result.Data.([]*model.Team), nil
} }
func (a *App) GetAllPrivateTeams() ([]*model.Team, *model.AppError) { func (a *App) GetAllPrivateTeams() ([]*model.Team, *model.AppError) {

Просмотреть файл

@@ -339,11 +339,11 @@ func (s SqlTeamStore) SearchPrivate(term string) ([]*model.Team, *model.AppError
var teams []*model.Team var teams []*model.Team
query := query :=
`SELECT * `SELECT *
FROM FROM
Teams Teams
WHERE WHERE
(Type != 'O' OR AllowOpenInvite = false) AND (Type != 'O' OR AllowOpenInvite = false) AND
(Name LIKE :Term OR DisplayName LIKE :Term)` (Name LIKE :Term OR DisplayName LIKE :Term)`
if _, err := s.GetReplica().Select(&teams, query, map[string]interface{}{"Term": term + "%"}); err != nil { if _, err := s.GetReplica().Select(&teams, query, map[string]interface{}{"Term": term + "%"}); err != nil {
return nil, model.NewAppError("SqlTeamStore.SearchPrivate", "store.sql_team.search_private_team.app_error", nil, "term="+term+", "+err.Error(), http.StatusInternalServerError) return nil, model.NewAppError("SqlTeamStore.SearchPrivate", "store.sql_team.search_private_team.app_error", nil, "term="+term+", "+err.Error(), http.StatusInternalServerError)
@@ -361,16 +361,25 @@ func (s SqlTeamStore) GetAll() ([]*model.Team, *model.AppError) {
return teams, nil return teams, nil
} }
func (s SqlTeamStore) GetAllPage(offset int, limit int) store.StoreChannel { func (s SqlTeamStore) GetAllPage(offset int, limit int) ([]*model.Team, *model.AppError) {
return store.Do(func(result *store.StoreResult) { var teams []*model.Team
var data []*model.Team
if _, err := s.GetReplica().Select(&data, "SELECT * FROM Teams ORDER BY DisplayName LIMIT :Limit OFFSET :Offset", map[string]interface{}{"Offset": offset, "Limit": limit}); err != nil {
result.Err = model.NewAppError("SqlTeamStore.GetAllTeams", "store.sql_team.get_all.app_error", nil, err.Error(), http.StatusInternalServerError)
return
}
result.Data = data if _, err := s.GetReplica().Select(&teams,
}) `SELECT
*
FROM
Teams
ORDER BY
DisplayName
LIMIT
:Limit
OFFSET
:Offset`, map[string]interface{}{"Offset": offset, "Limit": limit}); err != nil {
return nil, model.NewAppError("SqlTeamStore.GetAllTeams",
"store.sql_team.get_all.app_error", nil, err.Error(), http.StatusInternalServerError)
}
return teams, nil
} }
func (s SqlTeamStore) GetTeamsByUserId(userId string) store.StoreChannel { func (s SqlTeamStore) GetTeamsByUserId(userId string) store.StoreChannel {

Просмотреть файл

@@ -91,7 +91,7 @@ type TeamStore interface {
SearchOpen(term string) StoreChannel SearchOpen(term string) StoreChannel
SearchPrivate(term string) ([]*model.Team, *model.AppError) SearchPrivate(term string) ([]*model.Team, *model.AppError)
GetAll() ([]*model.Team, *model.AppError) GetAll() ([]*model.Team, *model.AppError)
GetAllPage(offset int, limit int) StoreChannel GetAllPage(offset int, limit int) ([]*model.Team, *model.AppError)
GetAllPrivateTeamListing() StoreChannel GetAllPrivateTeamListing() StoreChannel
GetAllPrivateTeamPageListing(offset int, limit int) ([]*model.Team, *model.AppError) GetAllPrivateTeamPageListing(offset int, limit int) ([]*model.Team, *model.AppError)
GetAllTeamListing() StoreChannel GetAllTeamListing() StoreChannel

Просмотреть файл

@@ -163,19 +163,28 @@ func (_m *TeamStore) GetAllForExportAfter(limit int, afterId string) store.Store
} }
// GetAllPage provides a mock function with given fields: offset, limit // GetAllPage provides a mock function with given fields: offset, limit
func (_m *TeamStore) GetAllPage(offset int, limit int) store.StoreChannel { func (_m *TeamStore) GetAllPage(offset int, limit int) ([]*model.Team, *model.AppError) {
ret := _m.Called(offset, limit) ret := _m.Called(offset, limit)
var r0 store.StoreChannel var r0 []*model.Team
if rf, ok := ret.Get(0).(func(int, int) store.StoreChannel); ok { if rf, ok := ret.Get(0).(func(int, int) []*model.Team); ok {
r0 = rf(offset, limit) r0 = rf(offset, limit)
} else { } else {
if ret.Get(0) != nil { if ret.Get(0) != nil {
r0 = ret.Get(0).(store.StoreChannel) r0 = ret.Get(0).([]*model.Team)
} }
} }
return r0 var r1 *model.AppError
if rf, ok := ret.Get(1).(func(int, int) *model.AppError); ok {
r1 = rf(offset, limit)
} else {
if ret.Get(1) != nil {
r1 = ret.Get(1).(*model.AppError)
}
}
return r0, r1
} }
// GetAllPrivateTeamListing provides a mock function with given fields: // GetAllPrivateTeamListing provides a mock function with given fields: