Remove model.AppError from searchlayer/channel_layer.go (#16428)

Automatic Merge
Этот коммит содержится в:
Mohammed Salman
2020-12-07 12:45:17 +03:00
коммит произвёл GitHub
родитель f27c55a884
Коммит 6e92b76932

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

@@ -4,12 +4,11 @@
package searchlayer package searchlayer
import ( import (
"net/http"
"github.com/mattermost/mattermost-server/v5/mlog" "github.com/mattermost/mattermost-server/v5/mlog"
"github.com/mattermost/mattermost-server/v5/model" "github.com/mattermost/mattermost-server/v5/model"
"github.com/mattermost/mattermost-server/v5/services/searchengine" "github.com/mattermost/mattermost-server/v5/services/searchengine"
"github.com/mattermost/mattermost-server/v5/store" "github.com/mattermost/mattermost-server/v5/store"
"github.com/pkg/errors"
) )
type SearchChannelStore struct { type SearchChannelStore struct {
@@ -130,15 +129,14 @@ func (c *SearchChannelStore) SaveDirectChannel(directchannel *model.Channel, mem
func (c *SearchChannelStore) AutocompleteInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, error) { func (c *SearchChannelStore) AutocompleteInTeam(teamId string, term string, includeDeleted bool) (*model.ChannelList, error) {
var channelList *model.ChannelList var channelList *model.ChannelList
var appErr *model.AppError var err error
var nErr error
allFailed := true allFailed := true
for _, engine := range c.rootStore.searchEngine.GetActiveEngines() { for _, engine := range c.rootStore.searchEngine.GetActiveEngines() {
if engine.IsAutocompletionEnabled() { if engine.IsAutocompletionEnabled() {
channelList, appErr = c.searchAutocompleteChannels(engine, teamId, term, includeDeleted) channelList, err = c.searchAutocompleteChannels(engine, teamId, term, includeDeleted)
if appErr != nil { if err != nil {
mlog.Error("Encountered error on AutocompleteChannels through SearchEngine. Falling back to default autocompletion.", mlog.String("search_engine", engine.GetName()), mlog.Err(appErr)) mlog.Error("Encountered error on AutocompleteChannels through SearchEngine. Falling back to default autocompletion.", mlog.String("search_engine", engine.GetName()), mlog.Err(err))
continue continue
} }
allFailed = false allFailed = false
@@ -149,20 +147,20 @@ func (c *SearchChannelStore) AutocompleteInTeam(teamId string, term string, incl
if allFailed { if allFailed {
mlog.Debug("Using database search because no other search engine is available") mlog.Debug("Using database search because no other search engine is available")
channelList, nErr = c.ChannelStore.AutocompleteInTeam(teamId, term, includeDeleted) channelList, err = c.ChannelStore.AutocompleteInTeam(teamId, term, includeDeleted)
if nErr != nil { if err != nil {
return nil, model.NewAppError("AutocompleteInTeam", "app.channel.search.app_error", nil, nErr.Error(), http.StatusInternalServerError) return nil, errors.Wrap(err, "Failed to autocomplete channels in team")
} }
} }
if appErr != nil { if err != nil {
return channelList, appErr return channelList, err
} }
return channelList, nil return channelList, nil
} }
func (c *SearchChannelStore) searchAutocompleteChannels(engine searchengine.SearchEngineInterface, teamId, term string, includeDeleted bool) (*model.ChannelList, *model.AppError) { func (c *SearchChannelStore) searchAutocompleteChannels(engine searchengine.SearchEngineInterface, teamId, term string, includeDeleted bool) (*model.ChannelList, error) {
channelIds, err := engine.SearchChannels(teamId, term) channelIds, err := engine.SearchChannels(teamId, term)
if err != nil { if err != nil {
return nil, err return nil, err
@@ -172,7 +170,7 @@ func (c *SearchChannelStore) searchAutocompleteChannels(engine searchengine.Sear
if len(channelIds) > 0 { if len(channelIds) > 0 {
channels, err := c.ChannelStore.GetChannelsByIds(channelIds, includeDeleted) channels, err := c.ChannelStore.GetChannelsByIds(channelIds, includeDeleted)
if err != nil { if err != nil {
return nil, model.NewAppError("searchAutocompleteChannels", "app.channel.get_channels_by_ids.app_error", nil, err.Error(), http.StatusInternalServerError) return nil, errors.Wrap(err, "Failed to get channels by ids")
} }
for _, ch := range channels { for _, ch := range channels {